Home
last modified time | relevance | path

Searched refs:STATE_GROUP_LEADER (Results 1 – 5 of 5) sorted by relevance

/rocksdb-6.9/db/
Dwrite_thread.cc380 SetState(w, STATE_GROUP_LEADER); in JoinBatchGroup()
400 AwaitState(w, STATE_GROUP_LEADER | STATE_MEMTABLE_WRITER_LEADER | in JoinBatchGroup()
685 SetState(next_leader, STATE_GROUP_LEADER); in ExitAsBatchGroupLeader()
718 SetState(last_writer->link_newer, STATE_GROUP_LEADER); in ExitAsBatchGroupLeader()
744 AwaitState(w, STATE_GROUP_LEADER, &eu_ctx); in EnterUnbatched()
760 SetState(next_leader, STATE_GROUP_LEADER); in ExitUnbatched()
Dwrite_callback_test.cc215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
Dwrite_thread.h50 STATE_GROUP_LEADER = 2, enumerator
Ddb_write_test.cc152 if (w->state == WriteThread::STATE_GROUP_LEADER) { in TEST_P()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc209 assert(w.state == WriteThread::STATE_GROUP_LEADER); in WriteImpl()
472 if (w.state == WriteThread::STATE_GROUP_LEADER) { in PipelinedWriteImpl()
676 assert(w.state == WriteThread::STATE_GROUP_LEADER); in WriteImplWALOnly()