Searched refs:opSeq (Results 1 - 2 of 2) sorted by relevance
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvstore_sync_manager.cpp | 30 uint32_t opSeq = ++syncOpSeq_; in AddSyncOperation() local
33 endFunc = [opSeq, delayMs, syncEnd, this](const std::map<std::string, DistributedDB::DBStatus> &devices) { in AddSyncOperation()
34 RemoveSyncingOp(opSeq, (delayMs == 0) ? realtimeSyncingOps_ : delaySyncingOps_); in AddSyncOperation()
40 KvSyncOperation syncOp{ syncId, opSeq, delayMs, syncFunc, endFunc, beginTime }; in AddSyncOperation()
48 RemoveSyncingOp(opSeq, realtimeSyncingOps_); in AddSyncOperation()
55 ZLOGD("add op %u delay %u count %zu.", opSeq, delayMs, scheduleSyncOps_.size()); in AddSyncOperation()
101 Status KvStoreSyncManager::RemoveSyncingOp(uint32_t opSeq, std::list<KvSyncOperation> &syncingOps) in RemoveSyncingOp() argument
103 ZLOGD("remove op %u", opSeq); in RemoveSyncingOp()
104 auto pred = [opSeq](const KvSyncOperation &op) -> bool { return opSeq in RemoveSyncingOp()
[all...] |
| H A D | kvstore_sync_manager.h | 46 uint32_t opSeq = 0; member
63 Status RemoveSyncingOp(uint32_t opSeq, std::list<KvSyncOperation> &syncingOps);
|
Completed in 2 milliseconds