| 2135 | } |
| 2136 | |
| 2137 | Status AdmissionController::ResolvePoolAndGetConfig(const TQueryCtx& query_ctx, |
| 2138 | string* pool_name, TPoolConfig* pool_config, TPoolConfig* root_config) { |
| 2139 | RETURN_IF_ERROR(request_pool_service_->ResolveRequestPool(query_ctx, pool_name)); |
| 2140 | DCHECK_EQ(query_ctx.request_pool, *pool_name); |
| 2141 | RETURN_IF_ERROR(request_pool_service_->GetPoolConfig(*pool_name, pool_config)); |
| 2142 | return request_pool_service_->GetPoolConfig(ROOT_POOL, root_config); |
| 2143 | } |
| 2144 | |
| 2145 | // Statestore subscriber callback for IMPALA_REQUEST_QUEUE_TOPIC. |
| 2146 | void AdmissionController::UpdatePoolStats( |
nothing calls this directly
no test coverage detected