| 1978 | } |
| 1979 | |
| 1980 | Status ImpalaServer::GetQueryHandle( |
| 1981 | const TUniqueId& query_id, QueryHandle* query_handle, bool return_unregistered) { |
| 1982 | DCHECK(query_handle != nullptr); |
| 1983 | shared_ptr<QueryDriver> query_driver = GetQueryDriver(query_id, return_unregistered); |
| 1984 | if (UNLIKELY(query_driver == nullptr)) { |
| 1985 | return GetInterruptedStatus(query_id); |
| 1986 | } |
| 1987 | ClientRequestState* request_state = query_driver->GetClientRequestState(query_id); |
| 1988 | if (UNLIKELY(request_state == nullptr)) { |
| 1989 | return GetInterruptedStatus(query_id); |
| 1990 | } |
| 1991 | query_handle->SetHandle(query_driver, request_state); |
| 1992 | return Status::OK(); |
| 1993 | } |
| 1994 | |
| 1995 | Status ImpalaServer::GetAllQueryHandles(const TUniqueId& query_id, |
| 1996 | QueryHandle* active_query_handle, QueryHandle* original_query_handle, |
no test coverage detected