Index: remoting/host/chromoting_host_unittest.cc |
=================================================================== |
--- remoting/host/chromoting_host_unittest.cc (revision 170590) |
+++ remoting/host/chromoting_host_unittest.cc (working copy) |
@@ -118,6 +118,19 @@ |
base::Bind(&ChromotingHostTest::QuitMainMessageLoop, |
base::Unretained(this))); |
+ EXPECT_CALL(context_, ui_task_runner()) |
+ .Times(AnyNumber()) |
+ .WillRepeatedly(Return(ui_task_runner_.get())); |
+ EXPECT_CALL(context_, capture_task_runner()) |
+ .Times(AnyNumber()) |
+ .WillRepeatedly(Return(ui_task_runner_.get())); |
+ EXPECT_CALL(context_, encode_task_runner()) |
+ .Times(AnyNumber()) |
+ .WillRepeatedly(Return(ui_task_runner_.get())); |
+ EXPECT_CALL(context_, network_task_runner()) |
+ .Times(AnyNumber()) |
+ .WillRepeatedly(Return(ui_task_runner_.get())); |
+ |
desktop_environment_factory_.reset(new MockDesktopEnvironmentFactory()); |
EXPECT_CALL(*desktop_environment_factory_, CreatePtr(_)) |
.Times(AnyNumber()) |
@@ -130,17 +143,18 @@ |
&signal_strategy_, |
desktop_environment_factory_.get(), |
scoped_ptr<protocol::SessionManager>(session_manager_), |
- ui_task_runner_, // Audio |
- ui_task_runner_, // Video capture |
- ui_task_runner_, // Video encode |
- ui_task_runner_); // Network |
+ context_.audio_task_runner(), |
+ context_.capture_task_runner(), |
+ context_.encode_task_runner(), |
+ context_.network_task_runner()); |
host_->AddStatusObserver(&host_status_observer_); |
disconnect_window_ = new MockDisconnectWindow(); |
continue_window_ = new MockContinueWindow(); |
local_input_monitor_ = new MockLocalInputMonitor(); |
it2me_host_user_interface_.reset( |
- new MockIt2MeHostUserInterface(ui_task_runner_, ui_task_runner_)); |
+ new MockIt2MeHostUserInterface(context_.network_task_runner(), |
+ context_.ui_task_runner())); |
it2me_host_user_interface_->InitFrom( |
scoped_ptr<DisconnectWindow>(disconnect_window_), |
scoped_ptr<ContinueWindow>(continue_window_), |
@@ -236,10 +250,10 @@ |
protocol::ConnectionToClient* connection_ptr = connection.get(); |
scoped_refptr<ClientSession> client = new ClientSession( |
host_.get(), |
- ui_task_runner_, // Audio |
- ui_task_runner_, // Video capture |
- ui_task_runner_, // Video encode |
- ui_task_runner_, // Network |
+ context_.audio_task_runner(), |
+ context_.capture_task_runner(), |
+ context_.encode_task_runner(), |
+ context_.network_task_runner(), |
connection.Pass(), |
desktop_environment_factory_.get(), |
base::TimeDelta()); |
@@ -247,22 +261,22 @@ |
connection_ptr->set_input_stub( |
client->desktop_environment()->event_executor()); |
- ui_task_runner_->PostTask( |
+ context_.network_task_runner()->PostTask( |
FROM_HERE, base::Bind(&ChromotingHostTest::AddClientToHost, |
host_, client)); |
if (authenticate) { |
- ui_task_runner_->PostTask( |
+ context_.network_task_runner()->PostTask( |
FROM_HERE, base::Bind(&ClientSession::OnConnectionAuthenticated, |
client, connection_ptr)); |
if (!reject) { |
- ui_task_runner_->PostTask( |
+ context_.network_task_runner()->PostTask( |
FROM_HERE, |
base::Bind(&ClientSession::OnConnectionChannelsConnected, |
client, connection_ptr)); |
} |
} else { |
- ui_task_runner_->PostTask( |
+ context_.network_task_runner()->PostTask( |
FROM_HERE, base::Bind(&ClientSession::OnConnectionClosed, |
client, connection_ptr, |
protocol::AUTHENTICATION_FAILED)); |
@@ -429,6 +443,7 @@ |
protected: |
MessageLoop message_loop_; |
scoped_refptr<AutoThreadTaskRunner> ui_task_runner_; |
+ MockChromotingHostContext context_; |
MockConnectionToClientEventHandler handler_; |
MockSignalStrategy signal_strategy_; |
scoped_ptr<MockDesktopEnvironmentFactory> desktop_environment_factory_; |