Home
last modified time | relevance | path

Searched refs:delayTimes_ (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_communicator_aggregator.cpp207 … bool isNeedDelay = ((sendDelayTime_ > 0) && (delayTimes_ > 0) && (messageId == delayMessageId_) && in DispatchMessageInner()
309 delayTimes_ = delayTimes; in SetSendDelayInfo()
318 delayTimes_ = 0; in ResetSendDelayInfo()
325 if ((skipTimes_ == 0) && delayTimes_ > 0 && (messageId == delayMessageId_) && in DelayTimeHandle()
327 delayTimes_--; in DelayTimeHandle()
H A Dvirtual_communicator_aggregator.h124 uint32_t delayTimes_ = 0; // ms variable
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_service_impl.cpp195 syncAgent.delayTimes_.erase(storeId); in Delete()
461 value.delayTimes_[storeId] = syncParam.allowedDelayMs; in SetSyncParam()
478 auto it = value.delayTimes_.find(storeId); in GetSyncParam()
479 if (it != value.delayTimes_.end()) { in GetSyncParam()
1231 auto it = agent.delayTimes_.find(storeId); in GetSyncDelayTime()
1232 if (it != agent.delayTimes_.end() && it->second != 0) { in GetSyncDelayTime()
1420 delayTimes_.clear(); in ReInit()
H A Dkvdb_service_impl.h104 std::map<std::string, uint32_t> delayTimes_; member