| 3290 | } |
| 3291 | |
| 3292 | void ImpalaServer::ExpireQuery(ClientRequestState* crs, const Status& status, |
| 3293 | bool unregister) { |
| 3294 | DCHECK(!status.ok()); |
| 3295 | cancellation_thread_pool_->Offer( |
| 3296 | CancellationWork::TerminatedByServer(crs->query_id(), status, unregister)); |
| 3297 | if (crs->is_expired()) { |
| 3298 | // Should only be re-entrant if we're now unregistering the query. |
| 3299 | DCHECK(unregister); |
| 3300 | } else { |
| 3301 | ImpaladMetrics::NUM_QUERIES_EXPIRED->Increment(1L); |
| 3302 | crs->set_expired(); |
| 3303 | } |
| 3304 | } |
| 3305 | |
| 3306 | Status ImpalaServer::Start(int32_t beeswax_port, int32_t hs2_port, |
| 3307 | int32_t hs2_http_port, int32_t external_fe_port) { |
nothing calls this directly
no test coverage detected