Home
last modified time | relevance | path

Searched refs:nfds (Results 1 – 25 of 118) sorted by relevance

12345

/netbsd/external/bsd/ntp/dist/sntp/libevent/
H A Dpoll.c117 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 Dselect.c144 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 Dpoll.c129 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 Dselect.c145 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 Dmsgio.c267 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 Depoll.c53 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 Dkqueue.c129 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 Dsunos.c117 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 Dos390.c584 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 Dposix-poll.c143 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 Dcompat_select.c64 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 Dsunos57-select.c56 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 Dlpd.c148 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 Drsh.c338 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 Dhijack.c2063 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 Dunixcons.c129 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 Dftw.c39 int nfds) in ftw() argument
48 if (nfds < 1 || nfds > OPEN_MAX) { in ftw()
H A Dnftw.c40 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 Dsvrside.c391 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 Dbpfopen.c211 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 Duipc_usrreq.c1414 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 Dsys_epoll.c555 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 Dmain.c105 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 Dio.cpp239 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 Dsession.c122 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()

12345