MCPcopy Create free account
hub / github.com/apache/impala / ReleaseThreadToken

Method ReleaseThreadToken

be/src/runtime/fragment-instance-state.cc:649–659  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

647}
648
649void FragmentInstanceState::ReleaseThreadToken() {
650 DCHECK(runtime_state_ != nullptr);
651 DCHECK(runtime_state_->resource_pool() != nullptr);
652 runtime_state_->resource_pool()->ReleaseThreadToken(true);
653 if (avg_thread_tokens_ != nullptr) {
654 PeriodicCounterUpdater::StopSamplingCounter(avg_thread_tokens_);
655 }
656 if (thread_usage_sampled_counter_ != nullptr) {
657 PeriodicCounterUpdater::StopTimeSeriesCounter(thread_usage_sampled_counter_);
658 }
659}
660
661Status FragmentInstanceState::WaitForOpen() {
662 return opened_promise_.Get();

Callers

nothing calls this directly

Calls 1

resource_poolMethod · 0.80

Tested by

no test coverage detected