commit d328229d38940257f69bddcdd1ee8e5960724b47
author Danil Chapovalov <danilchap@webrtc.org> Mon Nov 13 13:46:02 2017 +0100
committer Commit Bot <commit-bot@chromium.org> Mon Nov 13 14:50:11 2017 +0000
tree 10773b49bbe35a94b1bb4b9d0baa57529613b6af
parent b5b5bcee722c8b646e545ca6b85518aa8aaa1eda

Add sending REMB support to RtcpTransceiver

Bug: webrtc:8239
Change-Id: If22de91a69b5752baf616520a247f2fdedacc220
Reviewed-on: https://webrtc-review.googlesource.com/22080
Commit-Queue: Danil Chapovalov <danilchap@webrtc.org>
Reviewed-by: Niels Moller <nisse@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#20657}

modules/rtp_rtcp/source/rtcp_transceiver_impl.cc

diff --git a/modules/rtp_rtcp/source/rtcp_transceiver_impl.cc b/modules/rtp_rtcp/source/rtcp_transceiver_impl.cc
index 5b1224d..d6127a9 100644
--- a/modules/rtp_rtcp/source/rtcp_transceiver_impl.cc
+++ b/modules/rtp_rtcp/source/rtcp_transceiver_impl.cc
@@ -97,6 +97,21 @@
     ReschedulePeriodicCompoundPackets(config_.report_period_ms);
 }
 
+void RtcpTransceiverImpl::SetRemb(int bitrate_bps,
+                                  std::vector<uint32_t> ssrcs) {
+  RTC_DCHECK_GE(bitrate_bps, 0);
+  remb_.emplace();
+  remb_->SetSsrcs(std::move(ssrcs));
+  remb_->SetBitrateBps(bitrate_bps);
+  // TODO(bugs.webrtc.org/8239): Move logic from PacketRouter for sending remb
+  // immideately on large bitrate change when there is one RtcpTransceiver per
+  // rtp transport.
+}
+
+void RtcpTransceiverImpl::UnsetRemb() {
+  remb_.reset();
+}
+
 void RtcpTransceiverImpl::HandleReceivedPacket(
     const rtcp::CommonHeader& rtcp_packet_header) {
   switch (rtcp_packet_header.type()) {
@@ -149,9 +164,10 @@
 
 void RtcpTransceiverImpl::SendPacket() {
   PacketSender sender(config_.outgoing_transport, config_.max_packet_size);
+  const uint32_t sender_ssrc = config_.feedback_ssrc;
 
   rtcp::ReceiverReport receiver_report;
-  receiver_report.SetSenderSsrc(config_.feedback_ssrc);
+  receiver_report.SetSenderSsrc(sender_ssrc);
   receiver_report.SetReportBlocks(CreateReportBlocks());
   sender.AppendPacket(receiver_report);
 
@@ -162,6 +178,10 @@
                       << " to rtcp sdes packet.";
     sender.AppendPacket(sdes);
   }
+  if (remb_) {
+    remb_->SetSenderSsrc(sender_ssrc);
+    sender.AppendPacket(*remb_);
+  }
 
   sender.Send();
 }