Method GetEvents

phxbinlogsvr/core/handler/event_manager.cpp:101–128

}

int EventManager::GetEvents(string *data, uint32_t want_num) {
    if (want_num == 0) {
        want_num = option_->GetBinLogSvrConfig()->GetMaxEventCountToPush();
    }

    size_t get_num = 0;
    int ret = OK;
    while (get_num < want_num) {
        EventData event_data;
        ret = event_storage_->GetEvent(&event_data, get_num == 0);
        if (ret) {
            if (ret == EVENT_EMPTY) {
                if (get_num == 0) {
                    ColorLogInfo("%s no data", __func__);
                } else {
                    ret = OK;
                    break;
                }
            }
            break;
        }
        LogVerbose("get event %s data size %zu", event_data.gtid().c_str(), event_data.data().size());
        if (event_data.data().size() > 0)
            data->append(event_data.data());
        ++get_num;
    }
    return ret;
}

void EventManager::Notify() {
    event_storage_->Notify();