New class RtpDemuxer and RtpPacketSinkInterface, use in Call.

webrtc/modules/rtp_rtcp/source/flexfec_receiver.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 114 matching lines @@
         0) {
       return false;
     }
   }
   // Return recovered packets through callback.
   for (const auto& recovered_packet : recovered_packets_) {
     if (recovered_packet->returned) {
       continue;
     }
     ++packet_counter_.num_recovered_packets;
+    // Set this flag first, since OnRecoveredPacket may end up here

[brandtr, 2017/05/16 08:19:39]

I'll look into why this is the case.

+    // again, with the same packet.
+    recovered_packet->returned = true;
     recovered_packet_receiver_->OnRecoveredPacket(
         recovered_packet->pkt->data, recovered_packet->pkt->length);
-    recovered_packet->returned = true;
     // Periodically log the incoming packets.
     int64_t now_ms = clock_->TimeInMilliseconds();
     if (now_ms - last_recovered_packet_ms_ > kPacketLogIntervalMs) {
       uint32_t media_ssrc =
           ForwardErrorCorrection::ParseSsrc(recovered_packet->pkt->data);
       LOG(LS_VERBOSE) << "Recovered media packet with SSRC: " << media_ssrc
                       << " from FlexFEC stream with SSRC: " << ssrc_ << ".";
       last_recovered_packet_ms_ = now_ms;
     }
   }
   return true;
 }
 
 }  // namespace webrtc