| 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 duplicate_ack_(0), | 65 duplicate_ack_(0), |
| 67 last_skip_count_(0), | 66 last_skip_count_(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 } | 101 } |
| 105 | 102 |
| 106 VideoSender::~VideoSender() {} | 103 VideoSender::~VideoSender() {} |
| 107 | 104 |
| 108 void VideoSender::InitializeTimers() { | 105 void VideoSender::InitializeTimers() { |
| 109 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); | 106 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
| 110 if (!initialized_) { | 107 if (!initialized_) { |
| 111 initialized_ = true; | 108 initialized_ = true; |
| 112 ScheduleNextRtcpReport(); | 109 ScheduleNextRtcpReport(); |
| 113 ScheduleNextResendCheck(); | 110 ScheduleNextResendCheck(); |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 175 time_to_next = std::max(time_to_next, | 172 time_to_next = std::max(time_to_next, |
| 176 base::TimeDelta::FromMilliseconds(kMinSchedulingDelayMs)); | 173 base::TimeDelta::FromMilliseconds(kMinSchedulingDelayMs)); |
| 177 | 174 |
| 178 cast_environment_->PostDelayedTask(CastEnvironment::MAIN, FROM_HERE, | 175 cast_environment_->PostDelayedTask(CastEnvironment::MAIN, FROM_HERE, |
| 179 base::Bind(&VideoSender::SendRtcpReport, weak_factory_.GetWeakPtr()), | 176 base::Bind(&VideoSender::SendRtcpReport, weak_factory_.GetWeakPtr()), |
| 180 time_to_next); | 177 time_to_next); |
| 181 } | 178 } |
| 182 | 179 |
| 183 void VideoSender::SendRtcpReport() { | 180 void VideoSender::SendRtcpReport() { |
| 184 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); | 181 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
| 185 rtcp_->SendRtcpReport(incoming_feedback_ssrc_); | 182 rtcp_->SendRtcpFromRtpSender(NULL); // TODO(pwestin): add logging. |
| 186 ScheduleNextRtcpReport(); | 183 ScheduleNextRtcpReport(); |
| 187 } | 184 } |
| 188 | 185 |
| 189 void VideoSender::ScheduleNextResendCheck() { | 186 void VideoSender::ScheduleNextResendCheck() { |
| 190 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); | 187 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
| 191 base::TimeDelta time_to_next; | 188 base::TimeDelta time_to_next; |
| 192 if (last_send_time_.is_null()) { | 189 if (last_send_time_.is_null()) { |
| 193 time_to_next = rtp_max_delay_; | 190 time_to_next = rtp_max_delay_; |
| 194 } else { | 191 } else { |
| 195 time_to_next = last_send_time_ - cast_environment_->Clock()->NowTicks() + | 192 time_to_next = last_send_time_ - cast_environment_->Clock()->NowTicks() + |
| (...skipping 153 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 349 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); | 346 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
| 350 MissingFramesAndPacketsMap missing_frames_and_packets; | 347 MissingFramesAndPacketsMap missing_frames_and_packets; |
| 351 PacketIdSet missing; | 348 PacketIdSet missing; |
| 352 missing_frames_and_packets.insert(std::make_pair(resend_frame_id, missing)); | 349 missing_frames_and_packets.insert(std::make_pair(resend_frame_id, missing)); |
| 353 rtp_sender_->ResendPackets(missing_frames_and_packets); | 350 rtp_sender_->ResendPackets(missing_frames_and_packets); |
| 354 last_send_time_ = cast_environment_->Clock()->NowTicks(); | 351 last_send_time_ = cast_environment_->Clock()->NowTicks(); |
| 355 } | 352 } |
| 356 | 353 |
| 357 } // namespace cast | 354 } // namespace cast |
| 358 } // namespace media | 355 } // namespace media |
| OLD | NEW |