| 1119 | } |
| 1120 | |
| 1121 | void Coordinator::CancelBackends(bool fire_and_forget) { |
| 1122 | int num_cancelled = 0; |
| 1123 | for (BackendState* backend_state: backend_states_) { |
| 1124 | DCHECK(backend_state != nullptr); |
| 1125 | BackendState::CancelResult cr = backend_state->Cancel(fire_and_forget); |
| 1126 | if (cr.cancel_attempted) ++num_cancelled; |
| 1127 | if (!fire_and_forget && cr.became_done) backend_exec_complete_barrier_->Notify(); |
| 1128 | } |
| 1129 | if (fire_and_forget) backend_exec_complete_barrier_->NotifyRemaining(); |
| 1130 | VLOG_QUERY << Substitute( |
| 1131 | "CancelBackends() query_id=$0, tried to cancel $1 backends", |
| 1132 | PrintId(query_id()), num_cancelled); |
| 1133 | } |
| 1134 | |
| 1135 | Status Coordinator::UpdateBackendExecStatus(const ReportExecStatusRequestPB& request, |
| 1136 | const TRuntimeProfileForest& thrift_profiles) { |
nothing calls this directly
no test coverage detected