OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/video_sender/video_sender.h" | 5 #include "media/cast/video_sender/video_sender.h" |
6 | 6 |
7 #include <list> | 7 #include <list> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
46 | 46 |
47 private: | 47 private: |
48 RtpSender* rtp_sender_; | 48 RtpSender* rtp_sender_; |
49 }; | 49 }; |
50 | 50 |
51 VideoSender::VideoSender( | 51 VideoSender::VideoSender( |
52 scoped_refptr<CastEnvironment> cast_environment, | 52 scoped_refptr<CastEnvironment> cast_environment, |
53 const VideoSenderConfig& video_config, | 53 const VideoSenderConfig& video_config, |
54 VideoEncoderController* const video_encoder_controller, | 54 VideoEncoderController* const video_encoder_controller, |
55 PacedPacketSender* const paced_packet_sender) | 55 PacedPacketSender* const paced_packet_sender) |
56 : incoming_feedback_ssrc_(video_config.incoming_feedback_ssrc), | 56 : rtp_max_delay_( |
57 rtp_max_delay_( | |
58 base::TimeDelta::FromMilliseconds(video_config.rtp_max_delay_ms)), | 57 base::TimeDelta::FromMilliseconds(video_config.rtp_max_delay_ms)), |
59 max_frame_rate_(video_config.max_frame_rate), | 58 max_frame_rate_(video_config.max_frame_rate), |
60 cast_environment_(cast_environment), | 59 cast_environment_(cast_environment), |
61 rtcp_feedback_(new LocalRtcpVideoSenderFeedback(this)), | 60 rtcp_feedback_(new LocalRtcpVideoSenderFeedback(this)), |
62 rtp_sender_(new RtpSender(cast_environment->Clock(), NULL, &video_config, | 61 rtp_sender_(new RtpSender(cast_environment->Clock(), NULL, &video_config, |
63 paced_packet_sender)), | 62 paced_packet_sender)), |
64 last_acked_frame_id_(-1), | 63 last_acked_frame_id_(-1), |
65 last_sent_frame_id_(-1), | 64 last_sent_frame_id_(-1), |
66 last_sent_key_frame_id_(-1), | 65 last_sent_key_frame_id_(-1), |
67 duplicate_ack_(0), | 66 duplicate_ack_(0), |
(...skipping 21 matching lines...) Expand all Loading... |
89 video_encoder_controller_ = video_encoder_.get(); | 88 video_encoder_controller_ = video_encoder_.get(); |
90 } | 89 } |
91 rtcp_.reset(new Rtcp( | 90 rtcp_.reset(new Rtcp( |
92 cast_environment_->Clock(), | 91 cast_environment_->Clock(), |
93 rtcp_feedback_.get(), | 92 rtcp_feedback_.get(), |
94 paced_packet_sender, | 93 paced_packet_sender, |
95 rtp_video_sender_statistics_.get(), | 94 rtp_video_sender_statistics_.get(), |
96 NULL, | 95 NULL, |
97 video_config.rtcp_mode, | 96 video_config.rtcp_mode, |
98 base::TimeDelta::FromMilliseconds(video_config.rtcp_interval), | 97 base::TimeDelta::FromMilliseconds(video_config.rtcp_interval), |
99 true, | |
100 video_config.sender_ssrc, | 98 video_config.sender_ssrc, |
| 99 video_config.incoming_feedback_ssrc, |
101 video_config.rtcp_c_name)); | 100 video_config.rtcp_c_name)); |
102 | |
103 rtcp_->SetRemoteSSRC(video_config.incoming_feedback_ssrc); | |
104 ScheduleNextRtcpReport(); | 101 ScheduleNextRtcpReport(); |
105 ScheduleNextResendCheck(); | 102 ScheduleNextResendCheck(); |
106 ScheduleNextSkippedFramesCheck(); | 103 ScheduleNextSkippedFramesCheck(); |
107 } | 104 } |
108 | 105 |
109 VideoSender::~VideoSender() {} | 106 VideoSender::~VideoSender() {} |
110 | 107 |
111 void VideoSender::InsertRawVideoFrame( | 108 void VideoSender::InsertRawVideoFrame( |
112 const I420VideoFrame* video_frame, | 109 const I420VideoFrame* video_frame, |
113 const base::TimeTicks& capture_time, | 110 const base::TimeTicks& capture_time, |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
163 | 160 |
164 time_to_next = std::max(time_to_next, | 161 time_to_next = std::max(time_to_next, |
165 base::TimeDelta::FromMilliseconds(kMinSchedulingDelayMs)); | 162 base::TimeDelta::FromMilliseconds(kMinSchedulingDelayMs)); |
166 | 163 |
167 cast_environment_->PostDelayedTask(CastEnvironment::MAIN, FROM_HERE, | 164 cast_environment_->PostDelayedTask(CastEnvironment::MAIN, FROM_HERE, |
168 base::Bind(&VideoSender::SendRtcpReport, weak_factory_.GetWeakPtr()), | 165 base::Bind(&VideoSender::SendRtcpReport, weak_factory_.GetWeakPtr()), |
169 time_to_next); | 166 time_to_next); |
170 } | 167 } |
171 | 168 |
172 void VideoSender::SendRtcpReport() { | 169 void VideoSender::SendRtcpReport() { |
173 rtcp_->SendRtcpReport(incoming_feedback_ssrc_); | 170 rtcp_->SendRtcpFromRtpSender(NULL); // TODO(pwestin): add logging. |
174 ScheduleNextRtcpReport(); | 171 ScheduleNextRtcpReport(); |
175 } | 172 } |
176 | 173 |
177 void VideoSender::ScheduleNextResendCheck() { | 174 void VideoSender::ScheduleNextResendCheck() { |
178 base::TimeDelta time_to_next; | 175 base::TimeDelta time_to_next; |
179 if (last_send_time_.is_null()) { | 176 if (last_send_time_.is_null()) { |
180 time_to_next = rtp_max_delay_; | 177 time_to_next = rtp_max_delay_; |
181 } else { | 178 } else { |
182 time_to_next = last_send_time_ - cast_environment_->Clock()->NowTicks() + | 179 time_to_next = last_send_time_ - cast_environment_->Clock()->NowTicks() + |
183 rtp_max_delay_; | 180 rtp_max_delay_; |
(...skipping 149 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
333 void VideoSender::ResendFrame(uint8 resend_frame_id) { | 330 void VideoSender::ResendFrame(uint8 resend_frame_id) { |
334 MissingFramesAndPacketsMap missing_frames_and_packets; | 331 MissingFramesAndPacketsMap missing_frames_and_packets; |
335 PacketIdSet missing; | 332 PacketIdSet missing; |
336 missing_frames_and_packets.insert(std::make_pair(resend_frame_id, missing)); | 333 missing_frames_and_packets.insert(std::make_pair(resend_frame_id, missing)); |
337 rtp_sender_->ResendPackets(missing_frames_and_packets); | 334 rtp_sender_->ResendPackets(missing_frames_and_packets); |
338 last_send_time_ = cast_environment_->Clock()->NowTicks(); | 335 last_send_time_ = cast_environment_->Clock()->NowTicks(); |
339 } | 336 } |
340 | 337 |
341 } // namespace cast | 338 } // namespace cast |
342 } // namespace media | 339 } // namespace media |
OLD | NEW |