Periodically send RTCP report during Media Remoting.

chrome/browser/media/cast_remoting_sender.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/media/cast_remoting_sender.h"
 
 #include <algorithm>
 #include <map>
 
 #include "base/bind.h"
@@ skipping 483 matching lines @@
     remoting_event.size = remoting_frame.data.length();
     remoting_event.key_frame =
         remoting_frame.dependency == media::cast::EncodedFrame::KEY;
     recent_frame_events_.push_back(remoting_event);
   }
 
   RecordLatestFrameTimestamps(frame_id, remoting_frame.rtp_timestamp);
 
   transport_->InsertFrame(ssrc_, remoting_frame);
 
+  // Start periodically sending RTCP report to receiver to prevent keepalive
+  // timeouts on receiver side during media pause.
+  if (is_first_frame_to_be_sent)
+    ScheduleNextRtcpReport();
+
   return true;
 }
 
 void CastRemotingSender::CancelInFlightData() {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
   base::STLClearObject(&next_frame_data_);
 
   // TODO(miu): The following code is something we want to do as an
   // optimization. However, as-is, it's not quite correct. We can only cancel
@@ skipping 29 matching lines @@
     frame_event_cb_.Run(frame_events);
   }
 
   base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
       FROM_HERE,
       base::BindOnce(&CastRemotingSender::SendFrameEvents,
                      weak_factory_.GetWeakPtr()),
       logging_flush_interval_);
 }
 
+void CastRemotingSender::ScheduleNextRtcpReport() {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
+      FROM_HERE,
+      base::BindOnce(&CastRemotingSender::SendRtcpReport,
+                     weak_factory_.GetWeakPtr()),
+      base::TimeDelta::FromMilliseconds(media::cast::kRtcpReportIntervalMs));
+}
+
+void CastRemotingSender::SendRtcpReport() {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  DCHECK(!last_send_time_.is_null());
+
+  const base::TimeTicks now = clock_->NowTicks();
+  const base::TimeDelta time_delta = now - last_send_time_;
+  const media::cast::RtpTimeDelta rtp_delta =
+      media::cast::RtpTimeDelta::FromTimeDelta(
+          time_delta, media::cast::kRemotingRtpTimebase);
+  const media::cast::RtpTimeTicks now_as_rtp_timestamp =
+      GetRecordedRtpTimestamp(last_sent_frame_id_) + rtp_delta;
+  transport_->SendSenderReport(ssrc_, now, now_as_rtp_timestamp);
+
+  ScheduleNextRtcpReport();
+}
+
 }  // namespace cast