| 3627 | } |
| 3628 | |
| 3629 | void ImpalaServer::UpdateFilter(UpdateFilterResultPB* result, |
| 3630 | const UpdateFilterParamsPB& params, RpcContext* context) { |
| 3631 | DCHECK(params.has_query_id()); |
| 3632 | DCHECK(params.has_filter_id()); |
| 3633 | QueryHandle query_handle; |
| 3634 | Status status = GetQueryHandle(ProtoToQueryId(params.query_id()), &query_handle); |
| 3635 | if (!status.ok()) { |
| 3636 | LOG(INFO) << "Could not find query handle for query id: " |
| 3637 | << PrintId(ProtoToQueryId(params.query_id())); |
| 3638 | return; |
| 3639 | } |
| 3640 | ClientRequestState::RetryState retry_state = query_handle->retry_state(); |
| 3641 | if (retry_state != ClientRequestState::RetryState::RETRYING |
| 3642 | && retry_state != ClientRequestState::RetryState::RETRIED) { |
| 3643 | query_handle->UpdateFilter(params, context); |
| 3644 | } |
| 3645 | } |
| 3646 | |
| 3647 | Status ImpalaServer::CheckNotShuttingDown() const { |
| 3648 | if (!IsShuttingDown()) return Status::OK(); |
nothing calls this directly
no test coverage detected