| /base/startup/init/test/exec_test/ |
| H A D | client.c | 33 int sockFd = socket(PF_UNIX, SOCK_DGRAM, 0);
in main() local
34 if (sockFd < 0) {
in main()
46 if (connect(sockFd, (struct sockaddr *)&addr, sizeof(addr))) {
in main()
48 close(sockFd);
in main()
53 close(sockFd);
in main()
56 ret = write(sockFd, argv[ARG_COUNT], strlen(argv[ARG_COUNT]));
in main()
60 close(sockFd);
in main()
|
| H A D | server.c | 23 int sockFd = GetControlSocket("serversock");
in main() local
24 if (sockFd < 0) {
in main()
30 if (read(sockFd, buffer, sizeof(buffer) - 1) > 0) {
in main()
|
| /base/startup/init/services/init/ |
| H A D | init_service_socket.c | 80 if (setsockopt(sockopt->sockFd, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on))) { in SetSocketOptionAndBind()
87 if (setsockopt(sockopt->sockFd, SOL_SOCKET, SO_RCVBUFFORCE, &buffSize, sizeof(buffSize))) { in SetSocketOptionAndBind()
99 if (bind(sockopt->sockFd, (struct sockaddr *)&(addr.addrnl), sizeof(addr.addrnl))) { in SetSocketOptionAndBind()
108 if (bind(sockopt->sockFd, (struct sockaddr *)&(addr.addrun), sizeof(addr.addrun))) { in SetSocketOptionAndBind()
132 if (sockopt->sockFd >= 0) { in CreateSocket()
133 close(sockopt->sockFd); in CreateSocket()
134 sockopt->sockFd = -1; in CreateSocket()
136 sockopt->sockFd = socket(sockopt->family, sockopt->type, sockopt->protocol); in CreateSocket()
137 INIT_ERROR_CHECK(sockopt->sockFd >= 0, return -1, "socket fail %d ", errno); in CreateSocket()
141 close(sockopt->sockFd); in CreateSocket()
[all...] |
| /base/startup/init/ueventd/ |
| H A D | ueventd.c | 290 void ProcessUevent(int sockFd, char **devices, int num) in ProcessUevent() argument
296 while ((n = ReadUeventMessage(sockFd, ueventBuffer, sizeof(ueventBuffer) - 1)) > 0) { in ProcessUevent()
310 static void DoTrigger(const char *ueventPath, int sockFd, char **devices, int num) in DoTrigger() argument
332 if (sockFd >= 0) { in DoTrigger()
333 ProcessUevent(sockFd, devices, num); in DoTrigger()
337 static void Trigger(const char *path, int sockFd, char **devices, int num) in Trigger() argument
356 Trigger(pathBuffer, sockFd, devices, num); in Trigger()
366 DoTrigger(ueventBuffer, sockFd, devices, num); in Trigger()
372 void RetriggerUeventByPath(int sockFd, char *path) in RetriggerUeventByPath() argument
374 Trigger(path, sockFd, NUL in RetriggerUeventByPath()
377 RetriggerUevent(int sockFd, char **devices, int num) RetriggerUevent() argument
[all...] |
| H A D | ueventd_socket.c | 61 ssize_t ReadUeventMessage(int sockFd, char *buffer, size_t length) in ReadUeventMessage() argument
70 if (sockFd < 0 || buffer == NULL) { in ReadUeventMessage()
83 n = recvmsg(sockFd, &msghdr, 0); in ReadUeventMessage()
|
| /base/startup/init/ueventd/include/ |
| H A D | ueventd.h | 77 void RetriggerUevent(int sockFd, char **devices, int num);
78 void RetriggerUeventByPath(int sockFd, char *path);
79 void ProcessUevent(int sockFd, char **devices, int num);
|
| H A D | ueventd_socket.h | 27 ssize_t ReadUeventMessage(int sockFd, char *buffer, size_t length);
|
| /base/startup/init/interfaces/innerkits/fd_holder/ |
| H A D | fd_holder.c | 27 int sockFd; in BuildClientSocket() local
28 sockFd = socket(AF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC, 0); in BuildClientSocket()
29 BEGET_ERROR_CHECK(sockFd >= 0, return -1, "Failed to build socket, err = %d", errno); in BuildClientSocket()
36 BEGET_ERROR_CHECK(ret == 0, close(sockFd); in BuildClientSocket()
41 ret = connect(sockFd, (struct sockaddr *)&addr, len); in BuildClientSocket()
42 BEGET_ERROR_CHECK(ret >= 0, close(sockFd); in BuildClientSocket()
44 return sockFd; in BuildClientSocket()
|
| /base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_connection.cpp | 49 int32_t sockFd = socket(); in Connect() local
50 if (sockFd < 0) { in Connect()
53 return std::make_shared<SocketConnection>(sockFd, recv, onDisconnected); in Connect()
|
| H A D | socket_session_manager.cpp | 125 bool SocketSessionManager::SetBufferSize(int32_t sockFd, int32_t bufSize)
in SetBufferSize() argument
127 if (::setsockopt(sockFd, SOL_SOCKET, SO_SNDBUF, &bufSize, sizeof(bufSize)) != 0) {
in SetBufferSize()
128 FI_HILOGE("setsockopt(%{public}d) failed:%{public}s", sockFd, ::strerror(errno));
in SetBufferSize()
131 if (::setsockopt(sockFd, SOL_SOCKET, SO_RCVBUF, &bufSize, sizeof(bufSize)) != 0) {
in SetBufferSize()
132 FI_HILOGE("setsockopt(%{public}d) failed:%{public}s", sockFd, ::strerror(errno));
in SetBufferSize()
|
| /base/startup/init/test/mock/init/ueventd/ |
| H A D | ueventd.c | 16 void RetriggerUeventByPath(int sockFd, char *path) in RetriggerUeventByPath() argument
|
| /base/security/selinux_adapter/interfaces/policycoreutils/include/ |
| H A D | selinux_parameter.h | 41 int sockFd; member
|
| /base/startup/init/services/init/include/ |
| H A D | init_service_socket.h | 70 int sockFd; member
|
| /base/request/request/frameworks/native/include/ |
| H A D | request_service_proxy.h | 46 int32_t OpenChannel(int32_t &sockFd) override;
|
| H A D | request_service_interface.h | 45 virtual int32_t OpenChannel(int32_t &sockFd) = 0;
|
| H A D | response_message_receiver.h | 37 ResponseMessageReceiver(IResponseMessageHandler *handler, int32_t sockFd);
|
| /base/msdp/device_status/intention/ipc/socket/include/ |
| H A D | socket_session_manager.h | 67 bool SetBufferSize(int32_t sockFd, int32_t bufSize);
|
| /base/security/selinux_adapter/framework/policycoreutils/src/ |
| H A D | param_checker.c | 90 int rc = getpeercon(info->sockFd, &srcContext); in SetParamCheck()
|
| /base/startup/init/test/unittest/init/ |
| H A D | service_socket_unittest.cpp | 48 sockopt->sockFd = -1; in HWTEST_F()
|
| H A D | service_unittest.cpp | 164 ServiceSocket tmpSock = { .next = nullptr, .sockFd = 0 }; in HWTEST_F()
165 ServiceSocket tmpSock1 = { .next = &tmpSock, .sockFd = 0 }; in HWTEST_F()
298 service->socketCfg->sockFd = 0; in HWTEST_F()
|
| /base/startup/init/test/unittest/param/ |
| H A D | param_stub.h | 60 int sockFd;
member
|
| /base/startup/init/services/param/include/ |
| H A D | param_security.h | 71 int32_t sockFd;
member
|
| /base/request/request/frameworks/native/src/ |
| H A D | request_manager_impl.cpp | 395 int32_t sockFd = -1; in EnsureChannelOpen() local
396 int32_t ret = proxy->OpenChannel(sockFd); in EnsureChannelOpen()
401 REQUEST_HILOGD("EnsureChannelOpen ok: %{public}d", sockFd); in EnsureChannelOpen()
402 msgReceiver_ = std::make_shared<ResponseMessageReceiver>(this, sockFd); in EnsureChannelOpen()
|
| H A D | request_service_proxy.cpp | 364 int32_t RequestServiceProxy::OpenChannel(int32_t &sockFd)
in OpenChannel() argument
381 sockFd = reply.ReadFileDescriptor();
in OpenChannel()
383 REQUEST_HILOGD("End Request OpenChannel ok, fd: %{public}d", sockFd);
in OpenChannel()
|
| /base/request/request/test/unittest/cpp_test/fwkTest/src/ |
| H A D | response_message_receiver_test.cpp | 384 int32_t sockFd = -1; in HWTEST_F() local
385 ResponseMessageReceiver receiver = ResponseMessageReceiver(&handler, sockFd); in HWTEST_F()
702 int32_t sockFd = -1; in HWTEST_F() local
703 ResponseMessageReceiver receiver = ResponseMessageReceiver(&handler, sockFd); in HWTEST_F()
|