/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/udp_negotiation/src/ |
H A D | trans_udp_negotiation_exchange.c | 79 (void)GetJsonObjectStringItem(msg, "PKG_NAME", appInfo->peerData.pkgName, PKG_NAME_SIZE_MAX); in TransUnpackReplyUdpInfo() 80 (void)GetJsonObjectNumberItem(msg, "UID", &(appInfo->peerData.uid)); in TransUnpackReplyUdpInfo() 81 (void)GetJsonObjectNumberItem(msg, "PID", &(appInfo->peerData.pid)); in TransUnpackReplyUdpInfo() 93 (void)GetJsonObjectNumberItem(msg, "MY_PORT", &(appInfo->peerData.port)); in TransUnpackReplyUdpInfo() 94 …(void)GetJsonObjectStringItem(msg, "MY_IP", appInfo->peerData.addr, sizeof(appInfo->peerData.addr)… in TransUnpackReplyUdpInfo() 107 (void)GetJsonObjectStringItem(msg, "PKG_NAME", appInfo->peerData.pkgName, PKG_NAME_SIZE_MAX); in TransGetCommonUdpInfoFromJson() 113 (void)GetJsonObjectNumberItem(msg, "PID", &(appInfo->peerData.pid)); in TransGetCommonUdpInfoFromJson() 114 (void)GetJsonObjectNumberItem(msg, "UID", &(appInfo->peerData.uid)); in TransGetCommonUdpInfoFromJson() 147 …(void)GetJsonObjectStringItem(msg, "MY_IP", appInfo->peerData.addr, sizeof(appInfo->peerData.addr)… in TransUnpackRequestUdpInfo() 156 …(void)GetJsonObjectStringItem(msg, "MY_IP", appInfo->peerData.addr, sizeof(appInfo->peerData.addr)… in TransUnpackRequestUdpInfo() [all …]
|
H A D | trans_udp_negotiation.c | 139 info.peerSessionName = (char*)appInfo->peerData.sessionName; in NotifyUdpChannelOpened() 143 info.peerIp = (char*)appInfo->peerData.addr; in NotifyUdpChannelOpened() 145 info.peerPort = appInfo->peerData.port; in NotifyUdpChannelOpened() 326 (const char *)appInfo->peerData.deviceId, appInfo->peerNetWorkId, DEVICE_ID_SIZE_MAX); in AcceptUdpChannelAsServer() 491 if (memcpy_s(appInfo->peerData.deviceId, sizeof(appInfo->peerData.deviceId), in SetPeerDeviceIdByAuth() 526 …if (CheckSecLevelPublic(appInfo->myData.sessionName, appInfo->peerData.sessionName) != SOFTBUS_OK)… in ParseRequestAppInfo() 561 ret = mgr->getLocalIpByRemoteIp(appInfo->peerData.addr, localIp, sizeof(localIp)); in ParseRequestAppInfo() 643 if (LnnGetRemoteNodeInfoById(info->peerData.deviceId, CATEGORY_UUID, nodeInfo) == SOFTBUS_OK) { in ReportUdpRequestHandShakeStartEvent() 651 extra->peerChannelId = info->peerData.channelId; in ReportUdpRequestHandShakeStartEvent() 997 appInfo->peerData.port = connOpt->socketOption.port; in PrepareAppInfoForUdpOpen() [all …]
|
H A D | trans_udp_channel_manager.c | 554 if (udpChannelNode->info.peerData.channelId == appInfo->peerData.channelId) { in TransUdpGetChannelIdByAddr() 555 if (strcmp(udpChannelNode->info.peerData.addr, appInfo->peerData.addr) == EOK) { in TransUdpGetChannelIdByAddr() 728 if (strcpy_s(remoteIp, maxIpLen, udpChannelNode->info.peerData.addr) != EOK) { in TransUdpGetIpAndConnectTypeById()
|
/ohos5.0/foundation/communication/dsoftbus/core/transmission/common/src/ |
H A D | softbus_message_open_channel.c | 222 appInfo->peerData.uid = -1; in ParseMessageToAppInfo() 223 appInfo->peerData.pid = -1; in ParseMessageToAppInfo() 224 (void)GetJsonObjectNumberItem(msg, UID, &appInfo->peerData.uid); in ParseMessageToAppInfo() 225 (void)GetJsonObjectNumberItem(msg, PID, &appInfo->peerData.pid); in ParseMessageToAppInfo() 259 appInfo->peerData.apiVersion = (ApiVersion)apiVersion; in UnpackRequest() 323 if (appInfo->peerData.dataConfig != 0) { in PackReply() 369 if (strcmp(uuid, appInfo->peerData.deviceId) != 0) { in UnpackReply() 379 appInfo->peerData.apiVersion = (ApiVersion)apiVersion; in UnpackReply() 380 appInfo->peerData.uid = -1; in UnpackReply() 381 appInfo->peerData.pid = -1; in UnpackReply() [all …]
|
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/ |
H A D | trans_tcp_direct_message_static_test.cpp | 228 appInfo->peerData.dataConfig = 1; 330 appInfo->peerData.dataConfig = 0; 334 appInfo->peerData.dataConfig = 1; 687 appInfo->peerData.dataConfig = 1; 691 appInfo->peerData.dataConfig = 1; 697 appInfo->peerData.dataConfig = 0; 791 …(void)strcpy_s(conn.appInfo.peerData.sessionName, sizeof(conn.appInfo.peerData.sessionName), "test… 793 conn.appInfo.peerData.uid = 1; 794 conn.appInfo.peerData.pid = 1; 798 (void)strcpy_s(conn.appInfo.peerData.addr, sizeof(conn.appInfo.peerData.addr), "127.0.0.1"); [all …]
|
H A D | trans_tcp_direct_message_append_test.cpp | 119 conn->appInfo.peerData.uid = TEST_UID; in TestSetSessionConn() 120 conn->appInfo.peerData.pid = TEST_PID; in TestSetSessionConn() 123 conn->appInfo.peerData.port = TEST_PORT; in TestSetSessionConn() 135 conn->appInfo.peerData.dataConfig = 0; in TestSetSessionConn() 157 appInfo->peerData.uid = TEST_UID; in TestSetAppInfo() 158 appInfo->peerData.pid = TEST_PID; in TestSetAppInfo() 161 appInfo->peerData.port = TEST_PORT; in TestSetAppInfo() 166 appInfo->peerData.dataConfig = 0; in TestSetAppInfo() 1520 appInfo->peerData.dataConfig = 1; 1529 appInfo->peerData.dataConfig = 0; [all …]
|
H A D | trans_tcp_direct_p2p_test.cpp | 178 appInfo->peerData.apiVersion = API_V2; in TestGetMsgPack() 404 (void)memcpy_s(appInfo->peerData.deviceId, DEVICE_ID_SIZE_MAX, "test", DEVICE_ID_SIZE_MAX); 407 ret = OpenAuthConn(appInfo->peerData.deviceId, requestId, isMeta, type); 458 (void)memcpy_s(appInfo->peerData.deviceId, DEVICE_ID_SIZE_MAX, "test", DEVICE_ID_SIZE_MAX);
|
H A D | trans_tcp_direct_p2p_mock_test.cpp | 115 testConn->appInfo.peerData.uid = TEST_UID; in TestSetSessionConn() 116 testConn->appInfo.peerData.pid = TEST_PID; in TestSetSessionConn() 119 testConn->appInfo.peerData.port = TEST_PORT; in TestSetSessionConn() 131 testConn->appInfo.peerData.dataConfig = 0; in TestSetSessionConn() 134 testConn->appInfo.peerData.channelId = TEST_CHANNEL_ID; in TestSetSessionConn() 139 (void)memcpy_s(testConn->appInfo.peerData.sessionName, in TestSetSessionConn() 143 (void)memcpy_s(testConn->appInfo.peerData.addr, IP_LEN, IP, (strlen(IP) + 1)); in TestSetSessionConn()
|
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/auth/src/ |
H A D | trans_auth_message.c | 44 !AddStringToJsonObject(msg, "DST_BUS_NAME", appInfo->peerData.sessionName) || in TransAuthChannelMsgPack() 54 !AddStringToJsonObject(msg, "PEER_HML_RAW_IP", appInfo->peerData.addr)) { in TransAuthChannelMsgPack() 79 … if (!GetJsonObjectStringItem(obj, "DEVICE_ID", appInfo->peerData.deviceId, DEVICE_ID_SIZE_MAX) || in TransAuthChannelMsgUnpack() 80 !GetJsonObjectStringItem(obj, "PKG_NAME", appInfo->peerData.pkgName, PKG_NAME_SIZE_MAX) || in TransAuthChannelMsgUnpack() 81 …!GetJsonObjectStringItem(obj, "SRC_BUS_NAME", appInfo->peerData.sessionName, SESSION_NAME_SIZE_MAX… in TransAuthChannelMsgUnpack() 91 if (!GetJsonObjectNumberItem(obj, "MTU_SIZE", (int32_t *)&(appInfo->peerData.dataConfig))) { in TransAuthChannelMsgUnpack() 99 if (!GetJsonObjectStringItem(obj, "LOCAL_HML_RAW_IP", appInfo->peerData.addr, IP_LEN) || in TransAuthChannelMsgUnpack()
|
H A D | trans_auth_manager.c | 184 (char *)appInfo->peerData.deviceId : (char *)appInfo->peerNetWorkId; in NotifyOpenAuthChannelSuccess() 185 channelInfo.peerSessionName = (char *)appInfo->peerData.sessionName; in NotifyOpenAuthChannelSuccess() 236 if (memcpy_s(channelAppInfo->peerData.deviceId, DEVICE_ID_SIZE_MAX, in CopyPeerAppInfo() 240 memcpy_s(channelAppInfo->peerData.pkgName, PKG_NAME_SIZE_MAX, in CopyPeerAppInfo() 264 … if (memcpy_s((*item)->appInfo.peerData.addr, IP_LEN, appInfo->peerData.addr, IP_LEN) != EOK || in InitAuthChannelInfo() 362 if (appInfo->peerData.dataConfig != 0) { in TransAuthFillDataConfig() 479 extra.peerUdid = appInfo.peerData.deviceId; in OnRecvAuthChannelRequest() 502 if (appInfo->peerData.dataConfig != 0) { in TransAuthProcessDataConfig() 650 appInfo->peerData.apiVersion = API_V2; in GetAppInfo() 673 appInfo->peerData.apiVersion = API_V2; in GetAppInfo() [all …]
|
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/ |
H A D | softbus_proxychannel_listener.c | 61 info->peerSessionName = (char *)appInfo->peerData.sessionName; in GetProxyChannelInfo() 62 info->peerPid = appInfo->peerData.pid; in GetProxyChannelInfo() 63 info->peerUid = appInfo->peerData.uid; in GetProxyChannelInfo() 94 ret = LnnGetNetworkIdByUuid(appInfo->peerData.deviceId, buf, NETWORK_ID_BUF_LEN); in NotifyNormalChannelOpened() 97 Anonymize(appInfo->peerData.deviceId, &anonyUuid); in NotifyNormalChannelOpened() 107 info.peerDeviceId = (char *)appInfo->peerData.deviceId; in NotifyNormalChannelOpened() 171 … extra.peerUdid = appInfo->appType == APP_TYPE_AUTH ? appInfo->peerData.deviceId : extra.peerUdid; in OnProxyChannelOpened() 282 … .peerUdid = appInfo->appType == APP_TYPE_AUTH ? appInfo->peerData.deviceId : appInfo->peerUdid, in TransProxyReportOpenChannelFailEvent() 380 appInfo->peerData.apiVersion = API_V2; in TransProxyGetAppInfo() 381 …if (strcpy_s(appInfo->peerData.sessionName, sizeof(appInfo->peerData.sessionName), sessionName) !=… in TransProxyGetAppInfo() [all …]
|
H A D | softbus_proxychannel_message.c | 553 if (appInfo->peerData.dataConfig != 0) { in TransProxyPackHandshakeAckMsg() 645 sizeof(chanInfo->appInfo.peerData.deviceId))) { in TransProxyUnpackHandshakeAckMsg() 682 sizeof(chanInfo->appInfo.peerData.pkgName))) { in TransProxyUnpackHandshakeAckMsg() 734 if (!GetJsonObjectNumberItem(root, JSON_KEY_UID, &(appInfo->peerData.uid)) || in TransProxyUnpackNormalHandshakeMsg() 735 !GetJsonObjectNumberItem(root, JSON_KEY_PID, &(appInfo->peerData.pid)) || in TransProxyUnpackNormalHandshakeMsg() 736 !GetJsonObjectStringItem(root, JSON_KEY_PKG_NAME, appInfo->peerData.pkgName, in TransProxyUnpackNormalHandshakeMsg() 737 sizeof(appInfo->peerData.pkgName)) || in TransProxyUnpackNormalHandshakeMsg() 784 appInfo->peerData.pkgName, sizeof(appInfo->peerData.pkgName))) { in TransProxyUnpackAuthHandshakeMsg() 818 !GetJsonObjectStringItem(root, JSON_KEY_DEVICE_ID, appInfo->peerData.deviceId, in TransProxyUnpackHandshakeMsg() 819 sizeof(appInfo->peerData.deviceId)) || in TransProxyUnpackHandshakeMsg() [all …]
|
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
H A D | trans_tcp_direct_message.c | 242 Anonymize(conn->appInfo.peerData.deviceId, &tmpId); in SendFailToFlushDevice() 315 info->peerUid = conn->appInfo.peerData.uid; in GetChannelInfoFromConn() 316 info->peerPid = conn->appInfo.peerData.pid; in GetChannelInfoFromConn() 320 info->peerIp = conn->appInfo.peerData.addr; in GetChannelInfoFromConn() 321 info->peerPort = conn->appInfo.peerData.port; in GetChannelInfoFromConn() 350 …if (LnnSetDLP2pIp(appInfo->peerData.deviceId, CATEGORY_UUID, appInfo->peerData.addr) != SOFTBUS_OK… in GetServerSideIpInfo() 367 …if (LnnSetDLP2pIp(appInfo->peerData.deviceId, CATEGORY_UUID, appInfo->peerData.addr) != SOFTBUS_OK… in GetClientSideIpInfo() 597 if (appInfo->peerData.dataConfig != 0) { in TransTdcProcessDataConfig() 775 if (appInfo->peerData.dataConfig != 0) { in TransTdcFillDataConfig() 890 appInfo->myData.pid, appInfo->peerData.pid); in TransTdcFillAppInfoAndNotifyChannel() [all …]
|
H A D | trans_tcp_direct_p2p.c | 433 strcpy_s(peerDataAddr, sizeof(peerDataAddr), conn->appInfo.peerData.addr) != EOK) { in OnAuthConnOpened() 753 ret = VerifyP2pUnPack(json, conn->appInfo.peerData.addr, IP_LEN, &conn->appInfo.peerData.port); in OnVerifyP2pReply() 759 TRANS_LOGI(TRANS_CTRL, "peer wifi: peerPort=%{public}d", conn->appInfo.peerData.port); in OnVerifyP2pReply() 761 …fd = ConnectTcpDirectPeer(conn->appInfo.peerData.addr, conn->appInfo.peerData.port, conn->appInfo.… in OnVerifyP2pReply() 770 strcpy_s(peerAddr, sizeof(peerAddr), conn->appInfo.peerData.addr) != EOK || in OnVerifyP2pReply() 776 peerPort = conn->appInfo.peerData.port; in OnVerifyP2pReply() 856 int32_t ret = OpenAuthConn(appInfo->peerData.deviceId, conn->requestId, conn->isMeta, type); in OpenNewAuthConn() 892 …AuthGetLatestIdByUuid(conn->appInfo.peerData.deviceId, AUTH_LINK_TYPE_WIFI, false, &conn->authHand… in TransProxyGetAuthIdByUuid() 895 …AuthGetLatestIdByUuid(conn->appInfo.peerData.deviceId, AUTH_LINK_TYPE_BLE, false, &conn->authHandl… in TransProxyGetAuthIdByUuid() 899 …AuthGetLatestIdByUuid(conn->appInfo.peerData.deviceId, AUTH_LINK_TYPE_BR, false, &conn->authHandle… in TransProxyGetAuthIdByUuid() [all …]
|
H A D | trans_tcp_direct_manager.c | 53 .peerChannelId = node->appInfo.peerData.channelId, in OnSessionOpenFailProc() 254 appInfo->peerData.port = connInfo->socketOption.port; in TransUpdateAppInfo() 255 …if (strcpy_s(appInfo->peerData.addr, sizeof(appInfo->peerData.addr), connInfo->socketOption.addr) … in TransUpdateAppInfo()
|
H A D | trans_tcp_direct_wifi.c | 147 …AuthGetLatestIdByUuid(newConn->appInfo.peerData.deviceId, AUTH_LINK_TYPE_WIFI, false, &newConn->au… in OpenTcpDirectChannel() 149 …AuthGetLatestIdByUuid(newConn->appInfo.peerData.deviceId, AUTH_LINK_TYPE_BR, false, &newConn->auth… in OpenTcpDirectChannel()
|
H A D | trans_tcp_direct_listener.c | 170 conn->appInfo.peerData.port = clientAddr->socketOption.port; in CreateSessionConnNode() 180 …if (strcpy_s(conn->appInfo.peerData.addr, sizeof(conn->appInfo.peerData.addr), clientAddr->socketO… in CreateSessionConnNode()
|
/ohos5.0/foundation/communication/dsoftbus/core/common/dfx/statistics/instant/ |
H A D | instant_statistics.cpp | 227 return InstantIsParaMatch(rInfo->hmlIp, conn->appInfo.peerData.addr); in InstIsMatchSessionConn() 229 return InstantIsParaMatch(rInfo->p2pIp, conn->appInfo.peerData.addr); in InstIsMatchSessionConn() 281 remoteInfo->hmlIp = appInfo->peerData.addr; in InstSetIpForRemoteInfo() 284 remoteInfo->p2pIp = appInfo->peerData.addr; in InstSetIpForRemoteInfo() 287 remoteInfo->wlanIp = appInfo->peerData.addr; in InstSetIpForRemoteInfo() 477 if (InstantIsParaMatch(rInfo->uuid, info->info.peerData.deviceId)) { in InstIsMatchUdpChannel() 483 return InstantIsParaMatch(rInfo->hmlIp, info->info.peerData.addr); in InstIsMatchUdpChannel() 485 return InstantIsParaMatch(rInfo->p2pIp, info->info.peerData.addr); in InstIsMatchUdpChannel() 487 return InstantIsParaMatch(rInfo->wlanIp, info->info.peerData.addr); in InstIsMatchUdpChannel() 560 return InstantIsParaMatch(deviceId, conn->appInfo.peerData.deviceId); in InstIsMatchProxyChannel() [all …]
|
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/udp_negotiation/ |
H A D | trans_udp_negotiation_exchange_test.cpp | 66 res = strcpy_s(appInfo->peerData.addr, sizeof(appInfo->peerData.addr), TEST_SOCKET_ADDR); in GenerateAppInfo() 70 …res = strcpy_s(appInfo->peerData.sessionName, sizeof(appInfo->peerData.sessionName), g_sessionName… in GenerateAppInfo() 74 res = strcpy_s(appInfo->peerData.pkgName, sizeof(appInfo->peerData.pkgName), g_pkgName); in GenerateAppInfo()
|
H A D | trans_udp_nego_test.cpp | 112 Channel->info.peerData.apiVersion = API_V2; in CreateUdpChannelPackTest() 121 (void)memcpy_s(Channel->info.peerData.sessionName, SESSION_NAME_SIZE_MAX, in CreateUdpChannelPackTest() 123 (void)memcpy_s(Channel->info.peerData.deviceId, DEVICE_ID_SIZE_MAX, in CreateUdpChannelPackTest() 145 res = strcpy_s(appInfo->peerData.addr, sizeof(appInfo->peerData.addr), TEST_SOCKET_ADDR); in GenerateAppInfo() 149 …res = strcpy_s(appInfo->peerData.sessionName, sizeof(appInfo->peerData.sessionName), g_sessionName… in GenerateAppInfo() 153 res = strcpy_s(appInfo->peerData.pkgName, sizeof(appInfo->peerData.pkgName), g_pkgName); in GenerateAppInfo() 673 (void)memcpy_s(&appInfo->peerData.deviceId, DEVICE_ID_SIZE_MAX,
|
H A D | trans_udp_static_test.cpp | 234 info->peerData.channelId = TEST_CHANNEL_ID; 244 EXPECT_EQ(extra.peerChannelId, info->peerData.channelId);
|
/ohos5.0/foundation/communication/dsoftbus/core/common/dfx/hidumper_adapter/ |
H A D | softbus_hidumper_trans.c | 102 DataMasking(appInfo->peerData.deviceId, DEVICE_ID_SIZE_MAX, ID_DELIMITER, deviceId); in SoftBusTransDumpRunningSession() 104 DataMasking(appInfo->peerData.addr, IP_LEN, IP_DELIMITER, dstAddr); in SoftBusTransDumpRunningSession() 106 Anonymize(appInfo->peerData.sessionName, &remoteSessionName); in SoftBusTransDumpRunningSession()
|
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/common/src/ |
H A D | trans_channel_common.c | 261 …errCode = strcpy_s(appInfo->peerData.sessionName, sizeof(appInfo->peerData.sessionName), param->pe… in CopyAppInfoFromSessionParam() 265 appInfo->peerData.deviceId, sizeof(appInfo->peerData.deviceId)); in CopyAppInfoFromSessionParam() 288 appInfo->peerData.channelId = INVALID_CHANNEL_ID; in TransCommonGetAppInfo() 310 appInfo->peerData.apiVersion = API_V2; in TransCommonGetAppInfo()
|
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/common/softbus_message_open_channel_test/ |
H A D | softbus_message_open_channel_test.cpp | 73 appInfo->peerData.apiVersion = API_V2; in TestGetMsgPack() 98 !AddStringToJsonObject(msg, "DST_BUS_NAME", appInfo->peerData.sessionName) || in TestTransAuthChannelMsgPack() 327 appInfo->peerData.apiVersion = API_V2;
|
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/auth_channel/ |
H A D | trans_auth_channel_test.cpp | 103 strcpy_s(appInfo->peerData.addr, sizeof(appInfo->peerData.addr), TEST_CONN_IP) != EOK || in TestGenerateAppInfo() 105 …strcpy_s(appInfo->peerData.sessionName, sizeof(appInfo->peerData.sessionName), g_sessionName) != E… in TestGenerateAppInfo() 107 strcpy_s(appInfo->peerData.pkgName, sizeof(appInfo->peerData.pkgName), g_pkgName) != EOK || in TestGenerateAppInfo() 117 appInfo->peerData.apiVersion = API_V2; in TestGenerateAppInfo()
|