Searched refs:eof_ (Results 1 – 5 of 5) sorted by relevance
18 explicit channel() : eof_(false) {} in channel()25 eof_ = true; in sendEof()31 return buffer_.empty() && eof_; in eof()51 cv_.wait(lk, [&] { return eof_ || !buffer_.empty(); }); in read()52 if (eof_ && buffer_.empty()) { in read()65 bool eof_; variable
35 eof_(false), in Reader()209 eof_ = false; in UnmarkEOF()262 eof_ = true; in UnmarkEOFInternal()280 if (!eof_ && !read_error_) { in ReadMore()292 eof_ = true; in ReadMore()355 if (!eof_) { in ReadPhysicalRecord()505 eof_ = false; in UnmarkEOF()510 if (!eof_ && !read_error_) { in TryReadMore()522 eof_ = true; in TryReadMore()
77 return eof_; in IsEOF()109 bool eof_; // Last Read() indicated EOF by returning < kBlockSize variable
274 if (!eof_) { in ~WriteableCacheFile()320 if (eof_) { in Append()346 eof_ = disk_woff_ >= max_size_; in Append()356 assert(!eof_); in ExpandBuffer()399 if (!eof_ && buf_doff_ == buf_woff_) { in DispatchBuffer()404 assert(eof_ || buf_doff_ < buf_woff_); in DispatchBuffer()413 (eof_ && buf_doff_ == buf_woff_ && buf_woff_ < bufs_.size())); in DispatchBuffer()437 if (eof_ && buf_doff_ >= bufs_.size() && !pending_ios_) { in BufferWriteDone()
197 const bool closed = eof_ && bufs_.empty(); in Read()209 bool Eof() const { return eof_; } in Eof()244 bool eof_ = false; // End of file variable