Method PraseCommand

phxbinlogsvr/core/repl/replication_slave.cpp:295–341

}

int ReplicationSlave::PraseCommand(char *buffer, const size_t &size) {
    if (IsQuerryEnd(buffer, size)) {
        return 0;
    }

    vector < pair<char *, uint8_t> > fields;

    char *pos = buffer;
    const char *end = buffer + size;
    while (pos < end) {
        uint8_t len = *(uint8_t *) pos;
        pos++;
        if (pos + len > end)
            break;
        string get_buffer = string(pos, len);
        fields.push_back(make_pair(pos, len));
        pos += len;
    }

    for (size_t i = 0; i < fields.size(); ++i) {
        LogVerbose("%s get field len %d value %s", __func__, fields[i].second,
                   string(fields[i].first, fields[i].second).c_str());
        if (i == 1) {
            string old_value;
            if (ReWriteCommand(fields[i - 1].first, fields[i - 1].second, fields[i].first, fields[i].second,
                               "server_id", &old_value)) {
                uint32_t my_svrid = ctx_->GetOption()->GetBinLogSvrConfig()->GetEngineSvrID();

                uint32_t pkg_svrid = 0;
                for (uint8_t j = 0; j < old_value.size(); ++j) {
                    pkg_svrid = pkg_svrid * 10 + old_value[j] - '0';
                }
                if (pkg_svrid != my_svrid) {
                    ColorLogWarning("svr id conflit, mysql svr %d, agent svr id %d", pkg_svrid, my_svrid);
                    return SVR_ID_CONFIT;
                }

                string new_value = string(fields[i].first, fields[i].second);
                LogVerbose("%s old value %s new value %s", __func__, old_value.c_str(), new_value.c_str());
            } else
                ReWriteCommand(fields[i - 1].first, fields[i - 1].second, fields[i].first, fields[i].second,
                               "server_uuid", &old_value);
        }
    }

    return 0;
}

int ReplicationSlave::DealWithEvent(vector<string> &send_buffer) {
    string recv_buff;