Lines Matching refs:buf
94 bool Deserialize(const Slice& buf);
144 CacheWriteBuffer* buf = (*bufs)[*woff]; in Append() local
145 const size_t free = buf->Free(); in Append()
147 buf->Append(p, size); in Append()
150 buf->Append(p, free); in Append()
153 assert(!buf->Free()); in Append()
154 assert(buf->Used() == buf->Capacity()); in Append()
157 if (!buf->Free()) { in Append()
373 CacheWriteBuffer* const buf = alloc_->Allocate(); in ExpandBuffer() local
374 if (!buf) { in ExpandBuffer()
379 size_ += static_cast<uint32_t>(buf->Free()); in ExpandBuffer()
380 free += buf->Free(); in ExpandBuffer()
381 bufs_.push_back(buf); in ExpandBuffer()
409 auto* buf = bufs_[buf_doff_]; in DispatchBuffer() local
412 assert(!buf->Free() || in DispatchBuffer()
416 buf->FillTrailingZeros(); in DispatchBuffer()
418 assert(buf->Used() % kFileAlignmentSize == 0); in DispatchBuffer()
420 writer_->Write(file_.get(), buf, file_off, in DispatchBuffer()
483 auto* buf = bufs_[i]; in ReadBuffer() local
484 assert(i == buf_woff_ || !buf->Free()); in ReadBuffer()
486 size_t nbytes = pending_nbytes > (buf->Used() - start_off) in ReadBuffer()
487 ? (buf->Used() - start_off) in ReadBuffer()
489 memcpy(tmp, buf->Data() + start_off, nbytes); in ReadBuffer()
561 void ThreadedWriter::Write(WritableFile* const file, CacheWriteBuffer* buf, in Write() argument
564 q_.Push(IO(file, buf, file_off, callback)); in Write()