OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "media/cast/net/rtp/rtp_packetizer.h" | 5 #include "media/cast/net/rtp/rtp_packetizer.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
10 #include "base/test/simple_test_tick_clock.h" | 10 #include "base/test/simple_test_tick_clock.h" |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
103 protected: | 103 protected: |
104 RtpPacketizerTest() | 104 RtpPacketizerTest() |
105 : task_runner_(new test::FakeSingleThreadTaskRunner(&testing_clock_)), | 105 : task_runner_(new test::FakeSingleThreadTaskRunner(&testing_clock_)), |
106 video_frame_(), | 106 video_frame_(), |
107 packet_storage_(200) { | 107 packet_storage_(200) { |
108 config_.sequence_number = kSeqNum; | 108 config_.sequence_number = kSeqNum; |
109 config_.ssrc = kSsrc; | 109 config_.ssrc = kSsrc; |
110 config_.payload_type = kPayload; | 110 config_.payload_type = kPayload; |
111 config_.max_payload_length = kMaxPacketLength; | 111 config_.max_payload_length = kMaxPacketLength; |
112 transport_.reset(new TestRtpPacketTransport(config_)); | 112 transport_.reset(new TestRtpPacketTransport(config_)); |
113 pacer_.reset(new PacedSender( | 113 pacer_.reset(new PacedSender(kTargetBurstSize, |
114 &testing_clock_, &logging_, transport_.get(), task_runner_)); | 114 kMaxBurstSize, |
| 115 &testing_clock_, |
| 116 &logging_, |
| 117 transport_.get(), |
| 118 task_runner_)); |
115 pacer_->RegisterVideoSsrc(config_.ssrc); | 119 pacer_->RegisterVideoSsrc(config_.ssrc); |
116 rtp_packetizer_.reset(new RtpPacketizer( | 120 rtp_packetizer_.reset(new RtpPacketizer( |
117 pacer_.get(), &packet_storage_, config_)); | 121 pacer_.get(), &packet_storage_, config_)); |
118 video_frame_.dependency = EncodedFrame::DEPENDENT; | 122 video_frame_.dependency = EncodedFrame::DEPENDENT; |
119 video_frame_.frame_id = 0; | 123 video_frame_.frame_id = 0; |
120 video_frame_.referenced_frame_id = kStartFrameId; | 124 video_frame_.referenced_frame_id = kStartFrameId; |
121 video_frame_.data.assign(kFrameSize, 123); | 125 video_frame_.data.assign(kFrameSize, 123); |
122 video_frame_.rtp_timestamp = | 126 video_frame_.rtp_timestamp = |
123 GetVideoRtpTimestamp(testing_clock_.NowTicks()); | 127 GetVideoRtpTimestamp(testing_clock_.NowTicks()); |
124 } | 128 } |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
168 video_frame_.reference_time = testing_clock_.NowTicks(); | 172 video_frame_.reference_time = testing_clock_.NowTicks(); |
169 rtp_packetizer_->SendFrameAsPackets(video_frame_); | 173 rtp_packetizer_->SendFrameAsPackets(video_frame_); |
170 RunTasks(33 + 1); | 174 RunTasks(33 + 1); |
171 EXPECT_EQ(expected_num_of_packets, rtp_packetizer_->send_packet_count()); | 175 EXPECT_EQ(expected_num_of_packets, rtp_packetizer_->send_packet_count()); |
172 EXPECT_EQ(kFrameSize, rtp_packetizer_->send_octet_count()); | 176 EXPECT_EQ(kFrameSize, rtp_packetizer_->send_octet_count()); |
173 EXPECT_EQ(expected_num_of_packets, transport_->number_of_packets_received()); | 177 EXPECT_EQ(expected_num_of_packets, transport_->number_of_packets_received()); |
174 } | 178 } |
175 | 179 |
176 } // namespace cast | 180 } // namespace cast |
177 } // namespace media | 181 } // namespace media |
OLD | NEW |