Sixth patch in getting rid of caching MessageLoop pointers. Audio and automa...

chrome/browser/renderer_host/audio_renderer_host_unittest.cc

 // Copyright (c) 2009 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 "base/message_loop.h"
 #include "base/process_util.h"
 #include "base/scoped_ptr.h"
+#include "chrome/browser/chrome_thread.h"
 #include "chrome/browser/renderer_host/audio_renderer_host.h"
 #include "chrome/common/render_messages.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using ::testing::_;
 using ::testing::DoAll;
 using ::testing::InSequence;
 using ::testing::Return;
 using ::testing::SaveArg;
 using ::testing::SetArgumentPointee;
 
 namespace {
 
 const int kInvalidId = -1;
 const int kProcessId = 100;
 const int kRouteId = 200;
 const int kBufferCapacity = 65536;
 const int kPacketSize = 16384;
 
 }  // namespace
 
 class MockAudioRendererHost : public AudioRendererHost {
  public:
-  MockAudioRendererHost(MessageLoop* loop)
-      : AudioRendererHost(loop) {
+  MockAudioRendererHost()
+      : AudioRendererHost() {
   }
 
   virtual ~MockAudioRendererHost() {
   }
 
   // A list of mock methods.
   MOCK_METHOD4(OnRequestPacket,
                void(int routing_id, int stream_id,
                     size_t bytes_in_buffer, int64 message_timestamp));
 
@@ skipping 69 matching lines @@
 class AudioRendererHostTest : public testing::Test {
  public:
   AudioRendererHostTest()
       : current_stream_id_(0) {
   }
 
  protected:
   virtual void SetUp() {
     // Create a message loop so AudioRendererHost can use it.
     message_loop_.reset(new MessageLoop(MessageLoop::TYPE_IO));
-    host_ = new MockAudioRendererHost(message_loop_.get());
+    io_thread_.reset(new ChromeThread(ChromeThread::IO, message_loop_.get()));
+    host_ = new MockAudioRendererHost();
   }
 
   virtual void TearDown() {
     // This task post a task to message_loop_ to do internal destruction on
     // message_loop_.
     host_->Destroy();
 
+    // Release the reference to the mock object.
+    host_ = NULL;
+
     // We need to continue running message_loop_ to complete all destructions.
     message_loop_->RunAllPending();
 
-    // Release the reference to the mock object.
-    host_ = NULL;
+    io_thread_.reset();
   }
 
   AudioRendererHost::IPCAudioSource* CreateAudioStream(
       AudioManager::Format format) {
     InSequence s;
 
     // 1. We will first receive a OnStreamCreated() signal.
     EXPECT_CALL(*host_,
                 OnStreamCreated(kRouteId, current_stream_id_, kPacketSize));
 
@@ skipping 27 matching lines @@
 
   AudioRendererHost::IPCAudioSource* CreateMockStream() {
     return CreateAudioStream(AudioManager::AUDIO_MOCK);
   }
 
   int current_stream_id_;
   scoped_refptr<MockAudioRendererHost> host_;
   scoped_ptr<MessageLoop> message_loop_;
 
  private:
+  scoped_ptr<ChromeThread> io_thread_;
   DISALLOW_COPY_AND_ASSIGN(AudioRendererHostTest);
 };
 
 TEST_F(AudioRendererHostTest, MockStreamDataConversation) {
   scoped_ptr<AudioRendererHost::IPCAudioSource> source(CreateMockStream());
 
   // We will receive packet requests until the buffer is full. We first send
   // three packets of 16KB, then we send packets of 1KB until the buffer is
   // full. Then there will no more packet requests.
   InSequence s;
@@ skipping 21 matching lines @@
   source->NotifyPacketReady(kPacketSize);
   source->NotifyPacketReady(kPacketSize);
   source->NotifyPacketReady(kStep);
   source->NotifyPacketReady(kStep);
   source->NotifyPacketReady(kStep);
   source->NotifyPacketReady(kStep);
   source->Play();
   EXPECT_EQ(ViewMsg_AudioStreamState::kPlaying, state.state);
   source->Close();
 }