Added initial muted state to stream creation callback, to avoid races.

content/browser/renderer_host/media/audio_input_renderer_host.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/browser/renderer_host/media/audio_input_renderer_host.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/command_line.h"
@@ skipping 117 matching lines @@
 
 void AudioInputRendererHost::OnChannelClosing() {
   // Since the IPC sender is gone, close all requested audio streams.
   DeleteEntries();
 }
 
 void AudioInputRendererHost::OnDestruct() const {
   BrowserThread::DeleteOnIOThread::Destruct(this);
 }
 
-void AudioInputRendererHost::OnCreated(
-    media::AudioInputController* controller) {
+void AudioInputRendererHost::OnCreated(media::AudioInputController* controller,
+                                       bool initially_muted) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::BindOnce(&AudioInputRendererHost::DoCompleteCreation, this,
-                     base::RetainedRef(controller)));
+                     base::RetainedRef(controller), initially_muted));
 }
 
 void AudioInputRendererHost::OnError(media::AudioInputController* controller,
     media::AudioInputController::ErrorCode error_code) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::BindOnce(&AudioInputRendererHost::DoHandleError, this,
                      base::RetainedRef(controller), error_code));
 }
 
@@ skipping 12 matching lines @@
       base::Bind(&AudioInputRendererHost::DoNotifyMutedState, this,
                  base::RetainedRef(controller), is_muted));
 }
 
 void AudioInputRendererHost::set_renderer_pid(int32_t renderer_pid) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   renderer_pid_ = renderer_pid;
 }
 
 void AudioInputRendererHost::DoCompleteCreation(
-    media::AudioInputController* controller) {
+    media::AudioInputController* controller,
+    bool initially_muted) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
   AudioEntry* entry = LookupByController(controller);
   DCHECK(entry);
   AudioInputSyncWriter* writer = entry->writer.get();
   DCHECK(writer);
   DCHECK(PeerHandle());
 
   // Once the audio stream is created then complete the creation process by
   // mapping shared memory and sharing with the renderer process.
@@ skipping 11 matching lines @@
   // If we failed to prepare the sync socket for the renderer then we fail
   // the construction of audio input stream.
   if (!entry->foreign_socket.PrepareTransitDescriptor(
           PeerHandle(), &socket_transit_descriptor)) {
     foreign_memory_handle.Close();
     DeleteEntryOnError(entry, SYNC_SOCKET_ERROR);
     return;
   }
 
   LogMessage(entry->stream_id,
-             "DoCompleteCreation: IPC channel and stream are now open",
+             base::StringPrintf("DoCompleteCreation: IPC channel and stream "
+                                "are now open (initially %s",
+                                initially_muted ? "muted" : "not muted"),
              true);
 
   Send(new AudioInputMsg_NotifyStreamCreated(
       entry->stream_id, foreign_memory_handle, socket_transit_descriptor,
       writer->shared_memory()->requested_size(),
-      writer->shared_memory_segment_count()));
+      writer->shared_memory_segment_count(), initially_muted));
 
   // Free the foreign socket on here since it isn't needed anymore in this
   // process.
   entry->foreign_socket.Close();
 }
 
 void AudioInputRendererHost::DoHandleError(
     media::AudioInputController* controller,
     media::AudioInputController::ErrorCode error_code) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
@@ skipping 370 matching lines @@
     const base::FilePath& file,
     int stream_id) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   EnableDebugRecordingForId(GetDebugRecordingFilePathWithExtensions(file),
                             stream_id);
 }
 
 #endif  // BUILDFLAG(ENABLE_WEBRTC)
 
 }  // namespace content