Lines Matching refs:WriteThread
17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
34 uint8_t WriteThread::BlockingAwaitState(Writer* w, uint8_t goal_mask) { in BlockingAwaitState()
62 uint8_t WriteThread::AwaitState(Writer* w, uint8_t goal_mask, in AwaitState()
210 void WriteThread::SetState(Writer* w, uint8_t new_state) { in SetState()
223 bool WriteThread::LinkOne(Writer* w, std::atomic<Writer*>* newest_writer) { in LinkOne()
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
282 void WriteThread::CreateMissingNewerLinks(Writer* head) { in CreateMissingNewerLinks()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
305 void WriteThread::CompleteLeader(WriteGroup& write_group) { in CompleteLeader()
320 void WriteThread::CompleteFollower(Writer* w, WriteGroup& write_group) { in CompleteFollower()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
372 static WriteThread::AdaptationContext jbg_ctx("JoinBatchGroup");
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
407 size_t WriteThread::EnterAsBatchGroupLeader(Writer* leader, in EnterAsBatchGroupLeader()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
577 void WriteThread::LaunchParallelMemTableWriters(WriteGroup* write_group) { in LaunchParallelMemTableWriters()
585 static WriteThread::AdaptationContext cpmtw_ctx("CompleteParallelMemTableWriter");
587 bool WriteThread::CompleteParallelMemTableWriter(Writer* w) { in CompleteParallelMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
616 static WriteThread::AdaptationContext eabgl_ctx("ExitAsBatchGroupLeader");
617 void WriteThread::ExitAsBatchGroupLeader(WriteGroup& write_group, in ExitAsBatchGroupLeader()
736 static WriteThread::AdaptationContext eu_ctx("EnterUnbatched");
737 void WriteThread::EnterUnbatched(Writer* w, InstrumentedMutex* mu) { in EnterUnbatched()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
764 static WriteThread::AdaptationContext wfmw_ctx("WaitForMemTableWriters");
765 void WriteThread::WaitForMemTableWriters() { in WaitForMemTableWriters()