Home
last modified time | relevance | path

Searched refs:MessageHeader (Results 1 - 8 of 8) sorted by relevance

/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/
H A Dmessage_handler.cpp37 auto totalSize = sizeof(MessageHeader) + sizeof(SessionDeviceInfo) + sizeof(UserData) + uri_.size(); in MessageHandler()
49 MessageHeader *head = reinterpret_cast<MessageHeader *>(ptr); in PackData()
53 head->dataLen = htole32(totalLen - sizeof(MessageHeader)); in PackData()
56 ptr += sizeof(MessageHeader); in PackData()
88 if (!data || totalLen < sizeof(MessageHeader)) { in UnPackData()
95 MessageHeader *head = reinterpret_cast<MessageHeader *>(ptr); in UnPackData()
106 leftSize -= sizeof(MessageHeader); in UnPackData()
111 ptr += sizeof(MessageHeader); in UnPackData()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dheader_converter.h27 static void ConvertHostToNet(const MessageHeader &headerOriginal, MessageHeader &headerConverted);
32 static void ConvertNetToHost(const MessageHeader &headerOriginal, MessageHeader &headerConverted);
H A Dheader_converter.cpp46 void HeaderConverter::ConvertHostToNet(const MessageHeader &headerOriginal, MessageHeader &headerConverted) in ConvertHostToNet()
72 void HeaderConverter::ConvertNetToHost(const MessageHeader &headerOriginal, MessageHeader &headerConverted) in ConvertNetToHost()
H A Dframe_header.h61 * MessageHeader used to describe a message
63 struct MessageHeader { struct
70 uint32_t dataLen = 0; // Indicate length of data that follows MessageHeader
H A Dprotocol_proto.cpp87 uint32_t length = sizeof(CommPhyHeader) + sizeof(CommDivergeHeader) + sizeof(MessageHeader); in GetLengthBeforeSerializedData()
129 uint32_t payLoadLength = serializeLen + sizeof(MessageHeader); in ToSerialBuffer()
140 // Serialize the MessageHeader and data if need in ToSerialBuffer()
625 if (payloadByteLen.second < sizeof(MessageHeader)) { // For equal, only msgHeader case in SerializeMessage()
629 uint32_t dataLen = payloadByteLen.second - sizeof(MessageHeader); in SerializeMessage()
631 auto messageHdr = reinterpret_cast<MessageHeader *>(payloadByteLen.first); in SerializeMessage()
651 int result = function.serializeFunc(payloadByteLen.first + sizeof(MessageHeader), dataLen, inMsg); in SerializeMessage()
672 if (payloadByteLen.second < sizeof(MessageHeader)) { in DeSerializeMessage()
676 auto oriMsgHeader = reinterpret_cast<const MessageHeader *>(payloadByteLen.first); in DeSerializeMessage()
677 MessageHeader messageHd in DeSerializeMessage()
[all...]
/foundation/filemanagement/dfs_service/services/cloudsyncservice/include/transport/
H A Dmessage_handler.h31 struct MessageHeader { struct
75 void GetMessageHeader(MessageHeader &header);
87 MessageHeader msgHdr_{0};
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Dadapter_stub.cpp417 // Change field in MessageHeader. Assumpt that no fragment in ApplySendBitError()
418 if (length < sizeof(CommPhyHeader) + sizeof(CommDivergeHeader) + sizeof(MessageHeader)) { in ApplySendBitError()
422 auto msgHeader = reinterpret_cast<MessageHeader *>(edibleBytes); in ApplySendBitError()
H A Ddistributeddb_communicator_common.h135 sizeof(DistributedDB::MessageHeader); // 96 Bytes For Header, 32 phyHeader, 40 divergeHeader, 24 msgHeader

Completed in 6 milliseconds