| 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 150 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 161 send_audio_state_config.audio_mixer = AudioMixerImpl::Create(); | 161 send_audio_state_config.audio_mixer = AudioMixerImpl::Create(); |
| 162 Call::Config sender_config(event_log_.get()); | 162 Call::Config sender_config(event_log_.get()); |
| 163 sender_config.audio_state = AudioState::Create(send_audio_state_config); | 163 sender_config.audio_state = AudioState::Create(send_audio_state_config); |
| 164 Call::Config receiver_config(event_log_.get()); | 164 Call::Config receiver_config(event_log_.get()); |
| 165 receiver_config.audio_state = sender_config.audio_state; | 165 receiver_config.audio_state = sender_config.audio_state; |
| 166 CreateCalls(sender_config, receiver_config); | 166 CreateCalls(sender_config, receiver_config); |
| 167 | 167 |
| 168 | 168 |
| 169 VideoRtcpAndSyncObserver observer(Clock::GetRealTimeClock()); | 169 VideoRtcpAndSyncObserver observer(Clock::GetRealTimeClock()); |
| 170 | 170 |
| 171 // Helper class to ensure we deliver correct media_type to the receiving call. | |
| 172 class MediaTypePacketReceiver : public PacketReceiver { | |
| 173 public: | |
| 174 MediaTypePacketReceiver(PacketReceiver* packet_receiver, | |
| 175 MediaType media_type) | |
| 176 : packet_receiver_(packet_receiver), media_type_(media_type) {} | |
| 177 | |
| 178 DeliveryStatus DeliverPacket(MediaType media_type, | |
| 179 const uint8_t* packet, | |
| 180 size_t length, | |
| 181 const PacketTime& packet_time) override { | |
| 182 return packet_receiver_->DeliverPacket(media_type_, packet, length, | |
| 183 packet_time); | |
| 184 } | |
| 185 private: | |
| 186 PacketReceiver* packet_receiver_; | |
| 187 const MediaType media_type_; | |
| 188 | |
| 189 RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(MediaTypePacketReceiver); | |
| 190 }; | |
| 191 | |
| 192 FakeNetworkPipe::Config audio_net_config; | 171 FakeNetworkPipe::Config audio_net_config; |
| 193 audio_net_config.queue_delay_ms = 500; | 172 audio_net_config.queue_delay_ms = 500; |
| 194 audio_net_config.loss_percent = 5; | 173 audio_net_config.loss_percent = 5; |
| 195 | 174 |
| 196 std::map<uint8_t, MediaType> audio_pt_map; | 175 std::map<uint8_t, MediaType> audio_pt_map; |
| 197 std::map<uint8_t, MediaType> video_pt_map; | 176 std::map<uint8_t, MediaType> video_pt_map; |
| 198 std::copy_if(std::begin(payload_type_map_), std::end(payload_type_map_), | 177 std::copy_if(std::begin(payload_type_map_), std::end(payload_type_map_), |
| 199 std::inserter(audio_pt_map, audio_pt_map.end()), | 178 std::inserter(audio_pt_map, audio_pt_map.end()), |
| 200 [](const std::pair<const uint8_t, MediaType>& pair) { | 179 [](const std::pair<const uint8_t, MediaType>& pair) { |
| 201 return pair.second == MediaType::AUDIO; | 180 return pair.second == MediaType::AUDIO; |
| 202 }); | 181 }); |
| 203 std::copy_if(std::begin(payload_type_map_), std::end(payload_type_map_), | 182 std::copy_if(std::begin(payload_type_map_), std::end(payload_type_map_), |
| 204 std::inserter(video_pt_map, video_pt_map.end()), | 183 std::inserter(video_pt_map, video_pt_map.end()), |
| 205 [](const std::pair<const uint8_t, MediaType>& pair) { | 184 [](const std::pair<const uint8_t, MediaType>& pair) { |
| 206 return pair.second == MediaType::VIDEO; | 185 return pair.second == MediaType::VIDEO; |
| 207 }); | 186 }); |
| 208 | 187 |
| 209 test::PacketTransport audio_send_transport(sender_call_.get(), &observer, | 188 test::PacketTransport audio_send_transport(sender_call_.get(), &observer, |
| 210 test::PacketTransport::kSender, | 189 test::PacketTransport::kSender, |
| 211 audio_pt_map, audio_net_config); | 190 audio_pt_map, audio_net_config); |
| 212 MediaTypePacketReceiver audio_receiver(receiver_call_->Receiver(), | 191 audio_send_transport.SetReceiver(receiver_call_->Receiver()); |
| 213 MediaType::AUDIO); | |
| 214 audio_send_transport.SetReceiver(&audio_receiver); | |
| 215 | 192 |
| 216 test::PacketTransport video_send_transport( | 193 test::PacketTransport video_send_transport( |
| 217 sender_call_.get(), &observer, test::PacketTransport::kSender, | 194 sender_call_.get(), &observer, test::PacketTransport::kSender, |
| 218 video_pt_map, FakeNetworkPipe::Config()); | 195 video_pt_map, FakeNetworkPipe::Config()); |
| 219 MediaTypePacketReceiver video_receiver(receiver_call_->Receiver(), | 196 video_send_transport.SetReceiver(receiver_call_->Receiver()); |
| 220 MediaType::VIDEO); | |
| 221 video_send_transport.SetReceiver(&video_receiver); | |
| 222 | 197 |
| 223 test::PacketTransport receive_transport( | 198 test::PacketTransport receive_transport( |
| 224 receiver_call_.get(), &observer, test::PacketTransport::kReceiver, | 199 receiver_call_.get(), &observer, test::PacketTransport::kReceiver, |
| 225 payload_type_map_, FakeNetworkPipe::Config()); | 200 payload_type_map_, FakeNetworkPipe::Config()); |
| 226 receive_transport.SetReceiver(sender_call_->Receiver()); | 201 receive_transport.SetReceiver(sender_call_->Receiver()); |
| 227 | 202 |
| 228 test::FakeDecoder fake_decoder; | 203 test::FakeDecoder fake_decoder; |
| 229 | 204 |
| 230 CreateSendConfig(1, 0, 0, &video_send_transport); | 205 CreateSendConfig(1, 0, 0, &video_send_transport); |
| 231 CreateMatchingReceiveConfigs(&receive_transport); | 206 CreateMatchingReceiveConfigs(&receive_transport); |
| (...skipping 545 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 777 uint32_t last_set_bitrate_kbps_; | 752 uint32_t last_set_bitrate_kbps_; |
| 778 VideoSendStream* send_stream_; | 753 VideoSendStream* send_stream_; |
| 779 test::FrameGeneratorCapturer* frame_generator_; | 754 test::FrameGeneratorCapturer* frame_generator_; |
| 780 VideoEncoderConfig encoder_config_; | 755 VideoEncoderConfig encoder_config_; |
| 781 } test; | 756 } test; |
| 782 | 757 |
| 783 RunBaseTest(&test); | 758 RunBaseTest(&test); |
| 784 } | 759 } |
| 785 | 760 |
| 786 } // namespace webrtc | 761 } // namespace webrtc |
| OLD | NEW |