Home
last modified time | relevance | path

Searched refs:clientFd (Results 1 – 25 of 38) sorted by relevance

12

/ohos5.0/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
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, (const char *)buf, len); in Write()
117 static int32_t Read(int32_t clientFd, uint8_t *buf, const int32_t len) in Read() argument
119 int32_t ret = SppRead(clientFd, (char *)buf, len); in Read()
130 CONN_LOGI(CONN_BR, "[to get remotedeviceinfo, clientFd=%{public}d]", clientFd); in GetRemoteDeviceInfo()
[all …]
/ohos5.0/base/msdp/device_status/intention/ipc/socket/src/
H A Dsocket_server.cpp95 int32_t clientFd { -1 }; in Control() local
98 param.programName, param.moduleType, tokenType, context.uid, context.pid, clientFd); in Control()
101 if (clientFd >= 0 && close(clientFd) < 0) { in Control()
102 …HILOGE("Close client fd failed, error:%{public}s, clientFd:%{public}d", strerror(errno), clientFd); in Control()
106 AllocSocketPairReply replyData(tokenType, clientFd); in Control()
109 if (close(clientFd) < 0) { in Control()
110 …HILOGE("Close client fd failed, error:%{public}s, clientFd:%{public}d", strerror(errno), clientFd); in Control()
114 if (close(clientFd) < 0) { in Control()
115 …HILOGE("Close client fd failed, error:%{public}s, clientFd:%{public}d", strerror(errno), clientFd); in Control()
/ohos5.0/base/startup/init/services/param/linux/
H A Dparam_request.c134 int clientFd = socket(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0); in GetClientSocket() local
135 PARAM_CHECK(clientFd >= 0, return INVALID_SOCKET, "Failed to create socket"); in GetClientSocket()
136 int ret = ConnectServer(clientFd, CLIENT_PIPE_NAME); in GetClientSocket()
138 setsockopt(clientFd, SOL_SOCKET, SO_SNDTIMEO, (char *)&time, sizeof(struct timeval)); in GetClientSocket()
141 close(clientFd); in GetClientSocket()
142 clientFd = INVALID_SOCKET; in GetClientSocket()
144 return clientFd; in GetClientSocket()
147 static int StartRequest(int clientFd, ParamMessage *request, int timeout) in StartRequest() argument
150 ssize_t sendLen = send(clientFd, (char *)request, request->msgSize, 0); in StartRequest()
156 PARAM_LOGV("sendMessage sendLen fd %d %zd", clientFd, sendLen); in StartRequest()
[all …]
/ohos5.0/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()
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()
/ohos5.0/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);
/ohos5.0/base/sensors/sensor/services/src/
H A Dstream_server.cpp82 int32_t &serverFd, int32_t &clientFd) in AddSocketPairInfo() argument
91 clientFd = sockFds[1]; in AddSocketPairInfo()
92 if (serverFd < 0 || clientFd < 0) { in AddSocketPairInfo()
106 if (setsockopt(clientFd, SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
110 if (setsockopt(clientFd, SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
124 close(clientFd); in AddSocketPairInfo()
H A Dsensor_service_stub.cpp287 int32_t clientFd = -1; in CreateSocketChannelInner() local
288 int32_t ret = CreateSocketChannel(sensorClient, clientFd); in CreateSocketChannelInner()
293 if (!reply.WriteFileDescriptor(clientFd)) { in CreateSocketChannelInner()
295 close(clientFd); in CreateSocketChannelInner()
298 close(clientFd); in CreateSocketChannelInner()
/ohos5.0/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 …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()
/ohos5.0/base/sensors/sensor/test/fuzztest/services/service/createsocketchannel_fuzzer/
H A Dcreatesocketchannel_fuzzer.cpp84 int32_t clientFd = 0; in CreateSocketChannelFuzzTest() local
85 GetObject<int32_t>(clientFd, data, size); in CreateSocketChannelFuzzTest()
86 g_service->CreateSocketChannel(g_remote, clientFd); in CreateSocketChannelFuzzTest()
/ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/src/
H A Dsocket_server.cpp95 int32_t clientFd { -1 }; in Control() local
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() argument
92 clientFd = sockFds[1]; in AllocSocketFd()
/ohos5.0/base/startup/init/services/loopevent/socket/
H A Dle_socket.c217 int clientFd = -1; in AcceptSocket() local
220 clientFd = AcceptTcpSocket_(fd); in AcceptSocket()
222 clientFd = AcceptPipeSocket_(fd); in AcceptSocket()
227 SetNoBlock(clientFd); in AcceptSocket()
228 return clientFd; in AcceptSocket()
/ohos5.0/foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/
H A Dsocket_exec.cpp1602 int32_t clientFd = -1; in ExecTcpConnectionGetRemoteAddress() local
1610 clientFd = iter->second; in ExecTcpConnectionGetRemoteAddress()
1645 int32_t clientFd = -1; in ExecTcpConnectionGetLocalAddress() local
1650 clientFd = iter->second; in ExecTcpConnectionGetLocalAddress()
1722 int32_t clientFd = -1; in ExecTcpConnectionSend() local
1730 clientFd = iter->second; in ExecTcpConnectionSend()
1746 if (!IsRemoteConnect(context, clientFd)) { in ExecTcpConnectionSend()
2254 int32_t clientFd = -1; in TcpConnectionCloseCallback() local
2260 clientFd = iter->second; in TcpConnectionCloseCallback()
2266 if (shutdown(clientFd, SHUT_RDWR) != 0) { in TcpConnectionCloseCallback()
[all …]
/ohos5.0/base/msdp/device_status/services/communication/service/src/
H A Ddevicestatus_srv_stub.cpp635 int32_t clientFd = -1; in HandleAllocSocketFdStub() local
638 int32_t ret = AllocSocketFd(clientName, moduleId, clientFd, tokenType); in HandleAllocSocketFdStub()
641 if (clientFd >= 0) { in HandleAllocSocketFdStub()
642 if (close(clientFd) < 0) { in HandleAllocSocketFdStub()
643 …HILOGE("Close client fd failed, error:%{public}s, clientFd:%{public}d", strerror(errno), clientFd); in HandleAllocSocketFdStub()
649 if (!reply.WriteFileDescriptor(clientFd)) { in HandleAllocSocketFdStub()
651 if (close(clientFd) < 0) { in HandleAllocSocketFdStub()
652 …HILOGE("Close client fd failed, error:%{public}s, clientFd:%{public}d", strerror(errno), clientFd); in HandleAllocSocketFdStub()
658 …FI_HILOGD("Send clientFd to client, clientFd:%{public}d, tokenType:%{public}d", clientFd, tokenTyp… in HandleAllocSocketFdStub()
659 if (close(clientFd) < 0) { in HandleAllocSocketFdStub()
[all …]
/ohos5.0/base/sensors/sensor/frameworks/native/src/
H A Dsensor_service_client.cpp501 int32_t clientFd = -1; in HandleNetPacke() local
506 ret = sensorServer_->CreateSocketChannel(remoteObject, clientFd); in HandleNetPacke()
508 if (ret != ERR_OK || clientFd < 0) { in HandleNetPacke()
514 StreamSocketSetFd(streamSocketPtr_.get(), clientFd); in HandleNetPacke()
516 fd_ = clientFd; in HandleNetPacke()
H A Dsensor_service_proxy.cpp246 ErrCode SensorServiceProxy::CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) in CreateSocketChannel() argument
267 clientFd = reply.ReadFileDescriptor(); in CreateSocketChannel()
268 if (clientFd < 0) { in CreateSocketChannel()
269 SEN_HILOGE("Invalid fd, clientFd:%{public}d", clientFd); in CreateSocketChannel()
/ohos5.0/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()
/ohos5.0/foundation/communication/dsoftbus/tests/core/connection/common/unittest/
H A Dsoftbus_conn_common_test.cpp475 int clientFd = tcp->OpenClientSocket(nullptr, "127.5.0.1", false); variable
476 int ret = (clientFd < 0) ? SOFTBUS_INVALID_PARAM : SOFTBUS_OK;
478 ssize_t bytes = ConnSendSocketData(clientFd, "Hello world", 11, 0);
480 ConnShutdownSocket(clientFd);
/ohos5.0/foundation/multimodalinput/input/intention/prototype/include/
H A Di_socket_session_manager.h32 int32_t uid, int32_t pid, int32_t& clientFd) = 0;
/ohos5.0/base/msdp/device_status/intention/prototype/include/
H A Di_socket_session_manager.h32 int32_t uid, int32_t pid, int32_t& clientFd) = 0;
/ohos5.0/foundation/communication/netstack/frameworks/js/napi/tls/src/
H A Dmonitor_server.cpp505 [this, ServerEventManager](auto clientFd, std::shared_ptr<EventManager> eventManager) { in TLSServerRegEvent() argument
507 messageParma->clientID = clientFd; in TLSServerRegEvent()
529 … ptrConnection->OnMessage([this, eventManager](auto clientFd, auto data, auto remoteInfo) { in TLSConnectionRegEvent() argument
531 messageRecvParma->clientID = clientFd; in TLSConnectionRegEvent()
545 ptrConnection->OnClose([this, eventManager](auto clientFd) { in TLSConnectionRegEvent() argument
/ohos5.0/base/sensors/sensor/services/include/
H A Dstream_server.h35 …dSocketPairInfo(int32_t uid, int32_t pid, int32_t tokenType, int32_t &serverFd, int32_t &clientFd);
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/include/manager/
H A Dvpn_manager.h51 int32_t SendVpnInterfaceFdToClient(int32_t clientFd, int32_t tunFd);
/ohos5.0/base/sensors/sensor/frameworks/native/include/
H A Di_sensor_service.h47 virtual ErrCode CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) = 0;

12