| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/common/ |
| H A D | client_trans_udp_manager_static_test.cpp | 197 UdpChannel udpChannel; in HWTEST_F() local
198 (void)memset_s(&udpChannel, sizeof(UdpChannel), 0, sizeof(UdpChannel)); in HWTEST_F()
199 udpChannel.channelId = TEST_CHANNELID; in HWTEST_F()
200 udpChannel.businessType = BUSINESS_TYPE_FILE; in HWTEST_F()
201 ret = ClientTransAddUdpChannel(&udpChannel); in HWTEST_F()
204 ret = ClientTransAddUdpChannel(&udpChannel); in HWTEST_F()
207 ret = TransGetUdpChannel(TEST_CHANNELID, &udpChannel); in HWTEST_F()
261 UdpChannel udpChannel; in HWTEST_F() local
262 (void)memset_s(&udpChannel, sizeof(UdpChannel), 0, sizeof(UdpChannel)); in HWTEST_F()
263 udpChannel in HWTEST_F()
281 UdpChannel udpChannel; HWTEST_F() local
326 UdpChannel udpChannel; HWTEST_F() local
415 UdpChannel udpChannel; HWTEST_F() local
[all...] |
| H A D | client_trans_udp_manager_test.cpp | 365 UdpChannel udpChannel; in HWTEST_F() local
366 (void)memset_s(&udpChannel, sizeof(UdpChannel), 0, sizeof(UdpChannel)); in HWTEST_F()
367 ret = TransGetUdpChannelByFileId(TEST_DATA_TYPE, &udpChannel); in HWTEST_F()
371 ret = TransGetUdpChannelByFileId(TEST_DATA_TYPE, &udpChannel); in HWTEST_F()
|
| /foundation/communication/dsoftbus/core/transmission/trans_channel/udp_negotiation/src/ |
| H A D | trans_udp_channel_manager.c | 58 UdpChannelInfo *udpChannel = NULL; in NotifyTimeOutUdpChannel() local
60 LIST_FOR_EACH_ENTRY_SAFE(udpChannel, nextUdpChannel, udpChannelList, UdpChannelInfo, node) { in NotifyTimeOutUdpChannel()
61 if (udpChannel->info.udpChannelOptType == TYPE_UDP_CHANNEL_OPEN) { in NotifyTimeOutUdpChannel()
63 (void)NotifyUdpChannelOpenFailed(&(udpChannel->info), SOFTBUS_TRANS_HANDSHAKE_TIMEOUT); in NotifyTimeOutUdpChannel()
64 } else if (udpChannel->info.udpChannelOptType == TYPE_UDP_CHANNEL_CLOSE) { in NotifyTimeOutUdpChannel()
66 (void)NotifyUdpChannelClosed(&(udpChannel->info), MESSAGE_TYPE_NOMAL); in NotifyTimeOutUdpChannel()
68 ListDelete(&(udpChannel->node)); in NotifyTimeOutUdpChannel()
69 if (udpChannel->info.fastTransData != NULL) { in NotifyTimeOutUdpChannel()
70 SoftBusFree((void *)udpChannel->info.fastTransData); in NotifyTimeOutUdpChannel()
72 (void)memset_s(udpChannel in NotifyTimeOutUdpChannel()
91 UdpChannelInfo *udpChannel = NULL; TransUdpTimerProc() local
139 UdpChannelInfo *udpChannel = NULL; TransUdpChannelMgrDeinit() local
230 UdpChannelInfo *udpChannel = NULL; NotifyUdpChannelCloseInList() local
260 UdpChannelInfo *udpChannel = NULL; TransCloseUdpChannelByNetWorkId() local
[all...] |
| H A D | trans_udp_negotiation.c | 1024 UdpChannelInfo udpChannel; in TransUdpGetChannelAndOpenConn() local
1025 (void)memset_s(&udpChannel, sizeof(udpChannel), 0, sizeof(udpChannel)); in TransUdpGetChannelAndOpenConn()
1026 int32_t ret = TransGetUdpChannelById(channelId, &udpChannel); in TransUdpGetChannelAndOpenConn()
1027 (void)memset_s(udpChannel.info.sessionKey, sizeof(udpChannel.info.sessionKey), 0, in TransUdpGetChannelAndOpenConn()
1028 sizeof(udpChannel.info.sessionKey)); in TransUdpGetChannelAndOpenConn()
1034 ret = OpenAuthConnForUdpNegotiation(&udpChannel); in TransUdpGetChannelAndOpenConn()
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/src/ |
| H A D | client_trans_udp_virtual.c | 77 int32_t TransGetUdpChannelByFileId(int32_t dfileId, UdpChannel *udpChannel) in TransGetUdpChannelByFileId() argument
80 (void)udpChannel; in TransGetUdpChannelByFileId()
98 int32_t TransGetUdpChannel(int32_t channelId, UdpChannel *udpChannel) in TransGetUdpChannel() argument
101 (void)udpChannel; in TransGetUdpChannel()
|
| H A D | client_trans_udp_manager.c | 591 TRANS_LOGE(TRANS_SDK, "get udpChannel failed. channelId=%{public}d", channelId); in OnRawStreamEncryptOptGet()
685 int32_t TransGetUdpChannelByFileId(int32_t dfileId, UdpChannel *udpChannel) in TransGetUdpChannelByFileId() argument
700 if (memcpy_s(udpChannel, sizeof(UdpChannel), channelNode, sizeof(UdpChannel)) != EOK) { in TransGetUdpChannelByFileId()
|
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/src/ |
| H A D | client_trans_file.c | 209 static void FileSendErrorEvent(UdpChannel *udpChannel, FileListener *fileListener, const DFileMsg *msgData, in FileSendErrorEvent() argument
224 TransOnUdpChannelClosed(udpChannel->channelId, SHUTDOWN_REASON_SEND_FILE_ERR); in FileSendErrorEvent()
234 UdpChannel udpChannel; in FileSendListener() local
235 (void)memset_s(&udpChannel, sizeof(UdpChannel), 0, sizeof(UdpChannel)); in FileSendListener()
236 if (TransGetUdpChannelByFileId(dfileId, &udpChannel) != SOFTBUS_OK) { in FileSendListener()
241 g_udpChannelMgrCb->OnUdpChannelOpened(udpChannel.channelId); in FileSendListener()
248 if (TransGetFileListener(udpChannel.info.mySessionName, &fileListener) != SOFTBUS_OK) { in FileSendListener()
254 NotifySocketSendResult(udpChannel.sessionId, msgType, msgData, &fileListener); in FileSendListener()
261 if (g_udpChannelMgrCb->OnFileGetSessionId(udpChannel.channelId, &sessionId) != SOFTBUS_OK) { in FileSendListener()
268 FileSendErrorEvent(&udpChannel, in FileSendListener()
357 FileRecvErrorEvent(UdpChannel *udpChannel, FileListener *fileListener, const DFileMsg *msgData, DFileMsgType msgType, int32_t sessionId) FileRecvErrorEvent() argument
381 UdpChannel udpChannel; FileReceiveListener() local
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/include/ |
| H A D | client_trans_udp_manager.h | 81 int32_t TransGetUdpChannelByFileId(int32_t dfileId, UdpChannel *udpChannel);
83 int32_t TransGetUdpChannel(int32_t channelId, UdpChannel *udpChannel);
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/clienttransudpmanager_fuzzer/ |
| H A D | clienttransudpmanager_fuzzer.cpp | 110 UdpChannel udpChannel; in TransGetUdpChannelByFileIdTest() local
111 TransGetUdpChannelByFileId((int32_t)size, &udpChannel); in TransGetUdpChannelByFileIdTest()
|