Method DelCheckPointFile

phxbinlogsvr/core/storage/event_storage.cpp:317–350

}

int EventStorage::DelCheckPointFile(const string &maxfilename, const uint32_t &mintime, vector<string> *delfiles) {
    EventFileManager eventfilemanager(option_, true);
    int ret = eventfilemanager.DelCheckPointFile(maxfilename, mintime, delfiles);
    LogVerbose("%s del check point size %zu", __func__, delfiles->size());
    if (ret == 0) {
        for (auto file_name = delfiles->begin(); file_name != delfiles->end(); ++file_name) {
            EventDataInfo info;
            info.set_file_name(*file_name);
            info.set_offset(0);
            int ret = eventfilemanager.SetReadPos(info);
            if (ret) {
                return ret;
            }
            while (true) {
                EventData data;
                ret = eventfilemanager.ReadDataFromFile(&data);
                if (ret == DATA_EMPTY) {
                    break;
                }
                if (ret == DATA_ERR) {
                    break;
                }
                if (data.gtid().size()) {
                    event_index_status status = event_index_->DeleteGTIDIndex(data.gtid());
                    if (status != event_index_status::OK) {
                        return FILE_FAIL;
                    }
                }
            }
            RemoveFile(*file_name);
        }
    }
    return OK;
}

int EventStorage::CheckGtidInData(const string &gtid, const EventDataInfo &data_info) {
    int ret = OK;