| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/bind.h" | 5 #include "base/bind.h" |
| 6 #include "base/memory/scoped_ptr.h" | 6 #include "base/memory/scoped_ptr.h" |
| 7 #include "base/message_loop_proxy.h" | 7 #include "base/message_loop_proxy.h" |
| 8 #include "base/task.h" | 8 #include "base/task.h" |
| 9 #include "remoting/host/capturer_fake.h" | 9 #include "remoting/host/capturer_fake.h" |
| 10 #include "remoting/host/chromoting_host.h" | 10 #include "remoting/host/chromoting_host.h" |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 43 | 43 |
| 44 namespace { | 44 namespace { |
| 45 | 45 |
| 46 void PostQuitTask(MessageLoop* message_loop) { | 46 void PostQuitTask(MessageLoop* message_loop) { |
| 47 message_loop->PostTask(FROM_HERE, new MessageLoop::QuitTask()); | 47 message_loop->PostTask(FROM_HERE, new MessageLoop::QuitTask()); |
| 48 } | 48 } |
| 49 | 49 |
| 50 // Run the task and delete it afterwards. This action is used to deal with | 50 // Run the task and delete it afterwards. This action is used to deal with |
| 51 // done callbacks. | 51 // done callbacks. |
| 52 ACTION(RunDoneTask) { | 52 ACTION(RunDoneTask) { |
| 53 arg1->Run(); | 53 arg1.Run(); |
| 54 delete arg1; | |
| 55 } | 54 } |
| 56 | 55 |
| 57 ACTION_P(QuitMainMessageLoop, message_loop) { | 56 ACTION_P(QuitMainMessageLoop, message_loop) { |
| 58 PostQuitTask(message_loop); | 57 PostQuitTask(message_loop); |
| 59 } | 58 } |
| 60 | 59 |
| 61 void DummyDoneTask() { | 60 void DummyDoneTask() { |
| 62 } | 61 } |
| 63 | 62 |
| 64 } // namespace | 63 } // namespace |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 111 connection2_ = new MockConnectionToClient( | 110 connection2_ = new MockConnectionToClient( |
| 112 &handler_, &host_stub2_, &event_executor2_); | 111 &handler_, &host_stub2_, &event_executor2_); |
| 113 session_.reset(new MockSession()); | 112 session_.reset(new MockSession()); |
| 114 session2_.reset(new MockSession()); | 113 session2_.reset(new MockSession()); |
| 115 session_config_ = SessionConfig::GetDefault(); | 114 session_config_ = SessionConfig::GetDefault(); |
| 116 session_jid_ = "user@domain/rest-of-jid"; | 115 session_jid_ = "user@domain/rest-of-jid"; |
| 117 session2_jid_ = "user2@domain/rest-of-jid"; | 116 session2_jid_ = "user2@domain/rest-of-jid"; |
| 118 session_config2_ = SessionConfig::GetDefault(); | 117 session_config2_ = SessionConfig::GetDefault(); |
| 119 | 118 |
| 120 ON_CALL(video_stub_, ProcessVideoPacket(_, _)) | 119 ON_CALL(video_stub_, ProcessVideoPacket(_, _)) |
| 121 .WillByDefault( | 120 .WillByDefault(DeleteArg<0>()); |
| 122 DoAll(DeleteArg<0>(), DeleteArg<1>())); | |
| 123 ON_CALL(video_stub2_, ProcessVideoPacket(_, _)) | 121 ON_CALL(video_stub2_, ProcessVideoPacket(_, _)) |
| 124 .WillByDefault( | 122 .WillByDefault(DeleteArg<0>()); |
| 125 DoAll(DeleteArg<0>(), DeleteArg<1>())); | |
| 126 ON_CALL(*connection_.get(), video_stub()) | 123 ON_CALL(*connection_.get(), video_stub()) |
| 127 .WillByDefault(Return(&video_stub_)); | 124 .WillByDefault(Return(&video_stub_)); |
| 128 ON_CALL(*connection_.get(), client_stub()) | 125 ON_CALL(*connection_.get(), client_stub()) |
| 129 .WillByDefault(Return(&client_stub_)); | 126 .WillByDefault(Return(&client_stub_)); |
| 130 ON_CALL(*connection_.get(), session()) | 127 ON_CALL(*connection_.get(), session()) |
| 131 .WillByDefault(Return(session_.get())); | 128 .WillByDefault(Return(session_.get())); |
| 132 ON_CALL(*connection2_.get(), video_stub()) | 129 ON_CALL(*connection2_.get(), video_stub()) |
| 133 .WillByDefault(Return(&video_stub2_)); | 130 .WillByDefault(Return(&video_stub2_)); |
| 134 ON_CALL(*connection2_.get(), client_stub()) | 131 ON_CALL(*connection2_.get(), client_stub()) |
| 135 .WillByDefault(Return(&client_stub2_)); | 132 .WillByDefault(Return(&client_stub2_)); |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 184 | 181 |
| 185 context_.network_message_loop()->PostTask( | 182 context_.network_message_loop()->PostTask( |
| 186 FROM_HERE, | 183 FROM_HERE, |
| 187 NewRunnableFunction(&ChromotingHostTest::AddClientToHost, | 184 NewRunnableFunction(&ChromotingHostTest::AddClientToHost, |
| 188 host_, client)); | 185 host_, client)); |
| 189 context_.network_message_loop()->PostTask( | 186 context_.network_message_loop()->PostTask( |
| 190 FROM_HERE, | 187 FROM_HERE, |
| 191 NewRunnableMethod(client.get(), | 188 NewRunnableMethod(client.get(), |
| 192 &ClientSession::BeginSessionRequest, | 189 &ClientSession::BeginSessionRequest, |
| 193 &credentials_, | 190 &credentials_, |
| 194 NewRunnableFunction(&DummyDoneTask))); | 191 base::Bind(&DummyDoneTask))); |
| 195 } | 192 } |
| 196 | 193 |
| 197 // Helper method to remove a client connection from ChromotingHost. | 194 // Helper method to remove a client connection from ChromotingHost. |
| 198 void RemoveClientConnection() { | 195 void RemoveClientConnection() { |
| 199 context_.network_message_loop()->PostTask( | 196 context_.network_message_loop()->PostTask( |
| 200 FROM_HERE, | 197 FROM_HERE, |
| 201 NewRunnableMethod(host_.get(), | 198 NewRunnableMethod(host_.get(), |
| 202 &ChromotingHost::OnClientDisconnected, | 199 &ChromotingHost::OnClientDisconnected, |
| 203 connection_)); | 200 connection_)); |
| 204 } | 201 } |
| (...skipping 289 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 494 .InSequence(s1, s2); | 491 .InSequence(s1, s2); |
| 495 EXPECT_CALL(*connection_.get(), Disconnect()) | 492 EXPECT_CALL(*connection_.get(), Disconnect()) |
| 496 .InSequence(s1, s2) | 493 .InSequence(s1, s2) |
| 497 .RetiresOnSaturation(); | 494 .RetiresOnSaturation(); |
| 498 } | 495 } |
| 499 SimulateClientConnection(0, true); | 496 SimulateClientConnection(0, true); |
| 500 message_loop_.Run(); | 497 message_loop_.Run(); |
| 501 host_->set_it2me(false); | 498 host_->set_it2me(false); |
| 502 EXPECT_THAT(curtain_activated, false); | 499 EXPECT_THAT(curtain_activated, false); |
| 503 } | 500 } |
| 501 |
| 504 } // namespace remoting | 502 } // namespace remoting |
| OLD | NEW |