Searched refs:async_buffer_stream_ (Results 1 – 2 of 2) sorted by relevance
74 if (async_buffer_stream_) { in ~CacheClient()75 Status rc = async_buffer_stream_->ReleaseBuffer(); in ~CacheClient()121 if (async_buffer_stream_ == nullptr) { in AsyncWriteRow()124 RETURN_IF_NOT_OK(async_buffer_stream_->AsyncWrite(row)); in AsyncWriteRow()185 if (async_buffer_stream_) { in CreateCache()187 RETURN_IF_NOT_OK(async_buffer_stream_->Reset()); in CreateCache()215 async_buffer_stream_ = std::make_shared<AsyncBufferStream>(); in CreateCache()216 RETURN_IF_NOT_OK(async_buffer_stream_->Init(this)); in CreateCache()
266 if (async_buffer_stream_) { in FlushAsyncWriteBuffer()267 return async_buffer_stream_->SyncFlush(AsyncBufferStream::AsyncFlushFlag::kFlushBlocking); in FlushAsyncWriteBuffer()356 std::shared_ptr<AsyncBufferStream> async_buffer_stream_; variable