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 <stdint.h> | 5 #include <stdint.h> |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
83 virtual int64 GetBytesSent() OVERRIDE { | 83 virtual int64 GetBytesSent() OVERRIDE { |
84 return 0; | 84 return 0; |
85 } | 85 } |
86 | 86 |
87 int number_of_rtp_packets() const { return number_of_rtp_packets_; } | 87 int number_of_rtp_packets() const { return number_of_rtp_packets_; } |
88 | 88 |
89 int number_of_rtcp_packets() const { return number_of_rtcp_packets_; } | 89 int number_of_rtcp_packets() const { return number_of_rtcp_packets_; } |
90 | 90 |
91 void SetPause(bool paused) { | 91 void SetPause(bool paused) { |
92 paused_ = paused; | 92 paused_ = paused; |
93 if (!paused && stored_packet_) { | 93 if (!paused && stored_packet_.get()) { |
94 SendPacket(stored_packet_, callback_); | 94 SendPacket(stored_packet_, callback_); |
95 callback_.Run(); | 95 callback_.Run(); |
96 } | 96 } |
97 } | 97 } |
98 | 98 |
99 private: | 99 private: |
100 int number_of_rtp_packets_; | 100 int number_of_rtp_packets_; |
101 int number_of_rtcp_packets_; | 101 int number_of_rtcp_packets_; |
102 bool paused_; | 102 bool paused_; |
103 base::Closure callback_; | 103 base::Closure callback_; |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
196 transport_sender_.get())); | 196 transport_sender_.get())); |
197 } | 197 } |
198 ASSERT_EQ(STATUS_VIDEO_INITIALIZED, video_sender_->InitializationResult()); | 198 ASSERT_EQ(STATUS_VIDEO_INITIALIZED, video_sender_->InitializationResult()); |
199 } | 199 } |
200 | 200 |
201 scoped_refptr<media::VideoFrame> GetNewVideoFrame() { | 201 scoped_refptr<media::VideoFrame> GetNewVideoFrame() { |
202 gfx::Size size(kWidth, kHeight); | 202 gfx::Size size(kWidth, kHeight); |
203 scoped_refptr<media::VideoFrame> video_frame = | 203 scoped_refptr<media::VideoFrame> video_frame = |
204 media::VideoFrame::CreateFrame( | 204 media::VideoFrame::CreateFrame( |
205 VideoFrame::I420, size, gfx::Rect(size), size, base::TimeDelta()); | 205 VideoFrame::I420, size, gfx::Rect(size), size, base::TimeDelta()); |
206 PopulateVideoFrame(video_frame, last_pixel_value_++); | 206 PopulateVideoFrame(video_frame.get(), last_pixel_value_++); |
207 return video_frame; | 207 return video_frame; |
208 } | 208 } |
209 | 209 |
210 scoped_refptr<media::VideoFrame> GetLargeNewVideoFrame() { | 210 scoped_refptr<media::VideoFrame> GetLargeNewVideoFrame() { |
211 gfx::Size size(kWidth, kHeight); | 211 gfx::Size size(kWidth, kHeight); |
212 scoped_refptr<media::VideoFrame> video_frame = | 212 scoped_refptr<media::VideoFrame> video_frame = |
213 media::VideoFrame::CreateFrame( | 213 media::VideoFrame::CreateFrame( |
214 VideoFrame::I420, size, gfx::Rect(size), size, base::TimeDelta()); | 214 VideoFrame::I420, size, gfx::Rect(size), size, base::TimeDelta()); |
215 PopulateVideoFrameWithNoise(video_frame); | 215 PopulateVideoFrameWithNoise(video_frame.get()); |
216 return video_frame; | 216 return video_frame; |
217 } | 217 } |
218 | 218 |
219 void RunTasks(int during_ms) { | 219 void RunTasks(int during_ms) { |
220 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(during_ms)); | 220 task_runner_->Sleep(base::TimeDelta::FromMilliseconds(during_ms)); |
221 } | 221 } |
222 | 222 |
223 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. | 223 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. |
224 TestPacketSender transport_; | 224 TestPacketSender transport_; |
225 scoped_ptr<CastTransportSenderImpl> transport_sender_; | 225 scoped_ptr<CastTransportSenderImpl> transport_sender_; |
(...skipping 275 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
501 cast_feedback.ack_frame_id = 0; | 501 cast_feedback.ack_frame_id = 0; |
502 video_sender_->OnReceivedCastFeedback(cast_feedback); | 502 video_sender_->OnReceivedCastFeedback(cast_feedback); |
503 | 503 |
504 transport_.SetPause(false); | 504 transport_.SetPause(false); |
505 RunTasks(33); | 505 RunTasks(33); |
506 EXPECT_EQ(0, transport_.number_of_rtp_packets()); | 506 EXPECT_EQ(0, transport_.number_of_rtp_packets()); |
507 } | 507 } |
508 | 508 |
509 } // namespace cast | 509 } // namespace cast |
510 } // namespace media | 510 } // namespace media |
OLD | NEW |