RtpPacketReceiver base class and OnRtpPacket, with a pre-parsed RTP packet.

webrtc/call/flexfec_receive_stream_impl.cc

 /*
  *  Copyright (c) 2016 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 108 matching lines @@
 }
 
 }  // namespace
 
 FlexfecReceiveStreamImpl::FlexfecReceiveStreamImpl(
     const Config& config,
     RecoveredPacketReceiver* recovered_packet_receiver,
     RtcpRttStats* rtt_stats,
     ProcessThread* process_thread)
     : config_(config),
+      rtp_config_(config.rtp_header_extensions, config.transport_cc),
       started_(false),
       receiver_(MaybeCreateFlexfecReceiver(config_, recovered_packet_receiver)),
       rtp_receive_statistics_(
           ReceiveStatistics::Create(Clock::GetRealTimeClock())),
       rtp_rtcp_(CreateRtpRtcpModule(rtp_receive_statistics_.get(),
                                     config_.rtcp_send_transport,
                                     rtt_stats)),
       process_thread_(process_thread) {
   LOG(LS_INFO) << "FlexfecReceiveStreamImpl: " << config_.ToString();
 
   // RTCP reporting.
   rtp_rtcp_->SetSendingMediaStatus(false);
   rtp_rtcp_->SetRTCPStatus(config_.rtcp_mode);
   rtp_rtcp_->SetSSRC(config_.local_ssrc);
   process_thread_->RegisterModule(rtp_rtcp_.get());
 }
 
 FlexfecReceiveStreamImpl::~FlexfecReceiveStreamImpl() {
   LOG(LS_INFO) << "~FlexfecReceiveStreamImpl: " << config_.ToString();
   Stop();
   process_thread_->DeRegisterModule(rtp_rtcp_.get());
 }
 
-bool FlexfecReceiveStreamImpl::AddAndProcessReceivedPacket(
+bool FlexfecReceiveStreamImpl::OnRtpPacket(
     const RtpPacketReceived& packet) {
   {
     rtc::CritScope cs(&crit_);
     if (!started_)
       return false;
   }
 
   if (!receiver_)
     return false;
 
   if (!receiver_->AddAndProcessReceivedPacket(packet))
     return false;
 
   // Do not report media packets in the RTCP RRs generated by |rtp_rtcp_|.
   if (packet.Ssrc() == config_.remote_ssrc) {
     RTPHeader header;
     packet.GetHeader(&header);
     // FlexFEC packets are never retransmitted.
     const bool kNotRetransmitted = false;
     rtp_receive_statistics_->IncomingPacket(header, packet.size(),
                                             kNotRetransmitted);
   }
 
   return true;
 }
 
+const RtpPacketReceiver::RtpConfig&
+FlexfecReceiveStreamImpl::rtp_config() const {
+  return rtp_config_;
+}
+
 void FlexfecReceiveStreamImpl::Start() {
   rtc::CritScope cs(&crit_);
   started_ = true;
 }
 
 void FlexfecReceiveStreamImpl::Stop() {
   rtc::CritScope cs(&crit_);
   started_ = false;
 }
 
 // TODO(brandtr): Implement this member function when we have designed the
 // stats for FlexFEC.
 FlexfecReceiveStreamImpl::Stats FlexfecReceiveStreamImpl::GetStats() const {
   return FlexfecReceiveStream::Stats();
 }
 
 }  // namespace webrtc