Home
last modified time | relevance | path

Searched refs:waitAckSeq_ (Results 1 – 2 of 2) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator_linker.cpp187 if (waitAckSeq_.count(inTarget) == 0) { in ReceiveLabelExchangeAck()
191 if (waitAckSeq_[inTarget] < inSequenceId) { in ReceiveLabelExchangeAck()
193 ULL(inSequenceId), ULL(waitAckSeq_[inTarget])); in ReceiveLabelExchangeAck()
309 if (waitAckSeq_.count(toTarget) == 0) { in TriggerLabelExchangeEvent()
311 waitAckSeq_[toTarget] = sequenceId; in TriggerLabelExchangeEvent()
312 } else if (waitAckSeq_[toTarget] > sequenceId) { in TriggerLabelExchangeEvent()
315 …" be triggered for target=%s{private}", ULL(waitAckSeq_[toTarget]), ULL(sequenceId), toTarget.c_st… in TriggerLabelExchangeEvent()
320 waitAckSeq_[toTarget] = sequenceId; in TriggerLabelExchangeEvent()
373 if (waitAckSeq_[toTarget] > inSequenceId) { in SendLabelExchange()
384 …ULL(waitAckSeq_[toTarget]), ULL((recvAckSeq_.count(toTarget) != 0) ? recvAckSeq_[toTarget] : ~ULL(… in SendLabelExchange()
H A Dcommunicator_linker.h111 std::map<std::string, uint64_t> waitAckSeq_; variable