Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(147)

Side by Side Diff: webrtc/modules/video_coding/frame_buffer2.cc

Issue 2638423003: Revert of Make the new jitter buffer the default jitter buffer. (Closed)
Patch Set: Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 #include "webrtc/modules/video_coding/frame_buffer2.h" 11 #include "webrtc/modules/video_coding/frame_buffer2.h"
12 12
13 #include <algorithm> 13 #include <algorithm>
14 #include <cstring> 14 #include <cstring>
15 #include <queue> 15 #include <queue>
16 16
17 #include "webrtc/base/checks.h" 17 #include "webrtc/base/checks.h"
18 #include "webrtc/base/logging.h" 18 #include "webrtc/base/logging.h"
19 #include "webrtc/modules/video_coding/include/video_coding_defines.h"
20 #include "webrtc/modules/video_coding/jitter_estimator.h" 19 #include "webrtc/modules/video_coding/jitter_estimator.h"
21 #include "webrtc/modules/video_coding/timing.h" 20 #include "webrtc/modules/video_coding/timing.h"
22 #include "webrtc/system_wrappers/include/clock.h" 21 #include "webrtc/system_wrappers/include/clock.h"
23 #include "webrtc/system_wrappers/include/metrics.h" 22 #include "webrtc/system_wrappers/include/metrics.h"
24 23
25 namespace webrtc { 24 namespace webrtc {
26 namespace video_coding { 25 namespace video_coding {
27 26
28 namespace { 27 namespace {
29 // Max number of frames the buffer will hold. 28 // Max number of frames the buffer will hold.
30 constexpr int kMaxFramesBuffered = 600; 29 constexpr int kMaxFramesBuffered = 600;
31 30
32 // Max number of decoded frame info that will be saved. 31 // Max number of decoded frame info that will be saved.
33 constexpr int kMaxFramesHistory = 50; 32 constexpr int kMaxFramesHistory = 50;
34 } // namespace 33 } // namespace
35 34
36 FrameBuffer::FrameBuffer(Clock* clock, 35 FrameBuffer::FrameBuffer(Clock* clock,
37 VCMJitterEstimator* jitter_estimator, 36 VCMJitterEstimator* jitter_estimator,
38 VCMTiming* timing, 37 VCMTiming* timing)
39 VCMReceiveStatisticsCallback* stats_callback)
40 : clock_(clock), 38 : clock_(clock),
41 new_countinuous_frame_event_(false, false), 39 new_countinuous_frame_event_(false, false),
42 jitter_estimator_(jitter_estimator), 40 jitter_estimator_(jitter_estimator),
43 timing_(timing), 41 timing_(timing),
44 inter_frame_delay_(clock_->TimeInMilliseconds()), 42 inter_frame_delay_(clock_->TimeInMilliseconds()),
45 last_decoded_frame_it_(frames_.end()), 43 last_decoded_frame_it_(frames_.end()),
46 last_continuous_frame_it_(frames_.end()), 44 last_continuous_frame_it_(frames_.end()),
47 num_frames_history_(0), 45 num_frames_history_(0),
48 num_frames_buffered_(0), 46 num_frames_buffered_(0),
49 stopped_(false), 47 stopped_(false),
50 protection_mode_(kProtectionNack), 48 protection_mode_(kProtectionNack) {}
51 stats_callback_(stats_callback) {}
52 49
53 FrameBuffer::~FrameBuffer() {} 50 FrameBuffer::~FrameBuffer() {
51 UpdateHistograms();
52 }
54 53
55 FrameBuffer::ReturnReason FrameBuffer::NextFrame( 54 FrameBuffer::ReturnReason FrameBuffer::NextFrame(
56 int64_t max_wait_time_ms, 55 int64_t max_wait_time_ms,
57 std::unique_ptr<FrameObject>* frame_out) { 56 std::unique_ptr<FrameObject>* frame_out) {
58 int64_t latest_return_time = clock_->TimeInMilliseconds() + max_wait_time_ms; 57 int64_t latest_return_time = clock_->TimeInMilliseconds() + max_wait_time_ms;
59 int64_t wait_ms = max_wait_time_ms; 58 int64_t wait_ms = max_wait_time_ms;
60 FrameMap::iterator next_frame_it; 59 FrameMap::iterator next_frame_it;
61 60
62 do { 61 do {
63 int64_t now_ms = clock_->TimeInMilliseconds(); 62 int64_t now_ms = clock_->TimeInMilliseconds();
(...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after
157 void FrameBuffer::Stop() { 156 void FrameBuffer::Stop() {
158 rtc::CritScope lock(&crit_); 157 rtc::CritScope lock(&crit_);
159 stopped_ = true; 158 stopped_ = true;
160 new_countinuous_frame_event_.Set(); 159 new_countinuous_frame_event_.Set();
161 } 160 }
162 161
163 int FrameBuffer::InsertFrame(std::unique_ptr<FrameObject> frame) { 162 int FrameBuffer::InsertFrame(std::unique_ptr<FrameObject> frame) {
164 rtc::CritScope lock(&crit_); 163 rtc::CritScope lock(&crit_);
165 RTC_DCHECK(frame); 164 RTC_DCHECK(frame);
166 165
167 if (stats_callback_) 166 ++num_total_frames_;
168 stats_callback_->OnCompleteFrame(frame->num_references == 0, frame->size()); 167 if (frame->num_references == 0)
168 ++num_key_frames_;
169 169
170 FrameKey key(frame->picture_id, frame->spatial_layer); 170 FrameKey key(frame->picture_id, frame->spatial_layer);
171 int last_continuous_picture_id = 171 int last_continuous_picture_id =
172 last_continuous_frame_it_ == frames_.end() 172 last_continuous_frame_it_ == frames_.end()
173 ? -1 173 ? -1
174 : last_continuous_frame_it_->first.picture_id; 174 : last_continuous_frame_it_->first.picture_id;
175 175
176 if (num_frames_buffered_ >= kMaxFramesBuffered) { 176 if (num_frames_buffered_ >= kMaxFramesBuffered) {
177 LOG(LS_WARNING) << "Frame with (picture_id:spatial_id) (" << key.picture_id 177 LOG(LS_WARNING) << "Frame with (picture_id:spatial_id) (" << key.picture_id
178 << ":" << static_cast<int>(key.spatial_layer) 178 << ":" << static_cast<int>(key.spatial_layer)
(...skipping 193 matching lines...) Expand 10 before | Expand all | Expand 10 after
372 ref_info->second.num_missing_decodable); 372 ref_info->second.num_missing_decodable);
373 } 373 }
374 374
375 RTC_DCHECK_LE(info->second.num_missing_continuous, 375 RTC_DCHECK_LE(info->second.num_missing_continuous,
376 info->second.num_missing_decodable); 376 info->second.num_missing_decodable);
377 377
378 return true; 378 return true;
379 } 379 }
380 380
381 void FrameBuffer::UpdateJitterDelay() { 381 void FrameBuffer::UpdateJitterDelay() {
382 if (!stats_callback_) 382 int unused;
383 return; 383 int delay;
384 timing_->GetTimings(&unused, &unused, &unused, &unused, &delay, &unused,
385 &unused);
384 386
385 int decode_ms; 387 accumulated_delay_ += delay;
386 int max_decode_ms; 388 ++accumulated_delay_samples_;
387 int current_delay_ms; 389 }
388 int target_delay_ms; 390
389 int jitter_buffer_ms; 391 void FrameBuffer::UpdateHistograms() const {
390 int min_playout_delay_ms; 392 rtc::CritScope lock(&crit_);
391 int render_delay_ms; 393 if (num_total_frames_ > 0) {
392 if (timing_->GetTimings(&decode_ms, &max_decode_ms, &current_delay_ms, 394 int key_frames_permille = (static_cast<float>(num_key_frames_) * 1000.0f /
393 &target_delay_ms, &jitter_buffer_ms, 395 static_cast<float>(num_total_frames_) +
394 &min_playout_delay_ms, &render_delay_ms)) { 396 0.5f);
395 stats_callback_->OnFrameBufferTimingsUpdated( 397 RTC_HISTOGRAM_COUNTS_1000("WebRTC.Video.KeyFramesReceivedInPermille",
396 decode_ms, max_decode_ms, current_delay_ms, target_delay_ms, 398 key_frames_permille);
397 jitter_buffer_ms, min_playout_delay_ms, render_delay_ms); 399 }
400
401 if (accumulated_delay_samples_ > 0) {
402 RTC_HISTOGRAM_COUNTS_10000("WebRTC.Video.JitterBufferDelayInMs",
403 accumulated_delay_ / accumulated_delay_samples_);
398 } 404 }
399 } 405 }
400 406
401 void FrameBuffer::ClearFramesAndHistory() { 407 void FrameBuffer::ClearFramesAndHistory() {
402 frames_.clear(); 408 frames_.clear();
403 last_decoded_frame_it_ = frames_.end(); 409 last_decoded_frame_it_ = frames_.end();
404 last_continuous_frame_it_ = frames_.end(); 410 last_continuous_frame_it_ = frames_.end();
405 num_frames_history_ = 0; 411 num_frames_history_ = 0;
406 num_frames_buffered_ = 0; 412 num_frames_buffered_ = 0;
407 } 413 }
408 414
409 } // namespace video_coding 415 } // namespace video_coding
410 } // namespace webrtc 416 } // namespace webrtc
OLDNEW
« no previous file with comments | « webrtc/modules/video_coding/frame_buffer2.h ('k') | webrtc/modules/video_coding/frame_buffer2_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698