Method readPayloadImpl

src/Core/MySQL/PacketsConnection.cpp:38–76

}

void Handshake::readPayloadImpl(ReadBuffer & payload)
{
    payload.readStrict(reinterpret_cast<char *>(&protocol_version), 1);
    readNullTerminated(server_version, payload);
    payload.readStrict(reinterpret_cast<char *>(&connection_id), 4);

    auth_plugin_data.resize(AUTH_PLUGIN_DATA_PART_1_LENGTH);
    payload.readStrict(auth_plugin_data.data(), AUTH_PLUGIN_DATA_PART_1_LENGTH);

    payload.ignore(1);
    payload.readStrict(reinterpret_cast<char *>(&capability_flags), 2);
    payload.readStrict(reinterpret_cast<char *>(&character_set), 1);
    payload.readStrict(reinterpret_cast<char *>(&status_flags), 2);
    payload.readStrict((reinterpret_cast<char *>(&capability_flags)) + 2, 2);

    UInt8 auth_plugin_data_length = 0;
    if (capability_flags & Capability::CLIENT_PLUGIN_AUTH)
    {
        payload.readStrict(reinterpret_cast<char *>(&auth_plugin_data_length), 1);
    }
    else
    {
        payload.ignore(1);
    }

    payload.ignore(10);
    if (capability_flags & Capability::CLIENT_SECURE_CONNECTION)
    {
        UInt8 part2_length = (SCRAMBLE_LENGTH - AUTH_PLUGIN_DATA_PART_1_LENGTH);
        auth_plugin_data.resize(SCRAMBLE_LENGTH);
        payload.readStrict(auth_plugin_data.data() + AUTH_PLUGIN_DATA_PART_1_LENGTH, part2_length);
        payload.ignore(1);
    }

    if (capability_flags & Capability::CLIENT_PLUGIN_AUTH)
    {
        readNullTerminated(auth_plugin_name, payload);
    }
}

void Handshake::writePayloadImpl(WriteBuffer & buffer) const
{