Method SendEvent

phxbinlogsvr/core/agent/data_manager.cpp:49–63

}

int DataManager::SendEvent(const string &oldgtid, const string &newgtid, const string &event_buffer) {
    STATISTICS(MySqlBinlogSend());
    PhxTimer timer;
    if (event_buffer.size() == 0) {
        ColorLogWarning("send event value empty fail");
        return BUFFER_FAIL;
    }
    int ret = event_agent_->SendValue(oldgtid, newgtid, event_buffer);
    if (ret != OK) {
        STATISTICS(MySqlBinlogSendFail());
        ColorLogError("send value fail %d", ret);
    }
    STATISTICS(MySqlSendEventTime(timer.GetTime()));
    return ret;
}

int DataManager::GetLastSendGTID(const string &uuid, string *gtid) {
    STATISTICS(MySqlGetLastGTID());