/netbsd/external/bsd/ntp/dist/sntp/libevent/ |
H A D | poll.c | 117 for (i = 0; i < pop->nfds; ++i) { in poll_check_ok() 129 int res, i, j, nfds; in poll_dispatch() local 136 nfds = pop->nfds; in poll_dispatch() 156 sizeof(struct pollfd)*nfds); in poll_dispatch() 173 res = poll(event_set, nfds, msec); in poll_dispatch() 188 if (res == 0 || nfds == 0) in poll_dispatch() 192 for (j = 0; j < nfds; j++) { in poll_dispatch() 194 if (++i == nfds) in poll_dispatch() 258 i = pop->nfds++; in poll_add() 310 --pop->nfds; in poll_del() [all …]
|
H A D | select.c | 144 int res=0, i, j, nfds; in select_dispatch() local 170 nfds = sop->event_fds+1; in select_dispatch() 174 res = select(nfds, sop->event_readset_out, in select_dispatch() 193 i = evutil_weakrand_range_(&base->weakrand_seed, nfds); in select_dispatch() 194 for (j = 0; j < nfds; ++j) { in select_dispatch() 195 if (++i >= nfds) in select_dispatch()
|
/netbsd/external/bsd/libevent/dist/ |
H A D | poll.c | 129 for (i = 0; i < pop->nfds; ++i) { in poll_check_ok() 141 int res, i, j, nfds; in poll_dispatch() local 148 nfds = pop->nfds; in poll_dispatch() 168 sizeof(struct pollfd)*nfds); in poll_dispatch() 185 res = poll(event_set, nfds, msec); in poll_dispatch() 200 if (res == 0 || nfds == 0) in poll_dispatch() 204 for (j = 0; j < nfds; j++) { in poll_dispatch() 206 if (++i == nfds) in poll_dispatch() 272 i = pop->nfds++; in poll_add() 328 --pop->nfds; in poll_del() [all …]
|
H A D | select.c | 145 int res=0, i, j, nfds; in select_dispatch() local 171 nfds = sop->event_fds+1; in select_dispatch() 175 res = select(nfds, sop->event_readset_out, in select_dispatch() 194 i = evutil_weakrand_range_(&base->weakrand_seed, nfds); in select_dispatch() 195 for (j = 0; j < nfds; ++j) { in select_dispatch() 196 if (++i >= nfds) in select_dispatch()
|
/netbsd/sys/external/bsd/libnv/dist/ |
H A D | msgio.c | 267 PJDLOG_ASSERT(nfds > 0); in fd_package_send() 315 PJDLOG_ASSERT(nfds > 0); in fd_package_recv() 346 if (cmsg != NULL || i < nfds) { in fd_package_recv() 377 if (nfds == 0 || fds == NULL) { in fd_recv() 383 while (i < nfds) { in fd_recv() 384 if (PKG_MAX_SIZE < nfds - i) in fd_recv() 387 step = nfds - i; in fd_recv() 409 if (nfds == 0 || fds == NULL) { in fd_send() 415 while (i < nfds) { in fd_send() 416 if (PKG_MAX_SIZE < nfds - i) in fd_send() [all …]
|
/netbsd/external/mit/libuv/dist/src/unix/ |
H A D | epoll.c | 53 uintptr_t nfds; in uv__platform_invalidate_fd() local 62 for (i = 0; i < nfds; i++) in uv__platform_invalidate_fd() 129 int nfds; in uv__io_poll() local 136 if (loop->nfds == 0) { in uv__io_poll() 226 nfds = epoll_pwait(loop->backend_fd, in uv__io_poll() 231 if (nfds == -1 && errno == ENOSYS) { in uv__io_poll() 236 nfds = epoll_wait(loop->backend_fd, in uv__io_poll() 240 if (nfds == -1 && errno == ENOSYS) { in uv__io_poll() 256 if (nfds == 0) { in uv__io_poll() 276 if (nfds == -1) { in uv__io_poll() [all …]
|
H A D | kqueue.c | 129 int nfds; in uv__io_poll() local 136 if (loop->nfds == 0) { in uv__io_poll() 231 nfds = kevent(loop->backend_fd, in uv__io_poll() 247 if (nfds == 0) { in uv__io_poll() 261 if (nfds == -1) { in uv__io_poll() 285 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll() 286 for (i = 0; i < nfds; i++) { in uv__io_poll() 418 if (nfds == ARRAY_SIZE(events) && --count != 0) { in uv__io_poll() 447 uintptr_t nfds; in uv__platform_invalidate_fd() local 453 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd() [all …]
|
H A D | sunos.c | 117 uintptr_t nfds; in uv__platform_invalidate_fd() local 123 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd() 128 for (i = 0; i < nfds; i++) in uv__platform_invalidate_fd() 157 unsigned int nfds; in uv__io_poll() local 168 if (loop->nfds == 0) { in uv__io_poll() 227 nfds = 1; in uv__io_poll() 236 &nfds, in uv__io_poll() 275 if (nfds == 0) { in uv__io_poll() 285 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; in uv__io_poll() 286 for (i = 0; i < nfds; i++) { in uv__io_poll() [all …]
|
H A D | os390.c | 584 uintptr_t nfds; in uv__platform_invalidate_fd() local 590 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd() 593 for (i = 0; i < nfds; i++) in uv__platform_invalidate_fd() 816 int nfds; in uv__io_poll() local 823 if (loop->nfds == 0) { in uv__io_poll() 883 nfds = 0; in uv__io_poll() 894 nfds = epoll_wait(loop->ep, events, in uv__io_poll() 903 if (nfds == 0) { in uv__io_poll() 923 if (nfds == -1) { in uv__io_poll() 947 for (i = 0; i < nfds; i++) { in uv__io_poll() [all …]
|
H A D | posix-poll.c | 143 int nfds; in uv__io_poll() local 150 if (loop->nfds == 0) { in uv__io_poll() 204 nfds = poll(loop->poll_fds, (nfds_t)loop->poll_fds_used, timeout); in uv__io_poll() 215 if (nfds == 0) { in uv__io_poll() 229 if (nfds == -1) { in uv__io_poll()
|
/netbsd/lib/libc/compat/sys/ |
H A D | compat_select.c | 64 pollts(struct pollfd * __restrict fds, nfds_t nfds, in __weak_alias() 74 return __pollts50(fds, nfds, timp, sigmask); in __weak_alias() 78 select(int nfds, fd_set * __restrict readfds, fd_set * __restrict writefds, in select() argument 87 return __select50(nfds, readfds, writefds, exceptfds, timp); in select() 91 pselect(int nfds, fd_set * __restrict readfds, fd_set * __restrict writefds, in pselect() argument 101 return __pselect50(nfds, readfds, writefds, exceptfds, timp, sigmask); in pselect()
|
/netbsd/external/gpl2/xcvs/dist/lib/ |
H A D | sunos57-select.c | 56 rpl_select (int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, in rpl_select() argument 62 if (nfds < 1 || nfds > FD_SETSIZE) in rpl_select() 83 for (fd = 0; fd < nfds; fd++) in rpl_select() 206 for (fd = 0; fd < nfds; fd++) in rpl_select() 225 ret = select (nfds, readfds, writefds, exceptfds, timeout); in rpl_select()
|
/netbsd/usr.sbin/lpr/lpd/ |
H A D | lpd.c | 148 int lfd, errs, i, f, nfds; in main() local 315 rv = poll(socks, nfds, INFTIM); in main() 322 for (i = 0; i < nfds; i++) in main() 342 for (i = 0; i < nfds; i++) in main() 714 *nfds = 0; in socksetup() 739 socks[*nfds].fd = s; in socksetup() 740 socks[*nfds].events = POLLIN; in socksetup() 741 (*nfds)++; in socksetup() 807 socks[*nfds].fd = s; in socksetup() 808 socks[*nfds].events = POLLIN; in socksetup() [all …]
|
/netbsd/usr.bin/rsh/ |
H A D | rsh.c | 338 int nr, nw, nfds; in talk() local 396 nfds = 2; in talk() 401 nfds = 3; in talk() 411 if (poll(fdp, nfds, INFTIM) == -1) { in talk() 421 nfds--; in talk() 425 nfds--; in talk() 432 nfds--; in talk() 436 while (nfds); in talk()
|
/netbsd/lib/librumphijack/ |
H A D | hijack.c | 2063 for (i = 0; i < nfds; i++) { 2118 for (i = 0; i < nfds; i++) { 2134 for (i = 0; i < nfds; i++) { 2145 nfds_t nfds; member 2227 for (i = 0; i < nfds; i++) { 2261 pfd_host[nfds].fd = hpipe[0]; 2262 pfd_host[nfds].events = POLLIN; 2263 pfd_rump[nfds].fd = rpipe[0]; 2272 parg.nfds = nfds+1; 2300 for (i = 0; i < nfds; i++) { [all …]
|
/netbsd/sys/arch/zaurus/stand/zboot/ |
H A D | unixcons.c | 129 int nfds, n; in common_getc() local 137 nfds = 1; in common_getc() 140 n = uselect(nfds, &fdset, NULL, NULL, &tv); in common_getc() 146 for (fd = 0; fd < nfds; fd++) { in common_getc()
|
/netbsd/lib/libc/gen/ |
H A D | ftw.c | 39 int nfds) in ftw() argument 48 if (nfds < 1 || nfds > OPEN_MAX) { in ftw()
|
H A D | nftw.c | 40 struct FTW *), int nfds, int ftwflags) in nftw() argument 50 if (nfds < 1 || nfds > OPEN_MAX) { in nftw()
|
/netbsd/crypto/external/cpl/trousers/dist/src/tcsd/ |
H A D | svrside.c | 391 fd_set *rdfd_set, int *nfds) in prepare_for_select() argument 397 *nfds = 0; in prepare_for_select() 406 if (*nfds < socks_info[i].sd) // grab highest sd for select call in prepare_for_select() 407 *nfds = socks_info[i].sd; in prepare_for_select() 421 int nfds = 0; in main() local 503 prepare_for_select(socks_info, &num_fds, &rdfd_set, &nfds); in main() 532 rv = pselect(nfds+1, &rdfd_set, NULL, NULL, NULL, &oldsigmask); in main()
|
/netbsd/tests/net/if_vlan/ |
H A D | bpfopen.c | 211 int nfds; in bpf_read() local 242 nfds = poll(pfd, PFD_NUM, 1 * 1000); in bpf_read() 243 if (nfds == -1 && errno != EINTR) { in bpf_read() 248 if (nfds > 0 && (pfd[PFD_BPF].revents & POLLIN)) { in bpf_read()
|
/netbsd/sys/kern/ |
H A D | uipc_usrreq.c | 1414 if (nfds == 0) in unp_externalize() 1422 for (size_t i = 0; i < nfds; i++) { in unp_externalize() 1511 for (size_t i = 0; i < nfds; i++) in unp_externalize() 1543 int nfds, error; in unp_internalize() local 1562 for (i = 0; i < nfds; i++) { in unp_internalize() 1566 nfds = i; in unp_internalize() 1575 nfds = i; in unp_internalize() 1597 fdp = (int *)CMSG_DATA(cm) + nfds; in unp_internalize() 1598 rp = files + nfds; in unp_internalize() 1599 for (i = 0; i < nfds; i++) { in unp_internalize() [all …]
|
H A D | sys_epoll.c | 555 epoll_recover_watch_tree(struct epoll_edge *edges, size_t nedges, size_t nfds) { in epoll_recover_watch_tree() argument 560 for (i = 0; i < nfds && (edges == NULL || nedges_so_far < nedges); i++) in epoll_recover_watch_tree() 643 size_t nedges, nfds, seen_size; in epoll_check_loop_and_depth() local 655 nfds = l->l_proc->p_fd->fd_lastfile + 1; in epoll_check_loop_and_depth() 662 nedges = 1 + epoll_recover_watch_tree(NULL, 0, nfds); in epoll_check_loop_and_depth() 666 epoll_recover_watch_tree(edges + 1, nedges - 1, nfds); in epoll_check_loop_and_depth() 671 seen_size = __BITMAP_SIZE(char, nfds); in epoll_check_loop_and_depth() 674 error = epoll_dfs(edges, nedges, seen, nfds, epfd, 0); in epoll_check_loop_and_depth()
|
/netbsd/usr.sbin/mrouted/ |
H A D | main.c | 105 int nfds, n, i; in main() local 258 nfds = igmp_socket + 1; in main() 263 if (ihandlers[i].fd >= nfds) in main() 264 nfds = ihandlers[i].fd + 1; in main() 308 snmp_select_info(&nfds, &rfds, tvp, &block); in main() 311 if ((n = select(nfds, &rfds, NULL, NULL, tvp)) < 0) in main() 313 if ((n = select(nfds, &rfds, NULL, NULL, NULL)) < 0) in main()
|
/netbsd/external/bsd/atf/dist/tools/ |
H A D | io.cpp | 239 safe_poll(struct pollfd fds[], nfds_t nfds, int timeout) in safe_poll() argument 241 int ret = ::poll(fds, nfds, timeout); in safe_poll() 272 impl::muxer::muxer(const int* fds, const size_t nfds, const size_t bufsize) : in muxer() argument 274 m_nfds(nfds), in muxer() 276 m_buffers(new std::string[nfds]) in muxer()
|
/netbsd/crypto/dist/ipsec-tools/src/racoon/ |
H A D | session.c | 122 static int nfds = 0; 135 if (fd > nfds) in monitor_fd() 136 nfds = fd; in monitor_fd() 180 nfds = 0; in session() 300 error = select(nfds + 1, &active_mask, NULL, NULL, timeout); in session()
|