| /unit/src/ |
| H A D | nxt_select_engine.c | 282 int nevents, nfds, found; in nxt_select_poll() local
315 nevents = select(nfds, &engine->u.select.work_read_fd_set, in nxt_select_poll()
318 err = (nevents == -1) ? nxt_errno : 0; in nxt_select_poll()
322 nxt_debug(&engine->task, "select(): %d", nevents); in nxt_select_poll()
324 if (nevents == -1) { in nxt_select_poll()
330 for (fd = 0; fd < (nxt_uint_t) nfds && nevents != 0; fd++) { in nxt_select_poll()
368 nevents -= found; in nxt_select_poll()
|
| H A D | nxt_eventport_engine.c | 454 uint_t nevents; in nxt_eventport_poll() local
495 nevents = 1; in nxt_eventport_poll()
497 engine->u.eventport.mevents, &nevents, tp); in nxt_eventport_poll()
509 if (nevents != 0) { in nxt_eventport_poll()
511 engine->u.eventport.fd, err, nevents); in nxt_eventport_poll()
528 engine->u.eventport.fd, nevents); in nxt_eventport_poll()
530 for (i = 0; i < nevents; i++) { in nxt_eventport_poll()
|
| H A D | nxt_poll_engine.c | 502 int nevents; in nxt_poll() local
521 nevents = poll(engine->u.poll.set, engine->u.poll.nfds, timeout); in nxt_poll()
523 err = (nevents == -1) ? nxt_errno : 0; in nxt_poll()
527 nxt_debug(&engine->task, "poll(): %d", nevents); in nxt_poll()
529 if (nevents == -1) { in nxt_poll()
535 for (i = 0; i < engine->u.poll.nfds && nevents != 0; i++) { in nxt_poll()
631 nevents--; in nxt_poll()
|
| H A D | nxt_pollset_engine.c | 547 int nevents; in nxt_pollset_poll() local
565 nevents = pollset_poll(engine->u.pollset.ps, engine->u.pollset.events, in nxt_pollset_poll()
568 err = (nevents == -1) ? nxt_errno : 0; in nxt_pollset_poll()
573 engine->u.pollset.ps, nevents); in nxt_pollset_poll()
575 if (nevents == -1) { in nxt_pollset_poll()
584 for (i = 0; i < nevents; i++) { in nxt_pollset_poll()
|
| H A D | nxt_devpoll_engine.c | 558 int nevents; in nxt_devpoll_poll() local
581 nevents = ioctl(engine->u.devpoll.fd, DP_POLL, &dvp); in nxt_devpoll_poll()
583 err = (nevents == -1) ? nxt_errno : 0; in nxt_devpoll_poll()
588 engine->u.devpoll.fd, nevents); in nxt_devpoll_poll()
590 if (nevents == -1) { in nxt_devpoll_poll()
599 for (i = 0; i < nevents; i++) { in nxt_devpoll_poll()
|
| H A D | nxt_test_build.c | 28 epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout) in epoll_wait() argument
|
| H A D | nxt_kqueue_engine.c | 665 int nevents; in nxt_kqueue_poll() local
692 nevents = kevent(engine->u.kqueue.fd, in nxt_kqueue_poll()
696 err = (nevents == -1) ? nxt_errno : 0; in nxt_kqueue_poll()
700 nxt_debug(&engine->task, "kevent(%d): %d", engine->u.kqueue.fd, nevents); in nxt_kqueue_poll()
702 if (nevents == -1) { in nxt_kqueue_poll()
717 for (i = 0; i < nevents; i++) { in nxt_kqueue_poll()
|
| H A D | nxt_epoll_engine.c | 873 int nevents; in nxt_epoll_poll() local
895 nevents = epoll_wait(engine->u.epoll.fd, engine->u.epoll.events, in nxt_epoll_poll()
898 err = (nevents == -1) ? nxt_errno : 0; in nxt_epoll_poll()
902 nxt_debug(&engine->task, "epoll_wait(%d): %d", engine->u.epoll.fd, nevents); in nxt_epoll_poll()
904 if (nevents == -1) { in nxt_epoll_poll()
913 for (i = 0; i < nevents; i++) { in nxt_epoll_poll()
|
| H A D | nxt_test_build.h | 84 int epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout);
|
| H A D | nxt_unit.c | 4611 int nevents, res, err; in nxt_unit_read_buf() local
4674 nevents = poll(fds, nfds, -1); in nxt_unit_read_buf()
4675 if (nxt_slow_path(nevents == -1)) { in nxt_unit_read_buf()
4691 fds[0].fd, fds[1].fd, nevents, fds[0].revents, in nxt_unit_read_buf()
4713 fds[0].fd, fds[1].fd, nevents, fds[0].revents, in nxt_unit_read_buf()
|