Method CountCheckSum

phxbinlogsvr/core/repl/replication_transfer.cpp:125–165

}

void ReplicationTransfer::CountCheckSum(const vector<string> &event_list, const string &max_gtid) {
    LogVerbose("%s count check sum %llu, event size %zu", __func__, checksum_, event_list.size());
    if (checksum_ == 0) {
        EventDataInfo info;
        event_manager_->GetGTIDInfo(max_gtid, &info);
        checksum_ = info.checksum();
        LogVerbose("%s get data check sum %llu for init", __func__, checksum_);
    } else {
        vector < size_t > checksum_for_log;
        checksum_for_log.push_back(checksum_);
        size_t datasize = 0;
        size_t header_size = GtidHandler::GetEventHeaderSize();
        for (size_t i = 0; i < event_list.size(); ++i) {
            checksum_ = Utils::GetCheckSum(checksum_, event_list[i].c_str() + header_size,
                                           event_list[i].size() - header_size);
            datasize += event_list[i].size() - header_size;
            checksum_for_log.push_back(checksum_);
        }

        EventDataInfo info;
        int ret = event_manager_->GetGTIDInfo(max_gtid, &info);
        if (ret) {
            ColorLogError("%s get gtid data %s info fail", __func__, max_gtid.c_str());
            assert(ret == 0);
            return;
        }

        ColorLogInfo("%s get data check sum %llu, max gtid %s, gtid check sum %llu data size %zu", __func__, checksum_,
                    max_gtid.c_str(), info.checksum(), datasize);

        if (checksum_ != info.checksum()) {
            ColorLogError("%s get data check sum %llu, check fail, should be %llu", __func__, checksum_,
                           info.checksum());
            for (size_t i = 0; i < checksum_for_log.size(); ++i)
                ColorLogError("%s get check sum %llu", __func__, checksum_for_log[i]);
            checksum_for_log.push_back(checksum_);
            STATISTICS(ReplCheckSumFail());
            assert(checksum_ == info.checksum());
        }
    }
}

}