Method CollectQueriesToCancel

be/src/runtime/query-exec-mgr.cc:228–239

}

void QueryExecMgr::CollectQueriesToCancel(std::function<bool(QueryState*)> filter,
    bool is_coord_active, vector<QueryExecMgr::QueryCancellationTask>* to_cancel) {
  DCHECK(to_cancel != nullptr);
  ExecEnv::GetInstance()->query_exec_mgr()->qs_map_.DoFuncForAllEntries(
      [&](QueryState* qs) {
        if (qs != nullptr && !qs->IsCancelled() && filter(qs)) {
          // decremented by ReleaseQueryState()
          AcquireQueryStateLocked(qs);
          to_cancel->push_back(QueryCancellationTask(qs, is_coord_active));
        }
      });
}

void QueryExecMgr::CancelQueries(const QueryCancellationTask& to_cancel) {
  QueryState* qs = to_cancel.GetQueryState();