Removed VCMTiming from RtpVideoStreamReceiver.
Bug: webrtc:8909 Change-Id: Ib42e4cc4c2252f04ea5f7d440352546d36d2899f Reviewed-on: https://webrtc-review.googlesource.com/58740 Reviewed-by: Stefan Holmer <stefan@webrtc.org> Commit-Queue: Philip Eliasson <philipel@webrtc.org> Cr-Commit-Position: refs/heads/master@{#22224}
This commit is contained in:
@ -290,6 +290,9 @@ void FrameBuffer::UpdatePlayoutDelays(const EncodedFrame& frame) {
|
|||||||
|
|
||||||
if (playout_delay.max_ms >= 0)
|
if (playout_delay.max_ms >= 0)
|
||||||
timing_->set_max_playout_delay(playout_delay.max_ms);
|
timing_->set_max_playout_delay(playout_delay.max_ms);
|
||||||
|
|
||||||
|
if (!frame.delayed_by_retransmission())
|
||||||
|
timing_->IncomingTimestamp(frame.timestamp, frame.ReceivedTime());
|
||||||
}
|
}
|
||||||
|
|
||||||
int64_t FrameBuffer::InsertFrame(std::unique_ptr<EncodedFrame> frame) {
|
int64_t FrameBuffer::InsertFrame(std::unique_ptr<EncodedFrame> frame) {
|
||||||
@ -375,6 +378,7 @@ int64_t FrameBuffer::InsertFrame(std::unique_ptr<EncodedFrame> frame) {
|
|||||||
if (!UpdateFrameInfoWithIncomingFrame(*frame, info))
|
if (!UpdateFrameInfoWithIncomingFrame(*frame, info))
|
||||||
return last_continuous_picture_id;
|
return last_continuous_picture_id;
|
||||||
UpdatePlayoutDelays(*frame);
|
UpdatePlayoutDelays(*frame);
|
||||||
|
|
||||||
info->second.frame = std::move(frame);
|
info->second.frame = std::move(frame);
|
||||||
++num_frames_buffered_;
|
++num_frames_buffered_;
|
||||||
|
|
||||||
|
|||||||
@ -91,8 +91,7 @@ RtpVideoStreamReceiver::RtpVideoStreamReceiver(
|
|||||||
ProcessThread* process_thread,
|
ProcessThread* process_thread,
|
||||||
NackSender* nack_sender,
|
NackSender* nack_sender,
|
||||||
KeyFrameRequestSender* keyframe_request_sender,
|
KeyFrameRequestSender* keyframe_request_sender,
|
||||||
video_coding::OnCompleteFrameCallback* complete_frame_callback,
|
video_coding::OnCompleteFrameCallback* complete_frame_callback)
|
||||||
VCMTiming* timing)
|
|
||||||
: clock_(Clock::GetRealTimeClock()),
|
: clock_(Clock::GetRealTimeClock()),
|
||||||
config_(*config),
|
config_(*config),
|
||||||
packet_router_(packet_router),
|
packet_router_(packet_router),
|
||||||
@ -114,7 +113,6 @@ RtpVideoStreamReceiver::RtpVideoStreamReceiver(
|
|||||||
packet_router)),
|
packet_router)),
|
||||||
complete_frame_callback_(complete_frame_callback),
|
complete_frame_callback_(complete_frame_callback),
|
||||||
keyframe_request_sender_(keyframe_request_sender),
|
keyframe_request_sender_(keyframe_request_sender),
|
||||||
timing_(timing),
|
|
||||||
has_received_frame_(false) {
|
has_received_frame_(false) {
|
||||||
constexpr bool remb_candidate = true;
|
constexpr bool remb_candidate = true;
|
||||||
packet_router_->AddReceiveRtpModule(rtp_rtcp_.get(), remb_candidate);
|
packet_router_->AddReceiveRtpModule(rtp_rtcp_.get(), remb_candidate);
|
||||||
@ -389,8 +387,6 @@ void RtpVideoStreamReceiver::OnReceivedFrame(
|
|||||||
keyframe_request_sender_->RequestKeyFrame();
|
keyframe_request_sender_->RequestKeyFrame();
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!frame->delayed_by_retransmission())
|
|
||||||
timing_->IncomingTimestamp(frame->timestamp, clock_->TimeInMilliseconds());
|
|
||||||
reference_finder_->ManageFrame(std::move(frame));
|
reference_finder_->ManageFrame(std::move(frame));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -48,7 +48,6 @@ class RtpPacketReceived;
|
|||||||
class RtpReceiver;
|
class RtpReceiver;
|
||||||
class Transport;
|
class Transport;
|
||||||
class UlpfecReceiver;
|
class UlpfecReceiver;
|
||||||
class VCMTiming;
|
|
||||||
|
|
||||||
namespace vcm {
|
namespace vcm {
|
||||||
class VideoReceiver;
|
class VideoReceiver;
|
||||||
@ -74,8 +73,7 @@ class RtpVideoStreamReceiver : public RtpData,
|
|||||||
ProcessThread* process_thread,
|
ProcessThread* process_thread,
|
||||||
NackSender* nack_sender,
|
NackSender* nack_sender,
|
||||||
KeyFrameRequestSender* keyframe_request_sender,
|
KeyFrameRequestSender* keyframe_request_sender,
|
||||||
video_coding::OnCompleteFrameCallback* complete_frame_callback,
|
video_coding::OnCompleteFrameCallback* complete_frame_callback);
|
||||||
VCMTiming* timing);
|
|
||||||
~RtpVideoStreamReceiver();
|
~RtpVideoStreamReceiver();
|
||||||
|
|
||||||
bool AddReceiveCodec(const VideoCodec& video_codec,
|
bool AddReceiveCodec(const VideoCodec& video_codec,
|
||||||
@ -189,7 +187,6 @@ class RtpVideoStreamReceiver : public RtpData,
|
|||||||
// Members for the new jitter buffer experiment.
|
// Members for the new jitter buffer experiment.
|
||||||
video_coding::OnCompleteFrameCallback* complete_frame_callback_;
|
video_coding::OnCompleteFrameCallback* complete_frame_callback_;
|
||||||
KeyFrameRequestSender* keyframe_request_sender_;
|
KeyFrameRequestSender* keyframe_request_sender_;
|
||||||
VCMTiming* timing_;
|
|
||||||
std::unique_ptr<NackModule> nack_module_;
|
std::unique_ptr<NackModule> nack_module_;
|
||||||
rtc::scoped_refptr<video_coding::PacketBuffer> packet_buffer_;
|
rtc::scoped_refptr<video_coding::PacketBuffer> packet_buffer_;
|
||||||
std::unique_ptr<video_coding::RtpFrameReferenceFinder> reference_finder_;
|
std::unique_ptr<video_coding::RtpFrameReferenceFinder> reference_finder_;
|
||||||
|
|||||||
@ -20,7 +20,6 @@
|
|||||||
#include "modules/video_coding/include/video_coding_defines.h"
|
#include "modules/video_coding/include/video_coding_defines.h"
|
||||||
#include "modules/video_coding/packet.h"
|
#include "modules/video_coding/packet.h"
|
||||||
#include "modules/video_coding/rtp_frame_reference_finder.h"
|
#include "modules/video_coding/rtp_frame_reference_finder.h"
|
||||||
#include "modules/video_coding/timing.h"
|
|
||||||
#include "rtc_base/bytebuffer.h"
|
#include "rtc_base/bytebuffer.h"
|
||||||
#include "rtc_base/logging.h"
|
#include "rtc_base/logging.h"
|
||||||
#include "rtc_base/ptr_util.h"
|
#include "rtc_base/ptr_util.h"
|
||||||
@ -122,7 +121,6 @@ class RtpVideoStreamReceiverTest : public testing::Test {
|
|||||||
explicit RtpVideoStreamReceiverTest(std::string field_trials)
|
explicit RtpVideoStreamReceiverTest(std::string field_trials)
|
||||||
: override_field_trials_(field_trials),
|
: override_field_trials_(field_trials),
|
||||||
config_(CreateConfig()),
|
config_(CreateConfig()),
|
||||||
timing_(Clock::GetRealTimeClock()),
|
|
||||||
process_thread_(ProcessThread::Create("TestThread")) {}
|
process_thread_(ProcessThread::Create("TestThread")) {}
|
||||||
|
|
||||||
void SetUp() {
|
void SetUp() {
|
||||||
@ -132,8 +130,7 @@ class RtpVideoStreamReceiverTest : public testing::Test {
|
|||||||
&mock_transport_, nullptr, &packet_router_, &config_,
|
&mock_transport_, nullptr, &packet_router_, &config_,
|
||||||
rtp_receive_statistics_.get(), nullptr, process_thread_.get(),
|
rtp_receive_statistics_.get(), nullptr, process_thread_.get(),
|
||||||
&mock_nack_sender_,
|
&mock_nack_sender_,
|
||||||
&mock_key_frame_request_sender_, &mock_on_complete_frame_callback_,
|
&mock_key_frame_request_sender_, &mock_on_complete_frame_callback_);
|
||||||
&timing_);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
WebRtcRTPHeader GetDefaultPacket() {
|
WebRtcRTPHeader GetDefaultPacket() {
|
||||||
@ -196,7 +193,6 @@ class RtpVideoStreamReceiverTest : public testing::Test {
|
|||||||
MockTransport mock_transport_;
|
MockTransport mock_transport_;
|
||||||
MockOnCompleteFrameCallback mock_on_complete_frame_callback_;
|
MockOnCompleteFrameCallback mock_on_complete_frame_callback_;
|
||||||
PacketRouter packet_router_;
|
PacketRouter packet_router_;
|
||||||
VCMTiming timing_;
|
|
||||||
std::unique_ptr<ProcessThread> process_thread_;
|
std::unique_ptr<ProcessThread> process_thread_;
|
||||||
std::unique_ptr<ReceiveStatistics> rtp_receive_statistics_;
|
std::unique_ptr<ReceiveStatistics> rtp_receive_statistics_;
|
||||||
std::unique_ptr<RtpVideoStreamReceiver> rtp_video_stream_receiver_;
|
std::unique_ptr<RtpVideoStreamReceiver> rtp_video_stream_receiver_;
|
||||||
|
|||||||
@ -110,10 +110,9 @@ VideoReceiveStream::VideoReceiveStream(
|
|||||||
rtp_receive_statistics_.get(),
|
rtp_receive_statistics_.get(),
|
||||||
&stats_proxy_,
|
&stats_proxy_,
|
||||||
process_thread_,
|
process_thread_,
|
||||||
this, // NackSender
|
this, // NackSender
|
||||||
this, // KeyFrameRequestSender
|
this, // KeyFrameRequestSender
|
||||||
this, // OnCompleteFrameCallback
|
this), // OnCompleteFrameCallback
|
||||||
timing_.get()),
|
|
||||||
rtp_stream_sync_(this) {
|
rtp_stream_sync_(this) {
|
||||||
RTC_LOG(LS_INFO) << "VideoReceiveStream: " << config_.ToString();
|
RTC_LOG(LS_INFO) << "VideoReceiveStream: " << config_.ToString();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user