Home
last modified time | relevance | path

Searched refs:atomic (Results 1 – 25 of 671) sorted by relevance

12345678910>>...27

/rocksdb-6.9/third-party/folly/folly/synchronization/
DAtomicUtil-inl.h32 Atomic& atomic, in atomic_fetch_set_default() argument
35 using Integer = decltype(atomic.load()); in atomic_fetch_set_default()
42 Atomic& atomic, in atomic_fetch_reset_default() argument
45 using Integer = decltype(atomic.load()); in atomic_fetch_reset_default()
65 std::atomic<Integer>& atomic,
70 assert(atomic.is_lock_free());
95 std::atomic<Integer>& atomic,
100 assert(atomic.is_lock_free());
127 std::atomic<Integer>& atomic,
167 std::atomic<Integer>& atomic,
[all …]
DAtomicNotification-inl.h44 futexWait(atomic, expected); in atomic_wait_impl()
52 atomic, -1, [&] { return atomic->load() == expected; }, [] {}); in atomic_wait_impl()
74 const Atom<Integer, Args...>* atomic, in atomic_wait_until_impl() argument
79 atomic, -1, [&] { return atomic->load() == expected; }, [] {}, deadline)); in atomic_wait_until_impl()
84 futexWake(atomic, 1); in atomic_notify_one_impl()
99 futexWake(atomic); in atomic_notify_all_impl()
115 void atomic_wait(const std::atomic<Integer>* atomic, Integer expected) { in atomic_wait() argument
121 const std::atomic<Integer>* atomic, in atomic_wait_until() argument
125 atomic, expected, deadline); in atomic_wait_until()
129 void atomic_notify_one(const std::atomic<Integer>* atomic) { in atomic_notify_one() argument
[all …]
DAtomicNotification.h38 void atomic_wait(const std::atomic<Integer>* atomic, Integer expected);
41 const std::atomic<Integer>* atomic,
47 void atomic_notify_one(const std::atomic<Integer>* atomic);
50 void atomic_notify_all(const std::atomic<Integer>* atomic);
53 using atomic_uint_fast_wait_t = std::atomic<std::uint32_t>;
DAtomicUtil.h30 Atomic& atomic,
46 Atomic& atomic,
/rocksdb-6.9/third-party/folly/folly/synchronization/test/
DDistributedMutexTest.cpp665 auto&& atomic = std::atomic<std::uint64_t>{0}; in stressTryLockWithConcurrentLocks()
716 auto&& atomic = std::atomic<std::uint64_t>{0}; in concurrentTryLocks()
781 static auto&& atomic = std::atomic<std::uint64_t>{0}; in defaultConstructs()
782 return atomic; in defaultConstructs()
785 static auto&& atomic = std::atomic<std::uint64_t>{0}; in moveConstructs()
786 return atomic; in moveConstructs()
789 static auto&& atomic = std::atomic<std::uint64_t>{0}; in copyConstructs()
790 return atomic; in copyConstructs()
793 static auto&& atomic = std::atomic<std::uint64_t>{0}; in moveAssigns()
797 static auto&& atomic = std::atomic<std::uint64_t>{0}; in copyAssigns()
[all …]
/rocksdb-6.9/monitoring/
Dthread_status_updater.h85 std::atomic<uint64_t> thread_id;
86 std::atomic<ThreadStatus::ThreadType> thread_type;
87 std::atomic<void*> cf_key;
88 std::atomic<ThreadStatus::OperationType> operation_type;
89 std::atomic<uint64_t> op_start_time;
90 std::atomic<ThreadStatus::OperationStage> operation_stage;
91 std::atomic<uint64_t> op_properties[ThreadStatus::kNumOperationProperties];
92 std::atomic<ThreadStatus::StateType> state_type;
/rocksdb-6.9/db/
Ddb_test_util.h452 std::atomic<size_t>* bytes_read_; in NewRandomAccessFile()
541 std::atomic<bool> drop_writes_;
544 std::atomic<bool> no_space_;
547 std::atomic<bool> non_writable_;
556 std::atomic<bool> log_write_error_;
562 std::atomic<int> num_open_wal_file_;
574 std::atomic<int64_t> bytes_written_;
576 std::atomic<int> sync_counter_;
586 std::atomic<int64_t> addon_time_;
588 std::atomic<int> now_cpu_count_;
[all …]
Dmemtable.h466 std::atomic<uint64_t> data_size_;
467 std::atomic<uint64_t> num_entries_;
468 std::atomic<uint64_t> num_deletes_;
471 std::atomic<size_t> write_buffer_size_;
483 std::atomic<SequenceNumber> first_seqno_;
487 std::atomic<SequenceNumber> earliest_seqno_;
496 std::atomic<uint64_t> min_prep_log_referenced_;
504 std::atomic<FlushStateEnum> flush_state_;
515 std::atomic<uint64_t> oldest_key_time_;
528 std::atomic<uint64_t> approximate_memory_usage_;
Dwrite_thread.h83 std::atomic<size_t> running;
127 std::atomic<uint8_t> state; // write under StateMutex() or pre-link
250 std::atomic<int32_t> value;
370 std::atomic<Writer*> newest_writer_;
374 std::atomic<Writer*> newest_memtable_writer_;
407 bool LinkOne(Writer* w, std::atomic<Writer*>* newest_writer);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
Dwrite_callback_test.cc65 std::atomic<bool> was_called_{false};
179 std::atomic<uint64_t> threads_joining(0); in TEST_F()
181 std::atomic<uint64_t> threads_linked(0); in TEST_F()
183 std::atomic<uint64_t> threads_verified(0); in TEST_F()
185 std::atomic<uint64_t> seq(db_impl->GetLatestSequenceNumber()); in TEST_F()
258 std::atomic<uint32_t> thread_num(0); in TEST_F()
259 std::atomic<char> dummy_key(0); in TEST_F()
Dcolumn_family.h238 std::atomic<uint32_t> refs;
528 std::atomic<int> refs_; // outstanding references to ColumnFamilyData
529 std::atomic<bool> initialized_;
530 std::atomic<bool> dropped_; // true if client dropped it
555 std::atomic<uint64_t> super_version_number_;
572 std::atomic<FlushReason> flush_reason_;
595 std::atomic<uint64_t> last_memtable_id_;
Dforward_iterator_bench.cc52 std::atomic<uint64_t> written{0};
54 std::atomic<uint64_t> read{0};
55 std::atomic<uint64_t> cache_misses{0};
77 std::atomic<uint64_t> last_written{0};
81 std::atomic<uint64_t> last_read{0};
200 std::atomic<bool> done_{false};
317 std::atomic<bool> done_{false};
Ddb_io_failure_test.cc153 std::atomic<bool>* error_type = (iter == 0) ? &env_->manifest_sync_error_ in TEST_F()
272 std::atomic<int> range_sync_called(0); in TEST_F()
352 std::atomic<int> range_sync_called(0); in TEST_F()
391 std::atomic<int> close_called(0); in TEST_F()
443 std::atomic<int> close_called(0); in TEST_F()
482 std::atomic<int> sync_called(0); in TEST_F()
535 std::atomic<int> sync_called(0); in TEST_F()
Dwrite_controller.h95 std::atomic<int> total_stopped_;
96 std::atomic<int> total_delayed_;
97 std::atomic<int> total_compaction_pressure_;
/rocksdb-6.9/utilities/persistent_cache/
Dvolatile_tier_impl.h111 std::atomic<uint64_t> cache_misses_{0};
112 std::atomic<uint64_t> cache_hits_{0};
113 std::atomic<uint64_t> cache_inserts_{0};
114 std::atomic<uint64_t> cache_evicts_{0};
135 std::atomic<uint64_t> max_size_{0}; // Maximum size of the cache
136 std::atomic<uint64_t> size_{0}; // Size of the cache
Dblock_cache_tier.h125 std::atomic<uint64_t> cache_hits_{0};
126 std::atomic<uint64_t> cache_misses_{0};
127 std::atomic<uint64_t> cache_errors_{0};
128 std::atomic<uint64_t> insert_dropped_{0};
150 std::atomic<uint64_t> size_{0}; // Size of the cache
Dhash_table_bench.cc178 std::atomic<size_t> insert_key_; // Last inserted key
179 std::atomic<size_t> erase_key_; // Erase key
180 std::atomic<size_t> ninserts_; // Number of inserts
181 std::atomic<size_t> nreads_; // Number of reads
182 std::atomic<size_t> nerases_; // Number of erases
183 std::atomic<size_t> nerases_failed_; // Number of erases failed
/rocksdb-6.9/db_stress_tool/
Ddb_stress_shared_state.h89 sizeof(std::atomic<uint32_t>) * FLAGS_column_families * max_key_; in SharedState()
93 if (!std::atomic<uint32_t>{}.is_lock_free()) { in SharedState()
124 values_ = static_cast<std::atomic<uint32_t>*>( in SharedState()
135 new std::atomic<uint32_t>[FLAGS_column_families * max_key_]); in SharedState()
236 std::atomic<uint32_t>& Value(int cf, int64_t key) const { in Value()
348 std::atomic<bool> verification_failure_;
349 std::atomic<bool> should_stop_test_;
354 std::atomic<uint32_t>* values_;
355 std::unique_ptr<std::atomic<uint32_t>[]> values_allocation_;
360 std::atomic<bool> printing_verification_results_;
/rocksdb-6.9/utilities/blob_db/
Dblob_file.h65 std::atomic<uint64_t> blob_count_{0};
68 std::atomic<uint64_t> file_size_{0};
74 std::atomic<bool> closed_{false};
81 std::atomic<bool> obsolete_{false};
98 std::atomic<std::int64_t> last_access_{-1};
101 std::atomic<uint64_t> last_fsync_{0};
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.h71 const std::atomic<bool>* shutting_down = nullptr,
73 const std::atomic<bool>* manual_compaction_paused = nullptr,
86 const std::atomic<bool>* shutting_down = nullptr,
88 const std::atomic<bool>* manual_compaction_paused = nullptr,
167 const std::atomic<bool>* shutting_down_;
168 const std::atomic<bool>* manual_compaction_paused_;
Dcompaction_job.h68 const std::atomic<bool>* shutting_down,
81 const std::atomic<bool>* manual_compaction_paused = nullptr);
163 const std::atomic<bool>* shutting_down_;
164 const std::atomic<bool>* manual_compaction_paused_;
/rocksdb-6.9/third-party/folly/folly/detail/
DFutex.h37 template <template <typename> class Atom = std::atomic>
85 struct EmulatedFutexAtomic : public std::atomic<T> {
88 : std::atomic<T>(init) {} in EmulatedFutexAtomic()
/rocksdb-6.9/memory/
Dconcurrent_arena.h92 std::atomic<size_t> allocated_and_unused_;
111 std::atomic<size_t> arena_allocated_and_unused_;
112 std::atomic<size_t> memory_allocated_bytes_;
113 std::atomic<size_t> irregular_block_num_;
/rocksdb-6.9/file/
Ddelete_scheduler.h101 std::atomic<uint64_t> total_trash_size_;
103 std::atomic<int64_t> rate_bytes_per_sec_;
138 std::atomic<double> max_trash_db_ratio_;
/rocksdb-6.9/util/
Ddynamic_bloom.h83 std::atomic<uint64_t>* data_;
100 AddHash(hash, [](std::atomic<uint64_t>* ptr, uint64_t mask) { in AddHash()
107 AddHash(hash, [](std::atomic<uint64_t>* ptr, uint64_t mask) { in AddHashConcurrently()

12345678910>>...27