OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2013 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 175 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
186 const MediaType media_type_; | 186 const MediaType media_type_; |
187 | 187 |
188 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(MediaTypePacketReceiver); | 188 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(MediaTypePacketReceiver); |
189 }; | 189 }; |
190 | 190 |
191 FakeNetworkPipe::Config audio_net_config; | 191 FakeNetworkPipe::Config audio_net_config; |
192 audio_net_config.queue_delay_ms = 500; | 192 audio_net_config.queue_delay_ms = 500; |
193 audio_net_config.loss_percent = 5; | 193 audio_net_config.loss_percent = 5; |
194 test::PacketTransport audio_send_transport(sender_call_.get(), &observer, | 194 test::PacketTransport audio_send_transport(sender_call_.get(), &observer, |
195 test::PacketTransport::kSender, | 195 test::PacketTransport::kSender, |
196 MediaType::AUDIO, | |
197 audio_net_config); | 196 audio_net_config); |
198 MediaTypePacketReceiver audio_receiver(receiver_call_->Receiver(), | 197 MediaTypePacketReceiver audio_receiver(receiver_call_->Receiver(), |
199 MediaType::AUDIO); | 198 MediaType::AUDIO); |
200 audio_send_transport.SetReceiver(&audio_receiver); | 199 audio_send_transport.SetReceiver(&audio_receiver); |
201 | 200 |
202 test::PacketTransport video_send_transport(sender_call_.get(), &observer, | 201 test::PacketTransport video_send_transport(sender_call_.get(), &observer, |
203 test::PacketTransport::kSender, | 202 test::PacketTransport::kSender, |
204 MediaType::VIDEO, | |
205 FakeNetworkPipe::Config()); | 203 FakeNetworkPipe::Config()); |
206 MediaTypePacketReceiver video_receiver(receiver_call_->Receiver(), | 204 MediaTypePacketReceiver video_receiver(receiver_call_->Receiver(), |
207 MediaType::VIDEO); | 205 MediaType::VIDEO); |
208 video_send_transport.SetReceiver(&video_receiver); | 206 video_send_transport.SetReceiver(&video_receiver); |
209 | 207 |
210 test::PacketTransport receive_transport( | 208 test::PacketTransport receive_transport( |
211 receiver_call_.get(), &observer, test::PacketTransport::kReceiver, | 209 receiver_call_.get(), &observer, test::PacketTransport::kReceiver, |
212 MediaType::VIDEO, | |
213 FakeNetworkPipe::Config()); | 210 FakeNetworkPipe::Config()); |
214 receive_transport.SetReceiver(sender_call_->Receiver()); | 211 receive_transport.SetReceiver(sender_call_->Receiver()); |
215 | 212 |
216 test::FakeDecoder fake_decoder; | 213 test::FakeDecoder fake_decoder; |
217 | 214 |
218 CreateSendConfig(1, 0, 0, &video_send_transport); | 215 CreateSendConfig(1, 0, 0, &video_send_transport); |
219 CreateMatchingReceiveConfigs(&receive_transport); | 216 CreateMatchingReceiveConfigs(&receive_transport); |
220 | 217 |
221 AudioSendStream::Config audio_send_config(&audio_send_transport); | 218 AudioSendStream::Config audio_send_config(&audio_send_transport); |
222 audio_send_config.voe_channel_id = send_channel_id; | 219 audio_send_config.voe_channel_id = send_channel_id; |
(...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
338 start_time_ms_(start_time_ms), | 335 start_time_ms_(start_time_ms), |
339 run_time_ms_(run_time_ms), | 336 run_time_ms_(run_time_ms), |
340 creation_time_ms_(clock_->TimeInMilliseconds()), | 337 creation_time_ms_(clock_->TimeInMilliseconds()), |
341 capturer_(nullptr), | 338 capturer_(nullptr), |
342 rtp_start_timestamp_set_(false), | 339 rtp_start_timestamp_set_(false), |
343 rtp_start_timestamp_(0) {} | 340 rtp_start_timestamp_(0) {} |
344 | 341 |
345 private: | 342 private: |
346 test::PacketTransport* CreateSendTransport(Call* sender_call) override { | 343 test::PacketTransport* CreateSendTransport(Call* sender_call) override { |
347 return new test::PacketTransport( | 344 return new test::PacketTransport( |
348 sender_call, this, test::PacketTransport::kSender, MediaType::VIDEO, | 345 sender_call, this, test::PacketTransport::kSender, net_config_); |
349 net_config_); | |
350 } | 346 } |
351 | 347 |
352 test::PacketTransport* CreateReceiveTransport() override { | 348 test::PacketTransport* CreateReceiveTransport() override { |
353 return new test::PacketTransport( | 349 return new test::PacketTransport( |
354 nullptr, this, test::PacketTransport::kReceiver, MediaType::VIDEO, | 350 nullptr, this, test::PacketTransport::kReceiver, net_config_); |
355 net_config_); | |
356 } | 351 } |
357 | 352 |
358 void OnFrame(const VideoFrame& video_frame) override { | 353 void OnFrame(const VideoFrame& video_frame) override { |
359 rtc::CritScope lock(&crit_); | 354 rtc::CritScope lock(&crit_); |
360 if (video_frame.ntp_time_ms() <= 0) { | 355 if (video_frame.ntp_time_ms() <= 0) { |
361 // Haven't got enough RTCP SR in order to calculate the capture ntp | 356 // Haven't got enough RTCP SR in order to calculate the capture ntp |
362 // time. | 357 // time. |
363 return; | 358 return; |
364 } | 359 } |
365 | 360 |
(...skipping 377 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
743 uint32_t last_set_bitrate_kbps_; | 738 uint32_t last_set_bitrate_kbps_; |
744 VideoSendStream* send_stream_; | 739 VideoSendStream* send_stream_; |
745 test::FrameGeneratorCapturer* frame_generator_; | 740 test::FrameGeneratorCapturer* frame_generator_; |
746 VideoEncoderConfig encoder_config_; | 741 VideoEncoderConfig encoder_config_; |
747 } test; | 742 } test; |
748 | 743 |
749 RunBaseTest(&test); | 744 RunBaseTest(&test); |
750 } | 745 } |
751 | 746 |
752 } // namespace webrtc | 747 } // namespace webrtc |
OLD | NEW |