Searched refs:clientSocket (Results 1 - 7 of 7) sorted by relevance
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/core/ |
| H A D | nstackx_socket.c | 87 static int32_t ConnectTcpServerWithTargetDev(Socket *clientSocket, const struct sockaddr_in *sockAddr, in ConnectTcpServerWithTargetDev() argument
92 clientSocket->sockfd = socket(AF_INET, SOCK_STREAM, 0); in ConnectTcpServerWithTargetDev()
93 if (clientSocket->sockfd == INVALID_SOCKET) { in ConnectTcpServerWithTargetDev()
97 if (SetTcpSocketBufSize(clientSocket->sockfd, NSTACKX_TCP_SOCKET_BUFFER_SIZE) != NSTACKX_EOK) { in ConnectTcpServerWithTargetDev()
100 if (SetSocketNonBlock(clientSocket->sockfd) != NSTACKX_EOK) { in ConnectTcpServerWithTargetDev()
104 BindToDevInTheSameLan(clientSocket->sockfd, sockAddr); in ConnectTcpServerWithTargetDev()
107 if (BindToTargetDev(clientSocket->sockfd, localInterface) != NSTACKX_EOK) { in ConnectTcpServerWithTargetDev()
113 int32_t ret = connect(clientSocket->sockfd, (struct sockaddr *)sockAddr, addrLen); in ConnectTcpServerWithTargetDev()
122 clientSocket->dstAddr = *sockAddr; in ConnectTcpServerWithTargetDev()
126 CloseSocketInner(clientSocket in ConnectTcpServerWithTargetDev()
131 ConnectUdpServerWithTargetDev(Socket *clientSocket, const struct sockaddr_in *sockAddr, const char *localInterface) ConnectUdpServerWithTargetDev() argument
420 Socket *clientSocket = calloc(1, sizeof(Socket)); AcceptSocket() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | softbus_client.cpp | 104 int32_t clientSocket = Socket(socketInfo); in OpenConnect() local
105 if (clientSocket <= 0) { in OpenConnect()
107 ZLOGE("Create the client Socket:%{public}d failed, peerName:%{public}s", clientSocket, socketInfo.peerName); in OpenConnect()
110 auto task = [type = type_, clientSocket, listener, client = shared_from_this()]() { in OpenConnect()
116 KvStoreUtils::ToBeAnonymous(client->device_.deviceId).c_str(), clientSocket, type); in OpenConnect()
117 auto status = client->Open(clientSocket, QOS_INFOS[type % QOS_BUTT], listener); in OpenConnect()
|
| /foundation/ability/ability_runtime/services/appmgr/src/ |
| H A D | app_spawn_socket.cpp | 109 void AppSpawnSocket::SetClientSocket(const std::shared_ptr<OHOS::AppSpawn::ClientSocket> clientSocket) in SetClientSocket() argument
111 clientSocket_ = clientSocket; in SetClientSocket()
|
| /foundation/communication/netmanager_base/services/netmanagernative/include/netsys/ |
| H A D | dns_proxy_listen.h | 82 static void DnsSendRecvParseData(int32_t clientSocket, char *requestData, int32_t resLen,
|
| /foundation/communication/bluetooth/frameworks/inner/src/ |
| H A D | bluetooth_socket.cpp | 309 explicit BluetoothSocketObserverImp(std::weak_ptr<ClientSocket> clientSocket) : clientSocket_(clientSocket) in BluetoothSocketObserverImp() argument
437 HILOGE("clientSocket proxy is nullptr"); in Connect()
654 std::shared_ptr<ClientSocket> clientSocket = std::make_shared<ClientSocket>(acceptFd_, acceptAddress_, type_); in Accept() local
661 return clientSocket; in Accept()
|
| /foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/ |
| H A D | dns_proxy_listen.cpp | 195 void DnsProxyListen::DnsSendRecvParseData(int32_t clientSocket, char *requesData, int32_t resLen, in DnsSendRecvParseData() argument
204 if (PollUdpDataTransfer::PollUdpSendData(clientSocket, requesData, resLen, proxyAddr, addrLen) < 0) { in DnsSendRecvParseData()
|
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | softbus_adapter_standard.cpp | 364 int clientSocket = GetSocket(pipeInfo, deviceId);
in SendData() local
365 if (clientSocket == INVALID_SOCKET_ID) {
in SendData()
|
Completed in 6 milliseconds