| /base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_server.cpp | 95 int32_t clientFd { -1 }; in Control()
98 param.programName, param.moduleType, tokenType, context.uid, context.pid, clientFd); in Control()
101 if (clientFd >= 0 && close(clientFd) < 0) { in Control()
102 FI_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 FI_HILOGE("Close client fd failed, error:%{public}s, clientFd:%{public}d", strerror(errno), clientFd); in Control()
[all...] |
| H A D | socket_session_manager.cpp | 86 int32_t uid, int32_t pid, int32_t& clientFd)
in AllocSocketFd()
112 clientFd = sockFds[1];
in AllocSocketFd()
85 AllocSocketFd(const std::string& programName, int32_t moduleType, int32_t tokenType, int32_t uid, int32_t pid, int32_t& clientFd) AllocSocketFd() argument
|
| /base/startup/init/services/param/linux/ |
| H A D | param_request.c | 134 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()
139 setsockopt(clientFd, SOL_SOCKET, SO_RCVTIMEO, (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, (cha in StartRequest()
[all...] |
| /base/sensors/sensor/test/fuzztest/services/service/createsocketchannel_fuzzer/ |
| H A D | createsocketchannel_fuzzer.cpp | 84 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()
|
| /base/sensors/sensor/services/src/ |
| H A D | stream_server.cpp | 82 int32_t &serverFd, int32_t &clientFd) in AddSocketPairInfo()
91 clientFd = sockFds[1]; in AddSocketPairInfo()
92 if (serverFd < 0 || clientFd < 0) { in AddSocketPairInfo()
93 SEN_HILOGE("ServerFd or clientFd is invalid"); in AddSocketPairInfo()
106 if (setsockopt(clientFd, SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
107 SEN_HILOGE("Setsockopt clientFd send buffer size failed, errno:%{public}d", errno); in AddSocketPairInfo()
110 if (setsockopt(clientFd, SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize)) != 0) { in AddSocketPairInfo()
111 SEN_HILOGE("Setsockopt clientFd recv buffer size failed, errno:%{public}d", errno); in AddSocketPairInfo()
124 close(clientFd); in AddSocketPairInfo()
81 AddSocketPairInfo(int32_t uid, int32_t pid, int32_t tokenType, int32_t &serverFd, int32_t &clientFd) AddSocketPairInfo() argument
|
| H A D | sensor_service_stub.cpp | 293 int32_t clientFd = -1; in CreateSocketChannelInner() local
294 int32_t ret = CreateSocketChannel(sensorClient, clientFd); in CreateSocketChannelInner()
299 if (!reply.WriteFileDescriptor(clientFd)) { in CreateSocketChannelInner()
301 close(clientFd); in CreateSocketChannelInner()
304 close(clientFd); in CreateSocketChannelInner()
|
| H A D | sensor_service.cpp | 529 ErrCode SensorService::CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) in CreateSocketChannel() argument
536 serverFd, std::ref(clientFd)); in CreateSocketChannel()
|
| /base/startup/init/services/loopevent/socket/ |
| H A D | le_socket.c | 217 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()
|
| /base/sensors/sensor/frameworks/native/src/ |
| H A D | sensor_service_client.cpp | 534 int32_t SensorServiceClient::CreateSocketClientFd(int32_t &clientFd) in HandleNetPacke() argument
542 int ret = sensorServer_->CreateSocketChannel(remoteObject, clientFd); in HandleNetPacke()
559 int32_t clientFd = -1; in HandleNetPacke() local
560 ret = CreateSocketClientFd(clientFd); in HandleNetPacke()
561 if (ret != ERR_OK || clientFd < 0) { in HandleNetPacke()
567 StreamSocketSetFd(streamSocketPtr_.get(), clientFd); in HandleNetPacke()
569 fd_ = clientFd; in HandleNetPacke()
|
| H A D | sensor_service_proxy.cpp | 258 ErrCode SensorServiceProxy::CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) in CreateSocketChannel() argument
281 clientFd = reply.ReadFileDescriptor(); in CreateSocketChannel()
282 if (clientFd < 0) { in CreateSocketChannel()
283 SEN_HILOGE("Invalid fd, clientFd:%{public}d", clientFd); in CreateSocketChannel()
|
| /base/msdp/device_status/intention/prototype/include/ |
| H A D | i_socket_session_manager.h | 32 int32_t uid, int32_t pid, int32_t& clientFd) = 0;
|
| /base/sensors/sensor/services/include/ |
| H A D | stream_server.h | 35 int32_t AddSocketPairInfo(int32_t uid, int32_t pid, int32_t tokenType, int32_t &serverFd, int32_t &clientFd);
|
| H A D | sensor_service.h | 64 ErrCode CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) override;
|
| /base/sensors/sensor/frameworks/native/include/ |
| H A D | i_sensor_service.h | 47 virtual ErrCode CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) = 0;
|
| H A D | sensor_service_proxy.h | 41 ErrCode CreateSocketChannel(sptr<IRemoteObject> sensorClient, int32_t &clientFd) override;
|
| H A D | sensor_service_client.h | 62 int32_t CreateSocketClientFd(int32_t &clientFd);
|
| /base/msdp/device_status/services/communication/service/src/ |
| H A D | devicestatus_srv_stub.cpp | 635 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 FI_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 FI_HILOGE("Close client fd failed, error:%{public}s, clientFd:%{public}d", strerror(errno), clientFd); in HandleAllocSocketFdStub()
[all...] |
| /base/msdp/device_status/intention/ipc/socket/include/ |
| H A D | socket_session_manager.h | 47 int32_t uid, int32_t pid, int32_t& clientFd) override;
|
| /base/msdp/device_status/test/unittest/intention/ipc/src/ |
| H A D | socket_session_test.cpp | 418 int32_t clientFd { -1 }; in HWTEST_F()
419 int32_t ret = g_socketSessionManager->AllocSocketFd("", 1, 1, 1, 1, clientFd); in HWTEST_F()
|