Mojofication of the Chrome Audio Rendering Prototype

content/renderer/media/audio_message_filter.cc

Index: content/renderer/media/audio_message_filter.cc
diff --git a/content/renderer/media/audio_message_filter.cc b/content/renderer/media/audio_message_filter.cc
index 7ecf9b164140ffa8da08ad93e010e3600ae836de..561f7534538e370f4c0e96ab5e795688485e3aaf 100644
--- a/content/renderer/media/audio_message_filter.cc
+++ b/content/renderer/media/audio_message_filter.cc
@@ -105,9 +105,14 @@ void AudioMessageFilter::AudioOutputIPCImpl::CreateStream(
   DCHECK(!stream_created_);
   if (stream_id_ == kStreamIDNotSet)
     stream_id_ = filter_->delegates_.Add(delegate);
-
+  /*
   filter_->Send(
-      new AudioHostMsg_CreateStream(stream_id_, render_frame_id_, params));
+      new AudioHostMsg_CreateStream(stream_id_, render_frame_id_, params));*/
+  LOG(ERROR) << "test CreateStream " << stream_id_;
+  content::AudioOutputClient* audio_output_client =
+      content::AudioOutputClient::Get();
+  audio_output_client->CreateStream(stream_id_, render_frame_id_, params);
+  LOG(ERROR) << "test CreateStream " << stream_id_;
   stream_created_ = true;
 }
 
@@ -122,12 +127,18 @@ void AudioMessageFilter::AudioOutputIPCImpl::PauseStream() {
 }
 
 void AudioMessageFilter::AudioOutputIPCImpl::CloseStream() {
+  LOG(ERROR) << "test CloseStream " << stream_id_;
   DCHECK(filter_->io_task_runner_->BelongsToCurrentThread());
   DCHECK_NE(stream_id_, kStreamIDNotSet);
-  filter_->Send(new AudioHostMsg_CloseStream(stream_id_));
+  // filter_->Send(new AudioHostMsg_CloseStream(stream_id_));
   filter_->delegates_.Remove(stream_id_);
   stream_id_ = kStreamIDNotSet;
   stream_created_ = false;
+  LOG(ERROR) << "test CloseStream " << stream_id_;
+  content::AudioOutputClient* audio_output_client_ =
+      content::AudioOutputClient::Get();
+  audio_output_client_->CloseStream(stream_id_);
+  LOG(ERROR) << "test CloseStream " << stream_id_;
 }
 
 void AudioMessageFilter::AudioOutputIPCImpl::SetVolume(double volume) {
@@ -202,6 +213,12 @@ void AudioMessageFilter::OnStreamCreated(
     base::SyncSocket::TransitDescriptor socket_descriptor,
     uint32_t length) {
   DCHECK(io_task_runner_->BelongsToCurrentThread());
+  AudioOutputClient* audio_output_client_;
+
+  audio_output_client_ = AudioOutputClient::Get();
+
+  LOG(ERROR) << "Start establish MOJO";
+  DLOG(ERROR) << "end establish MOJO";
 
   WebRtcLogMessage(base::StringPrintf(
       "AMF::OnStreamCreated. stream_id=%d",