| /* |
| * Copyright (c) 2011 The WebRTC project authors. All Rights Reserved. |
| * |
| * Use of this source code is governed by a BSD-style license |
| * that can be found in the LICENSE file in the root of the source |
| * tree. An additional intellectual property rights grant can be found |
| * in the file PATENTS. All contributing project authors may |
| * be found in the AUTHORS file in the root of the source tree. |
| */ |
| |
| #include "webrtc/modules/video_coding/codec_timer.h" |
| |
| #include <assert.h> |
| |
| namespace webrtc |
| { |
| |
| // The first kIgnoredSampleCount samples will be ignored. |
| static const int32_t kIgnoredSampleCount = 5; |
| |
| VCMCodecTimer::VCMCodecTimer() |
| : |
| _filteredMax(0), |
| _ignoredSampleCount(0), |
| _shortMax(0), |
| _history() |
| { |
| Reset(); |
| } |
| |
| void VCMCodecTimer::Reset() |
| { |
| _filteredMax = 0; |
| _ignoredSampleCount = 0; |
| _shortMax = 0; |
| for (int i=0; i < MAX_HISTORY_SIZE; i++) |
| { |
| _history[i].shortMax = 0; |
| _history[i].timeMs = -1; |
| } |
| } |
| |
| // Update the max-value filter |
| void VCMCodecTimer::MaxFilter(int32_t decodeTime, int64_t nowMs) |
| { |
| if (_ignoredSampleCount >= kIgnoredSampleCount) |
| { |
| UpdateMaxHistory(decodeTime, nowMs); |
| ProcessHistory(nowMs); |
| } |
| else |
| { |
| _ignoredSampleCount++; |
| } |
| } |
| |
| void |
| VCMCodecTimer::UpdateMaxHistory(int32_t decodeTime, int64_t now) |
| { |
| if (_history[0].timeMs >= 0 && |
| now - _history[0].timeMs < SHORT_FILTER_MS) |
| { |
| if (decodeTime > _shortMax) |
| { |
| _shortMax = decodeTime; |
| } |
| } |
| else |
| { |
| // Only add a new value to the history once a second |
| if(_history[0].timeMs == -1) |
| { |
| // First, no shift |
| _shortMax = decodeTime; |
| } |
| else |
| { |
| // Shift |
| for(int i = (MAX_HISTORY_SIZE - 2); i >= 0 ; i--) |
| { |
| _history[i+1].shortMax = _history[i].shortMax; |
| _history[i+1].timeMs = _history[i].timeMs; |
| } |
| } |
| if (_shortMax == 0) |
| { |
| _shortMax = decodeTime; |
| } |
| |
| _history[0].shortMax = _shortMax; |
| _history[0].timeMs = now; |
| _shortMax = 0; |
| } |
| } |
| |
| void |
| VCMCodecTimer::ProcessHistory(int64_t nowMs) |
| { |
| _filteredMax = _shortMax; |
| if (_history[0].timeMs == -1) |
| { |
| return; |
| } |
| for (int i=0; i < MAX_HISTORY_SIZE; i++) |
| { |
| if (_history[i].timeMs == -1) |
| { |
| break; |
| } |
| if (nowMs - _history[i].timeMs > MAX_HISTORY_SIZE * SHORT_FILTER_MS) |
| { |
| // This sample (and all samples after this) is too old |
| break; |
| } |
| if (_history[i].shortMax > _filteredMax) |
| { |
| // This sample is the largest one this far into the history |
| _filteredMax = _history[i].shortMax; |
| } |
| } |
| } |
| |
| // Get the maximum observed time within a time window |
| int32_t VCMCodecTimer::RequiredDecodeTimeMs(FrameType /*frameType*/) const |
| { |
| return _filteredMax; |
| } |
| |
| } |