Method cancelQuery

src/Interpreters/ProcessList.cpp:552–590

}

CancellationCode QueryStatus::cancelQuery(bool kill, bool internal)
{
    UInt8 kill_flag = internal ? INTERNAL_KILL_BIT : EXTERNAL_KILL_BIT;
    {
        std::lock_guard lock(executors_mutex);
        if (!executors.empty())
        {
            if (is_killed.load())
                return CancellationCode::CancelSent;

            is_killed.store(kill_flag);

            for (auto * e : executors)
                e->cancel();

            return CancellationCode::CancelSent;
        }
    }

    /// Streams are destroyed, and ProcessListElement will be deleted from ProcessList soon. We need wait a little bit
    if (streamsAreReleased())
        return CancellationCode::CancelSent;

    BlockInputStreamPtr input_stream;
    BlockOutputStreamPtr output_stream;

    if (tryGetQueryStreams(input_stream, output_stream))
    {
        if (input_stream)
        {
            input_stream->cancel(kill);
            return CancellationCode::CancelSent;
        }
        return CancellationCode::CancelCannotBeSent;
    }
    /// Query is not even started
    is_killed.store(kill_flag);
    return CancellationCode::CancelSent;
}

void QueryStatus::addPipelineExecutor(PipelineExecutor * e)
{