Method GetGlobalMySQLMaxGTIDList

phxbinlogsvr/core/monitor/base/master_monitor.cpp:67–104

}

int MasterMonitor::GetGlobalMySQLMaxGTIDList(const Option *option, const vector<string> &iplist,
                                             vector<string> *gtid_list) {
    map<string, vector<size_t> > gtid_res;

    for (auto ip : iplist) {
        vector < string > tmp_gtid_list;
        int ret = MonitorComm::GetMySQLMaxGTIDList(option, "gtid_executed", &tmp_gtid_list, ip);
        if (ret) {
            ColorLogError("%s get from ip %s fail", __func__, ip.c_str());
            if (ret == GTID_FAIL && ip == option->GetBinLogSvrConfig()->GetEngineIP()) {
                STATISTICS(MySqlGTIDBroken());
                assert(ret == OK);
            }
            return ret;
        }
        for (auto gtid : tmp_gtid_list) {
            pair < string, size_t > parse_list = GtidHandler::ParseGTID(gtid);
            gtid_res[parse_list.first].push_back(parse_list.second);
            LogVerbose("%s get gtid %s-%u from ip %s", __func__, parse_list.first.c_str(), parse_list.second,
                       ip.c_str());
        }
    }

    for (auto &gtid_check : gtid_res) {
        const vector<size_t> &list = gtid_check.second;
        if (list.size() != iplist.size()) {
            continue;
        }

        size_t max_gtid = (size_t) - 1;
        for (auto gtid : list) {
            max_gtid = std::min(max_gtid, gtid);
        }
        gtid_list->push_back(GtidHandler::GenGTID(gtid_check.first, max_gtid));
    }

    return OK;
}

bool MasterMonitor::IsGTIDCompleted(const vector<string> &excute_gtid_list, const string &max_gtid) {
    pair < string, size_t > max_gtid_pair = GtidHandler::ParseGTID(max_gtid);