| /foundation/communication/dsoftbus/tests/core/authentication/unittest/ |
| H A D | auth_tcp_connection_test.cpp | 102 SocketPktHead pktHead; in HWTEST_F() local
103 (void)memset_s(&pktHead, sizeof(SocketPktHead), 0, sizeof(SocketPktHead)); in HWTEST_F()
104 int32_t ret = RecvPacketHead(AUTH, fd, &pktHead); in HWTEST_F()
117 SocketPktHead pktHead; in HWTEST_F() local
119 (void)memset_s(&pktHead, sizeof(SocketPktHead), 0, sizeof(SocketPktHead)); in HWTEST_F()
120 pktHead.module = MODULE_AUTH_CHANNEL; in HWTEST_F()
121 NotifyDataReceived(AUTH, fd, &pktHead, data); in HWTEST_F()
122 pktHead.module = MODULE_AUTH_MSG; in HWTEST_F()
123 NotifyDataReceived(AUTH, fd, &pktHead, data); in HWTEST_F()
124 pktHead in HWTEST_F()
[all...] |
| /foundation/communication/dsoftbus/core/authentication/src/ |
| H A D | auth_tcp_connection.c | 77 static int32_t PackSocketPkt(const SocketPktHead *pktHead, const uint8_t *data, in PackSocketPkt() argument
80 if (size < GetSocketPktSize(pktHead->len)) { in PackSocketPkt()
85 *(uint32_t *)buf = SoftBusHtoLl((uint32_t)pktHead->magic); in PackSocketPkt()
87 *(uint32_t *)(buf + offset) = SoftBusHtoLl((uint32_t)pktHead->module); in PackSocketPkt()
89 *(uint64_t *)(buf + offset) = SoftBusHtoLll((uint64_t)pktHead->seq); in PackSocketPkt()
91 *(uint32_t *)(buf + offset) = SoftBusHtoLl((uint32_t)pktHead->flag); in PackSocketPkt()
93 *(uint32_t *)(buf + offset) = SoftBusHtoLl(pktHead->len); in PackSocketPkt()
95 if (memcpy_s(buf + offset, size - offset, data, pktHead->len) != EOK) { in PackSocketPkt()
154 const SocketPktHead *pktHead, const uint8_t *data) in NotifyDataReceived()
156 if (pktHead in NotifyDataReceived()
153 NotifyDataReceived(ListenerModule module, int32_t fd, const SocketPktHead *pktHead, const uint8_t *data) NotifyDataReceived() argument
527 SocketPktHead pktHead = { SocketPostBytes() local
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_common.c | 471 struct FillpPktHead *pktHead = FILLP_NULL_PTR; in FillpSendNack() local
486 pktHead = (struct FillpPktHead *)nack->head; in FillpSendNack()
487 pktHead->flag = 0; in FillpSendNack()
488 FILLP_HEADER_SET_PKT_TYPE(pktHead->flag, FILLP_PKT_TYPE_NACK); in FillpSendNack()
489 FILLP_HEADER_SET_PROTOCOL_VERSION(pktHead->flag, FILLP_PROTOCOL_VERSION_NUMBER); in FillpSendNack()
490 pktHead->flag = FILLP_HTONS(pktHead->flag); in FillpSendNack()
492 pktHead->dataLen = 0; in FillpSendNack()
493 pktHead->dataLen = (FILLP_UINT16)(pktHead in FillpSendNack()
770 struct FillpPktHead *pktHead = (struct FillpPktHead *)pack->head; FillpBuildAndSendPack() local
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/ |
| H A D | client_trans_tcp_direct_message.c | 146 TcpDataPacketHead pktHead = { in TransTdcPackData() local
152 PackTcpDataPacketHead(&pktHead); in TransTdcPackData()
153 if (memcpy_s(buf, DC_DATA_HEAD_SIZE, &pktHead, sizeof(TcpDataPacketHead)) != EOK) { in TransTdcPackData()
439 TcpDataPacketHead *pktHead = (TcpDataPacketHead *)(node->data); in TransTdcProcessData() local
440 int32_t seqNum = pktHead->seq; in TransTdcProcessData()
441 uint32_t flag = pktHead->flags; in TransTdcProcessData()
442 uint32_t dataLen = pktHead->dataLen; in TransTdcProcessData()
525 TcpDataPacketHead *pktHead = (TcpDataPacketHead *)(node->data); in TransTdcProcAllData() local
526 UnpackTcpDataPacketHead(pktHead); in TransTdcProcAllData()
527 if (pktHead in TransTdcProcAllData()
[all...] |
| /foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
| H A D | trans_tcp_direct_message.c | 1077 static int32_t DecryptMessage(int32_t channelId, const TdcPacketHead *pktHead, const uint8_t *pktData, in DecryptMessage() argument
1081 int32_t ret = GetAuthIdByChannelInfo(channelId, pktHead->seq, pktHead->flags, &authHandle); in DecryptMessage()
1082 if (ret != SOFTBUS_OK || (authHandle.authId == AUTH_INVALID_ID && pktHead->flags == FLAG_P2P)) { in DecryptMessage()
1085 ret = GetAuthIdByChannelInfo(channelId, pktHead->seq, FLAG_ENHANCE_P2P, &authHandle); in DecryptMessage()
1094 uint32_t decDataLen = AuthGetDecryptSize(pktHead->dataLen) + 1; in DecryptMessage()
1100 if (AuthDecrypt(&authHandle, pktData, pktHead->dataLen, decData, &decDataLen) != SOFTBUS_OK) { in DecryptMessage()
1127 TdcPacketHead *pktHead = (TdcPacketHead *)(node->data); in ProcessReceivedData() local
1129 if (pktHead->module != MODULE_SESSION) { in ProcessReceivedData()
1134 seq = pktHead in ProcessReceivedData()
1184 TdcPacketHead *pktHead = (TdcPacketHead *)(node->data); TransTdcSrvProcData() local
1357 TdcPacketHead pktHead; TransReadDataLen() local
[all...] |
| /foundation/communication/dsoftbus/core/authentication/src/virtual/ |
| H A D | auth_meta_manager_virtual.c | 77 void AuthMetaNotifyDataReceived(uint32_t connectionId, const SocketPktHead *pktHead, const uint8_t *data) in AuthMetaNotifyDataReceived() argument
80 (void)pktHead; in AuthMetaNotifyDataReceived()
|
| /foundation/communication/dsoftbus/core/authentication/include/ |
| H A D | auth_meta_manager.h | 44 void AuthMetaNotifyDataReceived(uint32_t connectionId, const SocketPktHead *pktHead, const uint8_t *data);
|
| /foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/ |
| H A D | trans_tcp_direct_message_append_test.cpp | 1174 TdcPacketHead pktHead = {0}; in HWTEST_F() local
1175 pktHead.dataLen = 10; in HWTEST_F()
1185 int64_t ret = DecryptMessage(channelId, &pktHead, pktData, &outData, &outDataLen); in HWTEST_F()
1198 TdcPacketHead pktHead = {0}; in HWTEST_F() local
1199 pktHead.dataLen = 10; in HWTEST_F()
1209 int64_t ret = DecryptMessage(channelId, &pktHead, pktData, &outData, &outDataLen); in HWTEST_F()
1222 TdcPacketHead pktHead = {0}; in HWTEST_F() local
1223 pktHead.dataLen = 10; in HWTEST_F()
1232 int64_t ret = DecryptMessage(channelId, &pktHead, pktData, &outData, &outDataLen); in HWTEST_F()
1245 TdcPacketHead pktHead in HWTEST_F() local
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/ |
| H A D | client_trans_proxy_manager.c | 948 PacketHead *pktHead = (PacketHead *)dataInfo->outData; in ClientTransProxyPackBytes() local
949 pktHead->magicNumber = MAGIC_NUMBER; in ClientTransProxyPackBytes()
950 pktHead->seq = seq; in ClientTransProxyPackBytes()
951 pktHead->flags = flag; in ClientTransProxyPackBytes()
952 pktHead->dataLen = (int32_t)((int32_t)dataInfo->outLen - sizeof(PacketHead)); in ClientTransProxyPackBytes()
953 ClientPackPacketHead(pktHead); in ClientTransProxyPackBytes()
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/ |
| H A D | softbus_proxychannel_message.c | 964 PacketFastHead *pktHead = (PacketFastHead*)dataInfo->outData; in TransProxyPackFastDataHead() local
965 pktHead->magicNumber = MAGIC_NUMBER; in TransProxyPackFastDataHead()
966 pktHead->seq = seq; in TransProxyPackFastDataHead()
967 pktHead->flags = (appInfo->businessType == BUSINESS_TYPE_BYTE) ? FLAG_BYTES : FLAG_MESSAGE; in TransProxyPackFastDataHead()
968 pktHead->dataLen = (int32_t)cipherLength; in TransProxyPackFastDataHead()
969 FastDataPackPacketHead(pktHead); in TransProxyPackFastDataHead()
|
| /foundation/communication/dsoftbus/core/transmission/common/src/ |
| H A D | softbus_message_open_channel.c | 458 TcpFastDataPacketHead pktHead = { in TransTdcPackFastData() local
464 PackTcpFastDataPacketHead(&pktHead); in TransTdcPackFastData()
465 if (memcpy_s(buf, FAST_DATA_HEAD_SIZE, &pktHead, sizeof(TcpFastDataPacketHead)) != EOK) { in TransTdcPackFastData()
|