Chromium Code Reviews| Index: webrtc/audio/audio_send_stream.h |
| diff --git a/webrtc/audio/audio_send_stream.h b/webrtc/audio/audio_send_stream.h |
| index 5ee49da91a7a1469285d1fcf675c39c53a43ac5c..87d2a3b2e3a952adc47a09c196e418ad30357e22 100644 |
| --- a/webrtc/audio/audio_send_stream.h |
| +++ b/webrtc/audio/audio_send_stream.h |
| @@ -12,12 +12,14 @@ |
| #define WEBRTC_AUDIO_AUDIO_SEND_STREAM_H_ |
| #include <memory> |
| +#include <vector> |
| #include "webrtc/base/constructormagic.h" |
| #include "webrtc/base/thread_checker.h" |
| #include "webrtc/call/audio_send_stream.h" |
| #include "webrtc/call/audio_state.h" |
| #include "webrtc/call/bitrate_allocator.h" |
| +#include "webrtc/modules/rtp_rtcp/include/rtp_rtcp_defines.h" |
| namespace webrtc { |
| class CongestionController; |
| @@ -33,7 +35,8 @@ class ChannelProxy; |
| namespace internal { |
| class AudioSendStream final : public webrtc::AudioSendStream, |
| - public webrtc::BitrateAllocatorObserver { |
| + public webrtc::BitrateAllocatorObserver, |
| + public webrtc::TransportFeedbackAdapterObserver { |
| public: |
| AudioSendStream(const webrtc::AudioSendStream::Config& config, |
| const rtc::scoped_refptr<webrtc::AudioState>& audio_state, |
| @@ -62,6 +65,10 @@ class AudioSendStream final : public webrtc::AudioSendStream, |
| int64_t rtt, |
| int64_t probing_interval_ms) override; |
| + // From TransportFeedbackAdapterObserver |
| + void OnPacketAdded(uint32_t ssrc, uint16_t seq_num) override; |
| + void OnTransportFeedback(const rtcp::TransportFeedback& feedback) override; |
| + |
| const webrtc::AudioSendStream::Config& config() const; |
| void SetTransportOverhead(int transport_overhead_per_packet); |
| @@ -70,6 +77,7 @@ class AudioSendStream final : public webrtc::AudioSendStream, |
| bool SetupSendCodec(); |
| + const Clock* const clock_; |
| rtc::ThreadChecker thread_checker_; |
| rtc::TaskQueue* worker_queue_; |
| const webrtc::AudioSendStream::Config config_; |
| @@ -80,6 +88,10 @@ class AudioSendStream final : public webrtc::AudioSendStream, |
| CongestionController* const congestion_controller_; |
| std::unique_ptr<RtcpBandwidthObserver> bandwidth_observer_; |
| + rtc::CriticalSection packets_sent_since_last_feedback_cs_; |
| + std::vector<SentTransportPacketRecord> packets_sent_since_last_feedback_ |
|
minyue-webrtc
2017/03/15 10:54:13
I don't understand why we need this buffer given t
elad.alon_webrtc.org
2017/03/16 18:37:35
Because of the threading issue. Please see my othe
|
| + GUARDED_BY(&packets_sent_since_last_feedback_cs_); |
| + |
| RTC_DISALLOW_IMPLICIT_CONSTRUCTORS(AudioSendStream); |
| }; |
| } // namespace internal |