Home
last modified time | relevance | path

Searched refs:realtimeSyncingOps_ (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvstore_sync_manager.cpp34 RemoveSyncingOp(opSeq, (delayMs == 0) ? realtimeSyncingOps_ : delaySyncingOps_); in AddSyncOperation()
44 realtimeSyncingOps_.push_back(syncOp); in AddSyncOperation()
48 RemoveSyncingOp(opSeq, realtimeSyncingOps_); in AddSyncOperation()
74 uint32_t count = DoRemoveSyncingOp(pred, realtimeSyncingOps_); in RemoveSyncOperation()
127 if ((!realtimeSyncingOps_.empty()) && (!scheduleSyncOps_.empty())) { in GetTimeoutSyncOps()
130 if (currentTime < realtimeSyncingOps_.rbegin()->beginTime + priorSyncingTime) { in GetTimeoutSyncOps()
174 DoCheckSyncingTimeout(realtimeSyncingOps_); in Schedule()
H A Dkvstore_sync_manager.h74 std::list<KvSyncOperation> realtimeSyncingOps_; variable
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp282 EXPECT_TRUE(syncManager.realtimeSyncingOps_.empty());
286 syncManager.realtimeSyncingOps_.push_back(syncOp);
289 syncManager.realtimeSyncingOps_ = syncOps;
294 syncManager.realtimeSyncingOps_.push_back(syncOp);
296 EXPECT_TRUE(!syncManager.realtimeSyncingOps_.empty());