Method receivePacket

src/Client/Connection.cpp:1377–1486

}

Packet Connection::receivePacket()
{
    try
    {
        ensureConnected();

        Packet res;

        /// Have we already read packet type?
        if (last_input_packet_type)
        {
            res.type = *last_input_packet_type;
            last_input_packet_type.reset();
        }
        else
        {
            readVarUInt(res.type, *in);
        }

        switch (res.type)
        {
            case Protocol::Server::Data:
            case Protocol::Server::Totals:
            case Protocol::Server::Extremes:
                res.block = receiveData();
                return res;

            case Protocol::Server::Exception:
                res.exception = receiveException();
                return res;

            case Protocol::Server::Progress:
                res.progress = receiveProgress();
                return res;

            case Protocol::Server::ProfileInfo:
                res.profile_info = receiveProfileInfo();
                return res;

            case Protocol::Server::Log:
                res.block = receiveLogData();
                return res;

            case Protocol::Server::TableColumns:
                res.columns_description = receiveTableColumns();
                return res;

            case Protocol::Server::EndOfStream:
                return res;

            case Protocol::Server::PartUUIDs:
            {
                // allow_experimental_query_deduplication is no longer supported, but an old server
                // may still send this packet. Skip the obsolete, peer-controlled payload without
                // materializing it (do not resize a vector to a peer-chosen size).
                UInt64 num_part_uuids = 0;
                readVarUInt(num_part_uuids, *in);
                if (num_part_uuids > DEFAULT_MAX_STRING_SIZE)