Motown: Framework parts for mojo transport (producer/consumer/mediapipe) and control (audiotrack).

services/media/framework_mojo/mojo_producer.cc

+// Copyright 2016 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "base/logging.h"
+#include "services/media/framework_mojo/mojo_producer.h"
+
+namespace mojo {
+namespace media {
+
+MojoProducer::MojoProducer() {}
+
+MojoProducer::~MojoProducer() {}
+
+void MojoProducer::AddBinding(InterfaceRequest<MediaProducer> producer) {
+  bindings_.AddBinding(this, producer.Pass());
+}
+
+void MojoProducer::FlushConsumer(const FlushConsumerCallback& callback) {
+  DCHECK(consumer_.is_bound());
+  consumer_->Flush(callback);
+}
+
+void MojoProducer::Connect(
+    InterfaceHandle<MediaConsumer> consumer,
+    const ConnectCallback& callback) {
+  DCHECK(consumer);
+
+  consumer_ = MediaConsumerPtr::Create(std::move(consumer));
+
+  if (!mojo_allocator_.initialized()) {
+    mojo_allocator_.InitNew(256 * 1024); // TODO(dalesat): Made up!
+  }
+
+  consumer_->SetBuffer(
+      mojo_allocator_.GetDuplicateHandle(),
+      mojo_allocator_.size(),
+      [callback]() {
+    callback.Run();
+  });
+}
+
+void MojoProducer::Disconnect() {
+  OnConnectionLost();
+  consumer_.reset();
+}
+
+bool MojoProducer::IsConnected() {
+  return consumer_.is_bound();
+}
+
+void MojoProducer::PushPacketInternal(
+    Packet* packet_raw_ptr,
+    MediaPacketPtr media_packet) {
+  consumer_->PushPacket(
+    media_packet.Pass(),
+    [this, packet_raw_ptr]() {
+      PacketPtr packet = PacketPtr(packet_raw_ptr);
+      PushCompleted(packet);
+    });
+}
+
+} // namespace media
+} // namespace mojo