• Home
  • Raw
  • Download

Lines Matching refs:pfd

70 	struct pollfd pfd[3];  in thd_entry_event_wait()  local
76 pfd[0].fd = thd->eventfd; in thd_entry_event_wait()
77 pfd[0].events = POLLIN; in thd_entry_event_wait()
78 pfd[1].fd = fd_in; in thd_entry_event_wait()
79 pfd[1].events = POLLRDHUP; in thd_entry_event_wait()
80 pfd[2].fd = thread_pool_get_poll_fd(thd->pdata->pool); in thd_entry_event_wait()
81 pfd[2].events = POLLIN; in thd_entry_event_wait()
84 poll_nointr(pfd, 3); in thd_entry_event_wait()
86 if ((pfd[1].revents & POLLRDHUP) || (pfd[2].revents & POLLIN)) { in thd_entry_event_wait()
139 struct pollfd pfd[2]; in async_io() local
163 pfd[0].fd = pdata->aio_eventfd; in async_io()
164 pfd[0].events = POLLIN; in async_io()
165 pfd[0].revents = 0; in async_io()
166 pfd[1].fd = thread_pool_get_poll_fd(pdata->pool); in async_io()
167 pfd[1].events = POLLIN; in async_io()
168 pfd[1].revents = 0; in async_io()
172 poll_nointr(pfd, num_pfds); in async_io()
174 if (pfd[0].revents & POLLIN) { in async_io()
191 } else if ((num_pfds > 1 && pfd[1].revents & POLLIN)) { in async_io()
202 } while (!(pfd[0].revents & POLLIN)); in async_io()
234 struct pollfd pfd[2]; in readfd_io() local
236 pfd[0].fd = pdata->fd_in; in readfd_io()
237 pfd[0].events = POLLIN | POLLRDHUP; in readfd_io()
238 pfd[0].revents = 0; in readfd_io()
239 pfd[1].fd = thread_pool_get_poll_fd(pdata->pool); in readfd_io()
240 pfd[1].events = POLLIN; in readfd_io()
241 pfd[1].revents = 0; in readfd_io()
244 poll_nointr(pfd, 2); in readfd_io()
247 if (pfd[1].revents & POLLIN || pfd[0].revents & POLLRDHUP) in readfd_io()
249 if (pfd[0].revents & POLLERR) in readfd_io()
251 if (!(pfd[0].revents & POLLIN)) in readfd_io()
274 struct pollfd pfd[2]; in writefd_io() local
276 pfd[0].fd = pdata->fd_out; in writefd_io()
277 pfd[0].events = POLLOUT; in writefd_io()
278 pfd[0].revents = 0; in writefd_io()
279 pfd[1].fd = thread_pool_get_poll_fd(pdata->pool); in writefd_io()
280 pfd[1].events = POLLIN; in writefd_io()
281 pfd[1].revents = 0; in writefd_io()
284 poll_nointr(pfd, 2); in writefd_io()
287 if (pfd[1].revents & POLLIN || pfd[0].revents & POLLHUP) in writefd_io()
289 if (pfd[0].revents & POLLERR) in writefd_io()
291 if (!(pfd[0].revents & POLLOUT)) in writefd_io()
1293 struct pollfd pfd[2]; in read_line() local
1297 pfd[0].fd = pdata->fd_in; in read_line()
1298 pfd[0].events = POLLIN | POLLRDHUP; in read_line()
1299 pfd[0].revents = 0; in read_line()
1300 pfd[1].fd = thread_pool_get_poll_fd(pdata->pool); in read_line()
1301 pfd[1].events = POLLIN; in read_line()
1302 pfd[1].revents = 0; in read_line()
1307 poll_nointr(pfd, 2); in read_line()
1309 if (pfd[1].revents & POLLIN || in read_line()
1310 pfd[0].revents & POLLRDHUP) in read_line()