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

content/renderer/pepper/pepper_platform_audio_input.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_input.h"
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/single_thread_task_runner.h"
@@ skipping 61 matching lines @@
   client_ = NULL;
   io_task_runner_->PostTask(
       FROM_HERE,
       base::Bind(&PepperPlatformAudioInput::ShutDownOnIOThread, this));
 }
 
 void PepperPlatformAudioInput::OnStreamCreated(
     base::SharedMemoryHandle handle,
     base::SyncSocket::Handle socket_handle,
     int length,
-    int total_segments) {
+    int total_segments,
+    bool initially_muted) {
 #if defined(OS_WIN)
   DCHECK(handle.IsValid());
   DCHECK(socket_handle);
 #else
   DCHECK(base::SharedMemory::IsHandleValid(handle));
   DCHECK_NE(-1, socket_handle);
 #endif
   DCHECK(length);
   // TODO(yzshen): Make use of circular buffer scheme. crbug.com/181449.
   DCHECK_EQ(1, total_segments);
 
   if (base::ThreadTaskRunnerHandle::Get().get() != main_task_runner_.get()) {
     // If shutdown has occurred, |client_| will be NULL and the handles will be
     // cleaned up on the main thread.
     main_task_runner_->PostTask(
-        FROM_HERE, base::Bind(&PepperPlatformAudioInput::OnStreamCreated, this,
-                              handle, socket_handle, length, total_segments));
+        FROM_HERE,
+        base::Bind(&PepperPlatformAudioInput::OnStreamCreated, this, handle,
+                   socket_handle, length, total_segments, initially_muted));
   } else {
     // 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 {
       // Clean up the handles.
       base::SyncSocket temp_socket(socket_handle);
       base::SharedMemory temp_shared_memory(handle, false);
     }
@@ skipping 166 matching lines @@
 PepperMediaDeviceManager* PepperPlatformAudioInput::GetMediaDeviceManager() {
   DCHECK(main_task_runner_->BelongsToCurrentThread());
 
   RenderFrameImpl* const render_frame =
       RenderFrameImpl::FromRoutingID(render_frame_id_);
   return render_frame ?
       PepperMediaDeviceManager::GetForRenderFrame(render_frame).get() : NULL;
 }
 
 }  // namespace content