OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "media/formats/common/offset_byte_queue.h" | 5 #include "media/formats/common/offset_byte_queue.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 | 8 |
9 namespace media { | 9 namespace media { |
10 | 10 |
11 OffsetByteQueue::OffsetByteQueue() : buf_(NULL), size_(0), head_(0) {} | 11 OffsetByteQueue::OffsetByteQueue() : buf_(NULL), size_(0), head_(0) {} |
12 OffsetByteQueue::~OffsetByteQueue() {} | 12 OffsetByteQueue::~OffsetByteQueue() {} |
13 | 13 |
14 void OffsetByteQueue::Reset() { | 14 void OffsetByteQueue::Reset() { |
15 queue_.Reset(); | 15 queue_.Reset(); |
16 buf_ = NULL; | 16 buf_ = NULL; |
17 size_ = 0; | 17 size_ = 0; |
18 head_ = 0; | 18 head_ = 0; |
19 } | 19 } |
20 | 20 |
21 void OffsetByteQueue::Push(const uint8* buf, int size) { | 21 void OffsetByteQueue::Push(const uint8_t* buf, int size) { |
22 queue_.Push(buf, size); | 22 queue_.Push(buf, size); |
23 Sync(); | 23 Sync(); |
24 DVLOG(4) << "Buffer pushed. head=" << head() << " tail=" << tail(); | 24 DVLOG(4) << "Buffer pushed. head=" << head() << " tail=" << tail(); |
25 } | 25 } |
26 | 26 |
27 void OffsetByteQueue::Peek(const uint8** buf, int* size) { | 27 void OffsetByteQueue::Peek(const uint8_t** buf, int* size) { |
28 *buf = size_ > 0 ? buf_ : NULL; | 28 *buf = size_ > 0 ? buf_ : NULL; |
29 *size = size_; | 29 *size = size_; |
30 } | 30 } |
31 | 31 |
32 void OffsetByteQueue::Pop(int count) { | 32 void OffsetByteQueue::Pop(int count) { |
33 queue_.Pop(count); | 33 queue_.Pop(count); |
34 head_ += count; | 34 head_ += count; |
35 Sync(); | 35 Sync(); |
36 } | 36 } |
37 | 37 |
38 void OffsetByteQueue::PeekAt(int64 offset, const uint8** buf, int* size) { | 38 void OffsetByteQueue::PeekAt(int64_t offset, const uint8_t** buf, int* size) { |
39 DCHECK(offset >= head()); | 39 DCHECK(offset >= head()); |
40 if (offset < head() || offset >= tail()) { | 40 if (offset < head() || offset >= tail()) { |
41 *buf = NULL; | 41 *buf = NULL; |
42 *size = 0; | 42 *size = 0; |
43 return; | 43 return; |
44 } | 44 } |
45 *buf = &buf_[offset - head()]; | 45 *buf = &buf_[offset - head()]; |
46 *size = tail() - offset; | 46 *size = tail() - offset; |
47 } | 47 } |
48 | 48 |
49 bool OffsetByteQueue::Trim(int64 max_offset) { | 49 bool OffsetByteQueue::Trim(int64_t max_offset) { |
50 if (max_offset < head_) return true; | 50 if (max_offset < head_) return true; |
51 if (max_offset > tail()) { | 51 if (max_offset > tail()) { |
52 Pop(size_); | 52 Pop(size_); |
53 return false; | 53 return false; |
54 } | 54 } |
55 Pop(max_offset - head_); | 55 Pop(max_offset - head_); |
56 return true; | 56 return true; |
57 } | 57 } |
58 | 58 |
59 void OffsetByteQueue::Sync() { | 59 void OffsetByteQueue::Sync() { |
60 queue_.Peek(&buf_, &size_); | 60 queue_.Peek(&buf_, &size_); |
61 } | 61 } |
62 | 62 |
63 } // namespace media | 63 } // namespace media |
OLD | NEW |