Home
last modified time | relevance | path

Searched refs:syncOps (Results 1 - 3 of 3) sorted by relevance

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvstore_sync_manager.cpp75 auto &syncOps = scheduleSyncOps_; in RemoveSyncOperation() local
76 for (auto it = syncOps.begin(); it != syncOps.end();) { in RemoveSyncOperation()
79 it = syncOps.erase(it); in RemoveSyncOperation()
121 bool KvStoreSyncManager::GetTimeoutSyncOps(const TimePoint &currentTime, std::list<KvSyncOperation> &syncOps) in GetTimeoutSyncOps() argument
138 syncOps.push_back(op); in GetTimeoutSyncOps()
161 std::list<KvSyncOperation> syncOps; in Schedule() local
162 bool delaySchedule = GetTimeoutSyncOps(time, syncOps); in Schedule()
164 for (const auto &op : syncOps) { in Schedule()
H A Dkvstore_sync_manager.h65 bool GetTimeoutSyncOps(const TimePoint &currentTime, std::list<KvSyncOperation> &syncOps);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp281 std::list<DistributedKv::KvStoreSyncManager::KvSyncOperation> syncOps; in HWTEST_F() local
285 auto kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps); in HWTEST_F()
288 kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps); in HWTEST_F()
290 syncManager.realtimeSyncingOps_ = syncOps; in HWTEST_F()
292 kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps); in HWTEST_F()
299 kvStatus = syncManager.GetTimeoutSyncOps(currentTime, syncOps); in HWTEST_F()

Completed in 3 milliseconds