| 1548 | } |
| 1549 | |
| 1550 | void Coordinator::ReleaseBackendAdmissionControlResources( |
| 1551 | const vector<BackendState*>& backend_states) { |
| 1552 | AdmissionControlClient* admission_control_client = |
| 1553 | parent_request_state_->admission_control_client(); |
| 1554 | DCHECK(admission_control_client != nullptr); |
| 1555 | vector<NetworkAddressPB> host_addrs; |
| 1556 | host_addrs.reserve(backend_states.size()); |
| 1557 | for (auto backend_state : backend_states) { |
| 1558 | host_addrs.push_back(backend_state->impalad_address()); |
| 1559 | } |
| 1560 | admission_control_client->ReleaseQueryBackends(host_addrs); |
| 1561 | } |
| 1562 | |
| 1563 | Coordinator::ResourceUtilization Coordinator::ComputeQueryResourceUtilization() { |
| 1564 | DCHECK(exec_rpcs_complete_.Load()) << "Exec() must be called first"; |
nothing calls this directly
no test coverage detected