Home
last modified time | relevance | path

Searched refs:store (Results 1 – 25 of 103) sorted by relevance

12345

/rocksdb-6.9/utilities/cassandra/
Dcassandra_functional_test.cc186 store.Flush(); in TEST_F()
193 store.Flush(); in TEST_F()
194 store.Compact(); in TEST_F()
219 store.Flush(); in TEST_F()
226 store.Flush(); in TEST_F()
227 store.Compact(); in TEST_F()
249 store.Flush(); in TEST_F()
255 store.Flush(); in TEST_F()
275 store.Flush(); in TEST_F()
281 store.Flush(); in TEST_F()
[all …]
/rocksdb-6.9/monitoring/
Dhistogram.cc71 min_.store(bucketMapper.LastValue(), std::memory_order_relaxed); in Clear()
72 max_.store(0, std::memory_order_relaxed); in Clear()
73 num_.store(0, std::memory_order_relaxed); in Clear()
74 sum_.store(0, std::memory_order_relaxed); in Clear()
75 sum_squares_.store(0, std::memory_order_relaxed); in Clear()
77 buckets_[b].store(0, std::memory_order_relaxed); in Clear()
94 min_.store(value, std::memory_order_relaxed); in Add()
99 max_.store(value, std::memory_order_relaxed); in Add()
102 num_.store(num_.load(std::memory_order_relaxed) + 1, in Add()
104 sum_.store(sum_.load(std::memory_order_relaxed) + value, in Add()
[all …]
Dthread_status_updater.cc55 data->cf_key.store(const_cast<void*>(cf_key), std::memory_order_relaxed); in SetColumnFamilyInfoKey()
77 data->operation_type.store(type, std::memory_order_release); in SetThreadOperation()
79 data->operation_stage.store(ThreadStatus::STAGE_UNKNOWN, in SetThreadOperation()
90 data->op_properties[i].store(value, std::memory_order_relaxed); in SetThreadOperationProperty()
107 data->op_start_time.store(start_time, std::memory_order_relaxed); in SetOperationStartTime()
115 data->operation_stage.store(ThreadStatus::STAGE_UNKNOWN, in ClearThreadOperation()
117 data->operation_type.store(ThreadStatus::OP_UNKNOWN, in ClearThreadOperation()
128 data->op_properties[i].store(0, std::memory_order_relaxed); in ClearThreadOperationProperties()
146 data->state_type.store(type, std::memory_order_relaxed); in SetThreadState()
154 data->state_type.store(ThreadStatus::STATE_UNKNOWN, in ClearThreadState()
Dthread_status_updater.h68 thread_id.store(0); in ThreadStatusData()
69 thread_type.store(ThreadStatus::USER); in ThreadStatusData()
70 cf_key.store(nullptr); in ThreadStatusData()
71 operation_type.store(ThreadStatus::OP_UNKNOWN); in ThreadStatusData()
72 op_start_time.store(0); in ThreadStatusData()
73 state_type.store(ThreadStatus::STATE_UNKNOWN); in ThreadStatusData()
Dhistogram_windowing.cc46 current_window_.store(0, std::memory_order_relaxed); in Clear()
47 last_swap_time_.store(env_->NowMicros(), std::memory_order_relaxed); in Clear()
149 last_swap_time_.store(env_->NowMicros(), std::memory_order_relaxed); in SwapHistoryBucket()
173 stats_.min_.store(new_min, std::memory_order_relaxed); in SwapHistoryBucket()
184 stats_.max_.store(new_max, std::memory_order_relaxed); in SwapHistoryBucket()
196 current_window_.store(next_window, std::memory_order_relaxed); in SwapHistoryBucket()
/rocksdb-6.9/db/
Ddb_io_failure_test.cc34 env_->drop_writes_.store(true, std::memory_order_release); in TEST_F()
56 env_->drop_writes_.store(false, std::memory_order_release); in TEST_F()
76 env_->drop_writes_.store(true, std::memory_order_release); in TEST_F()
108 env_->no_space_.store(true, std::memory_order_release); in TEST_F()
115 env_->no_space_.store(false, std::memory_order_release); in TEST_F()
128 env_->non_writeable_rate_.store(100); in TEST_F()
138 env_->non_writeable_rate_.store(0); in TEST_F()
174 error_type->store(true, std::memory_order_release); in TEST_F()
178 error_type->store(false, std::memory_order_release); in TEST_F()
192 error_type->store(true, std::memory_order_release); in TEST_F()
[all …]
Dwrite_batch.cc326 content_flags_.store(0, std::memory_order_relaxed); in Clear()
350 content_flags_.store(rv, std::memory_order_relaxed); in ComputeContentFlags()
781 b->content_flags_.store( in Put()
834 b->content_flags_.store( in Put()
871 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in MarkEndPrepare()
886 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in MarkCommit()
895 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in MarkRollback()
912 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in Delete()
934 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in Delete()
958 b->content_flags_.store(b->content_flags_.load(std::memory_order_relaxed) | in SingleDelete()
[all …]
Dmemtable_list.cc354 imm_flush_needed.store(false, std::memory_order_release); in PickMemtablesToFlush()
382 imm_flush_needed.store(true, std::memory_order_release); in RollbackMemtableFlush()
526 imm_flush_needed.store(true, std::memory_order_release); in TryInstallMemtableFlushResults()
549 imm_flush_needed.store(true, std::memory_order_release); in Add()
587 current_memory_usage_excluding_last_.store(total_memtable_size, in UpdateCachedValuesFromMemTableListVersion()
591 current_has_history_.store(has_history, std::memory_order_relaxed); in UpdateCachedValuesFromMemTableListVersion()
741 imm->imm_flush_needed.store(true, std::memory_order_release); in InstallMemtableAtomicFlushResults()
767 imm_flush_needed.store(false, std::memory_order_release); in RemoveOldMemTables()
Dtrim_history_scheduler.cc18 is_empty_.store(false, std::memory_order_relaxed); in ScheduleWork()
30 is_empty_.store(true, std::memory_order_relaxed); in TakeNextColumnFamily()
Dmemtable.cc143 approximate_memory_usage_.store(total_usage, std::memory_order_relaxed); in ApproximateMemoryUsage()
164 approximate_memory_usage_.store(allocated_memory, std::memory_order_relaxed); in ShouldFlushNow()
521 num_entries_.store(num_entries_.load(std::memory_order_relaxed) + 1, in Add()
523 data_size_.store(data_size_.load(std::memory_order_relaxed) + encoded_len, in Add()
526 num_deletes_.store(num_deletes_.load(std::memory_order_relaxed) + 1, in Add()
541 first_seqno_.store(s, std::memory_order_relaxed); in Add()
544 earliest_seqno_.store(GetFirstSequenceNumber(), in Add()
587 is_range_del_table_empty_.store(false, std::memory_order_relaxed); in Add()
Dforward_iterator_bench.cc168 state.last_read.store(seq); in readOnceFromShard()
186 done_.store(true); in ~Reader()
251 state.last_written.store(seqno); in run()
306 done_.store(true); in ~StatsThread()
/rocksdb-6.9/
DUSERS.md8 3. ZippyDB -- Facebook's distributed key-value store with Paxos-style replication, built on top of…
12 6. LogDevice -- a distributed data store for logs [2]
16 [2] https://code.facebook.com/posts/357056558062811/logdevice-a-distributed-data-store-for-logs/
27 Yahoo is using RocksDB as a storage engine for their biggest distributed data store Sherpa. Learn m…
41 Tango is using RocksDB as a graph storage to store all users' connection data and other social acti…
44 Turn is using RocksDB as a storage layer for their key/value store, serving at peak 2.4MM QPS out o…
67 [VWO's](https://vwo.com/) Smart Code checker and URL helper uses RocksDB to store all the URLs wher…
80 [Apache Flink](https://flink.apache.org/news/2016/03/08/release-1.0.0.html) uses RocksDB to store s…
83 …ributed, low latency, high throughput Graph database .They use RocksDB to store state locally on a…
92 LzLabs is using RocksDB as a storage engine in their multi-database distributed framework to store …
[all …]
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction.cc156 txn_state_.store(AWAITING_COMMIT); in CommitBatch()
159 txn_state_.store(COMMITTED); in CommitBatch()
198 txn_state_.store(AWAITING_PREPARE); in Prepare()
206 txn_state_.store(PREPARED); in Prepare()
299 txn_state_.store(AWAITING_COMMIT); in Commit()
310 txn_state_.store(COMMITTED); in Commit()
314 txn_state_.store(AWAITING_COMMIT); in Commit()
333 txn_state_.store(COMMITTED); in Commit()
401 txn_state_.store(AWAITING_ROLLBACK); in Rollback()
411 txn_state_.store(ROLLEDBACK); in Rollback()
/rocksdb-6.9/tools/
Dwrite_stress.cc116 key_prefix_[i].store('a'); in WriteStress()
211 key_prefix_[0].store(static_cast<char>(char_dist(rng)), std::memory_order_relaxed); in PrefixMutatorThread()
214 key_prefix_[1].store(static_cast<char>(char_dist(rng)), std::memory_order_relaxed); in PrefixMutatorThread()
217 key_prefix_[2].store(static_cast<char>(char_dist(rng)), std::memory_order_relaxed); in PrefixMutatorThread()
236 stop_.store(true, std::memory_order_relaxed); in Run()
/rocksdb-6.9/third-party/folly/folly/synchronization/
DBaton.h103 state_.store(INIT, std::memory_order_relaxed); in reset()
117 state_.store(EARLY_DELIVERY, std::memory_order_release); in post()
143 state_.store(LATE_DELIVERY, std::memory_order_release); in post()
292 state_.store(TIMED_OUT, std::memory_order_release); in tryWaitSlow()
DDistributedMutex-inl.h243 futex_.store(futex, std::memory_order_release); in initialize()
961 sleeper->store(kWake, std::memory_order_release);
1188 state.next_.store(previous, std::memory_order_relaxed);
1303 waiter->futex_.store(kExceptionOccurred, std::memory_order_release);
1337 waiter->futex_.store(kCombined, std::memory_order_release);
1378 waiter->futex_.store(kWake, std::memory_order_release);
1405 waiter->futex_.store(kSkipped, std::memory_order_release);
1449 waiter->next_.store(head, std::memory_order_relaxed);
/rocksdb-6.9/memory/
Dconcurrent_arena.h188 s->allocated_and_unused_.store(avail - bytes, std::memory_order_relaxed); in AllocateImpl()
203 arena_allocated_and_unused_.store(arena_.AllocatedAndUnused(), in Fixup()
205 memory_allocated_bytes_.store(arena_.MemoryAllocatedBytes(), in Fixup()
207 irregular_block_num_.store(arena_.IrregularBlockNum(), in Fixup()
/rocksdb-6.9/third-party/folly/folly/synchronization/test/
DDistributedMutexTest.cpp126 stop.store(true); in lockWithTryAndTimedNThreads()
170 stop.store(true); in combineNThreads()
225 stop.store(true); in combineWithLockNThreads()
295 stop.store(true); in combineWithTryLockNThreads()
396 stop.store(true); in combineWithLockTryAndTimedNThreads()
809 copyAssigns().store(0); in reset()
810 destructs().store(0); in reset()
878 stop.store(true); in TEST()
921 stop.store(true); in concurrentLocksManyMutexes()
1029 stop.store(true); in concurrentExceptionPropagationStress()
[all …]
/rocksdb-6.9/memtable/
Dhash_linklist_rep.cc49 num_entries.store(GetNumEntries() + 1, std::memory_order_relaxed); in IncNumEntries()
76 next_.store(x, std::memory_order_release); in SetNext()
83 void NoBarrier_SetNext(Node* x) { next_.store(x, std::memory_order_relaxed); } in NoBarrier_SetNext()
515 buckets_[i].store(nullptr, std::memory_order_relaxed); in HashLinkListRep()
585 bucket.store(x, std::memory_order_release); in Insert()
601 bucket.store(header, std::memory_order_release); in Insert()
646 bucket.store(new_skip_list_header, std::memory_order_release); in Insert()
688 header->next.store(static_cast<void*>(x), std::memory_order_release); in Insert()
/rocksdb-6.9/utilities/simulator_cache/
Dsim_cache.cc55 activity_logging_enabled_.store(true); in StartLogging()
132 activity_logging_enabled_.store(false); in StopLoggingInternal()
275 miss_times_.store(0, std::memory_order_relaxed); in reset_counter()
276 hit_times_.store(0, std::memory_order_relaxed); in reset_counter()
/rocksdb-6.9/utilities/blob_db/
Dblob_file.cc103 obsolete_.store(true); in MarkObsolete()
164 last_fsync_.store(file_size_); in SetFromFooterLocked()
175 last_fsync_.store(file_size_.load()); in Fsync()
193 last_access_.store(current_time); in GetReader()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_shared_state.h212 void SetVerificationFailure() { verification_failure_.store(true); } in SetVerificationFailure()
216 void SetShouldStopTest() { should_stop_test_.store(true); } in SetShouldStopTest()
253 Value(cf, key).store(pending ? UNKNOWN_SENTINEL : value_base, in Put()
328 printing_verification_results_.store(false, std::memory_order_relaxed); in FinishPrintingVerificationResults()
/rocksdb-6.9/include/rocksdb/utilities/
Dtable_properties_collectors.h29 sliding_window_size_.store(sliding_window_size); in SetWindowSize()
34 deletion_trigger_.store(deletion_trigger); in SetDeletionTrigger()
/rocksdb-6.9/util/
Dconcurrent_task_limiter_impl.cc32 max_outstanding_tasks_.store(limit, std::memory_order_relaxed); in SetMaxOutstandingTask()
36 max_outstanding_tasks_.store(-1, std::memory_order_relaxed); in ResetMaxOutstandingTask()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator_test.cc48 last_seen.store(k); in FilterV2()
62 stall_at.store(k); in WaitForStall()
501 seek_done.store(true); in TEST_P()
509 shutting_down_.store(true); in TEST_P()
513 filter.stall_at.store(3); in TEST_P()
538 seek_done.store(true); in TEST_P()
546 shutting_down_.store(true); in TEST_P()
550 filter.stall_at.store(3); in TEST_P()

12345