Home
last modified time | relevance | path

Searched refs:inCommLabel (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dframe_retainer.cpp126 std::list<FrameInfo> FrameRetainer::FetchFramesForSpecificCommunicator(const LabelType &inCommLabel) in FetchFramesForSpecificCommunicator() argument
130 if (retainWorkPool_.count(inCommLabel) == 0) { in FetchFramesForSpecificCommunicator()
133 auto &perLabel = retainWorkPool_[inCommLabel]; in FetchFramesForSpecificCommunicator()
142 LogRetainInfo("[Retainer][Fetch] FETCH-OUT", inCommLabel, entry.second, entry.first, work); in FetchFramesForSpecificCommunicator()
143 outFrameList.emplace_back(FrameInfo{work.buffer, entry.second, inCommLabel, work.frameId}); in FetchFramesForSpecificCommunicator()
148 retainWorkPool_.erase(inCommLabel); in FetchFramesForSpecificCommunicator()
H A Dprotocol_proto.h88 static int SetDivergeHeader(SerialBuffer *inBuff, const LabelType &inCommLabel);
H A Dprotocol_proto.cpp403 int ProtocolProto::SetDivergeHeader(SerialBuffer *inBuff, const LabelType &inCommLabel) in SetDivergeHeader() argument
420 divergeHeader.commLabel[i] = inCommLabel[i]; in SetDivergeHeader()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dparse_result.h70 void SetCommLabel(const LabelType &inCommLabel) in SetCommLabel() argument
72 commLabel_ = inCommLabel; in SetCommLabel()
H A Dframe_retainer.h58 std::list<FrameInfo> FetchFramesForSpecificCommunicator(const LabelType &inCommLabel);