Method CheckAndSwitchFile

phxbinlogsvr/core/storage/event_storage.cpp:549–566

}

int EventStorage::CheckAndSwitchFile(bool force) {
    EventDataInfo data_info;
    event_file_manager_->GetWriteFileInfo(&data_info);
    if (!force || data_info.offset() > option_->GetBinLogSvrConfig()->GetMaxEventFileSize()) {
        STATISTICS(GtidEventSwitchDataFile());
        ColorLogInfo("%s file %s size %zu has full, max size %zu, switch", __func__,
                            data_info.file_name().c_str(), data_info.offset(),
                            option_->GetBinLogSvrConfig()->GetMaxEventFileSize());

        EventData event_headerdata;
        int ret = GetFileHeader(&event_headerdata, &data_info);
        if (ret == 0) {
            ret = EventStorage::SwitchNewFile(event_headerdata);
        }
        return ret;
    }
    return OK;
}

void EventStorage::Notify() {
    pthread_cond_broadcast(&cond_);