Searched refs:extendHandle (Results 1 – 4 of 4) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator.cpp | 109 std::shared_ptr<ExtendHeaderHandle> extendHandle = nullptr; in SendMessage() local
111 extendHandle = commAggrHandle_->GetExtendHeaderHandle(config.paramInfo); in SendMessage()
112 if (extendHandle == nullptr) { in SendMessage()
119 SerialBuffer *buffer = ProtocolProto::ToSerialBuffer(inMsg, extendHandle, false, error); in SendMessage()
120 extendHandle = nullptr; in SendMessage()
|
| H A D | protocol_proto.h | 61 std::shared_ptr<ExtendHeaderHandle> &extendHandle, bool onlyMsgHeader, int &outErrorNo);
131 …static int GetExtendHeadDataSize(std::shared_ptr<ExtendHeaderHandle> &extendHandle, uint32_t &head…
132 …static int FillExtendHeadDataIfNeed(std::shared_ptr<ExtendHeaderHandle> &extendHandle, SerialBuffe…
|
| H A D | protocol_proto.cpp | 98 std::shared_ptr<ExtendHeaderHandle> &extendHandle, bool onlyMsgHeader, int &outErrorNo) in ToSerialBuffer() argument
114 int errCode = GetExtendHeadDataSize(extendHandle, headSize); in ToSerialBuffer()
135 errCode = FillExtendHeadDataIfNeed(extendHandle, buffer, headSize); in ToSerialBuffer()
203 std::shared_ptr<ExtendHeaderHandle> extendHandle = nullptr; in BuildFeedbackMessageFrame() local
204 SerialBuffer *buffer = ToSerialBuffer(inMsg, extendHandle, true, outErrorNo); in BuildFeedbackMessageFrame()
1078 int ProtocolProto::GetExtendHeadDataSize(std::shared_ptr<ExtendHeaderHandle> &extendHandle, uint32_… in GetExtendHeadDataSize() argument
1080 if (extendHandle != nullptr) { in GetExtendHeadDataSize()
1081 DBStatus status = extendHandle->GetHeadDataSize(headSize); in GetExtendHeadDataSize()
1095 int ProtocolProto::FillExtendHeadDataIfNeed(std::shared_ptr<ExtendHeaderHandle> &extendHandle, Seri… in FillExtendHeadDataIfNeed() argument
1098 if (extendHandle != nullptr && headSize > 0) { in FillExtendHeadDataIfNeed()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator.cpp | 219 std::shared_ptr<ExtendHeaderHandle> extendHandle = nullptr; in TranslateMsg() local
220 auto buffer = ProtocolProto::ToSerialBuffer(inMsg, extendHandle, false, errCode); in TranslateMsg()
|