Searched refs:bufs_ (Results 1 – 3 of 3) sorted by relevance
73 bufs_.push_back(buf); in CacheWriteBufferAllocator()81 assert(bufs_.size() * buffer_size_ == Capacity()); in ~CacheWriteBufferAllocator()82 for (auto* buf : bufs_) { in ~CacheWriteBufferAllocator()85 bufs_.clear(); in ~CacheWriteBufferAllocator()90 if (bufs_.empty()) { in Allocate()94 assert(!bufs_.empty()); in Allocate()95 CacheWriteBuffer* const buf = bufs_.front(); in Allocate()96 bufs_.pop_front(); in Allocate()104 bufs_.push_back(buf); in Deallocate()111 while (bufs_.empty()) { in WaitUntilUsable()[all …]
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()429 assert(bufs_.size()); in BufferWriteDone()433 if (buf_doff_ < bufs_.size()) { in BufferWriteDone()483 auto* buf = bufs_[i]; in ReadBuffer()529 alloc_->Deallocate(bufs_[i]); in ClearBuffers()[all …]
197 const bool closed = eof_ && bufs_.empty(); in Read()241 std::vector<CacheWriteBuffer*> bufs_; // Written buffers variable