| /base/startup/init/interfaces/innerkits/fd_holder/ |
| H A D | fd_holder.c | 74 static int ServiceSendFds(const char *serviceName, int *fds, int fdCount, bool doPoll) in ServiceSendFds() argument
94 if (BuildControlMessage(&msghdr, fds, fdCount, true) < 0) { in ServiceSendFds()
125 int ServiceSaveFd(const char *serviceName, int *fds, int fdCount) in ServiceSaveFd() argument
129 fdCount < 0 || fdCount > MAX_HOLD_FDS) { in ServiceSaveFd()
133 return ServiceSendFds(serviceName, fds, fdCount, false); in ServiceSaveFd()
136 int ServiceSaveFdWithPoll(const char *serviceName, int *fds, int fdCount) in ServiceSaveFdWithPoll() argument
140 fdCount < 0 || fdCount > MAX_HOLD_FDS) { in ServiceSaveFdWithPoll()
144 return ServiceSendFds(serviceName, fds, fdCount, tru in ServiceSaveFdWithPoll()
167 int fdCount = 0; ServiceGetFd() local
[all...] |
| H A D | fd_holder_internal.c | 26 int BuildControlMessage(struct msghdr *msghdr, int *fds, int fdCount, bool sendUcred) in BuildControlMessage() argument
28 if (msghdr == NULL || (fdCount > 0 && fds == NULL)) { in BuildControlMessage()
33 if (fdCount > 0) { in BuildControlMessage()
34 msghdr->msg_controllen = CMSG_SPACE(sizeof(int) * fdCount); in BuildControlMessage()
50 if (fdCount > 0) { in BuildControlMessage()
53 cmsg->cmsg_len = CMSG_LEN(sizeof(int) * fdCount); in BuildControlMessage()
54 int ret = memcpy_s(CMSG_DATA(cmsg), cmsg->cmsg_len, fds, sizeof(int) * fdCount); in BuildControlMessage()
88 size_t fdCount = 0; in GetFdsFromMsg() local
92 fdCount = (cmsg->cmsg_len - CMSG_LEN(0)) / sizeof(int); in GetFdsFromMsg()
93 BEGET_ERROR_CHECK(fdCount < in GetFdsFromMsg()
[all...] |
| H A D | fd_holder_internal.h | 43 int BuildControlMessage(struct msghdr *msghdr, int *fds, int fdCount, bool sendUcred);
|
| /base/startup/init/services/init/standard/ |
| H A D | fd_holder_service.c | 35 static int HandlerHoldFds(Service *service, int *fds, size_t fdCount, const char *pollStr) in HandlerHoldFds() argument
37 if (fds == NULL || fdCount == 0 || fdCount > MAX_HOLD_FDS) { in HandlerHoldFds()
43 for (size_t i = 0; i < fdCount; i++) { in HandlerHoldFds()
46 if (UpdaterServiceFds(service, fds, fdCount) < 0) { in HandlerHoldFds()
108 static inline void CloseFds(int *fds, size_t fdCount) in CloseFds() argument
113 for (size_t i = 0; i < fdCount; i++) { in CloseFds()
121 size_t fdCount = 0; in HandlerFdHolder() local
127 int *fds = ReceiveFds(sock, iovec, &fdCount, true, &requestPid); in HandlerFdHolder()
135 CloseFds(fds, fdCount); in HandlerFdHolder()
[all...] |
| /base/startup/init/interfaces/innerkits/include/ |
| H A D | fd_holder.h | 24 int *ServiceGetFd(const char *serviceName, size_t *fdCount);
29 int ServiceSaveFdWithPoll(const char *serviceName, int *fds, int fdCount);
34 int ServiceSaveFd(const char *serviceName, int *fds, int fdCount);
|
| /base/startup/init/test/exec_test/ |
| H A D | fd_holder_test.c | 42 int fdCount = i;
in SaveFds() local
43 BEGET_LOGI("fdCount = %d\n", fdCount);
in SaveFds()
44 if (fdCount <= 0) {
in SaveFds()
48 int ret = ServiceSaveFd(serviceName, fds, (size_t)fdCount);
in SaveFds()
|
| /base/startup/init/test/fuzztest/servicesavefdwithpoll_fuzzer/ |
| H A D | servicesavefdwithpoll_fuzzer.cpp | 26 int fdCount = 10; // fd count in FuzzServiceSaveFdWithPoll() local
27 if (!ServiceSaveFdWithPoll(str.c_str(), fds, fdCount)) { in FuzzServiceSaveFdWithPoll()
|
| /base/startup/init/test/fuzztest/servicegetfd_fuzzer/ |
| H A D | servicegetfd_fuzzer.cpp | 25 size_t fdCount[1] = {0}; in FuzzServiceGetFd() local
26 if (!ServiceGetFd(str.c_str(), fdCount)) { in FuzzServiceGetFd()
|
| /base/startup/init/services/init/ |
| H A D | init_common_service.c | 322 // fdCount > 0, There is no reason fds is NULL
in CloseServiceFds()
323 if (service->fdCount != 0) {
in CloseServiceFds()
324 size_t fdCount = service->fdCount;
in CloseServiceFds() local
326 for (size_t i = 0; i < fdCount; i++) {
in CloseServiceFds()
334 service->fdCount = 0;
in CloseServiceFds()
344 if (service->fdCount == 0 || service->fds == NULL) {
in PublishHoldFds()
354 for (size_t i = 0; i < service->fdCount; i++) {
in PublishHoldFds()
692 if (service->fdCount != 0) {
in ServiceStop()
859 int UpdaterServiceFds(Service *service, int *fds, size_t fdCount)
in UpdaterServiceFds() argument
[all...] |
| /base/startup/appspawn/modules/native_adapter/ |
| H A D | native_adapter.cpp | 44 if (recvCtx.fdCount <= 0) { in BuildFdInfoMap()
45 APPSPAWN_LOGI("no need to build fd info %{public}d, %{public}d", recvCtx.fds != NULL, recvCtx.fdCount); in BuildFdInfoMap()
70 APPSPAWN_CHECK(findFdIndex < recvCtx.fdCount && recvCtx.fds[findFdIndex] > 0, in BuildFdInfoMap()
73 if (findFdIndex >= recvCtx.fdCount) { in BuildFdInfoMap()
|
| /base/startup/appspawn/modules/common/ |
| H A D | appspawn_common.c | 482 int fdCount = property->message->connection->receiverCtx.fdCount; in CloseFdArgs() local
484 if (fds != NULL && fdCount > 0) { in CloseFdArgs()
485 for (int i = 0; i < fdCount; i++) { in CloseFdArgs()
491 property->message->connection->receiverCtx.fdCount = 0; in CloseFdArgs()
504 APPSPAWN_CHECK(recvCtx.fds != NULL && recvCtx.fdCount > 0, return 0, in SetFdEnv()
505 "no need set fd info %{public}d, %{public}d", recvCtx.fds != NULL, recvCtx.fdCount); in SetFdEnv()
521 APPSPAWN_CHECK(findFdIndex < recvCtx.fdCount && recvCtx.fds[findFdIndex] > 0, return -1, in SetFdEnv()
523 findFdIndex, recvCtx.fdCount, recvCtx.fds[findFdIndex]); in SetFdEnv()
530 if (findFdIndex >= recvCtx.fdCount) { in SetFdEnv()
[all...] |
| /base/startup/init/test/unittest/innerkits/ |
| H A D | innerkits_unittest.cpp | 421 size_t fdCount = 0; in HWTEST_F() local
424 ServiceGetFd("testService", &fdCount); in HWTEST_F()
428 ServiceGetFd(wrongName, &fdCount); in HWTEST_F()
434 fds = ServiceGetFd("testServiceName", &fdCount); in HWTEST_F()
462 size_t fdCount = 0; in HWTEST_F() local
467 GetFdsFromMsg(&fdCount, &requestPid, msghdr); in HWTEST_F()
469 GetFdsFromMsg(&fdCount, &requestPid, msghdr); in HWTEST_F()
474 ReceiveFds(0, iovec, &fdCount, false, &requestPid); in HWTEST_F()
475 fds = ReceiveFds(0, iovec, &fdCount, true, &requestPid); in HWTEST_F()
|
| /base/startup/appspawn/interfaces/innerkits/client/ |
| H A D | appspawn_client.c | 169 static int WriteMessage(int socketFd, const uint8_t *buf, ssize_t len, int *fds, int *fdCount) in WriteMessage() argument
183 if (fdCount != NULL && fds != NULL && *fdCount > 0) { in WriteMessage()
184 msg.msg_controllen = CMSG_SPACE(*fdCount * sizeof(int)); in WriteMessage()
192 cmsg->cmsg_len = CMSG_LEN(*fdCount * sizeof(int)); in WriteMessage()
195 int ret = memcpy_s(CMSG_DATA(cmsg), cmsg->cmsg_len, fds, *fdCount * sizeof(int)); in WriteMessage()
198 APPSPAWN_LOGV("build fd info count %{public}d", *fdCount); in WriteMessage()
222 sendFd ? &reqNode->fdCount : NULL); in HandleMsgSend()
|
| H A D | appspawn_client.h | 76 int fdCount; member
|
| /base/startup/init/test/systest/ |
| H A D | loopclient_systest.c | 239 static int WriteMessage(int socketFd, const uint8_t *buf, ssize_t len, int *fds, int *fdCount) in WriteMessage() argument
253 if (fdCount != NULL && fds != NULL && *fdCount > 0) { in WriteMessage()
254 msg.msg_controllen = CMSG_SPACE(*fdCount * sizeof(int)); in WriteMessage()
267 cmsg->cmsg_len = CMSG_LEN(*fdCount * sizeof(int)); in WriteMessage()
270 int ret = memcpy_s(CMSG_DATA(cmsg), cmsg->cmsg_len, fds, *fdCount * sizeof(int)); in WriteMessage()
276 printf("build fd info count %d \n", *fdCount); in WriteMessage()
301 sendFd ? &reqNode->fdCount : NULL); in HandleMsgSend()
|
| H A D | loop_systest.h | 132 int fdCount; member
|
| /base/hiviewdfx/faultloggerd/test/unittest/backtrace/ |
| H A D | backtrace_utils_test.cpp | 63 uint32_t fdCount; member in OHOS::HiviewDFX::BacktraceUtilsTest
93 fdCount = GetSelfFdCount(); in SetUp()
104 CheckResourceUsage(fdCount, mapsCount, memCount); in TearDown()
|
| H A D | backtrace_local_test.cpp | 58 uint32_t fdCount; member in OHOS::HiviewDFX::BacktraceLocalTest
86 fdCount = GetSelfFdCount(); in SetUp()
93 CheckResourceUsage(fdCount, mapsCount, memCount); in TearDown()
|
| /base/security/security_guard/test/unittest/data_collect/sa/ |
| H A D | kernel_interface_adapter.h | 35 virtual int Poll(struct pollfd* const fds, nfds_t fdCount, int timeout) { return 0; }; in Poll() argument
|
| /base/startup/appspawn/test/unittest/ |
| H A D | app_spawn_test_helper.cpp | 271 int fdCount = (cmsg->cmsg_len - CMSG_LEN(0)) / sizeof(int); in HandleRecvMessage() local
273 APPSPAWN_CHECK(fdCount <= APP_MAX_FD_COUNT, in HandleRecvMessage()
274 return -1, "failed to recv fd %d %d", connection->receiverCtx.fdCount, fdCount); in HandleRecvMessage()
275 APPSPAWN_CHECK(memcpy_s(connection->receiverCtx.fds, fdCount * sizeof(int), fd, in HandleRecvMessage()
276 fdCount * sizeof(int)) == 0, return -1, "memcpy_s fd failed"); in HandleRecvMessage()
277 connection->receiverCtx.fdCount = fdCount; in HandleRecvMessage()
329 int fdCount = spawnConnection->receiverCtx.fdCount; in OnClose() local
[all...] |
| /base/startup/init/test/unittest/init/ |
| H A D | init_unittest.cpp | 104 size_t fdCount = 0; in TestProcessTimer() local
105 int *fds = ServiceGetFd("param_watcher", &fdCount); in TestProcessTimer()
|
| /base/startup/appspawn/standard/ |
| H A D | appspawn_service.h | 50 int fdCount; member
|
| /base/startup/appspawn/modules/ace_adapter/ |
| H A D | ace_adapter.cpp | 151 if (recvCtx.fdCount <= 0) { in BuildFdInfoMap()
152 APPSPAWN_LOGI("no need to build fd info %{public}d, %{public}d", recvCtx.fds != NULL, recvCtx.fdCount); in BuildFdInfoMap()
177 APPSPAWN_CHECK(findFdIndex < recvCtx.fdCount && recvCtx.fds[findFdIndex] > 0, in BuildFdInfoMap()
180 if (findFdIndex >= recvCtx.fdCount) { in BuildFdInfoMap()
|
| /base/startup/init/services/init/include/ |
| H A D | init_service.h | 172 size_t fdCount;
member
195 int UpdaterServiceFds(Service *service, int *fds, size_t fdCount);
|
| /base/hiviewdfx/faultloggerd/test/utils/ |
| H A D | dfx_test_util.h | 91 void CheckResourceUsage(uint32_t fdCount, uint32_t mapsCount, uint64_t memCount);
|