| 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 #include "webrtc/test/direct_transport.h" | 10 #include "webrtc/test/direct_transport.h" |
| 11 | 11 |
| 12 #include "webrtc/call/call.h" | 12 #include "webrtc/call/call.h" |
| 13 #include "webrtc/rtc_base/ptr_util.h" | 13 #include "webrtc/rtc_base/ptr_util.h" |
| 14 #include "webrtc/system_wrappers/include/clock.h" | 14 #include "webrtc/system_wrappers/include/clock.h" |
| 15 #include "webrtc/test/single_threaded_task_queue.h" | 15 #include "webrtc/test/single_threaded_task_queue.h" |
| 16 | 16 |
| 17 namespace webrtc { | 17 namespace webrtc { |
| 18 namespace test { | 18 namespace test { |
| 19 | 19 |
| 20 DirectTransport::DirectTransport( | 20 DirectTransport::DirectTransport( |
| 21 Call* send_call, | |
| 22 const std::map<uint8_t, MediaType>& payload_type_map) | |
| 23 : DirectTransport(FakeNetworkPipe::Config(), send_call, payload_type_map) {} | |
| 24 | |
| 25 DirectTransport::DirectTransport( | |
| 26 const FakeNetworkPipe::Config& config, | |
| 27 Call* send_call, | |
| 28 const std::map<uint8_t, MediaType>& payload_type_map) | |
| 29 : DirectTransport( | |
| 30 config, | |
| 31 send_call, | |
| 32 std::unique_ptr<Demuxer>(new DemuxerImpl(payload_type_map))) {} | |
| 33 | |
| 34 DirectTransport::DirectTransport(const FakeNetworkPipe::Config& config, | |
| 35 Call* send_call, | |
| 36 std::unique_ptr<Demuxer> demuxer) | |
| 37 : DirectTransport(nullptr, config, send_call, std::move(demuxer)) {} | |
| 38 | |
| 39 DirectTransport::DirectTransport( | |
| 40 SingleThreadedTaskQueueForTesting* task_queue, | 21 SingleThreadedTaskQueueForTesting* task_queue, |
| 41 Call* send_call, | 22 Call* send_call, |
| 42 const std::map<uint8_t, MediaType>& payload_type_map) | 23 const std::map<uint8_t, MediaType>& payload_type_map) |
| 43 : DirectTransport(task_queue, | 24 : DirectTransport(task_queue, |
| 44 FakeNetworkPipe::Config(), | 25 FakeNetworkPipe::Config(), |
| 45 send_call, | 26 send_call, |
| 46 payload_type_map) { | 27 payload_type_map) { |
| 47 } | 28 } |
| 48 | 29 |
| 49 DirectTransport::DirectTransport( | 30 DirectTransport::DirectTransport( |
| 50 SingleThreadedTaskQueueForTesting* task_queue, | 31 SingleThreadedTaskQueueForTesting* task_queue, |
| 51 const FakeNetworkPipe::Config& config, | 32 const FakeNetworkPipe::Config& config, |
| 52 Call* send_call, | 33 Call* send_call, |
| 53 const std::map<uint8_t, MediaType>& payload_type_map) | 34 const std::map<uint8_t, MediaType>& payload_type_map) |
| 54 : DirectTransport( | 35 : DirectTransport( |
| 55 task_queue, | 36 task_queue, |
| 56 config, | 37 config, |
| 57 send_call, | 38 send_call, |
| 58 std::unique_ptr<Demuxer>(new DemuxerImpl(payload_type_map))) { | 39 std::unique_ptr<Demuxer>(new DemuxerImpl(payload_type_map))) { |
| 59 } | 40 } |
| 60 | 41 |
| 61 DirectTransport::DirectTransport(SingleThreadedTaskQueueForTesting* task_queue, | 42 DirectTransport::DirectTransport(SingleThreadedTaskQueueForTesting* task_queue, |
| 62 const FakeNetworkPipe::Config& config, | 43 const FakeNetworkPipe::Config& config, |
| 63 Call* send_call, | 44 Call* send_call, |
| 64 std::unique_ptr<Demuxer> demuxer) | 45 std::unique_ptr<Demuxer> demuxer) |
| 65 : send_call_(send_call), | 46 : send_call_(send_call), |
| 66 clock_(Clock::GetRealTimeClock()), | 47 clock_(Clock::GetRealTimeClock()), |
| 67 task_queue_(task_queue), | 48 task_queue_(task_queue), |
| 68 fake_network_(clock_, config, std::move(demuxer)) { | 49 fake_network_(clock_, config, std::move(demuxer)) { |
| 69 // TODO(eladalon): When the deprecated ctors are removed, this check | 50 RTC_DCHECK(task_queue); |
| 70 // can be restored. https://bugs.chromium.org/p/webrtc/issues/detail?id=8125 | |
| 71 // RTC_DCHECK(task_queue); | |
| 72 if (!task_queue) { | |
| 73 deprecated_task_queue_ = | |
| 74 rtc::MakeUnique<SingleThreadedTaskQueueForTesting>("deprecated_queue"); | |
| 75 task_queue_ = deprecated_task_queue_.get(); | |
| 76 } | |
| 77 | |
| 78 if (send_call_) { | 51 if (send_call_) { |
| 79 send_call_->SignalChannelNetworkState(MediaType::AUDIO, kNetworkUp); | 52 send_call_->SignalChannelNetworkState(MediaType::AUDIO, kNetworkUp); |
| 80 send_call_->SignalChannelNetworkState(MediaType::VIDEO, kNetworkUp); | 53 send_call_->SignalChannelNetworkState(MediaType::VIDEO, kNetworkUp); |
| 81 } | 54 } |
| 82 SendPackets(); | 55 SendPackets(); |
| 83 } | 56 } |
| 84 | 57 |
| 85 DirectTransport::~DirectTransport() { | 58 DirectTransport::~DirectTransport() { |
| 86 RTC_DCHECK_CALLED_SEQUENTIALLY(&sequence_checker_); | 59 RTC_DCHECK_CALLED_SEQUENTIALLY(&sequence_checker_); |
| 87 // Constructor updates |next_scheduled_task_|, so it's guaranteed to | 60 // Constructor updates |next_scheduled_task_|, so it's guaranteed to |
| (...skipping 29 matching lines...) Expand all Loading... |
| 117 | 90 |
| 118 bool DirectTransport::SendRtcp(const uint8_t* data, size_t length) { | 91 bool DirectTransport::SendRtcp(const uint8_t* data, size_t length) { |
| 119 fake_network_.SendPacket(data, length); | 92 fake_network_.SendPacket(data, length); |
| 120 return true; | 93 return true; |
| 121 } | 94 } |
| 122 | 95 |
| 123 int DirectTransport::GetAverageDelayMs() { | 96 int DirectTransport::GetAverageDelayMs() { |
| 124 return fake_network_.AverageDelay(); | 97 return fake_network_.AverageDelay(); |
| 125 } | 98 } |
| 126 | 99 |
| 127 DirectTransport::ForceDemuxer::ForceDemuxer(MediaType media_type) | |
| 128 : media_type_(media_type) {} | |
| 129 | |
| 130 void DirectTransport::ForceDemuxer::SetReceiver(PacketReceiver* receiver) { | |
| 131 packet_receiver_ = receiver; | |
| 132 } | |
| 133 | |
| 134 void DirectTransport::ForceDemuxer::DeliverPacket( | |
| 135 const NetworkPacket* packet, | |
| 136 const PacketTime& packet_time) { | |
| 137 if (!packet_receiver_) | |
| 138 return; | |
| 139 packet_receiver_->DeliverPacket(media_type_, packet->data(), | |
| 140 packet->data_length(), packet_time); | |
| 141 } | |
| 142 | |
| 143 void DirectTransport::SendPackets() { | 100 void DirectTransport::SendPackets() { |
| 144 RTC_DCHECK_CALLED_SEQUENTIALLY(&sequence_checker_); | 101 RTC_DCHECK_CALLED_SEQUENTIALLY(&sequence_checker_); |
| 145 | 102 |
| 146 fake_network_.Process(); | 103 fake_network_.Process(); |
| 147 | 104 |
| 148 int64_t delay_ms = fake_network_.TimeUntilNextProcess(); | 105 int64_t delay_ms = fake_network_.TimeUntilNextProcess(); |
| 149 next_scheduled_task_ = task_queue_->PostDelayedTask([this]() { | 106 next_scheduled_task_ = task_queue_->PostDelayedTask([this]() { |
| 150 SendPackets(); | 107 SendPackets(); |
| 151 }, delay_ms); | 108 }, delay_ms); |
| 152 } | 109 } |
| 153 } // namespace test | 110 } // namespace test |
| 154 } // namespace webrtc | 111 } // namespace webrtc |
| OLD | NEW |