Home
last modified time | relevance | path

Searched refs:State (Results 1 – 20 of 20) sorted by relevance

/rocksdb-6.9/table/block_based/
Dblock_based_table_builder.cc334 enum class State { enum
339 State state;
501 assert(rep_->state == Rep::State::kClosed); in ~BlockBasedTableBuilder()
507 assert(rep_->state != Rep::State::kClosed); in Add()
549 if (r->state == Rep::State::kBuffered) { in Add()
619 if (r->state == Rep::State::kBuffered) { in WriteBlock()
1069 r->state = Rep::State::kUnbuffered; in EnterUnbuffered()
1134 assert(r->state != Rep::State::kClosed); in Finish()
1137 if (r->state == Rep::State::kBuffered) { in Finish()
1170 r->state = Rep::State::kClosed; in Finish()
[all …]
Ddata_block_hash_index_test.cc637 ASSERT_EQ(get_context.State(), GetContext::kFound); in TEST()
662 ASSERT_EQ(get_context.State(), GetContext::kFound); in TEST()
687 ASSERT_EQ(get_context.State(), GetContext::kFound); in TEST()
712 ASSERT_EQ(get_context.State(), GetContext::kNotFound); in TEST()
Dblock_based_table_reader.cc2239 if (get_context->State() == GetContext::GetState::kFound) { in Get()
2544 if (get_context->State() == GetContext::GetState::kFound) { in MultiGet()
/rocksdb-6.9/include/rocksdb/utilities/
Dldb_cmd_execute_result.h16 enum State { enum
24 LDBCommandExecuteResult(State state, std::string& msg) in LDBCommandExecuteResult()
64 State state_;
/rocksdb-6.9/db/
Dwrite_callback_test.cc215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
Dcompacted_db_impl.cc44 if (get_context.State() == GetContext::kFound) { in Get()
77 if (get_context.State() == GetContext::kFound) { in MultiGet()
Dwrite_thread.h31 enum State : uint8_t { enum
Dversion_set.cc1807 if (get_context.State() != GetContext::kNotFound && in Get()
1808 get_context.State() != GetContext::kMerge && in Get()
1812 switch (get_context.State()) { in Get()
1849 if (GetContext::kMerge == get_context.State()) { in Get()
1968 if (get_context.State() != GetContext::kNotFound && in MultiGet()
1969 get_context.State() != GetContext::kMerge && in MultiGet()
1979 switch (get_context.State()) { in MultiGet()
2033 if (GetContext::kMerge == get_context.State()) { in MultiGet()
/rocksdb-6.9/memtable/
Dskiplist_test.cc202 struct State { struct in ROCKSDB_NAMESPACE::ConcurrentTest
209 State() { in State() function
217 State current_;
239 State initial_state; in ReadStep()
Dinlineskiplist_test.cc377 struct State { struct in ROCKSDB_NAMESPACE::ConcurrentTest
384 State() { in State() function
392 State current_;
433 State initial_state; in ReadStep()
/rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/jmh/
DPutBenchmarks.java22 @State(Scope.Benchmark)
98 @State(Scope.Benchmark)
DComparatorBenchmarks.java22 @State(Scope.Benchmark)
124 @State(Scope.Benchmark)
DGetBenchmarks.java22 @State(Scope.Benchmark)
DMultiGetBenchmarks.java23 @State(Scope.Benchmark)
/rocksdb-6.9/build_tools/
Drun_ci_db_test.ps1424 $message = -join @($completed.Name, " State: ", ($completed.State)) in RunJobs()
428 if($completed.State -ne "Completed") { in RunJobs()
/rocksdb-6.9/table/
Dget_context.h129 GetState State() const { return state_; } in State() function
Dtable_test.cc2538 ASSERT_EQ(get_context.State(), GetContext::kFound); in TEST_P()
3063 ASSERT_EQ(get_context.State(), GetContext::kFound); in TEST_P()
3080 ASSERT_EQ(get_context.State(), GetContext::kNotFound); in TEST_P()
4625 ASSERT_EQ(get_context.State(), GetContext::kFound); in TEST_P()
4651 ASSERT_EQ(get_context.State(), GetContext::kNotFound); in TEST_P()
/rocksdb-6.9/third-party/folly/folly/synchronization/
DBaton.h240 enum State : uint32_t { enum
DDistributedMutex-inl.h1133 typename State,
1138 State& atomic,
/rocksdb-6.9/env/
Denv_test.cc363 struct State { struct
370 State* s = reinterpret_cast<State*>(arg); in ThreadBody()
378 State state; in TEST_P()