Let FlexfecReceiveStreamImpl send RTCP RRs.

webrtc/call/call.cc

 /*
  *  Copyright (c) 2013 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 684 matching lines @@
   UpdateAggregateNetworkState();
   delete receive_stream_impl;
 }
 
 FlexfecReceiveStream* Call::CreateFlexfecReceiveStream(
     const FlexfecReceiveStream::Config& config) {
   TRACE_EVENT0("webrtc", "Call::CreateFlexfecReceiveStream");
   RTC_DCHECK(configuration_thread_checker_.CalledOnValidThread());
 
   RecoveredPacketReceiver* recovered_packet_receiver = this;
-  FlexfecReceiveStreamImpl* receive_stream =
-      new FlexfecReceiveStreamImpl(config, recovered_packet_receiver);
+  FlexfecReceiveStreamImpl* receive_stream = new FlexfecReceiveStreamImpl(
+      config, recovered_packet_receiver, call_stats_->rtcp_rtt_stats(),
+      module_process_thread_.get());
 
   {
     WriteLockScoped write_lock(*receive_crit_);
 
     RTC_DCHECK(flexfec_receive_streams_.find(receive_stream) ==
                flexfec_receive_streams_.end());
     flexfec_receive_streams_.insert(receive_stream);
 
     for (auto ssrc : config.protected_media_ssrcs)
       flexfec_receive_ssrcs_media_.insert(std::make_pair(ssrc, receive_stream));
@@ skipping 441 matching lines @@
       return status;
     }
   }
   if (media_type == MediaType::ANY || media_type == MediaType::VIDEO) {
     auto it = flexfec_receive_ssrcs_protection_.find(ssrc);
     if (it != flexfec_receive_ssrcs_protection_.end()) {
       rtc::Optional<RtpPacketReceived> parsed_packet =
           ParseRtpPacket(packet, length, packet_time);
       if (parsed_packet) {
         NotifyBweOfReceivedPacket(*parsed_packet);
-        auto status =
-            it->second->AddAndProcessReceivedPacket(std::move(*parsed_packet))
-                ? DELIVERY_OK
-                : DELIVERY_PACKET_ERROR;
+        auto status = it->second->AddAndProcessReceivedPacket(*parsed_packet)
+                          ? DELIVERY_OK
+                          : DELIVERY_PACKET_ERROR;
         if (status == DELIVERY_OK)
           event_log_->LogRtpHeader(kIncomingPacket, media_type, packet, length);
         return status;
       }
     }
   }
   return DELIVERY_UNKNOWN_SSRC;
 }
 
 PacketReceiver::DeliveryStatus Call::DeliverPacket(
@@ skipping 24 matching lines @@
 
 void Call::NotifyBweOfReceivedPacket(const RtpPacketReceived& packet) {
   RTPHeader header;
   packet.GetHeader(&header);
   congestion_controller_->OnReceivedPacket(packet.arrival_time_ms(),
                                            packet.payload_size(), header);
 }
 
 }  // namespace internal
 }  // namespace webrtc