| /external/libchrome/base/posix/ |
| unix_domain_socket_linux.cc | 52 const std::vector<int>& fds) {
59 if (fds.size()) {
60 const unsigned control_len = CMSG_SPACE(sizeof(int) * fds.size());
69 cmsg->cmsg_len = CMSG_LEN(sizeof(int) * fds.size());
70 memcpy(CMSG_DATA(cmsg), &fds[0], sizeof(int) * fds.size()); local
89 std::vector<ScopedFD>* fds) {
90 return UnixDomainSocket::RecvMsgWithPid(fd, buf, length, fds, NULL);
97 std::vector<ScopedFD>* fds,
99 return UnixDomainSocket::RecvMsgWithFlags(fd, buf, length, 0, fds, pid)
[all...] |
| /external/libcups/cups/ |
| http-addrlist.c | 70 fds[100], /* Socket file descriptors */ local
122 httpAddrClose(NULL, fds[nfds]);
128 if (addrlist && nfds < (int)(sizeof(fds) / sizeof(fds[0])))
136 if ((fds[nfds] = (int)socket(httpAddrFamily(&(addrlist->addr)), SOCK_STREAM, 0)) < 0)
154 setsockopt(fds[nfds], SOL_SOCKET, SO_REUSEADDR, CUPS_SOCAST &val, sizeof(val));
158 setsockopt(fds[nfds], SOL_SOCKET, SO_REUSEPORT, CUPS_SOCAST &val, sizeof(val));
163 setsockopt(fds[nfds], SOL_SOCKET, SO_NOSIGPIPE, CUPS_SOCAST &val, sizeof(val));
172 setsockopt(fds[nfds], IPPROTO_TCP, TCP_NODELAY, CUPS_SOCAST &val, sizeof(val));
179 fcntl(fds[nfds], F_SETFD, FD_CLOEXEC)
[all...] |
| /external/libdrm/tests/kms/ |
| kms-universal-planes.c | 329 fd_set fds; local
331 FD_ZERO(&fds);
332 FD_SET(STDIN_FILENO, &fds);
334 err = select(STDIN_FILENO + 1, &fds, NULL, NULL, &timeout);
344 if (FD_ISSET(STDIN_FILENO, &fds))
|
| /external/libnl/lib/ |
| cache_mngr.c | 386 struct pollfd fds = { local
391 NL_DBG(3, "Cache manager %p, poll() fd %d\n", mngr, fds.fd);
392 ret = poll(&fds, 1, timeout);
|
| /external/libusb/libusb/os/ |
| linux_netlink.c | 360 struct pollfd fds[] = { local
371 while (poll(fds, 2, -1) >= 0) {
372 if (fds[0].revents & POLLIN) {
379 if (fds[1].revents & POLLIN) {
|
| /external/linux-kselftest/tools/testing/selftests/sync/ |
| sync.c | 60 struct pollfd fds; local
62 fds.fd = fd;
63 fds.events = POLLIN | POLLERR;
65 return poll(&fds, 1, timeout);
|
| /external/ltp/testcases/kernel/input/ |
| input_helper.c | 251 struct pollfd fds = {.fd = fd, .events = POLLIN}; local
258 ret = poll(&fds, 1, 30);
|
| /external/strace/tests/ |
| mmsg.c | 41 int fds[2]; local
42 if (socketpair(AF_UNIX, SOCK_DGRAM, 0, fds))
44 assert(0 == fds[0]);
45 assert(1 == fds[1]);
|
| recvmsg.c | 44 int fds[2]; local
45 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds))
47 assert(0 == fds[0]);
48 assert(1 == fds[1]);
|
| /external/strace/tests-m32/ |
| mmsg.c | 41 int fds[2]; local
42 if (socketpair(AF_UNIX, SOCK_DGRAM, 0, fds))
44 assert(0 == fds[0]);
45 assert(1 == fds[1]);
|
| recvmsg.c | 44 int fds[2]; local
45 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds))
47 assert(0 == fds[0]);
48 assert(1 == fds[1]);
|
| /external/strace/tests-mx32/ |
| mmsg.c | 41 int fds[2]; local
42 if (socketpair(AF_UNIX, SOCK_DGRAM, 0, fds))
44 assert(0 == fds[0]);
45 assert(1 == fds[1]);
|
| recvmsg.c | 44 int fds[2]; local
45 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds))
47 assert(0 == fds[0]);
48 assert(1 == fds[1]);
|
| /external/tensorflow/tensorflow/core/platform/posix/ |
| subprocess.cc | 334 struct pollfd fds[kNFds]; local
397 fds[fd_count].fd = parent_pipe_[i];
398 fds[fd_count].events = (i > 0) ? POLLIN : POLLOUT;
399 fds[fd_count].revents = 0;
408 int n = poll(fds, fd_count, -1);
418 if ((fds[i].revents & (POLLIN | POLLHUP)) != 0) {
420 ssize_t n = read(fds[i].fd, buf, sizeof(buf));
427 fds[i].fd = -1;
430 } else if ((fds[i].revents & POLLOUT) != 0) {
434 n = write(fds[i].fd, iobufs[i]->c_str() + nbytes[i], n)
[all...] |
| /frameworks/base/cmds/incident/ |
| main.cpp | 255 int fds[2]; local
256 pipe(fds);
258 unique_fd readEnd(fds[0]);
259 unique_fd writeEnd(fds[1]);
275 int amt = splice(fds[0], NULL, STDOUT_FILENO, NULL, 4096, 0);
|
| /frameworks/base/packages/MtpDocumentsProvider/tests/src/com/android/mtp/ |
| MtpManagerTest.java | 137 final ParcelFileDescriptor[] fds = ParcelFileDescriptor.createPipe(); local
140 new ParcelFileDescriptor.AutoCloseOutputStream(fds[1])) {
151 fds[0]);
|
| /frameworks/base/tools/bit/ |
| command.cpp | 107 int fds[2]; local
108 if (0 != pipe(fds)) {
120 while ((dup2(fds[1], STDOUT_FILENO) == -1) && (errno == EINTR)) {}
121 close(fds[1]);
122 close(fds[0]);
133 close(fds[1]);
138 ssize_t amt = read(fds[0], buf, size);
|
| /system/core/adb/ |
| framebuffer_service.cpp | 65 int fds[2]; local
68 if (pipe2(fds, O_CLOEXEC) < 0) goto pipefail;
74 dup2(fds[1], STDOUT_FILENO);
75 adb_close(fds[0]);
76 adb_close(fds[1]);
83 adb_close(fds[1]);
84 fd_screencap = fds[0];
183 adb_close(fds[0]);
|
| /system/core/adf/libadfhwc/ |
| adfhwc.cpp | 292 pollfd fds[dev->intf_fds.size()]; local
294 fds[i].fd = dev->intf_fds[i];
295 fds[i].events = POLLIN | POLLPRI;
299 if (TEMP_FAILURE_RETRY(poll(fds, dev->intf_fds.size(), -1)) < 0) {
305 if (fds[i].revents & (POLLIN | POLLPRI))
|
| /system/core/libappfuse/ |
| FuseBuffer.cc | 140 base::unique_fd fds[2]; local
147 fds[0].reset(raw_fds[0]);
148 fds[1].reset(raw_fds[1]);
152 if (setsockopt(fds[0], SOL_SOCKET, SO_SNDBUF, &kMaxMessageSize, sizeof(int)) != 0 ||
153 setsockopt(fds[1], SOL_SOCKET, SO_SNDBUF, &kMaxMessageSize, sizeof(int)) != 0) {
158 (*result)[0] = std::move(fds[0]);
159 (*result)[1] = std::move(fds[1]);
|
| /system/extras/verity/fec/ |
| image.cpp | 93 static void file_image_load(const std::vector<int>& fds, image *ctx)
98 for (auto fd : fds) {
139 for (auto fd : fds) {
155 std::vector<int> fds; local
164 fds.push_back(fd);
167 file_image_load(fds, ctx);
|
| /bionic/tests/ |
| fortify_filecheck_diagnostics_test.cpp | 268 pollfd fds[1]; local
272 poll(fds, 2, 0);
276 pollfd fds[1]; local
281 ppoll(fds, 2, &timeout, NULL);
|
| spawn_test.cpp | 231 int fds[2]; local
232 ASSERT_NE(-1, pipe(fds));
237 ASSERT_EQ(0, posix_spawn_file_actions_addclose(&fa, fds[0]));
238 ASSERT_EQ(0, posix_spawn_file_actions_adddup2(&fa, fds[1], 1));
239 ASSERT_EQ(0, posix_spawn_file_actions_addclose(&fa, fds[1]));
241 ASSERT_EQ(0, posix_spawn_file_actions_addclose(&fa, fds[1]));
250 ASSERT_EQ(0, close(fds[1]));
252 ASSERT_TRUE(android::base::ReadFdToString(fds[0], &content));
253 ASSERT_EQ(0, close(fds[0]));
267 int fds[2] local
[all...] |
| utils.h | 197 int fds[2]; local
198 ASSERT_NE(pipe(fds), -1);
205 close(fds[0]);
206 dup2(fds[1], STDOUT_FILENO);
207 dup2(fds[1], STDERR_FILENO);
208 if (fds[1] != STDOUT_FILENO && fds[1] != STDERR_FILENO) close(fds[1]);
214 close(fds[1]);
218 while ((bytes_read = TEMP_FAILURE_RETRY(read(fds[0], buf, sizeof(buf)))) > 0)
[all...] |
| /device/generic/goldfish/dhcp/client/ |
| dhcpclient.cpp | 216 struct pollfd fds; local
217 fds.fd = mSocket.get();
218 fds.events = POLLIN;
231 int res = ::ppoll(&fds, 1, &ts, &pollSignalMask);
|
