Home
last modified time | relevance | path

Searched refs:pollfds (Results 1 – 22 of 22) sorted by relevance

/external/google-breakpad/src/client/linux/crash_generation/
Dcrash_generation_server.cc161 struct pollfd pollfds[2]; in Run() local
162 memset(&pollfds, 0, sizeof(pollfds)); in Run()
164 pollfds[0].fd = server_fd_; in Run()
165 pollfds[0].events = POLLIN; in Run()
167 pollfds[1].fd = control_pipe_in_; in Run()
168 pollfds[1].events = POLLIN; in Run()
172 int nevents = poll(pollfds, sizeof(pollfds)/sizeof(pollfds[0]), -1); in Run()
181 if (pollfds[0].revents && !ClientEvent(pollfds[0].revents)) in Run()
184 if (pollfds[1].revents && !ControlEvent(pollfds[1].revents)) in Run()
/external/toybox/lib/
Dnet.c101 struct pollfd pollfds[2]; in pollinate() local
104 memset(pollfds, 0, 2*sizeof(struct pollfd)); in pollinate()
105 pollfds[0].events = pollfds[1].events = POLLIN; in pollinate()
106 pollfds[0].fd = in1; in pollinate()
107 pollfds[1].fd = in2; in pollinate()
111 if (!xpoll(pollfds, pollcount, timeout)) return pollcount; in pollinate()
114 if (pollfds[i].revents & POLLIN) { in pollinate()
115 int len = read(pollfds[i].fd, libbuf, sizeof(libbuf)); in pollinate()
116 if (len<1) pollfds[i].revents = POLLHUP; in pollinate()
122 if (pollfds[i].revents & POLLHUP) { in pollinate()
[all …]
/external/libwebsockets/minimal-examples/http-server/minimal-http-server-eventlib-custom/
Dminimal-http-server.c29 struct lws_pollfd pollfds[MAX_CUSTOM_POLLFDS]; member
50 if (cpcx->pollfds[n].fd == fd) in custom_poll_find_fd()
51 return &cpcx->pollfds[n]; in custom_poll_find_fd()
69 if (cpcx->count_pollfds == LWS_ARRAY_SIZE(cpcx->pollfds)) { in custom_poll_add_fd()
74 pfd = &cpcx->pollfds[cpcx->count_pollfds++]; in custom_poll_add_fd()
96 *pfd = cpcx->pollfds[cpcx->count_pollfds - 1]; in custom_poll_del_fd()
139 n = poll(cpcx->pollfds, (nfds_t)cpcx->count_pollfds, n); in custom_poll_run()
147 lws_sockfd_type fd = cpcx->pollfds[n].fd; in custom_poll_run()
150 if (!cpcx->pollfds[n].revents) in custom_poll_run()
153 m = lws_service_fd(context, &cpcx->pollfds[n]); in custom_poll_run()
[all …]
/external/ipsec-tools/
Dmain.c131 static struct pollfd pollfds[10]; variable
152 pollfds[monitors].fd = fd; in monitor_fd()
153 pollfds[monitors].events = callback ? POLLIN : 0; in monitor_fd()
186 if (poll(pollfds, monitors, timeout) > 0) { in main()
189 if (pollfds[i].revents & POLLHUP) { in main()
190 do_plog(LLV_INFO, "Connection is closed\n", pollfds[i].fd); in main()
197 if (pollfds[i].revents & POLLIN) { in main()
198 callbacks[i](pollfds[i].fd); in main()
/external/mtpd/
Dmtpd.c164 struct pollfd pollfds[3]; in main() local
192 pollfds[0].fd = the_socket; in main()
193 pollfds[0].events = POLLIN; in main()
194 pollfds[1].fd = signals[0]; in main()
195 pollfds[1].events = POLLIN; in main()
196 pollfds[2].fd = control; in main()
197 pollfds[2].events = 0; in main()
200 if (poll(pollfds, 3, timeout ? timeout : -1) == -1 && errno != EINTR) { in main()
204 if (pollfds[1].revents) { in main()
207 if (pollfds[2].revents) { in main()
[all …]
/external/libwebsockets/test-apps/
Dtest-server.c39 struct lws_pollfd *pollfds; variable
76 if (pollfds[n].fd == fd) in ext_find_fd()
77 return &pollfds[n]; in ext_find_fd()
113 count_pollfds = (int)((pfd - pollfds) + 1); in lws_callback_http()
567 pollfds = malloc((unsigned int)max_poll_elements * sizeof (struct lws_pollfd)); in main()
569 if (pollfds == NULL || fd_lookup == NULL) { in main()
574 pollfds[n].fd = LWS_SOCK_INVALID; in main()
696 n = poll(pollfds, (nfds_t)count_pollfds, n); in main()
702 if (pollfds[n].revents) in main()
709 &pollfds[n]) < 0) in main()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/io/
Dquic_poll_event_loop.cc138 auto pollfds = std::make_unique<pollfd[]>(registration_count); in ProcessIoEvents() local
143 pollfds[i].fd = fd; in ProcessIoEvents()
144 pollfds[i].events = GetPollMask(registration->events); in ProcessIoEvents()
145 pollfds[i].revents = 0; in ProcessIoEvents()
151 PollWithRetries(absl::Span<pollfd>(pollfds.get(), registration_count), in ProcessIoEvents()
162 DispatchIoEvent(ready_list, pollfds[i].fd, pollfds[i].revents); in ProcessIoEvents()
/external/toybox/toys/pending/
Dtftpd.c109 struct pollfd pollfds[1]; in do_action() local
115 pollfds[0].fd = TT.sfd; in do_action()
181 pollfds[0].events = POLLIN; in do_action()
182 pollfds[0].fd = TT.sfd; in do_action()
183 poll_ret = poll(pollfds, 1, timeout); in do_action()
193 len = read(pollfds[0].fd, rpkt, blksize + 4); in do_action()
/external/ltp/testcases/kernel/pty/
Dhangup01.c89 struct pollfd pollfds[1]; in parent() local
96 pollfds[0].fd = masterfd; in parent()
97 pollfds[0].events = POLLIN; in parent()
101 while ((i = poll(pollfds, 1, -1)) == 1) { in parent()
/external/wpa_supplicant_8/src/utils/
Deloop.c84 struct pollfd *pollfds; member
300 n = os_realloc_array(eloop.pollfds, nmax, in eloop_sock_table_add_sock()
306 eloop.pollfds = n; in eloop_sock_table_add_sock()
446 struct pollfd *pollfds, in eloop_sock_table_set_fds() argument
462 pollfds[nxt].fd = fd; in eloop_sock_table_set_fds()
463 pollfds[nxt].events = POLLIN; in eloop_sock_table_set_fds()
464 pollfds[nxt].revents = 0; in eloop_sock_table_set_fds()
465 pollfds_map[fd] = &(pollfds[nxt]); in eloop_sock_table_set_fds()
480 pfd = &(pollfds[nxt]); in eloop_sock_table_set_fds()
483 pollfds[i].revents = 0; in eloop_sock_table_set_fds()
[all …]
/external/ppp/pppd/
Dsys-solaris.c228 static struct pollfd pollfds[MAX_POLLFDS]; variable
1374 if (poll(pollfds, n_pollfds, t) < 0 && errno != EINTR)
1387 if (pollfds[n].fd == fd)
1390 pollfds[n_pollfds].fd = fd;
1391 pollfds[n_pollfds].events = POLLIN | POLLPRI | POLLHUP;
1406 if (pollfds[n].fd == fd) {
1408 pollfds[n-1] = pollfds[n];
/external/v4l2_codec2/common/
DV4L2Device.cpp1134 struct pollfd pollfds[2]; in poll() local
1138 pollfds[0].fd = mDevicePollInterruptFd.get(); in poll()
1139 pollfds[0].events = POLLIN | POLLERR; in poll()
1144 pollfds[nfds].fd = mDeviceFd.get(); in poll()
1145 pollfds[nfds].events = POLLIN | POLLOUT | POLLERR | POLLPRI; in poll()
1150 if (HANDLE_EINTR(::poll(pollfds, nfds, -1)) == -1) { in poll()
1154 *eventPending = (pollfd != -1 && pollfds[pollfd].revents & POLLPRI); in poll()
/external/libcups/backend/
Ddnssd.c109 static int poll_callback(struct pollfd *pollfds,
924 struct pollfd *pollfds, /* I - File descriptors */ in poll_callback() argument
935 val = poll(pollfds, num_pollfds, 500); in poll_callback()
/external/libusb/libusb/
Dio.c2791 void API_EXPORTED libusb_free_pollfds(const struct libusb_pollfd **pollfds) in libusb_free_pollfds() argument
2794 free((void *)pollfds); in libusb_free_pollfds()
2796 UNUSED(pollfds); in libusb_free_pollfds()
Dlibusb.h1929 void LIBUSB_CALL libusb_free_pollfds(const struct libusb_pollfd **pollfds);
/external/perfetto/src/perfetto_cmd/
Dperfetto_cmd.cc878 std::array<pollfd, 1> pollfds = {pollfd{fd.get(), POLLIN, 0}}; in WaitOnBgProcessPipe() local
880 int ret = PERFETTO_EINTR(poll(&pollfds[0], pollfds.size(), 30000 /*ms*/)); in WaitOnBgProcessPipe()
/external/grpc-grpc/src/core/lib/iomgr/
Dev_poll_posix.cc1666 struct pollfd* pollfds = static_cast<struct pollfd*>( local
1671 pollfds[idx].fd = fds[i].fd;
1672 pollfds[idx].events = fds[i].events;
1673 pollfds[idx].revents = 0;
1677 poll_args* pargs = get_poller_locked(pollfds, nsockfds);
/external/libcups/cups/
Dhttp-support.c126 static int http_poll_cb(struct pollfd *pollfds, unsigned int num_pollfds,
2467 struct pollfd *pollfds, /* I - File descriptors */ in http_poll_cb() argument
2475 return (poll(pollfds, num_pollfds, 2000)); in http_poll_cb()
Ddest.c205 static int cups_dnssd_poll_cb(struct pollfd *pollfds,
2869 struct pollfd *pollfds, /* I - File descriptors */ in cups_dnssd_poll_cb() argument
2879 …DEBUG_printf(("cups_dnssd_poll_cb(pollfds=%p, num_pollfds=%d, timeout=%d, context=%p)", pollfds, n… in cups_dnssd_poll_cb()
2883 val = poll(pollfds, num_pollfds, _CUPS_DNSSD_MAXTIME); in cups_dnssd_poll_cb()
/external/libcups/tools/
Dippfind.c179 static int poll_callback(struct pollfd *pollfds,
2512 struct pollfd *pollfds, /* I - File descriptors */ in poll_callback() argument
2523 val = poll(pollfds, num_pollfds, 500); in poll_callback()
/external/libusb/include/libusb/
Dlibusb.h1929 void LIBUSB_CALL libusb_free_pollfds(const struct libusb_pollfd **pollfds);
/external/libwebsockets/READMEs/
DREADME.coding.md371 You can pass all pollfds that need service to `lws_service_fd()`, even