Home
last modified time | relevance | path

Searched refs:state (Results 1 – 25 of 60) sorted by relevance

123

/rocksdb-6.9/util/
Dxxhash.cc549 memset(&state, 0, sizeof(state)); in XXH32_reset()
555 memcpy(statePtr, &state, sizeof(state) - sizeof(state.reserved)); in XXH32_reset()
583 XXH_memcpy((xxh_u8*)(state->mem32) + state->memsize, input, 16-state->memsize); in XXH32_update()
588 state->v4 = XXH32_round(state->v4, XXH_readLE32(p32)); in XXH32_update()
1036 memset(&state, 0, sizeof(state)); in XXH64_reset()
1042 memcpy(statePtr, &state, sizeof(state) - sizeof(state.reserved64)); in XXH64_reset()
1068 XXH_memcpy(((xxh_u8*)state->mem64) + state->memsize, input, 32-state->memsize); in XXH64_update()
1069 state->v1 = XXH64_round(state->v1, XXH_readLE64(state->mem64+0)); in XXH64_update()
1070 state->v2 = XXH64_round(state->v2, XXH_readLE64(state->mem64+1)); in XXH64_update()
1071 state->v3 = XXH64_round(state->v3, XXH_readLE64(state->mem64+2)); in XXH64_update()
[all …]
Dstatus.cc20 const char* Status::CopyState(const char* state) { in CopyState() argument
22 const size_t cch = std::strlen(state) + 1; // +1 for the null terminator in CopyState()
30 ret = strncpy_s(result, cch, state, cch - 1); in CopyState()
35 const size_t cch = std::strlen(state) + 1; // +1 for the null terminator in CopyState()
36 return std::strncpy(new char[cch], state, cch); in CopyState()
/rocksdb-6.9/java/rocksjni/
Dwrite_batch_test.cc54 std::string state; in Java_org_rocksdb_WriteBatchTest_getContents() local
76 state.append(")"); in Java_org_rocksdb_WriteBatchTest_getContents()
84 state.append(")"); in Java_org_rocksdb_WriteBatchTest_getContents()
90 state.append(")"); in Java_org_rocksdb_WriteBatchTest_getContents()
96 state.append(")"); in Java_org_rocksdb_WriteBatchTest_getContents()
104 state.append(")"); in Java_org_rocksdb_WriteBatchTest_getContents()
110 state.append(")"); in Java_org_rocksdb_WriteBatchTest_getContents()
117 state.append(")"); in Java_org_rocksdb_WriteBatchTest_getContents()
121 state.append("@"); in Java_org_rocksdb_WriteBatchTest_getContents()
128 state.append( in Java_org_rocksdb_WriteBatchTest_getContents()
[all …]
Drocksdb_exception_test.cc79 ROCKSDB_NAMESPACE::Slice state("test state"); in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionWithStatusCodeState() local
81 env, "test message", ROCKSDB_NAMESPACE::Status::NotSupported(state)); in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionWithStatusCodeState()
/rocksdb-6.9/db/
Dwrite_thread.cc42 auto state = w->state.load(std::memory_order_acquire); in BlockingAwaitState() local
45 w->state.compare_exchange_strong(state, STATE_LOCKED_WAITING)) { in BlockingAwaitState()
51 state = w->state.load(std::memory_order_relaxed); in BlockingAwaitState()
59 return state; in BlockingAwaitState()
64 uint8_t state = 0; in AwaitState() local
75 state = w->state.load(std::memory_order_acquire); in AwaitState()
77 return state; in AwaitState()
160 state = w->state.load(std::memory_order_acquire); in AwaitState()
207 return state; in AwaitState()
211 auto state = w->state.load(std::memory_order_acquire); in SetState() local
[all …]
Dforward_iterator_bench.cc118 ShardState& state = (*shard_states_)[shard]; in readOnceFromShard() local
119 if (!state.it) { in readOnceFromShard()
126 (const char*)&state.upper_bound, sizeof(state.upper_bound)); in readOnceFromShard()
130 state.it.reset(db_->NewIterator(options)); in readOnceFromShard()
138 const uint64_t upto = state.last_written.load(); in readOnceFromShard()
140 {state.it_cacheonly.get(), state.it.get()}) { in readOnceFromShard()
144 if (state.last_read.load() >= upto) { in readOnceFromShard()
168 state.last_read.store(seq); in readOnceFromShard()
242 ShardState& state = (*shard_states_)[shard]; in run() local
251 state.last_written.store(seqno); in run()
[all …]
Dwrite_batch_test.cc36 std::string state; in PrintContents() local
70 state.append(", "); in PrintContents()
72 state.append(")"); in PrintContents()
79 state.append(")"); in PrintContents()
86 state.append(")"); in PrintContents()
93 state.append(", "); in PrintContents()
95 state.append(")"); in PrintContents()
102 state.append(", "); in PrintContents()
104 state.append(")"); in PrintContents()
112 state.append("@"); in PrintContents()
[all …]
Dwrite_callback_test.cc214 ASSERT_TRUE(writer->state == in TEST_F()
217 ASSERT_TRUE(writer->state == in TEST_F()
246 ASSERT_TRUE(writer->state == in TEST_F()
249 ASSERT_TRUE(writer->state == in TEST_F()
252 writer->state == in TEST_F()
Dwrite_thread.h127 std::atomic<uint8_t> state; // write under StateMutex() or pre-link member
150 state(STATE_INIT), in Writer()
171 state(STATE_INIT), in batch()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc302 assert(state.HaveSomethingToDelete()); in PurgeObsoleteFiles()
305 assert(state.manifest_file_number != 0); in PurgeObsoleteFiles()
314 state.log_recycle_files.begin(), state.log_recycle_files.end()); in PurgeObsoleteFiles()
319 state.log_delete_files.size() + state.manifest_delete_files.size()); in PurgeObsoleteFiles()
321 for (auto& file : state.sst_delete_files) { in PurgeObsoleteFiles()
330 for (auto file_num : state.log_delete_files) { in PurgeObsoleteFiles()
348 if (state.prev_total_log_size > 0) { in PurgeObsoleteFiles()
353 state.job_id, state.size_log_to_delete, in PurgeObsoleteFiles()
354 state.prev_total_log_size, state.num_alive_log_files); in PurgeObsoleteFiles()
384 for (const auto w : state.logs_to_free) { in PurgeObsoleteFiles()
[all …]
/rocksdb-6.9/test_util/
Dfault_injection_test_env.cc347 db_file_state_[state.filename_] = state; in WritableFileClosed()
348 open_files_.erase(state.filename_); in WritableFileClosed()
356 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileSynced()
358 db_file_state_[state.filename_] = state; in WritableFileSynced()
367 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileAppended()
369 db_file_state_[state.filename_] = state; in WritableFileAppended()
383 const FileState& state = it->second; in DropFileData() local
384 if (!state.IsFullySynced()) { in DropFileData()
385 s = func(target(), state); in DropFileData()
393 return state.DropUnsyncedData(env); in DropUnsyncedFileData()
[all …]
Dfault_injection_test_fs.cc339 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileClosed()
340 db_file_state_[state.filename_] = state; in WritableFileClosed()
341 open_files_.erase(state.filename_); in WritableFileClosed()
347 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileSynced()
348 if (db_file_state_.find(state.filename_) == db_file_state_.end()) { in WritableFileSynced()
349 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileSynced()
351 db_file_state_[state.filename_] = state; in WritableFileSynced()
358 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileAppended()
359 if (db_file_state_.find(state.filename_) == db_file_state_.end()) { in WritableFileAppended()
360 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileAppended()
[all …]
Dfault_injection_test_env.h167 void WritableFileClosed(const FileState& state);
169 void WritableFileSynced(const FileState& state);
171 void WritableFileAppended(const FileState& state);
/rocksdb-6.9/memtable/
Dinlineskiplist_test.cc572 Random rnd(state->seed_); in ConcurrentReader()
576 state->t_.ReadStep(&rnd); in ConcurrentReader()
579 state->Change(TestState::DONE); in ConcurrentReader()
585 state->t_.ConcurrentWriteStep(k, state->use_hint_); in ConcurrentWriter()
586 state->AdjustPendingWriters(-1); in ConcurrentWriter()
598 TestState state(seed + 1); in RunConcurrentRead() local
603 state.t_.WriteStep(&rnd); in RunConcurrentRead()
606 state.Wait(TestState::DONE); in RunConcurrentRead()
622 TestState state(seed + 1); in RunConcurrentInsert() local
623 state.use_hint_ = use_hint; in RunConcurrentInsert()
[all …]
Dskiplist_test.cc345 TestState* state = reinterpret_cast<TestState*>(arg); in ConcurrentReader() local
346 Random rnd(state->seed_); in ConcurrentReader()
348 state->Change(TestState::RUNNING); in ConcurrentReader()
350 state->t_.ReadStep(&rnd); in ConcurrentReader()
353 state->Change(TestState::DONE); in ConcurrentReader()
365 TestState state(seed + 1); in RunConcurrent() local
367 Env::Default()->Schedule(ConcurrentReader, &state); in RunConcurrent()
368 state.Wait(TestState::RUNNING); in RunConcurrent()
370 state.t_.WriteStep(&rnd); in RunConcurrent()
372 state.quit_flag_.store(true, std::memory_order_release); in RunConcurrent()
[all …]
/rocksdb-6.9/third-party/folly/folly/synchronization/detail/
DProxyLockable-inl.h86 if (auto state = mtx.try_lock()) { in ProxyLockableUniqueLock() local
87 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
97 if (auto state = mtx.try_lock_for(duration)) { in ProxyLockableUniqueLock() local
98 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
108 if (auto state = mtx.try_lock_until(time)) { in ProxyLockableUniqueLock() local
109 proxy_.emplace(std::move(state)); in ProxyLockableUniqueLock()
135 if (auto state = mutex_->try_lock()) { in try_lock() local
136 proxy_.emplace(std::move(state)); in try_lock()
151 proxy_.emplace(std::move(state)); in try_lock_for()
165 if (auto state = mutex_->try_lock_until(time)) { in try_lock_until() local
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DStatus.java17 /* @Nullable */ private final String state; field in Status
19 public Status(final Code code, final SubCode subCode, final String state) { in Status() argument
22 this.state = state; in Status()
28 private Status(final byte code, final byte subCode, final String state) { in Status() argument
31 this.state = state; in Status()
43 return state; in getState()
/rocksdb-6.9/third-party/folly/folly/synchronization/
DDistributedMutex-inl.h1046 atomic_notify_one(state);
1063 if (!state.combined_) {
1068 unlock(std::move(state));
1151 return state;
1165 Waiter<Atomic> state{};
1166 auto&& task = coalesce(request, state);
1504 if (state.compare_exchange_strong(
1666 if (auto state = try_lock()) {
1667 return state;
1687 if (auto state = try_lock()) {
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_table_builder.cc339 State state; member
619 if (r->state == Rep::State::kBuffered) { in WriteBlock()
747 XXH32_reset(state, 0); in WriteRawBlock()
752 XXH32_freeState(state); in WriteRawBlock()
757 XXH64_reset(state, 0); in WriteRawBlock()
765 XXH64_freeState(state); in WriteRawBlock()
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 …]
/rocksdb-6.9/monitoring/
Dthread_status_util_debug.cc19 const ThreadStatus::StateType state, int micro) { in TEST_SetStateDelay() argument
20 states_delay[state].store(micro, std::memory_order_relaxed); in TEST_SetStateDelay()
23 void ThreadStatusUtil::TEST_StateDelay(const ThreadStatus::StateType state) { in TEST_StateDelay() argument
24 auto delay = states_delay[state].load(std::memory_order_relaxed); in TEST_StateDelay()
Dthread_status_util.h77 const ThreadStatus::StateType state, int micro);
78 static void TEST_StateDelay(const ThreadStatus::StateType state);
/rocksdb-6.9/table/
Dtwo_level_iterator.cc25 TwoLevelIteratorState* state,
85 TwoLevelIteratorState* state, in TwoLevelIndexIterator() argument
87 : state_(state), first_level_iter_(first_level_iter) {} in TwoLevelIndexIterator()
207 TwoLevelIteratorState* state, in NewTwoLevelIterator() argument
209 return new TwoLevelIndexIterator(state, first_level_iter); in NewTwoLevelIterator()
/rocksdb-6.9/third-party/folly/folly/synchronization/test/
DDistributedMutexTest.cpp413 auto state = mutex.lock(); in TEST() local
414 mutex.unlock(std::move(state)); in TEST()
421 auto state = mutex.try_lock(); in TEST() local
422 if (state) { in TEST()
612 auto state = mutex.try_lock(); in TEST() local
613 if (state) { in TEST()
627 auto state = mutex.lock(); in TEST() local
630 mutex.unlock(std::move(state)); in TEST()
645 auto state = mutex.lock(); in TEST() local
649 mutex.unlock(std::move(state)); in TEST()
[all …]
/rocksdb-6.9/env/
Denv_posix.cc453 StartThreadState* state = reinterpret_cast<StartThreadState*>(arg); in StartThreadWrapper() local
454 state->user_function(state->arg); in StartThreadWrapper()
455 delete state; in StartThreadWrapper()
461 StartThreadState* state = new StartThreadState; in StartThread() local
462 state->user_function = function; in StartThread()
463 state->arg = arg; in StartThread()
465 "start thread", pthread_create(&t, nullptr, &StartThreadWrapper, state)); in StartThread()
/rocksdb-6.9/include/rocksdb/utilities/
Dldb_cmd_execute_result.h24 LDBCommandExecuteResult(State state, std::string& msg) in LDBCommandExecuteResult() argument
25 : state_(state), message_(msg) {} in LDBCommandExecuteResult()

123