Home
last modified time | relevance | path

Searched refs:inLabel (Results 1 – 6 of 6) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator_linker.cpp104 int CommunicatorLinker::IncreaseLocalLabel(const LabelType &inLabel, std::set<std::string> &outOnli… in IncreaseLocalLabel() argument
108 localOnlineLabels_.insert(inLabel); in IncreaseLocalLabel()
113 if (entry.second.count(inLabel) != 0) { // This online target had opened then same Label in IncreaseLocalLabel()
123 int CommunicatorLinker::DecreaseLocalLabel(const LabelType &inLabel) in DecreaseLocalLabel() argument
127 localOnlineLabels_.erase(inLabel); in DecreaseLocalLabel()
H A Dcommunicator_linker.h57 int IncreaseLocalLabel(const LabelType &inLabel, std::set<std::string> &outOnlineTarget);
61 int DecreaseLocalLabel(const LabelType &inLabel);
H A Dcommunicator.cpp22 Communicator::Communicator(CommunicatorAggregator *inCommAggregator, const LabelType &inLabel) in Communicator() argument
23 : commAggrHandle_(inCommAggregator), commLabel_(inLabel) in Communicator()
H A Dcommunicator.h33 Communicator(CommunicatorAggregator *inCommAggregator, const LabelType &inLabel);
H A Dprotocol_proto.h66 …static SerialBuffer *BuildFeedbackMessageFrame(const Message *inMsg, const LabelType &inLabel, int…
H A Dprotocol_proto.cpp200 …ialBuffer *ProtocolProto::BuildFeedbackMessageFrame(const Message *inMsg, const LabelType &inLabel, in BuildFeedbackMessageFrame() argument
209 int errCode = ProtocolProto::SetDivergeHeader(buffer, inLabel); in BuildFeedbackMessageFrame()
211 …to][BuildFeedback] Set DivergeHeader fail, label=%.3s, errCode=%d.", VEC_TO_STR(inLabel), errCode); in BuildFeedbackMessageFrame()