Home
last modified time | relevance | path

Searched refs:ConcurrentTaskLimiterImpl (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/util/
Dconcurrent_task_limiter_impl.cc15 ConcurrentTaskLimiterImpl::ConcurrentTaskLimiterImpl( in ConcurrentTaskLimiterImpl() function in ROCKSDB_NAMESPACE::ConcurrentTaskLimiterImpl
23 ConcurrentTaskLimiterImpl::~ConcurrentTaskLimiterImpl() { in ~ConcurrentTaskLimiterImpl()
27 const std::string& ConcurrentTaskLimiterImpl::GetName() const { in GetName()
31 void ConcurrentTaskLimiterImpl::SetMaxOutstandingTask(int32_t limit) { in SetMaxOutstandingTask()
35 void ConcurrentTaskLimiterImpl::ResetMaxOutstandingTask() { in ResetMaxOutstandingTask()
39 int32_t ConcurrentTaskLimiterImpl::GetOutstandingTask() const { in GetOutstandingTask()
43 std::unique_ptr<TaskLimiterToken> ConcurrentTaskLimiterImpl::GetToken( in GetToken()
59 return new ConcurrentTaskLimiterImpl(name, limit); in NewConcurrentTaskLimiter()
Dconcurrent_task_limiter_impl.h21 class ConcurrentTaskLimiterImpl : public ConcurrentTaskLimiter {
23 explicit ConcurrentTaskLimiterImpl(const std::string& name,
26 ConcurrentTaskLimiterImpl(const ConcurrentTaskLimiterImpl&) = delete;
27 ConcurrentTaskLimiterImpl& operator=(const ConcurrentTaskLimiterImpl&) =
30 virtual ~ConcurrentTaskLimiterImpl();
55 explicit TaskLimiterToken(ConcurrentTaskLimiterImpl* limiter) in TaskLimiterToken()
60 ConcurrentTaskLimiterImpl* limiter_;
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc65 auto limiter = static_cast<ConcurrentTaskLimiterImpl*>( in RequestCompactionToken()