Home
last modified time | relevance | path

Searched refs:socketInfo (Results 1 - 25 of 25) sorted by relevance

/foundation/communication/netmanager_base/frameworks/native/netmanagernative/
H A Dnetsys_net_diag_data.cpp300 bool NetDiagUnixSocketInfo::Unmarshalling(Parcel &parcel, NetDiagUnixSocketInfo &socketInfo) in Unmarshalling() argument
302 if (!parcel.ReadUint16(socketInfo.refCnt_)) { in Unmarshalling()
305 if (!parcel.ReadUint32(socketInfo.inode_)) { in Unmarshalling()
308 if (!parcel.ReadString(socketInfo.protocol_)) { in Unmarshalling()
311 if (!parcel.ReadString(socketInfo.flags_)) { in Unmarshalling()
314 if (!parcel.ReadString(socketInfo.type_)) { in Unmarshalling()
317 if (!parcel.ReadString(socketInfo.state_)) { in Unmarshalling()
320 if (!parcel.ReadString(socketInfo.path_)) { in Unmarshalling()
358 bool NeyDiagNetProtoSocketInfo::Unmarshalling(Parcel &parcel, NeyDiagNetProtoSocketInfo &socketInfo) in Unmarshalling() argument
360 if (!parcel.ReadString(socketInfo in Unmarshalling()
433 NetDiagUnixSocketInfo socketInfo; Unmarshalling() local
446 NeyDiagNetProtoSocketInfo socketInfo; Unmarshalling() local
[all...]
/foundation/communication/dsoftbus/core/connection/tcp/src/
H A Dsoftbus_tcp_connect_manager.c165 status = DelTrigger((ListenerModule)target->info.socketInfo.moduleId, in DelTcpConnInfo()
166 target->info.socketInfo.fd, RW_TRIGGER); in DelTcpConnInfo()
168 ConnShutdownSocket(it->info.socketInfo.fd); in DelTcpConnInfo()
243 if (strcpy_s(tcpConnInfoNode->info.socketInfo.addr, sizeof(tcpConnInfoNode->info.socketInfo.addr), in TcpOnConnectEvent()
247 tcpConnInfoNode->info.socketInfo.port = clientAddr->socketOption.port; in TcpOnConnectEvent()
248 tcpConnInfoNode->info.socketInfo.fd = cfd; in TcpOnConnectEvent()
249 tcpConnInfoNode->info.socketInfo.moduleId = module; in TcpOnConnectEvent()
250 tcpConnInfoNode->info.socketInfo.protocol = clientAddr->socketOption.protocol; in TcpOnConnectEvent()
312 if (item->info.socketInfo in GetTcpInfoByFd()
[all...]
/foundation/communication/ipc/ipc/native/src/core/source/
H A Ddatabus_socket_listener.cpp115 DBinderSocketInfo socketInfo; in ClientOnShutdown() local
120 socketInfo = it->first; in ClientOnShutdown()
127 EraseDeviceLock(socketInfo); in ClientOnShutdown()
168 std::shared_ptr<std::mutex> DatabusSocketListener::QueryOrNewInfoMutex(DBinderSocketInfo socketInfo) in QueryOrNewInfoMutex() argument
171 auto it = infoMutexMap_.find(socketInfo); in QueryOrNewInfoMutex()
178 socketInfo.GetOwnName().c_str(), socketInfo.GetPeerName().c_str(), in QueryOrNewInfoMutex()
179 IPCProcessSkeleton::ConvertToSecureString(socketInfo.GetNetworkId()).c_str()); in QueryOrNewInfoMutex()
182 infoMutexMap_[socketInfo] = infoMutex; in QueryOrNewInfoMutex()
205 SocketInfo socketInfo in CreateClientSocket() local
239 DBinderSocketInfo socketInfo; ShutdownSocket() local
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/network/
H A Dnetwork_tcp_unit_test.cpp397 auto socketInfo = clientPtr->GetSocketInfo(); in HWTEST_F() local
398 ASSERT_TRUE(socketInfo != nullptr); in HWTEST_F()
412 auto socketInfo = tcpServer->GetSocketInfo(); in HWTEST_F() local
413 ASSERT_TRUE(socketInfo != nullptr); in HWTEST_F()
427 auto socketInfo = clientPtr->GetSocketInfo(); in HWTEST_F() local
428 ASSERT_TRUE(socketInfo != nullptr); in HWTEST_F()
429 EXPECT_EQ(socketInfo->GetLocalIp(), "127.0.0.1"); in HWTEST_F()
430 EXPECT_EQ(socketInfo->GetLocalPort(), 8889); in HWTEST_F()
431 EXPECT_NE(socketInfo->GetLocalFd(), -1); in HWTEST_F()
432 EXPECT_EQ(socketInfo in HWTEST_F()
447 auto socketInfo = tcpServer->GetSocketInfo(); HWTEST_F() local
459 auto socketInfo = clientPtr->GetSocketInfo(); HWTEST_F() local
468 auto socketInfo = tcpServer->GetSocketInfo(); HWTEST_F() local
[all...]
H A Dnetwork_udp_unit_test.cpp390 auto socketInfo = clientPtr->GetSocketInfo(); in HWTEST_F() local
391 ASSERT_TRUE(socketInfo != nullptr); in HWTEST_F()
405 auto socketInfo = udpServer->GetSocketInfo(); in HWTEST_F() local
406 ASSERT_TRUE(socketInfo != nullptr); in HWTEST_F()
420 auto socketInfo = clientPtr->GetSocketInfo(); in HWTEST_F() local
421 ASSERT_TRUE(socketInfo != nullptr); in HWTEST_F()
422 EXPECT_EQ(socketInfo->GetLocalIp(), "127.0.0.1"); in HWTEST_F()
423 EXPECT_EQ(socketInfo->GetLocalPort(), 8889); in HWTEST_F()
424 EXPECT_NE(socketInfo->GetLocalFd(), -1); in HWTEST_F()
425 EXPECT_EQ(socketInfo in HWTEST_F()
440 auto socketInfo = udpServer->GetSocketInfo(); HWTEST_F() local
452 auto socketInfo = clientPtr->GetSocketInfo(); HWTEST_F() local
461 auto socketInfo = udpServer->GetSocketInfo(); HWTEST_F() local
[all...]
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_manager_test/
H A Dnet_diag_wrapper_test.cpp370 NetDiagSocketsInfo socketInfo; in HWTEST_F() local
372 auto ret = netDiagWrapper->GetSocketsInfo(socketType, socketInfo); in HWTEST_F()
373 ShowSocketInfo(socketInfo); in HWTEST_F()
377 ret = netDiagWrapper->GetSocketsInfo(socketType, socketInfo); in HWTEST_F()
378 ShowSocketInfo(socketInfo); in HWTEST_F()
382 ret = netDiagWrapper->GetSocketsInfo(socketType, socketInfo); in HWTEST_F()
383 ShowSocketInfo(socketInfo); in HWTEST_F()
387 ret = netDiagWrapper->GetSocketsInfo(socketType, socketInfo); in HWTEST_F()
388 ShowSocketInfo(socketInfo); in HWTEST_F()
392 ret = netDiagWrapper->GetSocketsInfo(socketType, socketInfo); in HWTEST_F()
509 NetDiagUnixSocketInfo socketInfo; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_client.cpp94 SocketInfo socketInfo; in OpenConnect() local
96 socketInfo.peerName = const_cast<char *>(peerName.c_str()); in OpenConnect()
98 socketInfo.peerNetworkId = const_cast<char *>(networkId.c_str()); in OpenConnect()
100 socketInfo.name = const_cast<char *>(clientName.c_str()); in OpenConnect()
102 socketInfo.pkgName = pkgName.data(); in OpenConnect()
103 socketInfo.dataType = DATA_TYPE_BYTES; in OpenConnect()
104 int32_t clientSocket = Socket(socketInfo); in OpenConnect()
107 ZLOGE("Create the client Socket:%{public}d failed, peerName:%{public}s", clientSocket, socketInfo.peerName); in OpenConnect()
H A Dsoftbus_adapter_standard.cpp417 SocketInfo socketInfo; in CreateSessionServerAdapter() local
419 socketInfo.name = const_cast<char *>(sessionServerName.c_str()); in CreateSessionServerAdapter()
421 socketInfo.pkgName = pkgName.data(); in CreateSessionServerAdapter()
422 socket_ = Socket(socketInfo); in CreateSessionServerAdapter()
565 ServerSocketInfo socketInfo; in OnBind() local
566 socketInfo.name = info.name; in OnBind()
567 socketInfo.networkId = info.networkId; in OnBind()
568 socketInfo.pkgName = info.pkgName; in OnBind()
569 peerSocketInfos_.Insert(socket, socketInfo); in OnBind()
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/manager/trans_auth_negotiation_test/
H A Dtrans_auth_negotiation_test.cpp288 ConnSocketInfo socketInfo; in HWTEST_F() local
289 socketInfo.protocol = LNN_PROTOCOL_BLE; in HWTEST_F()
291 int32_t ret = SetWlanAuthConnInfo(&socketInfo, &authConnInfo); in HWTEST_F()
303 ConnSocketInfo socketInfo; in HWTEST_F() local
304 socketInfo.protocol = LNN_PROTOCOL_IP; in HWTEST_F()
305 socketInfo.port = SOFTBUS_PORT; in HWTEST_F()
306 socketInfo.moduleId = DIRECT_CHANNEL_SERVER_WIFI; in HWTEST_F()
307 (void)strcpy_s(socketInfo.addr, IP_LEN, ""); in HWTEST_F()
309 int32_t ret = SetWlanAuthConnInfo(&socketInfo, &authConnInfo); in HWTEST_F()
311 (void)strcpy_s(socketInfo in HWTEST_F()
[all...]
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnet_diag_wrapper.cpp505 NeyDiagNetProtoSocketInfo socketInfo; in ExtractNetProtoSocketsInfo() local
506 socketInfo.protocol_ = match[protoPos].str(); in ExtractNetProtoSocketsInfo()
507 socketInfo.recvQueue_ = static_cast<uint16_t>(CommonUtils::StrToUint(match[recvPos].str())); in ExtractNetProtoSocketsInfo()
508 socketInfo.sendQueue_ = static_cast<uint16_t>(CommonUtils::StrToUint(match[sendPos].str())); in ExtractNetProtoSocketsInfo()
509 socketInfo.localAddr_ = match[localAddrPos].str(); in ExtractNetProtoSocketsInfo()
510 socketInfo.foreignAddr_ = match[foreignAddrPos].str(); in ExtractNetProtoSocketsInfo()
511 socketInfo.state_ = match[statePos].str(); in ExtractNetProtoSocketsInfo()
512 socketInfo.user_ = match[userPos].str(); in ExtractNetProtoSocketsInfo()
513 socketInfo.inode_ = static_cast<uint16_t>(CommonUtils::StrToUint(match[iNodePos].str())); in ExtractNetProtoSocketsInfo()
514 socketInfo in ExtractNetProtoSocketsInfo()
534 NetDiagUnixSocketInfo socketInfo; ExtractUnixSocketsInfo() local
[all...]
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/test/sinkfuzztest/softbusonsinksessionopened_fuzzer/
H A Dsoftbusonsinksessionopened_fuzzer.cpp32 PeerSocketInfo socketInfo = { in SoftbusOnSinkSessionOpenedFuzzTest() local
38 DCameraSoftbusAdapter::GetInstance().SinkOnBind(sessionId, socketInfo); in SoftbusOnSinkSessionOpenedFuzzTest()
/foundation/distributedhardware/distributed_camera/interfaces/inner_kits/native_cpp/test/sourcefuzztest/softbusonsourcesessionopened_fuzzer/
H A Dsoftbusonsourcesessionopened_fuzzer.cpp32 PeerSocketInfo socketInfo = { in SoftbusOnSourceSessionOpenedFuzzTest() local
38 DCameraSoftbusAdapter::GetInstance().SourceOnBind(sessionId, socketInfo); in SoftbusOnSourceSessionOpenedFuzzTest()
/foundation/CastEngine/castengine_wifi_display/services/network/server/
H A Dtcp_server.cpp137 SocketInfo::Ptr socketInfo = in OnServerReadable() local
139 if (socketInfo) { in OnServerReadable()
140 socketInfo->SetSocketType(SOCKET_TYPE_TCP); in OnServerReadable()
141 BaseNetworkSession::Ptr session = std::make_shared<TcpSession>(std::move(socketInfo)); in OnServerReadable()
H A Dudp_server.cpp205 SocketInfo::Ptr socketInfo = in FindOrCreateSession() local
208 auto ret = memcpy_s(&socketInfo->udpClientAddr_, sizeof(struct sockaddr_in), &addr, sizeof(struct sockaddr_in)); in FindOrCreateSession()
213 socketInfo->SetSocketType(SOCKET_TYPE_UDP); in FindOrCreateSession()
215 if (socketInfo) { in FindOrCreateSession()
216 BaseNetworkSession::Ptr session = std::make_shared<UdpSession>(std::move(socketInfo)); in FindOrCreateSession()
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/
H A Dtrans_auth_negotiation.c258 static int32_t SetWlanAuthConnInfo(const struct ConnSocketInfo *socketInfo, AuthConnInfo *authConnInfo) in SetWlanAuthConnInfo() argument
260 if (socketInfo->protocol != LNN_PROTOCOL_IP) { in SetWlanAuthConnInfo()
261 TRANS_LOGE(TRANS_SVC, "tcp protocol=%{public}d not support", socketInfo->protocol); in SetWlanAuthConnInfo()
266 if (strcpy_s(authConnInfo->info.ipInfo.ip, IP_LEN, socketInfo->addr) != EOK) { in SetWlanAuthConnInfo()
270 authConnInfo->info.ipInfo.port = socketInfo->port; in SetWlanAuthConnInfo()
271 authConnInfo->info.ipInfo.moduleId = (ListenerModule)socketInfo->moduleId; in SetWlanAuthConnInfo()
308 return SetWlanAuthConnInfo(&(connInfo->socketInfo), authConnInfo); in ConvertConnInfoToAuthConnInfo()
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/
H A Dsoftbus_adapter_standard.cpp461 SocketInfo socketInfo; in CreateClientSocket() local
463 socketInfo.name = socketNameAndAppId.data(); in CreateClientSocket()
464 socketInfo.peerName = const_cast<char *>(pipeInfo.pipeId.c_str()); in CreateClientSocket()
466 socketInfo.peerNetworkId = networkId.data(); in CreateClientSocket()
467 socketInfo.pkgName = const_cast<char *>(PKG_NAME); in CreateClientSocket()
468 socketInfo.dataType = DATA_TYPE_BYTES; in CreateClientSocket()
469 int socketId = Socket(socketInfo); in CreateClientSocket()
534 SocketInfo socketInfo; in CreateSessionServerAdapter() local
536 socketInfo.name = socketNameAndAppId.data(); in CreateSessionServerAdapter()
537 socketInfo in CreateSessionServerAdapter()
[all...]
/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_common.c380 if (info->socketInfo.protocol != LNN_PROTOCOL_IP) { in ConvertToAuthConnInfo()
384 if (IsEnhanceP2pModuleId(info->socketInfo.moduleId)) { in ConvertToAuthConnInfo()
389 connInfo->info.ipInfo.moduleId = info->socketInfo.moduleId; in ConvertToAuthConnInfo()
390 connInfo->info.ipInfo.port = info->socketInfo.port; in ConvertToAuthConnInfo()
391 if (strcpy_s(connInfo->info.ipInfo.ip, IP_LEN, info->socketInfo.addr) != EOK) { in ConvertToAuthConnInfo()
/foundation/communication/netmanager_base/interfaces/innerkits/netmanagernative/include/
H A Dnetsys_net_diag_data.h104 static bool Unmarshalling(Parcel &parcel, NetDiagUnixSocketInfo &socketInfo);
119 static bool Unmarshalling(Parcel &parcel, NeyDiagNetProtoSocketInfo &socketInfo);
/foundation/communication/ipc/ipc/native/src/core/include/
H A Ddatabus_socket_listener.h86 std::shared_ptr<std::mutex> QueryOrNewInfoMutex(DBinderSocketInfo socketInfo);
/foundation/communication/ipc/services/dbinder/dbinder_service/src/socket/
H A Ddbinder_remote_listener.cpp147 SocketInfo socketInfo = { in CreateClientSocket() local
154 int32_t socketId = DBinderSoftbusClient::GetInstance().Socket(socketInfo); in CreateClientSocket()
/foundation/communication/dsoftbus/core/connection/interface/
H A Dsoftbus_conn_interface.h127 struct ConnSocketInfo socketInfo; member
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_transceiver.c483 connInfo->socketInfo.addr, sizeof(char) * IP_LEN); in TransConnInfoToConnOpt()
484 connOption->socketOption.protocol = connInfo->socketInfo.protocol; in TransConnInfoToConnOpt()
485 connOption->socketOption.port = connInfo->socketInfo.port; in TransConnInfoToConnOpt()
486 connOption->socketOption.moduleId = connInfo->socketInfo.moduleId; in TransConnInfoToConnOpt()
H A Dsoftbus_proxychannel_message.c121 if (strcpy_s(connInfo->info.ipInfo.ip, IP_LEN, info.socketInfo.addr) != EOK) { in TransProxyGetAuthConnInfo()
/foundation/communication/dsoftbus/tests/core/authentication/unittest/
H A Dauth_test.cpp1519 info.socketInfo.protocol = LNN_PROTOCOL_IP; in HWTEST_F()
1522 info.socketInfo.protocol = LNN_PROTOCOL_BR; in HWTEST_F()
/foundation/communication/dsoftbus/core/common/dfx/statistics/instant/
H A Dinstant_statistics.cpp598 (void)InstSetPeerDeviceIdForRemoteInfo(remoteInfo->wlanIp, std::string(info.socketInfo.addr));

Completed in 36 milliseconds