Method resetOutput

src/Client/ClientBase.cpp:1817–1888

Flush all buffers.

/// Flush all buffers.
void ClientBase::resetOutput()
{
    if (need_render_progress_table && tty_buf)
    {
        std::unique_lock lock(tty_mutex);
        progress_table.clearTableOutput(*tty_buf, lock);
    }

    /// Order is important: format, compression, file

    try
    {
        if (output_format)
            output_format->finalize();
    }
    catch (...)
    {
        /// We need to make sure we continue resetting output_format (will stop threads on parallel output)
        /// as well as cleaning other output related setup
        if (!have_error)
        {
            client_exception
                = std::make_unique<Exception>(getCurrentExceptionMessageAndPattern(print_stack_trace), getCurrentExceptionCode());
            have_error = true;
        }
    }

    output_format.reset();
    pending_progress.reset();

    /// out_file_buf wraps std_out_wrapper (via a raw pointer), so it must be finalized
    /// first to flush remaining data (e.g. the gzip footer) into std_out_wrapper.
    if (out_file_buf)
    {
        if (out_file_buf->isCanceled())
            out_file_buf.reset();
        else
            out_file_buf->finalize();
    }
    out_file_buf.reset();

    if (std_out_wrapper)
    {
        if (std_out_wrapper->isCanceled())
            std_out_wrapper.reset();
        else
            std_out_wrapper->finalize();
    }
    std_out_wrapper.reset();

    logs_out_stream.reset();

    out_logs_buf.reset();

    if (pager_cmd)
    {
        pager_cmd->in.close();
        /// The process will terminated in destructor anyway (due to terminate_in_destructor_strategy.terminate_in_destructor=true)