Method DoRun

phxqueue/store/keepsyncthread.cpp:79–109

}

void KeepSyncThread::DoRun() {
    if (!impl_->store) {
        return;
    }

    const int ngroup = impl_->store->GetStoreOption()->ngroup;
    impl_->next_make_cp_times.reset(new time_t[ngroup]);
    impl_->next_sync_times.reset(new time_t[ngroup]);
    for (int i{0}; i < ngroup; ++i) {
        impl_->next_make_cp_times[i] = 0;
        impl_->next_sync_times[i] = 0;
    }

    while (1) {
        if (impl_->stop) return;

        sleep(1);

        ClearSyncCtrl();

        MakeCheckPoint();

        SyncCursorID();

        Replay();

        ReportBacklog();

        ReportDelayStat();
    }
}

void KeepSyncThread::ClearSyncCtrl() {
    QLVerb("KeepSyncThread::ClearSyncCtrl");