| Index: chrome/common/partial_circular_buffer.cc
|
| diff --git a/chrome/common/partial_circular_buffer.cc b/chrome/common/partial_circular_buffer.cc
|
| index 4161cc1864706b2ddbce9037d26c72ecf0203e48..6e3e017e991f080a87f980f091a6b03b13230c83 100644
|
| --- a/chrome/common/partial_circular_buffer.cc
|
| +++ b/chrome/common/partial_circular_buffer.cc
|
| @@ -139,30 +139,49 @@ uint32 PartialCircularBuffer::Read(void* buffer, uint32 buffer_size) {
|
|
|
| void PartialCircularBuffer::Write(const void* buffer, uint32 buffer_size) {
|
| DCHECK(buffer_data_);
|
| - uint32 position_before_write = position_;
|
| -
|
| - uint32 to_eof = data_size_ - position_;
|
| - uint32 to_write = std::min(buffer_size, to_eof);
|
| - DoWrite(buffer_data_->data + position_, buffer, to_write);
|
| - if (position_ >= data_size_) {
|
| - DCHECK_EQ(position_, data_size_);
|
| - position_ = buffer_data_->wrap_position;
|
| + const uint8* input = static_cast<const uint8*>(buffer);
|
| + uint32 wrap_position = buffer_data_->wrap_position;
|
| + uint32 cycle_size = data_size_ - wrap_position;
|
| +
|
| + // First write the non-wrapping part.
|
| + if (position_ < wrap_position) {
|
| + uint32 space_left = wrap_position - position_;
|
| + uint32 write_size = std::min(buffer_size, space_left);
|
| + DoWrite(input, write_size);
|
| + input += write_size;
|
| + buffer_size -= write_size;
|
| }
|
|
|
| - if (to_write < buffer_size) {
|
| - uint32 remainder_to_write = buffer_size - to_write;
|
| - DCHECK_LT(position_, position_before_write);
|
| - DCHECK_LE(position_ + remainder_to_write, position_before_write);
|
| - DoWrite(buffer_data_->data + position_,
|
| - reinterpret_cast<const uint8*>(buffer) + to_write,
|
| - remainder_to_write);
|
| + // Skip the part that would overlap.
|
| + if (buffer_size > cycle_size) {
|
| + uint32 skip = buffer_size - cycle_size;
|
| + input += skip;
|
| + buffer_size -= skip;
|
| + position_ = wrap_position + (position_ - wrap_position + skip) % cycle_size;
|
| }
|
| +
|
| + // Finally write the wrapping part.
|
| + DoWrite(input, buffer_size);
|
| }
|
|
|
| -void PartialCircularBuffer::DoWrite(void* dest, const void* src, uint32 num) {
|
| - memcpy(dest, src, num);
|
| - position_ += num;
|
| +void PartialCircularBuffer::DoWrite(const uint8* input, uint32 input_size) {
|
| + DCHECK_LT(position_, data_size_);
|
| buffer_data_->total_written =
|
| - std::min(buffer_data_->total_written + num, data_size_);
|
| + std::min(buffer_data_->total_written + input_size, data_size_);
|
| +
|
| + // Write() skips any overlapping part, so this loop will run at most twice.
|
| + while (input_size > 0) {
|
| + uint32 space_left = data_size_ - position_;
|
| + uint32 write_size = std::min(input_size, space_left);
|
| + memcpy(buffer_data_->data + position_, input, write_size);
|
| + input += write_size;
|
| + input_size -= write_size;
|
| + position_ += write_size;
|
| + if (position_ >= data_size_) {
|
| + DCHECK_EQ(position_, data_size_);
|
| + position_ = buffer_data_->wrap_position;
|
| + }
|
| + }
|
| +
|
| buffer_data_->end_position = position_;
|
| }
|
|
|