Lines Matching refs:bufs_
339 if (!rec.Serialize(&bufs_, &buf_woff_)) { in Append()
360 for (size_t i = buf_woff_; i < bufs_.size(); ++i) { in ExpandBuffer()
361 free += bufs_[i]->Free(); in ExpandBuffer()
381 bufs_.push_back(buf); in ExpandBuffer()
391 assert(bufs_.size()); in DispatchBuffer()
393 assert(buf_woff_ <= bufs_.size()); in DispatchBuffer()
405 assert(buf_doff_ < bufs_.size()); in DispatchBuffer()
409 auto* buf = bufs_[buf_doff_]; in DispatchBuffer()
413 (eof_ && buf_doff_ == buf_woff_ && buf_woff_ < bufs_.size())); in DispatchBuffer()
429 assert(bufs_.size()); in BufferWriteDone()
433 if (buf_doff_ < bufs_.size()) { in BufferWriteDone()
437 if (eof_ && buf_doff_ >= bufs_.size() && !pending_ios_) { in BufferWriteDone()
481 for (size_t i = start_idx; pending_nbytes && i < bufs_.size(); ++i) { in ReadBuffer()
483 auto* buf = bufs_[i]; in ReadBuffer()
511 assert(buf_doff_ == bufs_.size()); in Close()
512 assert(bufs_.size() - buf_woff_ <= 1); in Close()
528 for (size_t i = 0; i < bufs_.size(); ++i) { in ClearBuffers()
529 alloc_->Deallocate(bufs_[i]); in ClearBuffers()
532 bufs_.clear(); in ClearBuffers()