65     uint64_t physical_record_offset = end_of_buffer_offset_ - buffer_.size();  in ReadRecord()
76           ReportCorruption(scratch->size(), "partial record without end(1)");  in ReadRecord()
91           ReportCorruption(scratch->size(), "partial record without end(2)");  in ReadRecord()
94         scratch->assign(fragment.data(), fragment.size());  in ReadRecord()
101           ReportCorruption(fragment.size(),  in ReadRecord()
104           scratch->append(fragment.data(), fragment.size());  in ReadRecord()
111           ReportCorruption(fragment.size(),  in ReadRecord()
114           scratch->append(fragment.data(), fragment.size());  in ReadRecord()
132             ReportCorruption(scratch->size(), "error reading trailing data");  in ReadRecord()
147               ReportCorruption(scratch->size(), "error reading trailing data");  in ReadRecord()
160           ReportCorruption(scratch->size(), "error in middle of record");  in ReadRecord()
180           ReportCorruption(scratch->size(), "error in middle of record");  in ReadRecord()
190             (fragment.size() + (in_fragmented_record ? scratch->size() : 0)),  in ReadRecord()
224   size_t consumed_bytes = eof_offset_ - buffer_.size();  in UnmarkEOFInternal()
233     memmove(backing_store_ + consumed_bytes, buffer_.data(), buffer_.size());  in UnmarkEOFInternal()
240   size_t added = read_buffer.size();  in UnmarkEOFInternal()
255       read_buffer.size());  in UnmarkEOFInternal()
284     end_of_buffer_offset_ += buffer_.size();  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()
316     if (buffer_.size() < static_cast<size_t>(kHeaderSize)) {  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()
386         *drop_size = buffer_.size();  in ReadPhysicalRecord()
407   uint64_t physical_record_offset = end_of_buffer_offset_ - buffer_.size();  in ReadRecord()
416           ReportCorruption(fragments_.size(), "partial record without end(1)");  in ReadRecord()
428           ReportCorruption(fragments_.size(), "partial record without end(2)");  in ReadRecord()
431         fragments_.assign(fragment.data(), fragment.size());  in ReadRecord()
438           ReportCorruption(fragment.size(),  in ReadRecord()
441           fragments_.append(fragment.data(), fragment.size());  in ReadRecord()
448           ReportCorruption(fragment.size(),  in ReadRecord()
451           fragments_.append(fragment.data(), fragment.size());  in ReadRecord()
452           scratch->assign(fragments_.data(), fragments_.size());  in ReadRecord()
466           ReportCorruption(fragments_.size(), "error in middle of record");  in ReadRecord()
479           ReportCorruption(fragments_.size(), "error in middle of record");  in ReadRecord()
490             fragment.size() + (in_fragmented_record_ ? fragments_.size() : 0),  in ReadRecord()
514     end_of_buffer_offset_ += buffer_.size();  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()
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()
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()
609       *drop_size = buffer_.size();  in TryReadFragment()