Home
last modified time | relevance | path

Searched refs:TaskLimiterToken (Results 1 – 4 of 4) sorted by relevance

/rocksdb-6.9/util/
Dconcurrent_task_limiter_impl.h19 class TaskLimiterToken; variable
43 virtual std::unique_ptr<TaskLimiterToken> GetToken(bool force);
46 friend class TaskLimiterToken;
53 class TaskLimiterToken {
55 explicit TaskLimiterToken(ConcurrentTaskLimiterImpl* limiter) in TaskLimiterToken() function
57 ~TaskLimiterToken();
63 TaskLimiterToken(const TaskLimiterToken&) = delete;
64 void operator=(const TaskLimiterToken&) = delete;
Dconcurrent_task_limiter_impl.cc43 std::unique_ptr<TaskLimiterToken> ConcurrentTaskLimiterImpl::GetToken( in GetToken()
51 return std::unique_ptr<TaskLimiterToken>(new TaskLimiterToken(this)); in GetToken()
62 TaskLimiterToken::~TaskLimiterToken() { in ~TaskLimiterToken()
/rocksdb-6.9/db/db_impl/
Ddb_impl.h73 class TaskLimiterToken; variable
1303 std::unique_ptr<TaskLimiterToken> task_token;
1593 std::unique_ptr<TaskLimiterToken>* token,
1627 std::unique_ptr<TaskLimiterToken>* token, LogBuffer* log_buffer);
Ddb_impl_compaction_flush.cc62 std::unique_ptr<TaskLimiterToken>* token, in RequestCompactionToken()
2087 std::unique_ptr<TaskLimiterToken>* token, LogBuffer* log_buffer) { in PickCompactionFromQueue()
2537 std::unique_ptr<TaskLimiterToken> task_token; in BackgroundCompaction()