Chromium Code Reviews| Index: media/base/seekable_buffer.cc |
| diff --git a/media/base/seekable_buffer.cc b/media/base/seekable_buffer.cc |
| index 6ad3b02fd5bd494a85448d5f78d3cc6e941363af..88e26ce69a29592e351252099308c902eeeff9fa 100644 |
| --- a/media/base/seekable_buffer.cc |
| +++ b/media/base/seekable_buffer.cc |
| @@ -11,8 +11,7 @@ |
| namespace media { |
| -SeekableBuffer::SeekableBuffer(int backward_capacity, |
| - int forward_capacity) |
| +SeekableBuffer::SeekableBuffer(int backward_capacity, int forward_capacity) |
| : current_buffer_offset_(0), |
| backward_capacity_(backward_capacity), |
| backward_bytes_(0), |
| @@ -22,8 +21,7 @@ SeekableBuffer::SeekableBuffer(int backward_capacity, |
| current_buffer_ = buffers_.begin(); |
| } |
| -SeekableBuffer::~SeekableBuffer() { |
| -} |
| +SeekableBuffer::~SeekableBuffer() {} |
| void SeekableBuffer::Clear() { |
| buffers_.clear(); |
| @@ -49,20 +47,19 @@ bool SeekableBuffer::GetCurrentChunk(const uint8** data, int* size) const { |
| int current_buffer_offset = current_buffer_offset_; |
| // Advance position if we are in the end of the current buffer. |
| while (current_buffer != buffers_.end() && |
| - current_buffer_offset >= (*current_buffer)->GetDataSize()) { |
| + current_buffer_offset >= (*current_buffer)->data_size()) { |
| ++current_buffer; |
| current_buffer_offset = 0; |
| } |
| - if (current_buffer == buffers_.end()) |
| - return false; |
| - *data = (*current_buffer)->GetData() + current_buffer_offset; |
| - *size = (*current_buffer)->GetDataSize() - current_buffer_offset; |
| + if (current_buffer == buffers_.end()) return false; |
|
scherkus (not reviewing)
2013/06/21 19:48:38
revert this change -- we don't do single-line ifs
|
| + *data = (*current_buffer)->data() + current_buffer_offset; |
| + *size = (*current_buffer)->data_size() - current_buffer_offset; |
| return true; |
| } |
| bool SeekableBuffer::Append(const scoped_refptr<DataBuffer>& buffer_in) { |
| - if (buffers_.empty() && buffer_in->GetTimestamp() != kNoTimestamp()) { |
| - current_time_ = buffer_in->GetTimestamp(); |
| + if (buffers_.empty() && buffer_in->timestamp() != kNoTimestamp()) { |
| + current_time_ = buffer_in->timestamp(); |
| } |
| // Since the forward capacity is only used to check the criteria for buffer |
| @@ -77,13 +74,12 @@ bool SeekableBuffer::Append(const scoped_refptr<DataBuffer>& buffer_in) { |
| } |
| // Update the |forward_bytes_| counter since we have more bytes. |
| - forward_bytes_ += buffer_in->GetDataSize(); |
| + forward_bytes_ += buffer_in->data_size(); |
| // Advise the user to stop append if the amount of forward bytes exceeds |
| // the forward capacity. A false return value means the user should stop |
| // appending more data to this buffer. |
| - if (forward_bytes_ >= forward_capacity_) |
| - return false; |
| + if (forward_bytes_ >= forward_capacity_) return false; |
|
scherkus (not reviewing)
2013/06/21 19:48:38
revert this change -- we don't do single-line ifs
|
| return true; |
| } |
| @@ -107,8 +103,7 @@ bool SeekableBuffer::Seek(int32 offset) { |
| bool SeekableBuffer::SeekForward(int size) { |
| // Perform seeking forward only if we have enough bytes in the queue. |
| - if (size > forward_bytes_) |
| - return false; |
| + if (size > forward_bytes_) return false; |
|
scherkus (not reviewing)
2013/06/21 19:48:38
revert this change -- we don't do single-line ifs
|
| // Do a read of |size| bytes. |
| int taken = InternalRead(NULL, size, true, 0); |
| @@ -117,8 +112,7 @@ bool SeekableBuffer::SeekForward(int size) { |
| } |
| bool SeekableBuffer::SeekBackward(int size) { |
| - if (size > backward_bytes_) |
| - return false; |
| + if (size > backward_bytes_) return false; |
|
scherkus (not reviewing)
2013/06/21 19:48:38
revert this change -- we don't do single-line ifs
|
| // Record the number of bytes taken. |
| int taken = 0; |
| // Loop until we taken enough bytes and rewind by the desired |size|. |
| @@ -150,13 +144,12 @@ bool SeekableBuffer::SeekBackward(int size) { |
| // The current buffer pointed by current iterator has been consumed. Move |
| // the iterator backward so it points to the previous buffer. |
| if (current_buffer_offset_ == 0) { |
| - if (current_buffer_ == buffers_.begin()) |
| - break; |
| + if (current_buffer_ == buffers_.begin()) break; |
|
scherkus (not reviewing)
2013/06/21 19:48:38
revert this change -- we don't do single-line ifs
|
| // Move the iterator backward. |
| --current_buffer_; |
| // Set the offset into the current buffer to be the buffer size as we |
| // are preparing for rewind for next iteration. |
| - current_buffer_offset_ = (*current_buffer_)->GetDataSize(); |
| + current_buffer_offset_ = (*current_buffer_)->data_size(); |
| } |
| } |
| @@ -170,18 +163,16 @@ void SeekableBuffer::EvictBackwardBuffers() { |
| // Advances the iterator until we hit the current pointer. |
| while (backward_bytes_ > backward_capacity_) { |
| BufferQueue::iterator i = buffers_.begin(); |
| - if (i == current_buffer_) |
| - break; |
| + if (i == current_buffer_) break; |
|
scherkus (not reviewing)
2013/06/21 19:48:38
revert this change -- we don't do single-line ifs
|
| scoped_refptr<DataBuffer> buffer = *i; |
| - backward_bytes_ -= buffer->GetDataSize(); |
| + backward_bytes_ -= buffer->data_size(); |
| DCHECK_GE(backward_bytes_, 0); |
| buffers_.erase(i); |
| } |
| } |
| -int SeekableBuffer::InternalRead(uint8* data, int size, |
| - bool advance_position, |
| +int SeekableBuffer::InternalRead(uint8* data, int size, bool advance_position, |
| int forward_offset) { |
| // Counts how many bytes are actually read from the buffer queue. |
| int taken = 0; |
| @@ -193,13 +184,12 @@ int SeekableBuffer::InternalRead(uint8* data, int size, |
| while (taken < size) { |
| // |current_buffer| is valid since the first time this buffer is appended |
| // with data. |
| - if (current_buffer == buffers_.end()) |
| - break; |
| + if (current_buffer == buffers_.end()) break; |
| scoped_refptr<DataBuffer> buffer = *current_buffer; |
| int remaining_bytes_in_buffer = |
| - buffer->GetDataSize() - current_buffer_offset; |
| + buffer->data_size() - current_buffer_offset; |
| if (bytes_to_skip == 0) { |
| // Find the right amount to copy from the current buffer referenced by |
| @@ -209,7 +199,8 @@ int SeekableBuffer::InternalRead(uint8* data, int size, |
| // |data| is NULL if we are seeking forward, so there's no need to copy. |
| if (data) |
| - memcpy(data + taken, buffer->GetData() + current_buffer_offset, copied); |
| + memcpy(data + taken, buffer->data() + current_buffer_offset, |
|
scherkus (not reviewing)
2013/06/21 19:48:38
can you fit "copied);" onto this line?
|
| + copied); |
| // Increase total number of bytes copied, which regulates when to end this |
| // loop. |
| @@ -225,7 +216,7 @@ int SeekableBuffer::InternalRead(uint8* data, int size, |
| } |
| // The buffer has been consumed. |
| - if (current_buffer_offset == buffer->GetDataSize()) { |
| + if (current_buffer_offset == buffer->data_size()) { |
| if (advance_position) { |
| // Next buffer may not have timestamp, so we need to update current |
| // timestamp before switching to the next buffer. |
| @@ -235,8 +226,7 @@ int SeekableBuffer::InternalRead(uint8* data, int size, |
| BufferQueue::iterator next = current_buffer; |
| ++next; |
| // If we are at the last buffer, don't advance. |
| - if (next == buffers_.end()) |
| - break; |
| + if (next == buffers_.end()) break; |
|
scherkus (not reviewing)
2013/06/21 19:48:38
revert this change -- we don't do single-line ifs
|
| // Advances the iterator. |
| current_buffer = next; |
| @@ -265,12 +255,13 @@ int SeekableBuffer::InternalRead(uint8* data, int size, |
| void SeekableBuffer::UpdateCurrentTime(BufferQueue::iterator buffer, |
| int offset) { |
| // Garbage values are unavoidable, so this check will remain. |
| - if (buffer != buffers_.end() && (*buffer)->GetTimestamp() != kNoTimestamp()) { |
| - int64 time_offset = ((*buffer)->GetDuration().InMicroseconds() * |
| - offset) / (*buffer)->GetDataSize(); |
| + if (buffer != buffers_.end() && |
| + (*buffer)->timestamp() != kNoTimestamp()) { |
| + int64 time_offset = ((*buffer)->duration().InMicroseconds() * offset) / |
| + (*buffer)->data_size(); |
| - current_time_ = (*buffer)->GetTimestamp() + |
| - base::TimeDelta::FromMicroseconds(time_offset); |
| + current_time_ = (*buffer)->timestamp() + |
| + base::TimeDelta::FromMicroseconds(time_offset); |
| } |
| } |