| 483 | } |
| 484 | |
| 485 | void Coordinator::BackendState::LogFirstInProgress( |
| 486 | std::vector<Coordinator::BackendState*> backend_states) { |
| 487 | for (Coordinator::BackendState* backend_state : backend_states) { |
| 488 | if (!backend_state->IsDone()) { |
| 489 | VLOG_QUERY << "query_id=" << PrintId(backend_state->query_id_) |
| 490 | << ": first in-progress backend: " << backend_state->impalad_address(); |
| 491 | break; |
| 492 | } |
| 493 | } |
| 494 | } |
| 495 | |
| 496 | bool Coordinator::BackendState::IsDone() { |
| 497 | unique_lock<mutex> lock(lock_); |