Method CheckMasterTimeOut

phxbinlogsvr/core/monitor/agent_monitor.cpp:325–353

}

int AgentMonitor::CheckMasterTimeOut() {
    bool is_master = master_manager_->CheckMasterBySvrID(option_->GetBinLogSvrConfig()->GetEngineSvrID());
    int ret = OK;
    if(!is_master) {
        ret=IsGTIDCompleted(option_, event_manager_);
        if (ret < 0) {
            return ret;
        }
    }
    
    if (!AgentExternalMonitor::IsHealthy()) {
        ColorLogWarning("%s external monitor not healthy", __func__);
        return SVR_FAIL;
    }

    if (ret == OK) {
        int ret = master_agent_->SetMaster(option_->GetBinLogSvrConfig()->GetEngineIP());
        if (ret == MASTER_CONFLICT) {
            LogVerbose("%s master info does not timeout, skip", __func__);
        } else {
            LogVerbose("%s set new master info, ret %d", __func__, ret);
        }
        return OK;
    } else {
        ColorLogInfo("%s master info not complated, skip, just check slave status", __func__);
        return CheckSlaveRunningStatus();
    }
    return ret;
}

int AgentMonitor::CheckSlaveRunningStatus() {
    if (IsSlaveReady()) {