MCPcopy Create free account
hub / github.com/apache/kudu / QueueOverloaded

Method QueueOverloaded

src/kudu/util/threadpool.cc:419–428  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

417}
418
419bool ThreadPool::QueueOverloaded(MonoDelta* overloaded_time,
420 MonoDelta* threshold) const {
421 if (!load_meter_) {
422 return false;
423 }
424 if (threshold) {
425 *threshold = load_meter_->queue_time_threshold();
426 }
427 return load_meter_->overloaded(overloaded_time);
428}
429
430void ThreadPool::ReleaseToken(ThreadPoolToken* t) {
431 std::lock_guard guard(lock_);

Callers 2

WriteMethod · 0.80
TEST_FFunction · 0.80

Calls 1

overloadedMethod · 0.80

Tested by 1

TEST_FFunction · 0.64