Rejigger audio capture pipeline to work with separate main+worker threads (Mac).

content/browser/renderer_host/media/web_contents_audio_input_stream_unittest.cc

 // Copyright (c) 2013 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/web_contents_audio_input_stream.h"
 
 #include <list>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
@@ skipping 71 matching lines @@
   virtual ~MockWebContentsTracker() {}
 
   DISALLOW_COPY_AND_ASSIGN(MockWebContentsTracker);
 };
 
 // A fully-functional VirtualAudioInputStream, but methods are mocked to allow
 // tests to check how/when they are invoked.
 class MockVirtualAudioInputStream : public VirtualAudioInputStream {
  public:
   explicit MockVirtualAudioInputStream(
-      const scoped_refptr<base::MessageLoopProxy>& message_loop)
-      : VirtualAudioInputStream(TestAudioParameters(), message_loop,
+      const scoped_refptr<base::MessageLoopProxy>& worker_loop)
+      : VirtualAudioInputStream(TestAudioParameters(), worker_loop,
                                 VirtualAudioInputStream::AfterCloseCallback()),
-        real_(TestAudioParameters(), message_loop,
+        real_(TestAudioParameters(), worker_loop,
               base::Bind(&MockVirtualAudioInputStream::OnRealStreamHasClosed,
                          base::Unretained(this))),
         real_stream_is_closed_(false) {
     // Set default actions of mocked methods to delegate to the concrete
     // implementation.
     ON_CALL(*this, Open())
         .WillByDefault(Invoke(&real_, &VirtualAudioInputStream::Open));
     ON_CALL(*this, Start(_))
         .WillByDefault(Invoke(&real_, &VirtualAudioInputStream::Start));
     ON_CALL(*this, Stop())
@@ skipping 105 matching lines @@
     ASSERT_EQ(kRenderViewId, current_render_view_id_);
     EXPECT_CALL(*mock_tracker_.get(), Start(kRenderProcessId, kRenderViewId, _))
         .WillOnce(DoAll(
              SaveArg<2>(&change_callback_),
              WithArgs<0, 1>(Invoke(&change_callback_,
                                    &WebContentsTracker::ChangeCallback::Run))));
     EXPECT_CALL(*mock_tracker_.get(), Stop());  // At Close() time.
 
     wcais_ = new WebContentsAudioInputStream(
         current_render_process_id_, current_render_view_id_,
-        audio_thread_.message_loop_proxy(), mock_mirroring_manager_.get(),
+        mock_mirroring_manager_.get(),
         mock_tracker_, mock_vais_);
     wcais_->Open();
   }
 
   void Start() {
     EXPECT_CALL(*mock_vais_, Start(&mock_input_callback_));
     EXPECT_CALL(*mock_vais_, Stop());  // At Stop() time.
 
     EXPECT_CALL(*mock_mirroring_manager_,
                 StartMirroring(kRenderProcessId, kRenderViewId, NotNull()))
@@ skipping 272 matching lines @@
   WaitForData();
   RUN_ON_AUDIO_THREAD(RemoveOneInputInFIFOOrder);
   WaitForData();
   RUN_ON_AUDIO_THREAD(ChangeMirroringTarget);
   RUN_ON_AUDIO_THREAD(RemoveOneInputInFIFOOrder);
   RUN_ON_AUDIO_THREAD(Stop);
   RUN_ON_AUDIO_THREAD(Close);
 }
 
 }  // namespace content