Method MasterInit

phxbinlogsvr/core/monitor/agent_monitor.cpp:209–258

}

int AgentMonitor::MasterInit() {
    MasterInfo master_info;
    int ret = master_manager_->GetMasterInfo(&master_info);
    if (ret) {
        return ret;
    }

    LogVerbose("%s master info %u version %u", __func__, master_info.svr_id(), master_info.version());

    if (master_info.svr_id() == option_->GetBinLogSvrConfig()->GetEngineSvrID()
            && !master_manager_->IsTimeOut(master_info)) {
        if (!init_) {
            //do not check root privilege beacuse its readonly option has not been set
            //after master has beed started, check again
            ret = MasterMonitor::CheckMasterInit(option_);
            if (ret == OK) {
                if (!MasterMonitor::IsMySqlInit(option_)) {
                    MySqlManager * mysql_manager = MySqlManager::GetGlobalMySqlManager(option_);
                    string current_admin_username = mysql_manager->GetAdminUserName();
                    string current_admin_pwd = mysql_manager->GetAdminPwd();
                    if (current_admin_username == "") {
                        ret = master_agent_->SetMySqlAdminInfo("", "", "root", "");

                        if (ret) {
                            ColorLogError("%s master set admin info failed ", __func__);
                            return ret;
                        }
                    }

                    string current_replica_username = mysql_manager->GetReplicaUserName();
                    string current_replica_pwd = mysql_manager->GetReplicaPwd();
                    if (current_replica_username == "") {
                        ret = master_agent_->SetMySqlReplicaInfo("", "", "replica", "replica123");
                        if (ret) {
                            ColorLogError("%s master set replica info failed ", __func__);
                            return ret;
                        }
                    }
                    init_ = true;
                }
                LogVerbose("%s master init done, version %u", __func__, master_info.version());
            }
        } else
            LogVerbose("%s master init has done, version %u, skip check init", __func__, master_info.version());
    } else {
        LogVerbose("%s i'm not master, skip check init", __func__);
    }

    return ret;
}

int AgentMonitor::CheckMasterInit() {
    int ret = OK;