Method killAllQueries

src/Interpreters/ProcessList.cpp:741–776

void ProcessList::killAllQueries()
{
    std::vector<std::shared_ptr<QueryStatus>> cancelled_processes;

    SCOPE_EXIT({
        std::lock_guard lock(mutex);
        for (auto & cancelled_process : cancelled_processes)
            cancelled_process->is_cancelling = false;
        cancelled_cv.notify_all();
    });

    {
        std::lock_guard lock(mutex);
        cancelled_processes.reserve(processes.size());
        for (const auto & [user, user_queries] : user_to_queries)
        {
            for (const auto & [query_id, status] : user_queries.queries)
            {
                cancelled_processes.push_back(status);
                status->is_cancelling = true;
            }
        }
    }

    for (auto & cancelled_process : cancelled_processes)
    {
        try
        {
            cancelled_process->cancelQuery(true, false);
        }
        catch (...)
        {
            tryLogCurrentException(__PRETTY_FUNCTION__, "Kill query failed with id: "+ cancelled_process->client_info.current_query_id + "");
        }
    }
}


QueryStatusInfo QueryStatus::getInfo(bool get_thread_list, bool get_profile_events, bool get_settings) const