Searched refs:ThreadedWriter (Results 1 – 3 of 3) sorted by relevance
538 ThreadedWriter::ThreadedWriter(PersistentCacheTier* const cache, in ThreadedWriter() function in ROCKSDB_NAMESPACE::ThreadedWriter542 port::Thread th(&ThreadedWriter::ThreadMain, this); in ThreadedWriter()547 void ThreadedWriter::Stop() { in Stop()561 void ThreadedWriter::Write(WritableFile* const file, CacheWriteBuffer* buf, in Write()567 void ThreadedWriter::ThreadMain() { in ThreadMain()590 void ThreadedWriter::DispatchIO(const IO& io) { in DispatchIO()
212 friend class ThreadedWriter;256 class ThreadedWriter : public Writer {276 explicit ThreadedWriter(PersistentCacheTier* const cache, const size_t qdepth,278 virtual ~ThreadedWriter() { assert(threads_.empty()); } in ~ThreadedWriter()
148 ThreadedWriter writer_; // Writer threads