Searched refs:toTarget (Results 1 – 2 of 2) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_linker.cpp | 309 if (waitAckSeq_.count(toTarget) == 0) { in TriggerLabelExchangeEvent()
311 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()
343 ackTriggerId_[toTarget] = ackId; in TriggerLabelExchangeAckEvent()
373 if (waitAckSeq_[toTarget] > inSequenceId) { in SendLabelExchange()
377 if (recvAckSeq_.count(toTarget) != 0 && recvAckSeq_[toTarget] >= inSequenceId) { in SendLabelExchange()
384 …ULL(waitAckSeq_[toTarget]), ULL((recvAckSeq_.count(toTarget) != 0) ? recvAckSeq_[toTarget] : ~ULL(… in SendLabelExchange()
408 toTarget.c_str(), ULL(inSequenceId)); in SendLabelExchange()
431 if (topRecvLabelSeq_.count(toTarget) != 0 && topRecvLabelSeq_[toTarget] > inSequenceId) { in SendLabelExchangeAck()
[all …]
|
| H A D | communicator_linker.h | 89 int TriggerLabelExchangeEvent(const std::string &toTarget);
90 int TriggerLabelExchangeAckEvent(const std::string &toTarget, uint64_t inSequenceId);
92 void SendLabelExchange(const std::string &toTarget, SerialBuffer *inBuff, uint64_t inSequenceId,
94 …void SendLabelExchangeAck(const std::string &toTarget, SerialBuffer *inBuff, uint64_t inSequenceId,
|