| 1993 | } |
| 1994 | |
| 1995 | Status ImpalaServer::GetAllQueryHandles(const TUniqueId& query_id, |
| 1996 | QueryHandle* active_query_handle, QueryHandle* original_query_handle, |
| 1997 | bool return_unregistered) { |
| 1998 | DCHECK(active_query_handle != nullptr); |
| 1999 | DCHECK(original_query_handle != nullptr); |
| 2000 | shared_ptr<QueryDriver> query_driver = GetQueryDriver(query_id, return_unregistered); |
| 2001 | if (UNLIKELY(query_driver == nullptr)) { |
| 2002 | return GetInterruptedStatus(query_id); |
| 2003 | } |
| 2004 | active_query_handle->SetHandle(query_driver, |
| 2005 | query_driver->GetActiveClientRequestState()); |
| 2006 | original_query_handle->SetHandle(query_driver, |
| 2007 | query_driver->GetClientRequestState(query_id)); |
| 2008 | return Status::OK(); |
| 2009 | } |
| 2010 | |
| 2011 | Status ImpalaServer::CancelInternal(const TUniqueId& query_id) { |
| 2012 | VLOG_QUERY << "Cancel(): query_id=" << PrintId(query_id); |
nothing calls this directly
no test coverage detected