Home
last modified time | relevance | path

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

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvstore_sync_manager.cpp54 scheduleSyncOps_.emplace(beginTime, syncOp); in AddSyncOperation()
55 ZLOGD("add op %u delay %u count %zu.", opSeq, delayMs, scheduleSyncOps_.size()); in AddSyncOperation()
56 if ((scheduleSyncOps_.size() == 1) || in AddSyncOperation()
75 auto &syncOps = scheduleSyncOps_; in RemoveSyncOperation()
124 if ((!realtimeSyncingOps_.empty()) && (!scheduleSyncOps_.empty())) { in GetTimeoutSyncOps()
131 for (auto it = scheduleSyncOps_.begin(); it != scheduleSyncOps_.end();) { in GetTimeoutSyncOps()
142 it = scheduleSyncOps_.erase(it); in GetTimeoutSyncOps()
171 if (!scheduleSyncOps_.empty()) { in Schedule()
172 auto nextTime = scheduleSyncOps_ in Schedule()
[all...]
H A Dkvstore_sync_manager.h76 std::multimap<TimePoint, KvSyncOperation> scheduleSyncOps_; member in OHOS::DistributedKv::KvStoreSyncManager
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp284 EXPECT_TRUE(syncManager.scheduleSyncOps_.empty()); in HWTEST_F()
291 syncManager.scheduleSyncOps_.insert(std::make_pair(syncOp.beginTime, syncOp)); in HWTEST_F()
296 syncManager.scheduleSyncOps_.insert(std::make_pair(syncOp.beginTime, syncOp)); in HWTEST_F()
298 EXPECT_TRUE(!syncManager.scheduleSyncOps_.empty()); in HWTEST_F()

Completed in 2 milliseconds