Home
last modified time | relevance | path

Searched refs:lock_guard (Results 1 – 25 of 33) sorted by relevance

12

/rocksdb-6.9/db/
Dlogs_with_prep_tracker.cc13 std::lock_guard<std::mutex> lock(prepared_section_completed_mutex_); in MarkLogAsHavingPrepSectionFlushed()
24 std::lock_guard<std::mutex> lock(logs_with_prep_mutex_); in MarkLogAsContainingPrepSection()
44 std::lock_guard<std::mutex> lock(logs_with_prep_mutex_); in FindMinLogContainingOutstandingPrep()
50 std::lock_guard<std::mutex> lock2(prepared_section_completed_mutex_); in FindMinLogContainingOutstandingPrep()
Dflush_scheduler.cc17 std::lock_guard<std::mutex> lock(checking_mutex_); in ScheduleWork()
50 std::lock_guard<std::mutex> lock(checking_mutex_); in TakeNextColumnFamily()
70 std::lock_guard<std::mutex> lock(checking_mutex_); in Empty()
Dtrim_history_scheduler.cc15 std::lock_guard<std::mutex> lock(checking_mutex_); in ScheduleWork()
22 std::lock_guard<std::mutex> lock(checking_mutex_); in TakeNextColumnFamily()
Dcompact_files_test.cc41 std::lock_guard<std::mutex> lock(mutex_); in OnFlushCompleted()
46 std::lock_guard<std::mutex> lock(mutex_); in GetFlushedFiles()
54 std::lock_guard<std::mutex> lock(mutex_); in ClearFlushedFiles()
Dforward_iterator_bench.cc107 std::lock_guard<std::mutex> guard(queue_mutex_); in run()
176 std::lock_guard<std::mutex> guard(queue_mutex_); in onWrite()
305 std::lock_guard<std::mutex> guard(cvm_); in ~StatsThread()
Dwrite_thread.cc216 std::lock_guard<std::mutex> guard(w->StateMutex()); in SetState()
591 std::lock_guard<std::mutex> guard(write_group->leader->StateMutex()); in CompleteParallelMemTableWriter()
Ddb_sst_test.cc31 std::lock_guard<std::mutex> lock(mutex_); in OnFlushCompleted()
36 std::lock_guard<std::mutex> lock(mutex_); in GetFlushedFiles()
44 std::lock_guard<std::mutex> lock(mutex_); in ClearFlushedFiles()
/rocksdb-6.9/monitoring/
Dthread_status_updater.cc24 std::lock_guard<std::mutex> lck(thread_list_mutex_); in RegisterThread()
33 std::lock_guard<std::mutex> lck(thread_list_mutex_); in UnregisterThread()
164 std::lock_guard<std::mutex> lck(thread_list_mutex_); in GetThreadList()
224 std::lock_guard<std::mutex> lck(thread_list_mutex_); in NewColumnFamilyInfo()
234 std::lock_guard<std::mutex> lck(thread_list_mutex_); in EraseColumnFamilyInfo()
254 std::lock_guard<std::mutex> lck(thread_list_mutex_); in EraseDatabaseInfo()
Dhistogram_windowing.cc40 std::lock_guard<std::mutex> lock(mutex_); in Clear()
75 std::lock_guard<std::mutex> lock(mutex_); in Merge()
Dhistogram.cc240 std::lock_guard<std::mutex> lock(mutex_); in Clear()
260 std::lock_guard<std::mutex> lock(mutex_); in Merge()
/rocksdb-6.9/util/
Dchannel.h24 std::lock_guard<std::mutex> lk(lock_); in sendEof()
30 std::lock_guard<std::mutex> lk(lock_); in eof()
35 std::lock_guard<std::mutex> lk(lock_); in size()
Dthreadpool_imp.cc177 std::lock_guard<std::mutex> lock(mu_); in LowerIOPriority()
183 std::lock_guard<std::mutex> lock(mu_); in LowerCPUPriority()
316 std::lock_guard<std::mutex> lock(mu_); in SetBackgroundThreadsInternal()
361 std::lock_guard<std::mutex> lock(mu_); in Submit()
395 std::lock_guard<std::mutex> lock(mu_); in UnSchedule()
/rocksdb-6.9/utilities/transactions/
Dpessimistic_transaction_db.cc548 std::lock_guard<std::mutex> lock(map_mutex_); in InsertExpirableTransaction()
553 std::lock_guard<std::mutex> lock(map_mutex_); in RemoveExpirableTransaction()
559 std::lock_guard<std::mutex> lock(map_mutex_); in TryStealingExpiredTransactionLocks()
580 std::lock_guard<std::mutex> lock(name_map_mutex_); in GetTransactionByName()
593 std::lock_guard<std::mutex> lock(name_map_mutex_); in GetAllPreparedTransactions()
619 std::lock_guard<std::mutex> lock(name_map_mutex_); in RegisterTransaction()
625 std::lock_guard<std::mutex> lock(name_map_mutex_); in UnregisterTransaction()
Dpessimistic_transaction.h74 std::lock_guard<std::mutex> lock(wait_mutex_); in GetWaitingTxns()
84 std::lock_guard<std::mutex> lock(wait_mutex_); in SetWaitingTxn()
91 std::lock_guard<std::mutex> lock(wait_mutex_); in ClearWaitingTxn()
Dtransaction_lock_mgr.cc97 std::lock_guard<std::mutex> lock(paths_buffer_mutex_); in AddNewPath()
108 std::lock_guard<std::mutex> lock(paths_buffer_mutex_); in Resize()
145 std::lock_guard<std::mutex> lock(paths_buffer_mutex_); in PrepareBuffer()
418 std::lock_guard<std::mutex> lock(wait_txn_map_mutex_); in DecrementWaiters()
444 std::lock_guard<std::mutex> lock(wait_txn_map_mutex_); in IncrementWaiters()
/rocksdb-6.9/test_util/
Dsync_point_impl.h49 std::lock_guard<std::mutex> lock(mutex_); in SetCallBack()
62 std::lock_guard<std::mutex> lock(mutex_); in ClearTrace()
Dsync_point_impl.cc34 std::lock_guard<std::mutex> lock(mutex_); in LoadDependency()
48 std::lock_guard<std::mutex> lock(mutex_); in LoadDependencyAndMarkers()
/rocksdb-6.9/memtable/
Dwrite_buffer_manager.cc84 std::lock_guard<std::mutex> lock(cache_rep_->cache_mutex_); in ReserveMemWithCache()
107 std::lock_guard<std::mutex> lock(cache_rep_->cache_mutex_); in FreeMemWithCache()
/rocksdb-6.9/third-party/folly/folly/synchronization/
DParkingLot.h49 std::lock_guard<std::mutex> nodeLock(mutex_); in wake()
274 std::lock_guard<std::mutex> bucketLock(bucket.mutex_); in park_until()
296 std::lock_guard<std::mutex> bucketLock(bucket.mutex_); in unpark()
DDistributedMutexSpecializations.h29 class lock_guard<
/rocksdb-6.9/utilities/
Denv_librados.cc332 std::lock_guard<std::mutex> lock(_mutex); in Append()
366 std::lock_guard<std::mutex> lock(_mutex); in Truncate()
409 std::lock_guard<std::mutex> lock(_mutex); in Flush()
431 std::lock_guard<std::mutex> lock(_mutex); in Sync()
466 std::lock_guard<std::mutex> lock(_mutex); in GetFileSize()
/rocksdb-6.9/trace_replay/
Dblock_cache_tracer.cc450 InstrumentedMutexLock lock_guard(&trace_writer_mutex_); in StartTrace() local
462 InstrumentedMutexLock lock_guard(&trace_writer_mutex_); in EndTrace() local
477 InstrumentedMutexLock lock_guard(&trace_writer_mutex_); in WriteBlockAccess() local
/rocksdb-6.9/table/
Dmock_table.cc70 MutexLock lock_guard(&file_system_.mutex); in NewTableReader() local
Dmock_table.h146 MutexLock lock_guard(&file_system_->mutex); in Finish()
/rocksdb-6.9/memory/
Dconcurrent_arena.h161 std::lock_guard<SpinMutex> reload_lock(arena_mutex_); in AllocateImpl()

12