OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright 2012 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 199 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
210 size_t num_candidates_removed_ = 0; | 210 size_t num_candidates_removed_ = 0; |
211 }; | 211 }; |
212 | 212 |
213 class WebRtcSessionForTest : public webrtc::WebRtcSession { | 213 class WebRtcSessionForTest : public webrtc::WebRtcSession { |
214 public: | 214 public: |
215 WebRtcSessionForTest(webrtc::MediaControllerInterface* media_controller, | 215 WebRtcSessionForTest(webrtc::MediaControllerInterface* media_controller, |
216 rtc::Thread* network_thread, | 216 rtc::Thread* network_thread, |
217 rtc::Thread* worker_thread, | 217 rtc::Thread* worker_thread, |
218 rtc::Thread* signaling_thread, | 218 rtc::Thread* signaling_thread, |
219 cricket::PortAllocator* port_allocator, | 219 cricket::PortAllocator* port_allocator, |
220 webrtc::IceObserver* ice_observer) | 220 webrtc::IceObserver* ice_observer, |
| 221 cricket::TransportController* transport_controller) |
221 : WebRtcSession(media_controller, | 222 : WebRtcSession(media_controller, |
222 network_thread, | 223 network_thread, |
223 worker_thread, | 224 worker_thread, |
224 signaling_thread, | 225 signaling_thread, |
225 port_allocator) { | 226 port_allocator, |
| 227 transport_controller) { |
226 RegisterIceObserver(ice_observer); | 228 RegisterIceObserver(ice_observer); |
227 } | 229 } |
228 virtual ~WebRtcSessionForTest() {} | 230 virtual ~WebRtcSessionForTest() {} |
229 | 231 |
230 // Note that these methods are only safe to use if the signaling thread | 232 // Note that these methods are only safe to use if the signaling thread |
231 // is the same as the worker thread | 233 // is the same as the worker thread |
232 cricket::TransportChannel* voice_rtp_transport_channel() { | 234 cricket::TransportChannel* voice_rtp_transport_channel() { |
233 return rtp_transport_channel(voice_channel()); | 235 return rtp_transport_channel(voice_channel()); |
234 } | 236 } |
235 | 237 |
(...skipping 143 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
379 | 381 |
380 // If |cert_generator| != null or |rtc_configuration| contains |certificates| | 382 // If |cert_generator| != null or |rtc_configuration| contains |certificates| |
381 // then DTLS will be enabled unless explicitly disabled by |rtc_configuration| | 383 // then DTLS will be enabled unless explicitly disabled by |rtc_configuration| |
382 // options. When DTLS is enabled a certificate will be used if provided, | 384 // options. When DTLS is enabled a certificate will be used if provided, |
383 // otherwise one will be generated using the |cert_generator|. | 385 // otherwise one will be generated using the |cert_generator|. |
384 void Init( | 386 void Init( |
385 std::unique_ptr<rtc::RTCCertificateGeneratorInterface> cert_generator) { | 387 std::unique_ptr<rtc::RTCCertificateGeneratorInterface> cert_generator) { |
386 ASSERT_TRUE(session_.get() == NULL); | 388 ASSERT_TRUE(session_.get() == NULL); |
387 session_.reset(new WebRtcSessionForTest( | 389 session_.reset(new WebRtcSessionForTest( |
388 media_controller_.get(), rtc::Thread::Current(), rtc::Thread::Current(), | 390 media_controller_.get(), rtc::Thread::Current(), rtc::Thread::Current(), |
389 rtc::Thread::Current(), allocator_.get(), &observer_)); | 391 rtc::Thread::Current(), allocator_.get(), &observer_, |
| 392 new cricket::TransportController( |
| 393 rtc::Thread::Current(), rtc::Thread::Current(), allocator_.get()))); |
390 session_->SignalDataChannelOpenMessage.connect( | 394 session_->SignalDataChannelOpenMessage.connect( |
391 this, &WebRtcSessionTest::OnDataChannelOpenMessage); | 395 this, &WebRtcSessionTest::OnDataChannelOpenMessage); |
392 session_->GetOnDestroyedSignal()->connect( | 396 session_->GetOnDestroyedSignal()->connect( |
393 this, &WebRtcSessionTest::OnSessionDestroyed); | 397 this, &WebRtcSessionTest::OnSessionDestroyed); |
394 | 398 |
395 EXPECT_EQ(PeerConnectionInterface::kIceConnectionNew, | 399 EXPECT_EQ(PeerConnectionInterface::kIceConnectionNew, |
396 observer_.ice_connection_state_); | 400 observer_.ice_connection_state_); |
397 EXPECT_EQ(PeerConnectionInterface::kIceGatheringNew, | 401 EXPECT_EQ(PeerConnectionInterface::kIceGatheringNew, |
398 observer_.ice_gathering_state_); | 402 observer_.ice_gathering_state_); |
399 | 403 |
(...skipping 4019 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
4419 } | 4423 } |
4420 | 4424 |
4421 // TODO(bemasc): Add a TestIceStatesBundle with BUNDLE enabled. That test | 4425 // TODO(bemasc): Add a TestIceStatesBundle with BUNDLE enabled. That test |
4422 // currently fails because upon disconnection and reconnection OnIceComplete is | 4426 // currently fails because upon disconnection and reconnection OnIceComplete is |
4423 // called more than once without returning to IceGatheringGathering. | 4427 // called more than once without returning to IceGatheringGathering. |
4424 | 4428 |
4425 INSTANTIATE_TEST_CASE_P(WebRtcSessionTests, | 4429 INSTANTIATE_TEST_CASE_P(WebRtcSessionTests, |
4426 WebRtcSessionTest, | 4430 WebRtcSessionTest, |
4427 testing::Values(ALREADY_GENERATED, | 4431 testing::Values(ALREADY_GENERATED, |
4428 DTLS_IDENTITY_STORE)); | 4432 DTLS_IDENTITY_STORE)); |
OLD | NEW |