Home
last modified time | relevance | path

Searched refs:clientFd (Results 1 - 22 of 22) sorted by relevance

/foundation/CastEngine/castengine_wifi_display/services/network/server/
H A Dtcp_server.cpp115 int32_t clientFd = SocketUtils::AcceptSocket(fd, &clientAddr, &addrLen); in OnServerReadable() local
116 if (clientFd < 0) { in OnServerReadable()
120 SocketUtils::SetNonBlocking(clientFd); in OnServerReadable()
121 SocketUtils::SetNoDelay(clientFd, true); in OnServerReadable()
122 SocketUtils::SetSendBuf(clientFd); in OnServerReadable()
123 SocketUtils::SetRecvBuf(clientFd); in OnServerReadable()
124 SocketUtils::SetCloseWait(clientFd); in OnServerReadable()
125 SocketUtils::SetCloExec(clientFd, true); in OnServerReadable()
126 SocketUtils::SetKeepAlive(clientFd); in OnServerReadable()
127 SHARING_LOGD("onReadable accept client fd: %{public}d.", clientFd); in OnServerReadable()
[all...]
/foundation/communication/dsoftbus/core/adapter/br/mock/
H A Dwrapper_br_interface.c89 static int32_t DisConnect(int32_t clientFd) in DisConnect() argument
91 CONN_LOGI(CONN_BR, "[DisConnect, and clientFd=%{public}d]", clientFd); in DisConnect()
92 return SppDisconnect(clientFd); in DisConnect()
95 static bool IsConnected(int32_t clientFd) in IsConnected() argument
97 CONN_LOGI(CONN_BR, "[get connected state from bt, clientFd=%{public}d]", clientFd); in IsConnected()
98 return IsSppConnected(clientFd); in IsConnected()
112 static int32_t Write(int32_t clientFd, const uint8_t *buf, const int32_t len) in Write() argument
114 return SppWrite(clientFd, (cons in Write()
117 Read(int32_t clientFd, uint8_t *buf, const int32_t len) Read() argument
128 GetRemoteDeviceInfo(int32_t clientFd, const BluetoothRemoteDevice *device) GetRemoteDeviceInfo() argument
[all...]
/foundation/communication/dsoftbus/core/adapter/br/include/
H A Dwrapper_br_interface.h52 int32_t (*DisConnect)(int32_t clientFd);
53 bool (*IsConnected)(int32_t clientFd);
55 int32_t (*Write)(int32_t clientFd, const uint8_t *buf, const int32_t length);
56 int32_t (*Read)(int32_t clientFd, uint8_t *buf, const int32_t length);
57 int32_t (*GetRemoteDeviceInfo)(int32_t clientFd, const BluetoothRemoteDevice* device);
/foundation/communication/ipc/ipc/test/rpc/socket_trans/src/
H A Drpc_mini_socket_trans.c111 int32_t clientFd = *(int32_t *)args; in HandleAccept() local
114 ret = g_callback.OnConnected(clientFd, 0); in HandleAccept()
124 ssize_t readLen = read(clientFd, buf, DEFAULT_PACKET_SIZE); in HandleAccept()
127 g_callback.OnDisconnected(clientFd); in HandleAccept()
128 TcpShutDown(clientFd); in HandleAccept()
133 TcpShutDown(clientFd); in HandleAccept()
136 ret = g_callback.OnRecieved(clientFd, (void *)buf, (uint32_t)readLen); in HandleAccept()
180 int32_t clientFd = accept(fd, (struct sockaddr *)&addr, &len); in OpenTcpServerSocket() local
181 RPC_LOG_INFO("accept get fd %d", clientFd); in OpenTcpServerSocket()
196 ret = pthread_create(&threadId, &threadAttr, HandleAccept, (void *)&clientFd); in OpenTcpServerSocket()
[all...]
H A Drpc_socket_trans.c108 int32_t clientFd = *(int32_t *)args; in HandleAccept() local
111 ret = g_callback.OnConnected(clientFd, 0); in HandleAccept()
121 ssize_t readLen = read(clientFd, buf, DEFAULT_PACKET_SIZE); in HandleAccept()
124 g_callback.OnDisconnected(clientFd); in HandleAccept()
125 TcpShutDown(clientFd); in HandleAccept()
130 TcpShutDown(clientFd); in HandleAccept()
133 ret = g_callback.OnRecieved(clientFd, (void *)buf, (uint32_t)readLen); in HandleAccept()
175 int32_t clientFd = accept(fd, (struct sockaddr *)&addr, &len); in OpenTcpServerSocket() local
177 pthread_create(&threadId, NULL, HandleAccept, (void *)&clientFd); in OpenTcpServerSocket()
/foundation/communication/netmanager_base/services/netmanagernative/src/manager/
H A Dvpn_manager.cpp252 int32_t VpnManager::SendVpnInterfaceFdToClient(int32_t clientFd, int32_t tunFd) in SendVpnInterfaceFdToClient() argument
284 if (sendmsg(clientFd, &message, 0) < 0) { in SendVpnInterfaceFdToClient()
285 NETNATIVE_LOGE("sendmsg error: %{public}d, clientfd[%{public}d], tunfd[%{public}d]", errno, clientFd, tunFd); in SendVpnInterfaceFdToClient()
304 int32_t clientFd = accept(serverfd, reinterpret_cast<sockaddr *>(&clientAddr), &len); in StartUnixSocketListen() local
305 if (clientFd < 0) { in StartUnixSocketListen()
310 SendVpnInterfaceFdToClient(clientFd, tunFd_); in StartUnixSocketListen()
311 close(clientFd); in StartUnixSocketListen()
/foundation/multimodalinput/input/intention/ipc/socket/src/
H A Dsocket_server.cpp95 int32_t clientFd { -1 }; in Control()
98 param.programName, param.moduleType, tokenType, context.uid, context.pid, clientFd); in Control()
103 AllocSocketPairReply replyData(tokenType, clientFd); in Control()
H A Dsocket_session_manager.cpp63 int32_t uid, int32_t pid, int32_t& clientFd) in AllocSocketFd()
92 clientFd = sockFds[1]; in AllocSocketFd()
62 AllocSocketFd(const std::string& programName, int32_t moduleType, int32_t tokenType, int32_t uid, int32_t pid, int32_t& clientFd) AllocSocketFd() argument
/foundation/multimodalinput/input/intention/prototype/include/
H A Di_socket_session_manager.h32 int32_t uid, int32_t pid, int32_t& clientFd) = 0;
/foundation/communication/netmanager_base/services/netmanagernative/include/manager/
H A Dvpn_manager.h51 int32_t SendVpnInterfaceFdToClient(int32_t clientFd, int32_t tunFd);
/foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/
H A Dsocket_exec.cpp1618 int32_t clientFd = -1; in ExecTcpConnectionGetRemoteAddress() local
1626 clientFd = iter->second; in ExecTcpConnectionGetRemoteAddress()
1640 int ret = getsockname(clientFd, &sockAddr, &len); in ExecTcpConnectionGetRemoteAddress()
1647 return GetIPv4Address(context, clientFd, sockAddr); in ExecTcpConnectionGetRemoteAddress()
1649 return GetIPv6Address(context, clientFd, sockAddr); in ExecTcpConnectionGetRemoteAddress()
1661 int32_t clientFd = -1; in ExecTcpConnectionGetLocalAddress() local
1666 clientFd = iter->second; in ExecTcpConnectionGetLocalAddress()
1673 if (getsockname(clientFd, reinterpret_cast<struct sockaddr *>(&addr), &addrLen) < 0) { in ExecTcpConnectionGetLocalAddress()
1699 static bool IsRemoteConnect(TcpServerSendContext *context, int32_t clientFd) in IsRemoteConnect() argument
1703 if (getsockname(clientFd, in IsRemoteConnect()
1738 int32_t clientFd = -1; ExecTcpConnectionSend() local
1839 IsClientFdClosed(int32_t clientFd) IsClientFdClosed() argument
[all...]
/foundation/communication/dsoftbus/tests/core/connection/common/unittest/
H A Dsoftbus_conn_common_test.cpp475 int32_t clientFd = tcp->OpenClientSocket(nullptr, "127.5.0.1", false); in HWTEST_F() local
476 int32_t ret = (clientFd < 0) ? SOFTBUS_INVALID_PARAM : SOFTBUS_OK; in HWTEST_F()
478 ssize_t bytes = ConnSendSocketData(clientFd, "Hello world", 11, 0); in HWTEST_F()
480 ConnShutdownSocket(clientFd); in HWTEST_F()
/foundation/communication/dsoftbus/tests/core/connection/br/
H A Dbr_connection_test.cpp84 int32_t Read(int32_t clientFd, uint8_t *buf, const int32_t length) in Read() argument
86 (void)clientFd; in Read()
94 int32_t Write(int32_t clientFd, const uint8_t *buf, const int32_t length) in Write() argument
96 (void)clientFd; in Write()
H A Dconnection_br_connection_test.cpp42 int32_t GetRemoteDeviceInfo(int32_t clientFd, const BluetoothRemoteDevice *device) in GetRemoteDeviceInfo() argument
45 return clientFd; in GetRemoteDeviceInfo()
/foundation/multimodalinput/input/intention/ipc/socket/include/
H A Dsocket_session_manager.h46 int32_t uid, int32_t pid, int32_t& clientFd) override;
/foundation/communication/dhcp/test/unittest/services/dhcp_server/unittest/
H A Ddhcp_message_sim.h66 int clientFd; member
H A Ddhcp_message_sim.cpp172 context->clientFd = 1; in InitialDhcpClient()
/foundation/CastEngine/castengine_wifi_display/services/network/socket/
H A Dsocket_utils.cpp507 int32_t clientFd = accept(fd, reinterpret_cast<struct sockaddr *>(clientAddr), addrLen); in AcceptSocket() local
508 if (clientFd < 0) { in AcceptSocket()
512 return clientFd; in AcceptSocket()
/foundation/communication/netstack/frameworks/js/napi/tls/src/
H A Dmonitor_server.cpp505 [this, ServerEventManager](auto clientFd, std::shared_ptr<EventManager> eventManager) { in TLSServerRegEvent()
507 messageParma->clientID = clientFd; in TLSServerRegEvent()
529 ptrConnection->OnMessage([this, eventManager](auto clientFd, auto data, auto remoteInfo) { in TLSConnectionRegEvent()
531 messageRecvParma->clientID = clientFd; in TLSConnectionRegEvent()
545 ptrConnection->OnClose([this, eventManager](auto clientFd) { in TLSConnectionRegEvent()
/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_base_listener.c848 int32_t clientFd = -1; in ProcessSpecifiedServerAcceptEvent() local
859 status = SOFTBUS_TEMP_FAILURE_RETRY(socketIf->AcceptClient(listenFd, &clientAddr, &clientFd)); in ProcessSpecifiedServerAcceptEvent()
869 "clientIp=%{public}s, clientFd=%{public}d", wakeupTrace, module, listenFd, animizedIp, clientFd); in ProcessSpecifiedServerAcceptEvent()
870 listener->onConnectEvent(module, clientFd, &clientAddr); in ProcessSpecifiedServerAcceptEvent()
874 "listenFd=%{public}d, clientIp=%{public}s, clientFd=%{public}d", in ProcessSpecifiedServerAcceptEvent()
875 wakeupTrace, module, listenFd, animizedIp, clientFd); in ProcessSpecifiedServerAcceptEvent()
876 ConnCloseSocket(clientFd); in ProcessSpecifiedServerAcceptEvent()
/foundation/multimodalinput/input/service/connect_manager/src/
H A Dmultimodal_input_connect_stub.cpp478 int32_t clientFd = INVALID_SOCKET_FD; in StubHandleAllocSocketFd() local
480 int32_t ret = AllocSocketFd(req->data.clientName, req->data.moduleId, clientFd, tokenType); in StubHandleAllocSocketFd()
483 if (clientFd >= 0) { in StubHandleAllocSocketFd()
484 close(clientFd); in StubHandleAllocSocketFd()
489 if (!reply.WriteFileDescriptor(clientFd)) { in StubHandleAllocSocketFd()
491 close(clientFd); in StubHandleAllocSocketFd()
496 MMI_HILOGI("Send clientFd to client, clientFd:%{public}d, tokenType:%{public}d", clientFd, tokenType); in StubHandleAllocSocketFd()
497 close(clientFd); in StubHandleAllocSocketFd()
[all...]
/foundation/communication/bluetooth/frameworks/inner/src/
H A Dbluetooth_socket.cpp692 int clientFd = *(reinterpret_cast<int *>(CMSG_DATA(cmptr))); in RecvSocketFd() local
711 return clientFd; in RecvSocketFd()

Completed in 21 milliseconds