Home
last modified time | relevance | path

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

/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()
73 uint32_t count = DoRemoveSyncingOp(pred, realtimeSyncingOps_); in RemoveSyncOperation()
124 if ((!realtimeSyncingOps_.empty()) && (!scheduleSyncOps_.empty())) { in GetTimeoutSyncOps()
127 if (currentTime < realtimeSyncingOps_.rbegin()->beginTime + priorSyncingTime) { in GetTimeoutSyncOps()
169 DoCheckSyncingTimeout(realtimeSyncingOps_); in Schedule()
H A Dkvstore_sync_manager.h74 std::list<KvSyncOperation> realtimeSyncingOps_; member in OHOS::DistributedKv::KvStoreSyncManager
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp283 EXPECT_TRUE(syncManager.realtimeSyncingOps_.empty()); in HWTEST_F()
287 syncManager.realtimeSyncingOps_.push_back(syncOp); in HWTEST_F()
290 syncManager.realtimeSyncingOps_ = syncOps; in HWTEST_F()
295 syncManager.realtimeSyncingOps_.push_back(syncOp); in HWTEST_F()
297 EXPECT_TRUE(!syncManager.realtimeSyncingOps_.empty()); in HWTEST_F()

Completed in 3 milliseconds