Method receiveEndOfQueryForInsert

src/Client/ClientBase.cpp:2347–2388

Process Log packets, exit when receive Exception or EndOfStream

/// Process Log packets, exit when receive Exception or EndOfStream
bool ClientBase::receiveEndOfQueryForInsert()
{
    while (true)
    {
        Packet packet = connection->receivePacket();

        switch (packet.type)
        {
            case Protocol::Server::EndOfStream:
                onEndOfStream();
                return true;

            case Protocol::Server::Exception:
                onReceiveExceptionFromServer(std::move(packet.exception));
                /// We cannot be sure that in case of exception all data had been sent to the server
                /// and we either need to send Cancel or disconnect, disconnect is more stable.
                connection->disconnect();
                return false;

            case Protocol::Server::Log:
                onLogData(packet.block);
                break;

            case Protocol::Server::Progress:
                onProgress(packet.progress);
                break;

            case Protocol::Server::ProfileEvents:
                onProfileEvents(packet.block);
                break;

            case Protocol::Server::TimezoneUpdate:
                onTimezoneUpdate(packet.server_timezone);
                break;

            default:
                throw NetException(ErrorCodes::UNEXPECTED_PACKET_FROM_SERVER,
                    "Unexpected packet from server (expected Exception, EndOfStream, Log, Progress or ProfileEvents. Got {})",
                    String(Protocol::Server::toString(packet.type)));
        }
    }
}

bool ClientBase::sendCancel(std::exception_ptr exception_ptr)
{