Switch stream creation and closing in Chrome audio rendering from IPC to Mojo

content/browser/media/audio_output_impl.cc

Index: content/browser/media/audio_output_impl.cc
diff --git a/content/browser/media/audio_output_impl.cc b/content/browser/media/audio_output_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..960983911c6b8e948f446261dfaeb19ffd8e6275
--- /dev/null
+++ b/content/browser/media/audio_output_impl.cc
@@ -0,0 +1,90 @@
+// 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 "content/browser/media/audio_output_impl.h"
+#include "content/browser/media/audio_output_stream_impl.h"
+
+namespace content {
+
+AudioOutputImpl::AudioOutputImpl(
+    scoped_refptr<AudioRendererHost> audio_renderer_host,
+    int render_frame_id,
+    media::mojom::AudioOutputRequest request)
+    : audio_renderer_host_(audio_renderer_host.get()),
+      render_frame_id_(render_frame_id),
+      binding_(this) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  binding_.Bind(std::move(request));
+  LOG(ERROR) << "AudioOutputImpl";
+  factory_ = base::Bind(AudioOutputStreamFactory::Factory);
+}
+
+AudioOutputImpl::~AudioOutputImpl() {
+  LOG(ERROR) << "~AudioOutputImpl";
+}
+
+// static
+void AudioOutputImpl::CreateService(
+    scoped_refptr<AudioRendererHost> audio_renderer_host,
+    int render_frame_id,
+    media::mojom::AudioOutputRequest request) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(&AudioOutputImpl::CreateServiceOnIOThread, audio_renderer_host,
+                 render_frame_id, base::Passed(&request)));
+}
+
+// static
+void AudioOutputImpl::CreateServiceOnIOThread(
+    scoped_refptr<AudioRendererHost> audio_renderer_host,
+    int render_frame_id,
+    media::mojom::AudioOutputRequest request) {
+  if (request.is_pending()) {
+    DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  }
+
+  auto service = new AudioOutputImpl(audio_renderer_host, render_frame_id,
+                                     std::move(request));
+
+  audio_renderer_host->set_audio_output_impl(render_frame_id, service);
+}
+
+void AudioOutputImpl::CreateStream(int stream_id,
+                                   const media::AudioParameters& params,
+                                   const CreateStreamCallback& callback) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  media::mojom::AudioOutputStreamPtr stream;
+  audio_renderer_host_->CreateStream(stream_id, render_frame_id_, params,
+                                     callback);
+}
+
+media::mojom::AudioOutputStreamPtr AudioOutputImpl::StreamFactory(
+    int stream_id,
+    int render_frame_id,
+    AudioRendererHost* audio_renderer_host) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  media::mojom::AudioOutputStreamPtr stream =
+      media::mojom::AudioOutputStreamPtr();
+  std::unique_ptr<AudioOutputStreamImpl> stream_ptr(
+      factory_.Run(mojo::GetProxy(&stream), stream_id, render_frame_id,
+                   audio_renderer_host));
+
+  auto ret =
+      stream_impls_.insert(std::make_pair(stream_id, std::move(stream_ptr)));
+  DCHECK(ret.second);
+  return stream;
+}
+
+bool AudioOutputImpl::RemoveStream(int stream_id) {
+  LOG(ERROR) << "rm stream_id" << stream_id;
+  if (stream_impls_.erase(stream_id))
+    return true;
+  else
+    return false;
+}
+
+}  // namespace content