| /device/google/cuttlefish_common/guest/hals/camera/ |
| EmulatedCameraDevice.cpp | 297 "%s: Thread control FDs are opened", __FUNCTION__);
298 /* Create a pair of FDs that would be used to control the thread. */
308 ALOGE("%s: Unable to create thread control FDs: %d -> %s", __FUNCTION__,
345 /* Close control FDs. */
365 ALOGE("%s: Thread control FDs are not opened", __FUNCTION__);
373 fd_set fds[1]; local
379 FD_ZERO(fds);
380 FD_SET(mControlFD, fds);
382 FD_SET(fd, fds);
389 int res = TEMP_FAILURE_RETRY(select(fd_num, fds, NULL, NULL, tvp))
[all...] |
| /device/google/cuttlefish_common/guest/hals/sensors/ |
| vsoc_sensors.cpp | 66 // Create a pair of FDs that would be used to control the
69 ALOGE("%s: Receiver control FDs are opened", __FUNCTION__);
73 ALOGE("%s: Unable to create thread control FDs: %d -> %s", __FUNCTION__,
276 cvd::SharedFDSet fds; local
278 fds.Set(*it);
280 fds.Set(control_receiver_socket_);
281 // fds.Set(sensor_listener_socket_);
282 int res = cvd::Select(&fds, NULL, NULL, NULL);
290 } else if (fds.IsSet(sensor_listener_socket_)) {
293 } else if (fds.IsSet(control_receiver_socket_))
[all...] |
| /external/autotest/client/site_tests/platform_ToolchainTests/src/ |
| clang-fortify-tests.cpp | 262 // expected-warning@+1{{fds buffer too small}}
264 // expected-warning@+1{{fds buffer too small}}
272 } fds = {{invalid_poll_fd, invalid_poll_fd}, {invalid_poll_fd}}; local
273 _Static_assert(sizeof(fds) >= sizeof(struct pollfd) * 3, "");
276 // expected-warning@+2{{fds buffer too small}}
278 EXPECT_DEATH_STRUCT(poll(fds.few, 3, 0));
282 // expected-warning@+2{{fds buffer too small}}
284 EXPECT_DEATH_STRUCT(ppoll(fds.few, 3, &timeout, 0));
|
| /external/autotest/client/tests/hackbench/src/ |
| hackbench.c | 130 static void fdpair(int fds[2])
133 if (pipe(fds) == 0)
136 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds) == 0)
273 int fds[2]; local
281 fdpair(fds);
284 ctx->in_fds[0] = fds[0];
285 ctx->in_fds[1] = fds[1];
291 snd_ctx->out_fds[i] = fds[1];
293 close(fds[0]);
296 /* Now we have all the fds, fork the senders *
[all...] |
| /external/e2fsprogs/e2fsck/ |
| logfile.c | 211 int c, fd, fds[2]; local
226 if (pipe(fds) < 0) {
247 close(fds[1]);
248 while (do_read(fds[0]) > 0)
250 close(fds[0]);
280 close(fds[0]);
281 ret = fdopen(fds[1], "w");
283 close(fds[1]);
|
| /external/google-breakpad/src/client/linux/minidump_writer/ |
| minidump_writer_unittest.cc | 68 int fds[2]; local
69 ASSERT_NE(-1, pipe(fds));
73 close(fds[1]);
75 IGNORE_RET(HANDLE_EINTR(read(fds[0], &b, sizeof(b))));
76 close(fds[0]);
79 close(fds[0]);
93 close(fds[1]);
97 int fds[2]; local
98 ASSERT_NE(-1, pipe(fds));
102 close(fds[1])
129 int fds[2]; local
238 int fds[2]; local
355 int fds[2]; local
435 int fds[2]; local
507 int fds[2]; local
597 int fds[2]; local
[all...] |
| /external/google-breakpad/src/client/mac/tests/ |
| exception_handler_test.cc | 105 int fds[2]; local
106 ASSERT_EQ(0, pipe(fds));
111 close(fds[0]);
112 ExceptionHandler eh(tempDir.path(), NULL, MDCallback, &fds[1], true, NULL);
121 close(fds[1]);
123 ssize_t nbytes = read(fds[0], minidump_file, sizeof(minidump_file));
244 int fds[2]; local
245 ASSERT_EQ(0, pipe(fds));
251 close(fds[1]);
264 read(fds[0], &data, 1)
309 int fds[2]; local
408 int fds[2]; local
504 int fds[2]; local
604 int fds[2]; local
661 int fds[2]; local
[all...] |
| /external/iputils/ |
| tracepath.c | 69 fd_set fds; local
71 FD_ZERO(&fds);
72 FD_SET(fd, &fds);
75 select(fd+1, &fds, NULL, NULL, &tv);
|
| /external/libbrillo/brillo/streams/ |
| file_stream_unittest.cc | 957 int fds[2] = {-1, -1}; local
996 int fds[2] = {-1, -1}; local
1040 int fds[2] = {-1, -1}; local
1099 int fds[2] = {-1, -1}; local
[all...] |
| /external/libdaemon/libdaemon/ |
| dfork.c | 409 fd_set fds; local
414 FD_ZERO(&fds);
415 FD_SET(_daemon_retval_pipe[0], &fds);
417 if ((s = select(FD_SETSIZE, &fds, 0, 0, &tv)) != 1) {
490 /** Same as daemon_close_all but takes an array of fds, terminated by -1 */
|
| /external/libdrm/tests/exynos/ |
| exynos_fimg2d_event.c | 39 struct pollfd fds; member in struct:exynos_evhandler
62 evhandler->fds.fd = fd;
63 evhandler->fds.events = POLLIN;
80 data->evhandler.fds.revents = 0;
82 if (poll(&data->evhandler.fds, 1, timeout) < 0)
85 if (data->evhandler.fds.revents & (POLLHUP | POLLERR))
88 if (data->evhandler.fds.revents & POLLIN)
|
| /external/libmojo/mojo/edk/system/ |
| channel_posix.cc | 381 std::vector<int> fds; local
383 fds.push_back(handle.handle);
390 new Channel::Message(sizeof(fds[0]) * fds.size(), 0,
392 memcpy(fds_message->mutable_payload(), fds.data(),
393 sizeof(fds[0]) * fds.size());
408 // On OS X if sendmsg() is trying to send fds between processes and
486 const int* fds = reinterpret_cast<const int*>(payload); variable
487 if (!CloseHandles(fds, num_fds)
[all...] |
| /external/libvncserver/libvncclient/ |
| sockets.c | 248 fd_set fds; local
275 FD_ZERO(&fds);
276 FD_SET(client->sock,&fds);
278 if (select(client->sock+1, NULL, &fds, NULL, NULL) <= 0) {
806 fd_set fds; local
817 FD_ZERO(&fds);
818 FD_SET(client->sock,&fds);
820 num=select(client->sock+1, &fds, NULL, NULL, &timeout);
|
| /external/libvncserver/libvncserver/ |
| httpd.c | 170 fd_set fds; local
185 FD_ZERO(&fds);
186 FD_SET(rfbScreen->httpListenSock, &fds);
188 FD_SET(rfbScreen->httpListen6Sock, &fds);
191 FD_SET(rfbScreen->httpSock, &fds);
195 nfds = select(max(rfbScreen->httpListen6Sock, max(rfbScreen->httpSock,rfbScreen->httpListenSock)) + 1, &fds, NULL, NULL, &tv);
208 if ((rfbScreen->httpSock >= 0) && FD_ISSET(rfbScreen->httpSock, &fds)) {
212 if (FD_ISSET(rfbScreen->httpListenSock, &fds) || FD_ISSET(rfbScreen->httpListen6Sock, &fds)) {
215 if(FD_ISSET(rfbScreen->httpListenSock, &fds)) {
[all...] |
| sockets.c | 286 fd_set fds; local
301 memcpy((char *)&fds, (char *)&(rfbScreen->allFds), sizeof(fd_set));
304 nfds = select(rfbScreen->maxFd + 1, &fds, NULL, NULL /* &fds */, &tv);
329 if (rfbScreen->listenSock != -1 && FD_ISSET(rfbScreen->listenSock, &fds)) {
334 FD_CLR(rfbScreen->listenSock, &fds);
339 if (rfbScreen->listen6Sock != -1 && FD_ISSET(rfbScreen->listen6Sock, &fds)) {
344 FD_CLR(rfbScreen->listen6Sock, &fds);
349 if ((rfbScreen->udpSock != -1) && FD_ISSET(rfbScreen->udpSock, &fds)) {
380 FD_CLR(rfbScreen->udpSock, &fds);
574 fd_set fds; local
666 fd_set fds; local
744 fd_set fds; local
[all...] |
| /external/libxcam/xcore/ |
| drm_display.cpp | 474 fd_set fds; local
479 FD_ZERO(&fds);
480 FD_SET(_fd, &fds);
481 select(_fd + 1, &fds, NULL, NULL, &timeout);
|
| /external/linux-kselftest/tools/testing/selftests/net/ |
| psock_fanout.c | 219 static int sock_fanout_read(int fds[], char *rings[], const int expect[])
223 ret[0] = sock_fanout_read_ring(fds[0], rings[0]);
224 ret[1] = sock_fanout_read_ring(fds[1], rings[1]);
253 int fds[2]; local
257 fds[0] = sock_fanout_open(PACKET_FANOUT_HASH, 0);
258 if (fds[0] == -1) {
276 fds[1] = sock_fanout_open(PACKET_FANOUT_HASH, 0);
277 if (fds[1] == -1) {
281 if (close(fds[1]) || close(fds[0]))
290 int fds[3]; local
348 int fds[2], fds_udp[2][2], ret; local
[all...] |
| /external/ltp/testcases/kernel/sched/cfs-scheduler/ |
| hackbench.c | 102 static void fdpair(int fds[2])
105 if (pipe(fds) == 0)
108 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds) == 0)
249 int fds[2]; local
258 fdpair(fds);
261 ctx->in_fds[0] = fds[0];
262 ctx->in_fds[1] = fds[1];
268 snd_ctx->out_fds[i] = fds[1];
270 close(fds[0]);
273 /* Now we have all the fds, fork the senders *
[all...] |
| /external/ltp/testcases/kernel/syscalls/epoll/ |
| epoll-ltp.c | 54 fd == INT_MAX and that it will instead choose to allocate fds
389 int fds[] = { -1, INT_MAX }; local
435 /* One of the fds we want to test is the valid one */
466 fd_index < (sizeof(fds) / sizeof(int));
496 fds[fd_index],
|
| /external/ltp/testcases/kernel/syscalls/ppoll/ |
| ppoll01.c | 51 struct pollfd *fds; /* fds ppoll parameter */ member in struct:test_case
88 * EFAULT v ('fds' array in the invalid address space)
102 .fds = fds_good,
111 .fds = fds_good,
121 .fds = fds_good,
130 .fds = fds_already_closed,
138 .fds = fds_good,
150 .fds = fds_good,
160 .fds = fds_good
[all...] |
| /external/oj-libjdwp/src/solaris/transport/socket/ |
| socket_md.c | 246 struct pollfd fds[1]; local
249 fds[0].fd = fd;
250 fds[0].events = 0;
252 fds[0].events |= POLLIN;
255 fds[0].events |= POLLOUT;
257 fds[0].revents = 0;
259 rv = poll(&fds[0], 1, timeout);
262 if (fds[0].revents & POLLIN) {
265 if (fds[0].revents & POLLOUT) {
|
| /external/perfetto/src/ipc/ |
| unix_socket.cc | 425 int* fds = nullptr; local
434 PERFETTO_DCHECK(fds == nullptr);
435 fds = reinterpret_cast<int*>(CMSG_DATA(cmsg));
442 for (size_t i = 0; fds && i < fds_len; ++i)
443 close(fds[i]);
449 for (size_t i = 0; fds && i < fds_len; ++i) {
451 recv_fd->reset(fds[i]);
453 close(fds[i]);
|
| /external/strace/ |
| msghdr.c | 64 const int *fds = cmsg_data; local
65 const unsigned int nfds = data_len / sizeof(*fds);
77 printfd(tcp, fds[i]);
|
| /external/syslinux/gpxe/src/arch/i386/interface/syslinux/ |
| comboot_call.c | 418 fd_set fds; local
422 FD_ZERO ( &fds );
423 FD_SET ( fd, &fds );
425 select ( &fds, 1 );
|
| /frameworks/av/media/libmedia/include/media/omx/1.0/ |
| Conversion.h | 630 int* fds = new int[numFds]; local
648 std::copy(handle->data, intsStart, fds);
654 int const* constFds = static_cast<int const*>(fds);
657 delete [] fds;
|
