Unmute Tab Audio For Desktop Share

media/audio/audio_output_controller.cc

Index: media/audio/audio_output_controller.cc
diff --git a/media/audio/audio_output_controller.cc b/media/audio/audio_output_controller.cc
index d780687d1b8415aee8f6223be8497905a80b8800..43a8b0fb167c5930c3f3b0dd3f9a4b754bc150d9 100644
--- a/media/audio/audio_output_controller.cc
+++ b/media/audio/audio_output_controller.cc
@@ -119,7 +119,8 @@ void AudioOutputController::DoCreate(bool is_for_device_change) {
   if (state_ == kClosed)
     return;
 
-  DoStopCloseAndClearStream();  // Calls RemoveOutputDeviceChangeListener().
+  // Calls RemoveOutputDeviceChangeListener().
+  DoStopCloseAndClearStream(is_for_device_change);
   DCHECK_EQ(kEmpty, state_);
 
   stream_ = diverting_to_stream_ ?
@@ -132,7 +133,7 @@ void AudioOutputController::DoCreate(bool is_for_device_change) {
   }
 
   if (!stream_->Open()) {
-    DoStopCloseAndClearStream();
+    DoStopCloseAndClearStream(false);
     state_ = kError;
     handler_->OnError();
     return;
@@ -169,6 +170,8 @@ void AudioOutputController::DoPlay() {
   state_ = kPlaying;
 
   stream_->Start(this);
+  for (auto& target : duplicating_targets_)
+    target->Start();
 
   // For UMA tracking purposes, start the wedge detection timer.  This allows us
   // to record statistics about the number of wedged playbacks in the field.
@@ -196,6 +199,9 @@ void AudioOutputController::StopStream() {
     wedge_timer_.reset();
     stream_->Stop();
 
+    for (auto& target : duplicating_targets_)
+      target->Stop();
+
     // A stopped stream is silent, and power_montior_.Scan() is no longer being
     // called; so we must reset the power monitor.
     power_monitor_.Reset();
@@ -228,7 +234,7 @@ void AudioOutputController::DoClose() {
   TRACE_EVENT0("audio", "AudioOutputController::DoClose");
 
   if (state_ != kClosed) {
-    DoStopCloseAndClearStream();
+    DoStopCloseAndClearStream(false);
     sync_reader_->Close();
     state_ = kClosed;
   }
@@ -301,6 +307,9 @@ int AudioOutputController::OnMoreData(AudioBus* dest,
   sync_reader_->UpdatePendingBytes(
       total_bytes_delay + frames * params_.GetBytesPerFrame(), frames_skipped);
 
+  for (auto& target : duplicating_targets_)
+    target->OnData(dest);

[miu, 2016/04/21 00:15:25]

Please pass the delay information here as well, ideally as a TimeTicks (the
Chrome media stack really needs to update the delay values in these interfaces).
 Suggestion:

  const base::TimeTicks reference_time = base::TimeTicks::Now() +
base::TimeDelta::FromMicroseconds(1000000.0 * total_bytes_delay /
params_.GetBytesPerSecond());
  for (VirtualAudioSink* target : duplicating_targets_)
    target->OnData(*dest, reference_time);

[qiangchen, 2016/04/28 00:00:56]

Done.

+
   if (will_monitor_audio_levels())
     power_monitor_.Scan(*dest, frames);
 
@@ -319,7 +328,8 @@ void AudioOutputController::OnError(AudioOutputStream* stream) {
       &AudioOutputController::DoReportError, this));
 }
 
-void AudioOutputController::DoStopCloseAndClearStream() {
+void AudioOutputController::DoStopCloseAndClearStream(
+    bool is_for_device_change) {
   DCHECK(message_loop_->BelongsToCurrentThread());
 
   // Allow calling unconditionally and bail if we don't have a stream_ to close.
@@ -336,6 +346,14 @@ void AudioOutputController::DoStopCloseAndClearStream() {
 
     StopStream();
     stream_->Close();
+
+    // Only close duplicating streams when this is really a close class
+    // For device change call, duplicating streams should remain unchanged.
+    if (!is_for_device_change) {
+      for (auto& target : duplicating_targets_)
+        target->Close();
+    }
+
     if (stream_ == diverting_to_stream_)
       diverting_to_stream_ = NULL;
     stream_ = NULL;
@@ -392,6 +410,18 @@ void AudioOutputController::StopDiverting() {
       FROM_HERE, base::Bind(&AudioOutputController::DoStopDiverting, this));
 }
 
+void AudioOutputController::StartDuplicating(AudioPushSink* sink) {
+  message_loop_->PostTask(
+      FROM_HERE,
+      base::Bind(&AudioOutputController::DoStartDuplicating, this, sink));
+}
+
+void AudioOutputController::StopDuplicating(AudioPushSink* sink) {
+  message_loop_->PostTask(
+      FROM_HERE,
+      base::Bind(&AudioOutputController::DoStopDuplicating, this, sink));
+}
+
 void AudioOutputController::DoStartDiverting(AudioOutputStream* to_stream) {
   DCHECK(message_loop_->BelongsToCurrentThread());
 
@@ -419,6 +449,34 @@ void AudioOutputController::DoStopDiverting() {
   DCHECK(!diverting_to_stream_);
 }
 
+void AudioOutputController::DoStartDuplicating(AudioPushSink* to_stream) {
+  DCHECK(message_loop_->BelongsToCurrentThread());
+  if (state_ == kClosed)
+    return;
+
+  // Already serving the stream.
+  if (duplicating_targets_.find(to_stream) != duplicating_targets_.end())
+    return;
+
+  duplicating_targets_.insert(to_stream);
+  if (state_ == kPlaying)
+    to_stream->Start();
+}
+
+void AudioOutputController::DoStopDuplicating(AudioPushSink* to_stream) {
+  DCHECK(message_loop_->BelongsToCurrentThread());
+
+  if (state_ == kClosed)
+    return;
+
+  // No such stream.
+  if (duplicating_targets_.find(to_stream) == duplicating_targets_.end())
+    return;
+
+  duplicating_targets_.erase(to_stream);
+  to_stream->Close();
+}
+
 std::pair<float, bool> AudioOutputController::ReadCurrentPowerAndClip() {
   DCHECK(will_monitor_audio_levels());
   return power_monitor_.ReadCurrentPowerAndClip();