Method CheckRunningStatus

phxbinlogsvr/core/handler/event_monitor.cpp:46–83

}

int EventMonitor::CheckRunningStatus() {
    int ret = OK;
    vector < string > gtid_list;
    if (option_->GetBinLogSvrConfig()->IsForceMakingCheckPoint()) {
        ret = MasterMonitor::GetMySQLMaxGTIDList(option_, &gtid_list,master_manager_->IsMaster());
    } else {
        vector < string > member_iplist;
        master_manager_->GetMemberIPList(&member_iplist);

        ret = MasterMonitor::GetGlobalMySQLMaxGTIDList(option_, member_iplist, &gtid_list);
    }

    LogVerbose("%s get gtid list ret %d", __func__, ret);
    if (ret == OK) {
        ret = storage_manager_->MakeCheckPoint(gtid_list);

        uint64_t max_instanceid = 0;
        EventStorage *event_storage = storage_manager_->GetEventStorage();
        for (const auto &gtid : gtid_list) {
            EventDataInfo data_info;
            int ret = event_storage->GetGTIDInfo(gtid, &data_info, true);
            if (ret) {
                continue;
            }
            max_instanceid = std::max(max_instanceid, (uint64_t) data_info.instance_id());
        }

        uint64_t storage_instanceid = event_storage->GetLastInstanceID();
        ColorLogInfo("%s current mysql instanceid %lu, binlog svr instanceid %lu", __func__, max_instanceid,
                     storage_instanceid);

        if (max_instanceid && max_instanceid <= storage_instanceid) {
            STATISTICS(MySqlGtidNumDiff(storage_instanceid - max_instanceid));
        }
    }

    return ret;
}

int EventMonitor::Process() {
    while (!stop_) {