Add a FlexfecReceiver class.

webrtc/modules/rtp_rtcp/source/flexfec_receiver_impl.h

Index: webrtc/modules/rtp_rtcp/source/flexfec_receiver_impl.h
diff --git a/webrtc/modules/rtp_rtcp/source/flexfec_receiver_impl.h b/webrtc/modules/rtp_rtcp/source/flexfec_receiver_impl.h
new file mode 100644
index 0000000000000000000000000000000000000000..0b5e5ec4ca978c7e0d85bde1a7feaf05a2039fe2
--- /dev/null
+++ b/webrtc/modules/rtp_rtcp/source/flexfec_receiver_impl.h
@@ -0,0 +1,58 @@
+/*
+ *  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.
+ */
+
+#ifndef WEBRTC_MODULES_RTP_RTCP_SOURCE_FLEXFEC_RECEIVER_IMPL_H_
+#define WEBRTC_MODULES_RTP_RTCP_SOURCE_FLEXFEC_RECEIVER_IMPL_H_
+
+#include <memory>
+
+#include "webrtc/base/basictypes.h"
+#include "webrtc/base/thread_checker.h"
+#include "webrtc/call.h"
+#include "webrtc/modules/rtp_rtcp/include/flexfec_receiver.h"
+#include "webrtc/modules/rtp_rtcp/source/forward_error_correction.h"
+#include "webrtc/system_wrappers/include/clock.h"
+
+namespace webrtc {
+
+class FlexfecReceiverImpl : public FlexfecReceiver {
+ public:
+  FlexfecReceiverImpl(uint32_t flexfec_ssrc,
+                      uint32_t protected_media_ssrc,
+                      RecoveredPacketReceiver* callback);
+  ~FlexfecReceiverImpl();
+
+  // Implements FlexfecReceiver.
+  bool AddReceivedPacket(const uint8_t* packet, size_t packet_length);
+  bool ProcessReceivedPackets();
+  FecPacketCounter GetPacketCounter() const;
+
+ private:
+  // Config.
+  const uint32_t flexfec_ssrc_;
+  const uint32_t protected_media_ssrc_;
+
+  // Erasure code interfacing and callback.
+  std::unique_ptr<ForwardErrorCorrection> erasure_code_;
+  ForwardErrorCorrection::ReceivedPacketList received_packets_;
+  ForwardErrorCorrection::RecoveredPacketList recovered_packets_;
+  RecoveredPacketReceiver* callback_;

[stefan-webrtc, 2016/10/05 14:45:59]

RecoveredPacketReceiver* const callback_

[brandtr, 2016/10/06 08:38:57]

Done.

+
+  // Logging and stats.
+  Clock* const clock_;
+  int64_t last_recovered_packet_ms_;
+  FecPacketCounter packet_counter_;
+
+  rtc::ThreadChecker thread_checker_;

[danilchap, 2016/10/05 14:32:04]

may be use SequentialThreadChecker to support upcoming ThreadQueue.

[brandtr, 2016/10/06 08:38:57]

Sounds good! I wasn't aware that the SequencedTaskChecker worked for threads as
well.

+};
+
+}  // namespace webrtc
+
+#endif  // WEBRTC_MODULES_RTP_RTCP_SOURCE_FLEXFEC_RECEIVER_IMPL_H_