Index: webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.h |
diff --git a/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.h b/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.h |
index 4b5524877c77206c58eb8db145ba0f88202b75c9..e4ec8f5d049d472a11db110d5de5128fdd4e4c1b 100644 |
--- a/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.h |
+++ b/webrtc/modules/rtp_rtcp/source/rtp_receiver_impl.h |
@@ -12,6 +12,7 @@ |
#define WEBRTC_MODULES_RTP_RTCP_SOURCE_RTP_RECEIVER_IMPL_H_ |
#include <memory> |
+#include <vector> |
#include "webrtc/base/criticalsection.h" |
#include "webrtc/modules/rtp_rtcp/include/rtp_receiver.h" |
@@ -21,6 +22,9 @@ |
namespace webrtc { |
+// The maximum size of the ring buffer of the RtpContributingSource objects. |
+static const size_t kContributingSourcesBufferSize = 500; |
hbos
2017/03/30 09:51:54
What is the reason for choosing 500? Is this arbit
Zhi Huang
2017/03/31 06:44:04
I'm not sure what is right size of this. It is exp
|
+ |
class RtpReceiverImpl : public RtpReceiver { |
public: |
// Callbacks passed in here may not be NULL (use Null Object callbacks if you |
@@ -56,6 +60,8 @@ class RtpReceiverImpl : public RtpReceiver { |
TelephoneEventHandler* GetTelephoneEventHandler() override; |
+ const std::vector<RtpContributingSource*>& GetContributingSources() override; |
+ |
private: |
bool HaveReceivedFrame() const; |
@@ -66,6 +72,8 @@ class RtpReceiverImpl : public RtpReceiver { |
bool* is_red, |
PayloadUnion* payload); |
+ void UpdateContributingSource(); |
+ |
Clock* clock_; |
RTPPayloadRegistry* rtp_payload_registry_; |
std::unique_ptr<RTPReceiverStrategy> rtp_media_receiver_; |
@@ -84,6 +92,16 @@ class RtpReceiverImpl : public RtpReceiver { |
uint32_t last_received_timestamp_; |
int64_t last_received_frame_time_ms_; |
uint16_t last_received_sequence_number_; |
+ |
+ // Contributing Sources. |
+ std::vector<RtpContributingSource*> contributing_sources_; |
+ RtpContributingSource |
+ contributing_sources_buffer_[kContributingSourcesBufferSize]; |
+ // The contribuing source that uses the |ssrc_|. |
+ std::unique_ptr<RtpContributingSource> ssrc_source_; |
+ |
+ size_t current_buffer_index_; |
+ size_t current_buffer_size_; |
}; |
} // namespace webrtc |
#endif // WEBRTC_MODULES_RTP_RTCP_SOURCE_RTP_RECEIVER_IMPL_H_ |