Searched refs:KvSyncOperation (Results 1 - 3 of 3) sorted by relevance
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvstore_sync_manager.h | 44 struct KvSyncOperation { struct in OHOS::DistributedKv::KvStoreSyncManager
52 using OpPred = std::function<bool(KvSyncOperation &)>;
62 uint32_t DoRemoveSyncingOp(OpPred pred, std::list<KvSyncOperation> &syncingOps);
63 Status RemoveSyncingOp(uint32_t opSeq, std::list<KvSyncOperation> &syncingOps);
65 bool GetTimeoutSyncOps(const TimePoint ¤tTime, std::list<KvSyncOperation> &syncOps);
66 void DoCheckSyncingTimeout(std::list<KvSyncOperation> &syncingOps);
74 std::list<KvSyncOperation> realtimeSyncingOps_;
75 std::list<KvSyncOperation> delaySyncingOps_;
76 std::multimap<TimePoint, KvSyncOperation> scheduleSyncOps_;
|
| H A D | kvstore_sync_manager.cpp | 40 KvSyncOperation syncOp{ syncId, opSeq, delayMs, syncFunc, endFunc, beginTime }; in AddSyncOperation()
71 auto pred = [syncId](const KvSyncOperation &op) -> bool { return syncId == op.syncId; }; in RemoveSyncOperation()
87 uint32_t KvStoreSyncManager::DoRemoveSyncingOp(OpPred pred, std::list<KvSyncOperation> &syncingOps) in DoRemoveSyncingOp()
101 Status KvStoreSyncManager::RemoveSyncingOp(uint32_t opSeq, std::list<KvSyncOperation> &syncingOps) in RemoveSyncingOp()
104 auto pred = [opSeq](const KvSyncOperation &op) -> bool { return opSeq == op.opSeq; }; in RemoveSyncingOp()
121 bool KvStoreSyncManager::GetTimeoutSyncOps(const TimePoint ¤tTime, std::list<KvSyncOperation> &syncOps) in GetTimeoutSyncOps()
147 void KvStoreSyncManager::DoCheckSyncingTimeout(std::list<KvSyncOperation> &syncingOps) in DoCheckSyncingTimeout()
149 auto syncingTimeoutPred = [](const KvSyncOperation &op) -> bool { in DoCheckSyncingTimeout()
161 std::list<KvSyncOperation> syncOps; in Schedule()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | kvdb_service_test.cpp | 278 DistributedKv::KvStoreSyncManager::KvSyncOperation syncOp;
in HWTEST_F()
281 std::list<DistributedKv::KvStoreSyncManager::KvSyncOperation> syncOps;
in HWTEST_F()
|
Completed in 3 milliseconds