Searched refs:AsyncBufferStream (Results 1 – 2 of 2) sorted by relevance
267 return async_buffer_stream_->SyncFlush(AsyncBufferStream::AsyncFlushFlag::kFlushBlocking); in FlushAsyncWriteBuffer()310 class AsyncBufferStream {312 AsyncBufferStream();313 ~AsyncBufferStream();330 friend class AsyncBufferStream;356 std::shared_ptr<AsyncBufferStream> async_buffer_stream_;
215 async_buffer_stream_ = std::make_shared<AsyncBufferStream>(); in CreateCache()353 CacheClient::AsyncBufferStream::AsyncBufferStream() : cc_(nullptr), offset_addr_(-1), cur_(0) {} in AsyncBufferStream() function in mindspore::dataset::CacheClient::AsyncBufferStream355 CacheClient::AsyncBufferStream::~AsyncBufferStream() { in ~AsyncBufferStream()360 Status CacheClient::AsyncBufferStream::ReleaseBuffer() { in ReleaseBuffer()371 Status CacheClient::AsyncBufferStream::Init(CacheClient *cc) { in Init()392 Status CacheClient::AsyncBufferStream::AsyncWrite(const TensorRow &row) { in AsyncWrite()421 Status CacheClient::AsyncBufferStream::SyncFlush(AsyncFlushFlag flag) { in SyncFlush()464 Status CacheClient::AsyncBufferStream::AsyncWriter::Write(int64_t sz, const std::vector<ReadableSli… in Write()476 Status CacheClient::AsyncBufferStream::Reset() { in Reset()