| 2088 | } |
| 2089 | |
| 2090 | void ClientRequestState::UpdateExecState(ExecState exec_state) { |
| 2091 | { |
| 2092 | lock_guard<mutex> l(exec_state_lock_); |
| 2093 | exec_state_.Store(exec_state); |
| 2094 | summary_profile_->AddInfoString("Query State", PrintValue(BeeswaxQueryState())); |
| 2095 | summary_profile_->AddInfoString("Impala Query State", ExecStateToString(exec_state)); |
| 2096 | } |
| 2097 | // Drop exec_state_lock_ before signalling |
| 2098 | exec_state_cv_.NotifyAll(); |
| 2099 | } |
| 2100 | |
| 2101 | void ClientRequestState::WaitForCompletionExecState() { |
| 2102 | if (query_options().long_polling_time_ms <= 0) return; |
nothing calls this directly
no test coverage detected