Home
last modified time | relevance | path

Searched refs:outstanding_tasks_ (Results 1 – 2 of 2) sorted by relevance

/rocksdb-6.9/util/
Dconcurrent_task_limiter_impl.cc19 outstanding_tasks_{0} {
24 assert(outstanding_tasks_ == 0); in ~ConcurrentTaskLimiterImpl()
40 return outstanding_tasks_.load(std::memory_order_relaxed); in GetOutstandingTask()
46 int32_t tasks = outstanding_tasks_.load(std::memory_order_relaxed); in GetToken()
50 if (outstanding_tasks_.compare_exchange_weak(tasks, tasks + 1)) { in GetToken()
63 --limiter_->outstanding_tasks_; in ~TaskLimiterToken()
64 assert(limiter_->outstanding_tasks_ >= 0); in ~TaskLimiterToken()
Dconcurrent_task_limiter_impl.h50 std::atomic<int32_t> outstanding_tasks_; variable