| 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 |