| /rocksdb-6.9/logging/ |
| D | event_logger.h | 30 state_ = kExpectValue; in AddKey()
35 assert(state_ == kExpectValue || state_ == kInArray); in AddValue()
41 state_ = kExpectKey; in AddValue()
48 assert(state_ == kExpectValue || state_ == kInArray); in AddValue()
54 state_ = kExpectKey; in AddValue()
61 state_ = kInArray; in StartArray()
69 state_ = kExpectKey; in EndArray()
77 state_ = kExpectKey; in StartObject()
90 state_ = kExpectValue; in StartArrayedObject()
100 state_ = kInArray; in EndArrayedObject()
[all …]
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 53 state_(init_state), in GetContext()
92 state_ = kFound; in MarkKeyMayExist()
102 state_ = kFound; in SaveValue()
225 assert(state_ == kNotFound || state_ == kMerge); in SaveValue()
232 state_ = kFound; in SaveValue()
254 state_ = kFound; in SaveValue()
290 assert(state_ == kNotFound || state_ == kMerge); in SaveValue()
294 state_ = kFound; in SaveValue()
313 assert(state_ == kNotFound || state_ == kMerge); in SaveValue()
314 state_ = kMerge; in SaveValue()
[all …]
|
| D | two_level_iterator.cc | 31 delete state_; in ~TwoLevelIndexIterator()
75 TwoLevelIteratorState* state_; member in ROCKSDB_NAMESPACE::__anond75762610111::TwoLevelIndexIterator
87 : state_(state), first_level_iter_(first_level_iter) {} in TwoLevelIndexIterator()
197 state_->NewSecondaryIterator(handle); in InitDataBlock()
|
| D | get_context.h | 129 GetState State() const { return state_; } in State()
169 GetState state_; variable
|
| /rocksdb-6.9/third-party/folly/folly/synchronization/ |
| D | Baton.h | 49 constexpr Baton() noexcept : state_(INIT) {} in Baton()
75 auto s = state_.load(std::memory_order_acquire); in ready()
103 state_.store(INIT, std::memory_order_relaxed); in reset()
115 ((1 << state_.load(std::memory_order_relaxed)) & in post()
128 state_.compare_exchange_strong( in post()
143 state_.store(LATE_DELIVERY, std::memory_order_release); in post()
144 detail::futexWake(&state_, 1); in post()
274 if (!state_.compare_exchange_strong( in tryWaitSlow()
292 state_.store(TIMED_OUT, std::memory_order_release); in tryWaitSlow()
316 uint32_t s = state_.load(std::memory_order_acquire); in tryWaitSlow()
[all …]
|
| D | DistributedMutex-inl.h | 847 : state_{kUnlocked} {}
1062 auto&& state = lockImplementation(*this, state_, task);
1084 wakeTimedWaiters(&state_, state.timedWaiters_);
1092 return lockImplementation(*this, state_, null);
1123 if (state_.load(std::memory_order_relaxed) != kUnlocked) {
1127 return tryLockNoLoad(state_, *this);
1536 wakeTimedWaiters(&state_, proxy.timedWaiters_);
1564 if (tryUnlockClean(state_, proxy, sleepers)) {
1579 auto head = state_.exchange(kLocked, std::memory_order_acq_rel);
1673 state_,
[all …]
|
| D | DistributedMutex.h | 288 Atomic<std::uintptr_t> state_{0};
|
| /rocksdb-6.9/include/rocksdb/ |
| D | status.h | 27 Status() : code_(kOk), subcode_(kNone), sev_(kNoError), state_(nullptr) {} in Status()
28 ~Status() { delete[] state_; } in ~Status()
99 const char* getState() const { return state_; } in getState()
318 const char* state_; variable
332 state_ = (s.state_ == nullptr) ? nullptr : CopyState(s.state_); in Status()
336 state_ = (s.state_ == nullptr) ? nullptr : CopyState(s.state_); in Status()
345 delete[] state_;
346 state_ = (s.state_ == nullptr) ? nullptr : CopyState(s.state_);
371 delete[] state_;
372 state_ = nullptr;
[all …]
|
| D | io_status.h | 169 state_ = result; in IOStatus()
176 state_ = (s.state_ == nullptr) ? nullptr : CopyState(s.state_); in IOStatus()
187 delete[] state_;
188 state_ = (s.state_ == nullptr) ? nullptr : CopyState(s.state_);
215 delete[] state_;
216 state_ = nullptr;
217 std::swap(state_, s.state_);
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | ldb_cmd_execute_result.h | 22 LDBCommandExecuteResult() : state_(EXEC_NOT_STARTED), message_("") {} in LDBCommandExecuteResult()
25 : state_(state), message_(msg) {} in LDBCommandExecuteResult()
29 switch (state_) { in ToString()
45 state_ = EXEC_NOT_STARTED; in Reset()
49 bool IsSucceed() { return state_ == EXEC_SUCCEED; } in IsSucceed()
51 bool IsNotStarted() { return state_ == EXEC_NOT_STARTED; } in IsNotStarted()
53 bool IsFailed() { return state_ == EXEC_FAILED; } in IsFailed()
64 State state_;
|
| /rocksdb-6.9/test_util/ |
| D | fault_injection_test_fs.cc | 73 : state_(fname), in TestFSWritableFile()
78 state_.pos_ = 0; in TestFSWritableFile()
93 state_.buffer_.append(data.data(), data.size()); in Append()
94 state_.pos_ += data.size(); in Append()
95 fs_->WritableFileAppended(state_); in Append()
108 state_.buffer_.resize(0); in Close()
113 fs_->WritableFileClosed(state_); in Close()
124 state_.pos_at_last_flush_ = state_.pos_; in Flush()
135 state_.buffer_.resize(0); in Sync()
137 state_.pos_at_last_sync_ = state_.pos_; in Sync()
[all …]
|
| D | fault_injection_test_env.cc | 111 : state_(fname), in TestWritableFile()
116 state_.pos_ = 0; in TestWritableFile()
131 state_.pos_ += data.size(); in Append()
132 env_->WritableFileAppended(state_); in Append()
141 env_->WritableFileClosed(state_); in Close()
149 state_.pos_at_last_flush_ = state_.pos_; in Flush()
159 state_.pos_at_last_sync_ = state_.pos_; in Sync()
160 env_->WritableFileSynced(state_); in Sync()
|
| D | fault_injection_test_env.h | 79 FileState state_;
|
| D | fault_injection_test_fs.h | 88 FSFileState state_;
|
| /rocksdb-6.9/db/ |
| D | c.cc | 199 void* state_; member
219 state_, in Filter()
237 void* state_; member
257 void* state_; member
279 void* state_; member
324 void* state_; member
421 void* state_; member
1554 void* state_; member in H
1571 handler.state_ = state; in rocksdb_writebatch_iterate()
1815 handler.state_ = state; in rocksdb_writebatch_wi_iterate()
[all …]
|
| /rocksdb-6.9/util/ |
| D | status.cc | 73 state_ = result; in Status()
137 if (state_ != nullptr) { in ToString()
138 result.append(state_); in ToString()
|
| /rocksdb-6.9/memtable/ |
| D | skiplist_test.cc | 321 : seed_(s), quit_flag_(false), state_(STARTING), state_cv_(&mu_) {} in TestState()
325 while (state_ != s) { in Wait()
333 state_ = s; in Change()
340 ReaderState state_; member in ROCKSDB_NAMESPACE::TestState
|
| D | inlineskiplist_test.cc | 527 state_(STARTING), in TestState()
533 while (state_ != s) { in Wait()
541 state_ = s; in Change()
565 ReaderState state_; member in ROCKSDB_NAMESPACE::TestState
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest-all.cc | 1812 state_ = static_cast<UInt32>(1103515245ULL*state_ + 12345U) % kMaxRange; in Generate()
1823 return state_ % range; in Generate()
|
| D | gtest.h | 8679 explicit Random(UInt32 seed) : state_(seed) {}
8681 void Reseed(UInt32 seed) { state_ = seed; }
8688 UInt32 state_;
|