OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/bind_helpers.h" | 6 #include "base/bind_helpers.h" |
7 #include "base/memory/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
8 #include "remoting/base/auto_thread_task_runner.h" | 8 #include "remoting/base/auto_thread_task_runner.h" |
9 #include "remoting/host/audio_capturer.h" | 9 #include "remoting/host/audio_capturer.h" |
10 #include "remoting/host/chromoting_host.h" | 10 #include "remoting/host/chromoting_host.h" |
(...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
111 session_unowned_jid2_ = "user4@doman/rest-of-jid"; | 111 session_unowned_jid2_ = "user4@doman/rest-of-jid"; |
112 | 112 |
113 EXPECT_CALL(*session1_, jid()) | 113 EXPECT_CALL(*session1_, jid()) |
114 .WillRepeatedly(ReturnRef(session_jid1_)); | 114 .WillRepeatedly(ReturnRef(session_jid1_)); |
115 EXPECT_CALL(*session2_, jid()) | 115 EXPECT_CALL(*session2_, jid()) |
116 .WillRepeatedly(ReturnRef(session_jid2_)); | 116 .WillRepeatedly(ReturnRef(session_jid2_)); |
117 EXPECT_CALL(*session_unowned1_, jid()) | 117 EXPECT_CALL(*session_unowned1_, jid()) |
118 .WillRepeatedly(ReturnRef(session_unowned_jid1_)); | 118 .WillRepeatedly(ReturnRef(session_unowned_jid1_)); |
119 EXPECT_CALL(*session_unowned2_, jid()) | 119 EXPECT_CALL(*session_unowned2_, jid()) |
120 .WillRepeatedly(ReturnRef(session_unowned_jid2_)); | 120 .WillRepeatedly(ReturnRef(session_unowned_jid2_)); |
121 EXPECT_CALL(*session1_, SetEventHandler(_)) | |
122 .Times(AnyNumber()); | |
123 EXPECT_CALL(*session2_, SetEventHandler(_)) | |
124 .Times(AnyNumber()); | |
125 EXPECT_CALL(*session_unowned1_, SetEventHandler(_)) | 121 EXPECT_CALL(*session_unowned1_, SetEventHandler(_)) |
126 .Times(AnyNumber()) | 122 .Times(AnyNumber()) |
127 .WillRepeatedly(SaveArg<0>(&session_unowned1_event_handler_)); | 123 .WillRepeatedly(SaveArg<0>(&session_unowned1_event_handler_)); |
128 EXPECT_CALL(*session_unowned2_, SetEventHandler(_)) | 124 EXPECT_CALL(*session_unowned2_, SetEventHandler(_)) |
129 .Times(AnyNumber()) | 125 .Times(AnyNumber()) |
130 .WillRepeatedly(SaveArg<0>(&session_unowned2_event_handler_)); | 126 .WillRepeatedly(SaveArg<0>(&session_unowned2_event_handler_)); |
131 EXPECT_CALL(*session1_, config()) | 127 EXPECT_CALL(*session1_, config()) |
132 .WillRepeatedly(ReturnRef(*session_config1_)); | 128 .WillRepeatedly(ReturnRef(*session_config1_)); |
133 EXPECT_CALL(*session2_, config()) | 129 EXPECT_CALL(*session2_, config()) |
134 .WillRepeatedly(ReturnRef(*session_config2_)); | 130 .WillRepeatedly(ReturnRef(*session_config2_)); |
135 | 131 |
136 owned_connection1_.reset(new MockConnectionToClient(session1_, | 132 owned_connection1_.reset( |
137 &host_stub1_)); | 133 new MockConnectionToClient(make_scoped_ptr(session1_), &host_stub1_)); |
138 connection1_ = owned_connection1_.get(); | 134 connection1_ = owned_connection1_.get(); |
139 owned_connection2_.reset(new MockConnectionToClient(session2_, | 135 owned_connection2_.reset( |
140 &host_stub2_)); | 136 new MockConnectionToClient(make_scoped_ptr(session2_), &host_stub2_)); |
141 connection2_ = owned_connection2_.get(); | 137 connection2_ = owned_connection2_.get(); |
142 | 138 |
143 ON_CALL(video_stub1_, ProcessVideoPacketPtr(_, _)) | 139 ON_CALL(video_stub1_, ProcessVideoPacketPtr(_, _)) |
144 .WillByDefault(DeleteArg<0>()); | 140 .WillByDefault(DeleteArg<0>()); |
145 ON_CALL(video_stub2_, ProcessVideoPacketPtr(_, _)) | 141 ON_CALL(video_stub2_, ProcessVideoPacketPtr(_, _)) |
146 .WillByDefault(DeleteArg<0>()); | 142 .WillByDefault(DeleteArg<0>()); |
147 ON_CALL(*connection1_, video_stub()) | 143 ON_CALL(*connection1_, video_stub()) |
148 .WillByDefault(Return(&video_stub1_)); | 144 .WillByDefault(Return(&video_stub1_)); |
149 ON_CALL(*connection1_, client_stub()) | 145 ON_CALL(*connection1_, client_stub()) |
150 .WillByDefault(Return(&client_stub1_)); | 146 .WillByDefault(Return(&client_stub1_)); |
151 ON_CALL(*connection1_, session()) | |
152 .WillByDefault(Return(session1_)); | |
153 ON_CALL(*connection2_, video_stub()) | 147 ON_CALL(*connection2_, video_stub()) |
154 .WillByDefault(Return(&video_stub2_)); | 148 .WillByDefault(Return(&video_stub2_)); |
155 ON_CALL(*connection2_, client_stub()) | 149 ON_CALL(*connection2_, client_stub()) |
156 .WillByDefault(Return(&client_stub2_)); | 150 .WillByDefault(Return(&client_stub2_)); |
157 ON_CALL(*connection2_, session()) | |
158 .WillByDefault(Return(session2_)); | |
159 EXPECT_CALL(*connection1_, video_stub()) | 151 EXPECT_CALL(*connection1_, video_stub()) |
160 .Times(AnyNumber()); | 152 .Times(AnyNumber()); |
161 EXPECT_CALL(*connection1_, client_stub()) | 153 EXPECT_CALL(*connection1_, client_stub()) |
162 .Times(AnyNumber()); | 154 .Times(AnyNumber()); |
163 EXPECT_CALL(*connection1_, session()) | |
164 .Times(AnyNumber()); | |
165 EXPECT_CALL(*connection2_, video_stub()) | 155 EXPECT_CALL(*connection2_, video_stub()) |
166 .Times(AnyNumber()); | 156 .Times(AnyNumber()); |
167 EXPECT_CALL(*connection2_, client_stub()) | 157 EXPECT_CALL(*connection2_, client_stub()) |
168 .Times(AnyNumber()); | 158 .Times(AnyNumber()); |
169 EXPECT_CALL(*connection2_, session()) | |
170 .Times(AnyNumber()); | |
171 } | 159 } |
172 | 160 |
173 // Helper method to pretend a client is connected to ChromotingHost. | 161 // Helper method to pretend a client is connected to ChromotingHost. |
174 void SimulateClientConnection(int connection_index, bool authenticate, | 162 void SimulateClientConnection(int connection_index, bool authenticate, |
175 bool reject) { | 163 bool reject) { |
176 scoped_ptr<protocol::ConnectionToClient> connection = | 164 scoped_ptr<protocol::ConnectionToClient> connection = |
177 ((connection_index == 0) ? owned_connection1_ : owned_connection2_) | 165 ((connection_index == 0) ? owned_connection1_ : owned_connection2_) |
178 .Pass(); | 166 .Pass(); |
179 protocol::ConnectionToClient* connection_ptr = connection.get(); | 167 protocol::ConnectionToClient* connection_ptr = connection.get(); |
180 scoped_ptr<ClientSession> client(new ClientSession( | 168 scoped_ptr<ClientSession> client(new ClientSession( |
(...skipping 489 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
670 ExpectClientDisconnected(0, true, video_packet_sent, | 658 ExpectClientDisconnected(0, true, video_packet_sent, |
671 InvokeWithoutArgs(this, &ChromotingHostTest::ShutdownHost)); | 659 InvokeWithoutArgs(this, &ChromotingHostTest::ShutdownHost)); |
672 EXPECT_CALL(host_status_observer_, OnShutdown()); | 660 EXPECT_CALL(host_status_observer_, OnShutdown()); |
673 | 661 |
674 host_->Start(xmpp_login_); | 662 host_->Start(xmpp_login_); |
675 SimulateClientConnection(0, true, false); | 663 SimulateClientConnection(0, true, false); |
676 message_loop_.Run(); | 664 message_loop_.Run(); |
677 } | 665 } |
678 | 666 |
679 } // namespace remoting | 667 } // namespace remoting |
OLD | NEW |