Home
last modified time | relevance | path

Searched refs:STATE_COMPLETED (Results 1 – 4 of 4) sorted by relevance

/rocksdb-6.9/db/
Dwrite_thread.cc234 SetState(w, STATE_COMPLETED); in LinkOne()
317 SetState(leader, STATE_COMPLETED); in CompleteLeader()
331 SetState(w, STATE_COMPLETED); in CompleteFollower()
346 SetState(w, STATE_COMPLETED); in BeginWriteStall()
401 STATE_PARALLEL_MEMTABLE_WRITER | STATE_COMPLETED, in JoinBatchGroup()
566 SetState(w, STATE_COMPLETED); in ExitAsMemTableWriter()
574 SetState(leader, STATE_COMPLETED); in ExitAsMemTableWriter()
597 AwaitState(w, STATE_COMPLETED, &cpmtw_ctx); in CompleteParallelMemTableWriter()
612 assert(w->state == STATE_COMPLETED); in ExitAsBatchGroupFollower()
613 SetState(write_group->leader, STATE_COMPLETED); in ExitAsBatchGroupFollower()
[all …]
Dwrite_thread.h68 STATE_COMPLETED = 16, enumerator
Dwrite_callback_test.cc250 WriteThread::State::STATE_COMPLETED || in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc193 assert(w.state == WriteThread::STATE_COMPLETED); in WriteImpl()
198 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
595 assert(w.state == WriteThread::STATE_COMPLETED); in PipelinedWriteImpl()
666 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()