zqz/platform-external-webrtc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add ability to cap the video jitter estimate to a max value.

Browse Source 
Bug: webrtc:10572
Change-Id: I21112824dc02afa71db61bb8c2f02723e8b325b6
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/133963
Commit-Queue: Michael Horowitz <mhoro@webrtc.org>
Reviewed-by: Stefan Holmer <stefan@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#27744}
This commit is contained in:
“Michael
2019-04-24 08:04:34 -05:00
committed by Commit Bot
parent 9b809d3e7f
commit a8ae407a48
6 changed files with 19 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
modules/video_coding/frame_buffer2.cc
View File

@ -299,10 +299,14 @@ EncodedFrame* FrameBuffer::GetNextFrame() {
} }
float rtt_mult = protection_mode_ == kProtectionNackFEC ? 0.0 : 1.0; float rtt_mult = protection_mode_ == kProtectionNackFEC ? 0.0 : 1.0;
float jitter_est_cap_ms = 300.0;
if (RttMultExperiment::RttMultEnabled()) { if (RttMultExperiment::RttMultEnabled()) {
rtt_mult = RttMultExperiment::GetRttMultValue(); rtt_mult = RttMultExperiment::GetRttMultValue();
// TODO(mhoro): add RttMultExperiment::GetJitterEstCapValue();
jitter_est_cap_ms = 300.0;
} }
timing_->SetJitterDelay(jitter_estimator_->GetJitterEstimate(rtt_mult)); timing_->SetJitterDelay(
jitter_estimator_->GetJitterEstimate(rtt_mult, jitter_est_cap_ms));
timing_->UpdateCurrentDelay(render_time_ms, now_ms); timing_->UpdateCurrentDelay(render_time_ms, now_ms);
} else { } else {
if (RttMultExperiment::RttMultEnabled() || add_rtt_to_playout_delay_) if (RttMultExperiment::RttMultEnabled() || add_rtt_to_playout_delay_)

7
modules/video_coding/frame_buffer2_unittest.cc
View File

@ -83,7 +83,8 @@ class VCMJitterEstimatorMock : public VCMJitterEstimator {
void(int64_t frameDelayMs, void(int64_t frameDelayMs,
uint32_t frameSizeBytes, uint32_t frameSizeBytes,
bool incompleteFrame)); bool incompleteFrame));
MOCK_METHOD1(GetJitterEstimate, int(double rttMultiplier)); MOCK_METHOD2(GetJitterEstimate,
int(double rttMultiplier, double jitterEstCapMs));
}; };
class FrameObjectFake : public EncodedFrame { class FrameObjectFake : public EncodedFrame {
@ -403,12 +404,12 @@ TEST_F(TestFrameBuffer2, ProtectionMode) {
uint16_t pid = Rand(); uint16_t pid = Rand();
uint32_t ts = Rand(); uint32_t ts = Rand();
EXPECT_CALL(jitter_estimator_, GetJitterEstimate(1.0)); EXPECT_CALL(jitter_estimator_, GetJitterEstimate(1.0, 300.0));
InsertFrame(pid, 0, ts, false, true); InsertFrame(pid, 0, ts, false, true);
ExtractFrame(); ExtractFrame();
buffer_->SetProtectionMode(kProtectionNackFEC); buffer_->SetProtectionMode(kProtectionNackFEC);
EXPECT_CALL(jitter_estimator_, GetJitterEstimate(0.0)); EXPECT_CALL(jitter_estimator_, GetJitterEstimate(0.0, 300.0));
InsertFrame(pid + 1, 0, ts, false, true); InsertFrame(pid + 1, 0, ts, false, true);
ExtractFrame(); ExtractFrame();
} }

3
modules/video_coding/jitter_buffer.cc
View File

@ -582,7 +582,8 @@ void VCMJitterBuffer::FindAndInsertContinuousFramesWithState(
uint32_t VCMJitterBuffer::EstimatedJitterMs() { uint32_t VCMJitterBuffer::EstimatedJitterMs() {
rtc::CritScope cs(&crit_sect_); rtc::CritScope cs(&crit_sect_);
const double rtt_mult = 1.0f; const double rtt_mult = 1.0f;
return jitter_estimate_.GetJitterEstimate(rtt_mult); const double jitter_est_cap_ms = 300.0f;
return jitter_estimate_.GetJitterEstimate(rtt_mult, jitter_est_cap_ms);
} }
void VCMJitterBuffer::SetNackSettings(size_t max_nack_list_size, void VCMJitterBuffer::SetNackSettings(size_t max_nack_list_size,

7
modules/video_coding/jitter_estimator.cc
View File

@ -384,7 +384,8 @@ void VCMJitterEstimator::UpdateMaxFrameSize(uint32_t frameSizeBytes) {
// Returns the current filtered estimate if available, // Returns the current filtered estimate if available,
// otherwise tries to calculate an estimate. // otherwise tries to calculate an estimate.
int VCMJitterEstimator::GetJitterEstimate(double rttMultiplier) { int VCMJitterEstimator::GetJitterEstimate(double rttMultiplier,
double jitterEstCapMs) {
double jitterMS = CalculateEstimate() + OPERATING_SYSTEM_JITTER; double jitterMS = CalculateEstimate() + OPERATING_SYSTEM_JITTER;
uint64_t now = clock_->TimeInMicroseconds(); uint64_t now = clock_->TimeInMicroseconds();
@ -393,8 +394,10 @@ int VCMJitterEstimator::GetJitterEstimate(double rttMultiplier) {
if (_filterJitterEstimate > jitterMS) if (_filterJitterEstimate > jitterMS)
jitterMS = _filterJitterEstimate; jitterMS = _filterJitterEstimate;
if (_nackCount >= _nackLimit) if (_nackCount >= _nackLimit) {
jitterMS += _rttFilter.RttMs() * rttMultiplier; jitterMS += _rttFilter.RttMs() * rttMultiplier;
jitterMS = std::min(jitterMS, jitterEstCapMs);
}
static const double kJitterScaleLowThreshold = 5.0; static const double kJitterScaleLowThreshold = 5.0;
static const double kJitterScaleHighThreshold = 10.0; static const double kJitterScaleHighThreshold = 10.0;

2
modules/video_coding/jitter_estimator.h
View File

@ -47,7 +47,7 @@ class VCMJitterEstimator {
// - rttMultiplier : RTT param multiplier (when applicable). // - rttMultiplier : RTT param multiplier (when applicable).
// //
// Return value : Jitter estimate in milliseconds. // Return value : Jitter estimate in milliseconds.
virtual int GetJitterEstimate(double rttMultiplier); virtual int GetJitterEstimate(double rttMultiplier, double jitterEstCapMs);
// Updates the nack counter. // Updates the nack counter.
void FrameNacked(); void FrameNacked();

4
modules/video_coding/jitter_estimator_tests.cc
View File

@ -67,7 +67,7 @@ TEST_F(TestVCMJitterEstimator, TestLowRate) {
estimator_->UpdateEstimate(gen.Delay(), gen.FrameSize()); estimator_->UpdateEstimate(gen.Delay(), gen.FrameSize());
AdvanceClock(time_delta_us); AdvanceClock(time_delta_us);
if (i > 2) if (i > 2)
EXPECT_EQ(estimator_->GetJitterEstimate(0), 0); EXPECT_EQ(estimator_->GetJitterEstimate(0, 300), 0);
gen.Advance(); gen.Advance();
} }
} }
@ -98,7 +98,7 @@ TEST_F(TestVCMJitterEstimator, TestUpperBound) {
estimator_->UpdateEstimate(gen.Delay(), gen.FrameSize()); estimator_->UpdateEstimate(gen.Delay(), gen.FrameSize());
AdvanceClock(time_delta_us); AdvanceClock(time_delta_us);
context.percentiles.Add( context.percentiles.Add(
static_cast<uint32_t>(estimator_->GetJitterEstimate(0))); static_cast<uint32_t>(estimator_->GetJitterEstimate(0, 300)));
gen.Advance(); gen.Advance();
} }
} }