Lines Matching refs:buffer_
34 buffer_(), in Reader()
65 uint64_t physical_record_offset = end_of_buffer_offset_ - buffer_.size(); in ReadRecord()
224 size_t consumed_bytes = eof_offset_ - buffer_.size(); in UnmarkEOFInternal()
230 if (buffer_.data() != backing_store_ + consumed_bytes) { in UnmarkEOFInternal()
233 memmove(backing_store_ + consumed_bytes, buffer_.data(), buffer_.size()); in UnmarkEOFInternal()
258 buffer_ = Slice(backing_store_ + consumed_bytes, in UnmarkEOFInternal()
282 buffer_.clear(); in ReadMore()
283 Status status = file_->Read(kBlockSize, &buffer_, backing_store_); in ReadMore()
284 end_of_buffer_offset_ += buffer_.size(); in ReadMore()
286 buffer_.clear(); in ReadMore()
291 } else if (buffer_.size() < static_cast<size_t>(kBlockSize)) { in ReadMore()
293 eof_offset_ = buffer_.size(); in ReadMore()
301 if (buffer_.size()) { in ReadMore()
302 *drop_size = buffer_.size(); in ReadMore()
303 buffer_.clear(); in ReadMore()
307 buffer_.clear(); in ReadMore()
316 if (buffer_.size() < static_cast<size_t>(kHeaderSize)) { in ReadPhysicalRecord()
328 const char* header = buffer_.data(); in ReadPhysicalRecord()
335 if (end_of_buffer_offset_ - buffer_.size() == 0) { in ReadPhysicalRecord()
340 if (buffer_.size() < static_cast<size_t>(kRecyclableHeaderSize)) { in ReadPhysicalRecord()
352 if (header_size + length > buffer_.size()) { in ReadPhysicalRecord()
353 *drop_size = buffer_.size(); in ReadPhysicalRecord()
354 buffer_.clear(); in ReadPhysicalRecord()
373 buffer_.clear(); in ReadPhysicalRecord()
386 *drop_size = buffer_.size(); in ReadPhysicalRecord()
387 buffer_.clear(); in ReadPhysicalRecord()
392 buffer_.remove_prefix(header_size + length); in ReadPhysicalRecord()
407 uint64_t physical_record_offset = end_of_buffer_offset_ - buffer_.size(); in ReadRecord()
512 buffer_.clear(); in TryReadMore()
513 Status status = file_->Read(kBlockSize, &buffer_, backing_store_); in TryReadMore()
514 end_of_buffer_offset_ += buffer_.size(); in TryReadMore()
516 buffer_.clear(); in TryReadMore()
521 } else if (buffer_.size() < static_cast<size_t>(kBlockSize)) { in TryReadMore()
523 eof_offset_ = buffer_.size(); in TryReadMore()
535 *drop_size = buffer_.size(); in TryReadMore()
536 if (buffer_.size() > 0) { in TryReadMore()
539 buffer_.clear(); in TryReadMore()
550 while (buffer_.size() < static_cast<size_t>(kHeaderSize)) { in TryReadFragment()
551 size_t old_size = buffer_.size(); in TryReadFragment()
556 } else if (old_size == buffer_.size()) { in TryReadFragment()
560 const char* header = buffer_.data(); in TryReadFragment()
567 if (end_of_buffer_offset_ - buffer_.size() == 0) { in TryReadFragment()
571 while (buffer_.size() < static_cast<size_t>(kRecyclableHeaderSize)) { in TryReadFragment()
572 size_t old_size = buffer_.size(); in TryReadFragment()
577 } else if (old_size == buffer_.size()) { in TryReadFragment()
588 while (header_size + length > buffer_.size()) { in TryReadFragment()
589 size_t old_size = buffer_.size(); in TryReadFragment()
594 } else if (old_size == buffer_.size()) { in TryReadFragment()
600 buffer_.clear(); in TryReadFragment()
609 *drop_size = buffer_.size(); in TryReadFragment()
610 buffer_.clear(); in TryReadFragment()
616 buffer_.remove_prefix(header_size + length); in TryReadFragment()