Searched refs:syncOps (Results 1 – 3 of 3) sorted by relevance
77 auto &syncOps = scheduleSyncOps_; in RemoveSyncOperation() local78 for (auto it = syncOps.begin(); it != syncOps.end();) { in RemoveSyncOperation()81 it = syncOps.erase(it); in RemoveSyncOperation()124 …reSyncManager::GetTimeoutSyncOps(const TimePoint ¤tTime, std::list<KvSyncOperation> &syncOps) in GetTimeoutSyncOps() argument142 syncOps.push_back(op); in GetTimeoutSyncOps()166 std::list<KvSyncOperation> syncOps; in Schedule() local167 bool delaySchedule = GetTimeoutSyncOps(time, syncOps); in Schedule()169 for (const auto &op : syncOps) { in Schedule()
65 bool GetTimeoutSyncOps(const TimePoint ¤tTime, std::list<KvSyncOperation> &syncOps);
280 std::list<DistributedKv::KvStoreSyncManager::KvSyncOperation> syncOps; variable284 auto kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps);287 kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps);289 syncManager.realtimeSyncingOps_ = syncOps;291 kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps);298 kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps);