Decouple IPC::MessageFilter from IPC::Channel

content/browser/renderer_host/media/audio_renderer_host_unittest.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 "base/bind.h"
 #include "base/command_line.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/run_loop.h"
 #include "base/sync_socket.h"
+#include "content/browser/browser_message_filter_peer.h"
 #include "content/browser/media/capture/audio_mirroring_manager.h"
 #include "content/browser/media/media_internals.h"
 #include "content/browser/renderer_host/media/audio_input_device_manager.h"
 #include "content/browser/renderer_host/media/audio_renderer_host.h"
 #include "content/browser/renderer_host/media/media_stream_manager.h"
 #include "content/common/media/audio_messages.h"
 #include "content/public/common/content_switches.h"
 #include "content/public/test/test_browser_thread_bundle.h"
 #include "ipc/ipc_message_utils.h"
 #include "media/audio/audio_manager.h"
@@ skipping 139 matching lines @@
     audio_manager_.reset(media::AudioManager::CreateForTesting());
     CommandLine::ForCurrentProcess()->AppendSwitch(
         switches::kUseFakeDeviceForMediaStream);
     media_stream_manager_.reset(new MediaStreamManager(audio_manager_.get()));
     host_ = new MockAudioRendererHost(audio_manager_.get(),
                                       &mirroring_manager_,
                                       MediaInternals::GetInstance(),
                                       media_stream_manager_.get());
 
     // Simulate IPC channel connected.
-    host_->set_peer_pid_for_testing(base::GetCurrentProcId());
+    host_peer_.reset(new BrowserMessageFilterPeer(base::GetCurrentProcId()));
+    host_->OnFilterAddedToHost(host_peer_.get());
   }
 
   virtual ~AudioRendererHostTest() {
     // Simulate closing the IPC channel and give the audio thread time to close
     // the underlying streams.
-    host_->OnChannelClosing();
+    host_->OnSenderClosing();
     SyncWithAudioThread();
 
     // Release the reference to the mock object.  The object will be destructed
     // on message_loop_.
     host_ = NULL;
   }
 
  protected:
   void Create(bool unified_stream) {
     EXPECT_CALL(*host_.get(), OnStreamCreated(kStreamId, _));
@@ skipping 89 matching lines @@
   }
 
  private:
   // MediaStreamManager uses a DestructionObserver, so it must outlive the
   // TestBrowserThreadBundle.
   scoped_ptr<MediaStreamManager> media_stream_manager_;
   TestBrowserThreadBundle thread_bundle_;
   scoped_ptr<media::AudioManager> audio_manager_;
   MockAudioMirroringManager mirroring_manager_;
   scoped_refptr<MockAudioRendererHost> host_;
+  scoped_ptr<BrowserMessageFilterPeer> host_peer_;
 
   DISALLOW_COPY_AND_ASSIGN(AudioRendererHostTest);
 };
 
 TEST_F(AudioRendererHostTest, CreateAndClose) {
   Create(false);
   Close();
 }
 
 // Simulate the case where a stream is not properly closed.
@@ skipping 52 matching lines @@
 }
 
 TEST_F(AudioRendererHostTest, CreateUnifiedStreamAndClose) {
   Create(true);
   Close();
 }
 
 // TODO(hclam): Add tests for data conversation in low latency mode.
 
 }  // namespace content