Mojofication of the Chrome Audio Rendering Prototype

content/renderer/pepper/pepper_platform_audio_output.cc

 // Copyright (c) 2012 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/renderer/pepper/pepper_platform_audio_output.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/single_thread_task_runner.h"
 #include "base/thread_task_runner_handle.h"
 #include "build/build_config.h"
+#include "content/browser/media/audio_output_impl.h"
 #include "content/child/child_process.h"
 #include "content/common/media/audio_messages.h"
 #include "content/renderer/media/audio_message_filter.h"
 #include "content/renderer/pepper/audio_helper.h"
 #include "content/renderer/render_thread_impl.h"
 #include "media/base/audio_hardware_config.h"
 #include "ppapi/shared_impl/ppb_audio_config_shared.h"
 
 namespace content {
 
@@ skipping 10 matching lines @@
                                source_render_frame_id,
                                client)) {
     // Balanced by Release invoked in
     // PepperPlatformAudioOutput::ShutDownOnIOThread().
     audio_output->AddRef();
     return audio_output.get();
   }
   return NULL;
 }
 
+media::AudioOutputIPC* PepperPlatformAudioOutput::getIPC() {
+  return ipc_.get();
+}
+
 bool PepperPlatformAudioOutput::StartPlayback() {
   if (ipc_) {
     io_task_runner_->PostTask(
         FROM_HERE,
         base::Bind(&PepperPlatformAudioOutput::StartPlaybackOnIOThread, this));
     return true;
   }
   return false;
 }
 
@@ skipping 19 matching lines @@
 void PepperPlatformAudioOutput::OnStateChanged(
     media::AudioOutputIPCDelegateState state) {}
 
 void PepperPlatformAudioOutput::OnDeviceAuthorized(
     media::OutputDeviceStatus device_status,
     const media::AudioParameters& output_params) {
   NOTREACHED();
 }
 
 void PepperPlatformAudioOutput::OnStreamCreated(
+    mojom::AudioOutputStreamPtr* stream,
     base::SharedMemoryHandle handle,
     base::SyncSocket::Handle socket_handle,
     int length) {
 #if defined(OS_WIN)
   DCHECK(handle.IsValid());
   DCHECK(socket_handle);
 #else
   DCHECK(base::SharedMemory::IsHandleValid(handle));
   DCHECK_NE(-1, socket_handle);
 #endif
   DCHECK(length);
 
+  stream_ = stream;
   if (base::ThreadTaskRunnerHandle::Get().get() == main_task_runner_.get()) {
     // Must dereference the client only on the main thread. Shutdown may have
     // occurred while the request was in-flight, so we need to NULL check.
     if (client_)
       client_->StreamCreated(handle, length, socket_handle);
   } else {
     main_task_runner_->PostTask(
         FROM_HERE, base::Bind(&PepperPlatformAudioOutput::OnStreamCreated, this,
-                              handle, socket_handle, length));
+                              stream_, handle, socket_handle, length));
   }
 }
 
 void PepperPlatformAudioOutput::OnIPCClosed() { ipc_.reset(); }
 
 PepperPlatformAudioOutput::~PepperPlatformAudioOutput() {
   // Make sure we have been shut down. Warning: this will usually happen on
   // the I/O thread!
   DCHECK(!ipc_);
   DCHECK(!client_);
@@ skipping 56 matching lines @@
     return;
 
   ipc_->CloseStream();
   ipc_.reset();
 
   Release();  // Release for the delegate, balances out the reference taken in
               // PepperPlatformAudioOutput::Create.
 }
 
 }  // namespace content