| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2014 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2014 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 122 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 133 if (num_audio_streams_ > 0) | 133 if (num_audio_streams_ > 0) |
| 134 DestroyVoiceEngines(); | 134 DestroyVoiceEngines(); |
| 135 } | 135 } |
| 136 | 136 |
| 137 void CallTest::Start() { | 137 void CallTest::Start() { |
| 138 if (video_send_stream_) | 138 if (video_send_stream_) |
| 139 video_send_stream_->Start(); | 139 video_send_stream_->Start(); |
| 140 for (VideoReceiveStream* video_recv_stream : video_receive_streams_) | 140 for (VideoReceiveStream* video_recv_stream : video_receive_streams_) |
| 141 video_recv_stream->Start(); | 141 video_recv_stream->Start(); |
| 142 if (audio_send_stream_) { | 142 if (audio_send_stream_) { |
| 143 fake_send_audio_device_->Start(); | 143 fake_send_audio_device_->StartRecordingSine(1000, 256); |
| 144 audio_send_stream_->Start(); | 144 audio_send_stream_->Start(); |
| 145 EXPECT_EQ(0, voe_send_.base->StartSend(voe_send_.channel_id)); | 145 EXPECT_EQ(0, voe_send_.base->StartSend(voe_send_.channel_id)); |
| 146 } | 146 } |
| 147 for (AudioReceiveStream* audio_recv_stream : audio_receive_streams_) | 147 for (AudioReceiveStream* audio_recv_stream : audio_receive_streams_) |
| 148 audio_recv_stream->Start(); | 148 audio_recv_stream->Start(); |
| 149 if (!audio_receive_streams_.empty()) { | 149 if (!audio_receive_streams_.empty()) { |
| 150 fake_recv_audio_device_->Start(); | 150 fake_recv_audio_device_->StartPlayout(); |
| 151 EXPECT_EQ(0, voe_recv_.base->StartPlayout(voe_recv_.channel_id)); | 151 EXPECT_EQ(0, voe_recv_.base->StartPlayout(voe_recv_.channel_id)); |
| 152 } | 152 } |
| 153 for (FlexfecReceiveStream* flexfec_recv_stream : flexfec_receive_streams_) | 153 for (FlexfecReceiveStream* flexfec_recv_stream : flexfec_receive_streams_) |
| 154 flexfec_recv_stream->Start(); | 154 flexfec_recv_stream->Start(); |
| 155 if (frame_generator_capturer_.get() != NULL) | 155 if (frame_generator_capturer_.get() != NULL) |
| 156 frame_generator_capturer_->Start(); | 156 frame_generator_capturer_->Start(); |
| 157 } | 157 } |
| 158 | 158 |
| 159 void CallTest::Stop() { | 159 void CallTest::Stop() { |
| 160 if (frame_generator_capturer_.get() != NULL) | 160 if (frame_generator_capturer_.get() != NULL) |
| 161 frame_generator_capturer_->Stop(); | 161 frame_generator_capturer_->Stop(); |
| 162 for (FlexfecReceiveStream* flexfec_recv_stream : flexfec_receive_streams_) | 162 for (FlexfecReceiveStream* flexfec_recv_stream : flexfec_receive_streams_) |
| 163 flexfec_recv_stream->Stop(); | 163 flexfec_recv_stream->Stop(); |
| 164 if (!audio_receive_streams_.empty()) { | 164 if (!audio_receive_streams_.empty()) { |
| 165 fake_recv_audio_device_->Stop(); | 165 fake_recv_audio_device_->StopPlayout(); |
| 166 EXPECT_EQ(0, voe_recv_.base->StopPlayout(voe_recv_.channel_id)); | 166 EXPECT_EQ(0, voe_recv_.base->StopPlayout(voe_recv_.channel_id)); |
| 167 } | 167 } |
| 168 for (AudioReceiveStream* audio_recv_stream : audio_receive_streams_) | 168 for (AudioReceiveStream* audio_recv_stream : audio_receive_streams_) |
| 169 audio_recv_stream->Stop(); | 169 audio_recv_stream->Stop(); |
| 170 if (audio_send_stream_) { | 170 if (audio_send_stream_) { |
| 171 fake_send_audio_device_->Stop(); | 171 fake_send_audio_device_->StopRecording(); |
| 172 EXPECT_EQ(0, voe_send_.base->StopSend(voe_send_.channel_id)); | 172 EXPECT_EQ(0, voe_send_.base->StopSend(voe_send_.channel_id)); |
| 173 audio_send_stream_->Stop(); | 173 audio_send_stream_->Stop(); |
| 174 } | 174 } |
| 175 for (VideoReceiveStream* video_recv_stream : video_receive_streams_) | 175 for (VideoReceiveStream* video_recv_stream : video_receive_streams_) |
| 176 video_recv_stream->Stop(); | 176 video_recv_stream->Stop(); |
| 177 if (video_send_stream_) | 177 if (video_send_stream_) |
| 178 video_send_stream_->Stop(); | 178 video_send_stream_->Stop(); |
| 179 } | 179 } |
| 180 | 180 |
| 181 void CallTest::CreateCalls(const Call::Config& sender_config, | 181 void CallTest::CreateCalls(const Call::Config& sender_config, |
| (...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 302 int width, | 302 int width, |
| 303 int height) { | 303 int height) { |
| 304 frame_generator_capturer_.reset( | 304 frame_generator_capturer_.reset( |
| 305 test::FrameGeneratorCapturer::Create(width, height, framerate, clock_)); | 305 test::FrameGeneratorCapturer::Create(width, height, framerate, clock_)); |
| 306 video_send_stream_->SetSource( | 306 video_send_stream_->SetSource( |
| 307 frame_generator_capturer_.get(), | 307 frame_generator_capturer_.get(), |
| 308 VideoSendStream::DegradationPreference::kBalanced); | 308 VideoSendStream::DegradationPreference::kBalanced); |
| 309 } | 309 } |
| 310 | 310 |
| 311 void CallTest::CreateFakeAudioDevices() { | 311 void CallTest::CreateFakeAudioDevices() { |
| 312 fake_send_audio_device_.reset(new FakeAudioDevice( | 312 fake_send_audio_device_.reset( |
| 313 clock_, test::ResourcePath("voice_engine/audio_long16", "pcm"), | 313 new FakeAudioDevice(clock_, DriftingClock::kNoDrift)); |
| 314 DriftingClock::kNoDrift)); | 314 fake_recv_audio_device_.reset( |
| 315 fake_recv_audio_device_.reset(new FakeAudioDevice( | 315 new FakeAudioDevice(clock_, DriftingClock::kNoDrift)); |
| 316 clock_, test::ResourcePath("voice_engine/audio_long16", "pcm"), | |
| 317 DriftingClock::kNoDrift)); | |
| 318 } | 316 } |
| 319 | 317 |
| 320 void CallTest::CreateVideoStreams() { | 318 void CallTest::CreateVideoStreams() { |
| 321 RTC_DCHECK(video_send_stream_ == nullptr); | 319 RTC_DCHECK(video_send_stream_ == nullptr); |
| 322 RTC_DCHECK(video_receive_streams_.empty()); | 320 RTC_DCHECK(video_receive_streams_.empty()); |
| 323 RTC_DCHECK(audio_send_stream_ == nullptr); | 321 RTC_DCHECK(audio_send_stream_ == nullptr); |
| 324 RTC_DCHECK(audio_receive_streams_.empty()); | 322 RTC_DCHECK(audio_receive_streams_.empty()); |
| 325 | 323 |
| 326 video_send_stream_ = sender_call_->CreateVideoSendStream( | 324 video_send_stream_ = sender_call_->CreateVideoSendStream( |
| 327 video_send_config_.Copy(), video_encoder_config_.Copy()); | 325 video_send_config_.Copy(), video_encoder_config_.Copy()); |
| (...skipping 181 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 509 | 507 |
| 510 EndToEndTest::EndToEndTest(unsigned int timeout_ms) : BaseTest(timeout_ms) { | 508 EndToEndTest::EndToEndTest(unsigned int timeout_ms) : BaseTest(timeout_ms) { |
| 511 } | 509 } |
| 512 | 510 |
| 513 bool EndToEndTest::ShouldCreateReceivers() const { | 511 bool EndToEndTest::ShouldCreateReceivers() const { |
| 514 return true; | 512 return true; |
| 515 } | 513 } |
| 516 | 514 |
| 517 } // namespace test | 515 } // namespace test |
| 518 } // namespace webrtc | 516 } // namespace webrtc |
| OLD | NEW |