media/base/decoder_buffer_queue.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "media/base/decoder_buffer_queue.h"
   6
   7 #include "base/logging.h"
   8 #include "base/numerics/safe_conversions.h"
   9 #include "media/base/buffers.h"
  10 #include "media/base/decoder_buffer.h"
  11
  12 namespace media {
  13
  14 DecoderBufferQueue::DecoderBufferQueue()
  15     : earliest_valid_timestamp_(kNoTimestamp()),
  16       data_size_(0) {
  17 }
  18
  19 DecoderBufferQueue::~DecoderBufferQueue() {}
  20
  21 void DecoderBufferQueue::Push(const scoped_refptr<DecoderBuffer>& buffer) {
  22   CHECK(!buffer->end_of_stream());
  23
  24   queue_.push_back(buffer);
  25
  26   // TODO(damienv): Remove the cast here and in every place in this file
  27   // when DecoderBuffer::data_size is modified to return a size_t.
  28   data_size_ += base::checked_cast<size_t, int>(buffer->data_size());
  29
  30   // TODO(scherkus): FFmpeg returns some packets with no timestamp after
  31   // seeking. Fix and turn this into CHECK(). See http://crbug.com/162192
  32   if (buffer->timestamp() == kNoTimestamp()) {
  33     DVLOG(1) << "Buffer has no timestamp";
  34     return;
  35   }
  36
  37   if (earliest_valid_timestamp_ == kNoTimestamp()) {
  38     earliest_valid_timestamp_ = buffer->timestamp();
  39   }
  40
  41   if (buffer->timestamp() < earliest_valid_timestamp_) {
  42     DVLOG(1)
  43         << "Out of order timestamps: "
  44         << buffer->timestamp().InMicroseconds()
  45         << " vs. "
  46         << earliest_valid_timestamp_.InMicroseconds();
  47     return;
  48   }
  49
  50   earliest_valid_timestamp_ = buffer->timestamp();
  51   in_order_queue_.push_back(buffer);
  52 }
  53
  54 scoped_refptr<DecoderBuffer> DecoderBufferQueue::Pop() {
  55   scoped_refptr<DecoderBuffer> buffer = queue_.front();
  56   queue_.pop_front();
  57
  58   size_t buffer_data_size =
  59       base::checked_cast<size_t, int>(buffer->data_size());
  60   DCHECK_LE(buffer_data_size, data_size_);
  61   data_size_ -= buffer_data_size;
  62
  63   if (!in_order_queue_.empty() &&
  64       in_order_queue_.front().get() == buffer.get()) {
  65     in_order_queue_.pop_front();
  66   }
  67
  68   return buffer;
  69 }
  70
  71 void DecoderBufferQueue::Clear() {
  72   queue_.clear();
  73   data_size_ = 0;
  74   in_order_queue_.clear();
  75   earliest_valid_timestamp_ = kNoTimestamp();
  76 }
  77
  78 bool DecoderBufferQueue::IsEmpty() {
  79   return queue_.empty();
  80 }
  81
  82 base::TimeDelta DecoderBufferQueue::Duration() {
  83   if (in_order_queue_.size() < 2)
  84     return base::TimeDelta();
  85
  86   base::TimeDelta start = in_order_queue_.front()->timestamp();
  87   base::TimeDelta end = in_order_queue_.back()->timestamp();
  88   return end - start;
  89 }
  90
  91 }  // namespace media