OLD | NEW |
---|---|
1 /* | 1 /* |
2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
11 #ifndef WEBRTC_CALL_FLEXFEC_RECEIVE_STREAM_IMPL_H_ | 11 #ifndef WEBRTC_CALL_FLEXFEC_RECEIVE_STREAM_IMPL_H_ |
12 #define WEBRTC_CALL_FLEXFEC_RECEIVE_STREAM_IMPL_H_ | 12 #define WEBRTC_CALL_FLEXFEC_RECEIVE_STREAM_IMPL_H_ |
13 | 13 |
14 #include <memory> | 14 #include <memory> |
15 #include <string> | |
16 | 15 |
17 #include "webrtc/base/basictypes.h" | |
18 #include "webrtc/base/criticalsection.h" | 16 #include "webrtc/base/criticalsection.h" |
19 #include "webrtc/call/flexfec_receive_stream.h" | 17 #include "webrtc/call/flexfec_receive_stream.h" |
20 #include "webrtc/modules/rtp_rtcp/include/flexfec_receiver.h" | |
21 #include "webrtc/modules/rtp_rtcp/source/rtp_packet_received.h" | |
22 | 18 |
23 namespace webrtc { | 19 namespace webrtc { |
24 | 20 |
21 class FlexfecReceiver; | |
brandtr
2017/01/10 11:57:52
https://chromium.googlesource.com/chromium/src/+/m
| |
22 class ProcessThread; | |
23 class ReceiveStatistics; | |
24 class RecoveredPacketReceiver; | |
25 class RtcpRttStats; | |
26 class RtpPacketReceived; | |
27 class RtpRtcp; | |
28 | |
25 class FlexfecReceiveStreamImpl : public FlexfecReceiveStream { | 29 class FlexfecReceiveStreamImpl : public FlexfecReceiveStream { |
26 public: | 30 public: |
27 FlexfecReceiveStreamImpl(const Config& config, | 31 FlexfecReceiveStreamImpl(const Config& config, |
28 RecoveredPacketReceiver* recovered_packet_receiver); | 32 RecoveredPacketReceiver* recovered_packet_receiver, |
33 RtcpRttStats* rtt_stats, | |
34 ProcessThread* process_thread); | |
29 ~FlexfecReceiveStreamImpl() override; | 35 ~FlexfecReceiveStreamImpl() override; |
30 | 36 |
31 const Config& GetConfig() const { return config_; } | 37 const Config& GetConfig() const { return config_; } |
32 | 38 |
33 bool AddAndProcessReceivedPacket(RtpPacketReceived packet); | 39 bool AddAndProcessReceivedPacket(const RtpPacketReceived& packet); |
34 | 40 |
35 // Implements FlexfecReceiveStream. | 41 // Implements FlexfecReceiveStream. |
36 void Start() override; | 42 void Start() override; |
37 void Stop() override; | 43 void Stop() override; |
38 Stats GetStats() const override; | 44 Stats GetStats() const override; |
39 | 45 |
40 private: | 46 private: |
47 // Config. | |
48 const Config config_; | |
49 bool started_ GUARDED_BY(crit_); | |
41 rtc::CriticalSection crit_; | 50 rtc::CriticalSection crit_; |
42 bool started_ GUARDED_BY(crit_); | |
43 | 51 |
44 const Config config_; | 52 // Erasure code interfacing. |
45 const std::unique_ptr<FlexfecReceiver> receiver_; | 53 const std::unique_ptr<FlexfecReceiver> receiver_; |
54 | |
55 // RTCP reporting. | |
56 const std::unique_ptr<ReceiveStatistics> rtp_receive_statistics_; | |
57 const std::unique_ptr<RtpRtcp> rtp_rtcp_; | |
58 ProcessThread* process_thread_; | |
46 }; | 59 }; |
47 | 60 |
48 } // namespace webrtc | 61 } // namespace webrtc |
49 | 62 |
50 #endif // WEBRTC_CALL_FLEXFEC_RECEIVE_STREAM_IMPL_H_ | 63 #endif // WEBRTC_CALL_FLEXFEC_RECEIVE_STREAM_IMPL_H_ |
OLD | NEW |