Home
last modified time | relevance | path

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

12345

/netbsd-src/external/bsd/libevent/dist/
H A Dpoll.c76 int nfds; /* Highest number used */ member
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()
203 i = evutil_weakrand_range_(&base->weakrand_seed, nfds); in poll_dispatch()
204 for (j = 0; j < nfds; j++) { in poll_dispatch()
206 if (++i == nfds) in poll_dispatch()
[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-src/sys/external/bsd/libnv/dist/
H A Dmsgio.c256 fd_package_send(int sock, const int *fds, size_t nfds) in fd_package_send() argument
267 PJDLOG_ASSERT(nfds > 0); in fd_package_send()
280 msg.msg_controllen = nfds * CMSG_SPACE(sizeof(int)); in fd_package_send()
287 for (i = 0, cmsg = CMSG_FIRSTHDR(&msg); i < nfds && cmsg != NULL; in fd_package_send()
305 fd_package_recv(int sock, int *fds, size_t nfds) in fd_package_recv() argument
315 PJDLOG_ASSERT(nfds > 0); in fd_package_recv()
329 msg.msg_controllen = nfds * CMSG_SPACE(sizeof(int)); in fd_package_recv()
339 for (i = 0, cmsg = CMSG_FIRSTHDR(&msg); i < nfds && cmsg != NULL; in fd_package_recv()
346 if (cmsg != NULL || i < nfds) { in fd_package_recv()
372 fd_recv(int sock, int *fds, size_t nfds) in fd_recv() argument
[all …]
/netbsd-src/external/mit/libuv/dist/src/unix/
H A Depoll.c53 uintptr_t nfds; in uv__platform_invalidate_fd() local
59 nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1]; in uv__platform_invalidate_fd()
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()
[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()
946 loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds; 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-src/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-src/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-src/external/gpl3/gdb/dist/gnulib/import/
H A Dselect.c267 rpl_select (int nfds, fd_set *rfds, fd_set *wfds, fd_set *xfds, in rpl_select() argument
282 if (nfds > FD_SETSIZE) in rpl_select()
283 nfds = FD_SETSIZE; in rpl_select()
363 for (i = 0; i < nfds; i++) in rpl_select()
478 for (i = 0; i < nfds; i++) in rpl_select()
524 for (i = 0; i < nfds; i++) in rpl_select()
567 rpl_select (int nfds, fd_set *rfds, fd_set *wfds, fd_set *xfds, in rpl_select() argument
573 if (nfds < 0 || nfds > FD_SETSIZE) in rpl_select()
578 for (i = 0; i < nfds; i++) in rpl_select()
588 if (nfds == 0) in rpl_select()
[all …]
/netbsd-src/usr.sbin/lpr/lpd/
H A Dlpd.c148 int lfd, errs, i, f, nfds; in main() local
284 socks = socksetup(PF_UNSPEC, options, port, &nfds); in main()
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()
706 socksetup(int af, int options, const char *port, int *nfds) in socksetup() argument
714 *nfds = 0; in socksetup()
739 socks[*nfds].fd = s; in socksetup()
740 socks[*nfds].events = POLLIN; in socksetup()
741 (*nfds)++; in socksetup()
[all …]
/netbsd-src/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-src/lib/librumphijack/
H A Dhijack.c1725 const int nfds = (int)(size / sizeof(int));
1726 const int * const efdp = fdp + nfds;
2001 REALPSELECT(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds,
2009 DPRINTF(("pselect %d %p %p %p %p %p\n", nfds,
2015 * nb5 poll() silently refuses nfds > process_maxopen_fds.
2020 for (i = 0, realnfds = 0; i < nfds; i++) {
2043 for (i = 0, j = 0; i < nfds; i++) {
2081 for (i = 0; i < nfds; i++) {
2119 REALSELECT(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds,
2127 return REALPSELECT(nfds, readfd
1707 const int nfds = (int)(size / sizeof(int)); global() local
1983 REALPSELECT(int nfds,fd_set * readfds,fd_set * writefds,fd_set * exceptfds,const struct timespec * timeout,const sigset_t * sigmask) global() argument
2101 REALSELECT(int nfds,fd_set * readfds,fd_set * writefds,fd_set * exceptfds,struct timeval * timeout) global() argument
2114 checkpoll(struct pollfd * fds,nfds_t nfds,int * hostcall,int * rumpcall) global() argument
2130 adjustpoll(struct pollfd * fds,nfds_t nfds,int (* fdadj)(int)) global() argument
2145 nfds_t nfds; global() member
2170 REALPOLLTS(struct pollfd * fds,nfds_t nfds,const struct timespec * ts,const sigset_t * sigmask) global() argument
2364 poll(struct pollfd * fds,nfds_t nfds,int timeout) global() argument
[all...]
/netbsd-src/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-src/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-src/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-src/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-src/sys/kern/
H A Duipc_usrreq.c1415 const size_t nfds = (cm->cmsg_len - CMSG_ALIGN(sizeof(*cm))) / in unp_externalize()
1417 if (nfds == 0) in unp_externalize()
1420 int * const fdp = kmem_alloc(nfds * sizeof(int), KM_SLEEP); in unp_externalize()
1425 for (size_t i = 0; i < nfds; i++) { in unp_externalize()
1452 for (size_t i = 0; i < nfds; i++) { in unp_externalize()
1481 for (size_t i = 0; i < nfds; i++) { in unp_externalize()
1508 cm->cmsg_len = CMSG_LEN(nfds * sizeof(int)); in unp_externalize()
1509 rights->m_len = CMSG_SPACE(nfds * sizeof(int)); in unp_externalize()
1514 for (size_t i = 0; i < nfds; i++) in unp_externalize()
1524 kmem_free(fdp, nfds * sizeo in unp_externalize()
1412 const size_t nfds = (cm->cmsg_len - CMSG_ALIGN(sizeof(*cm))) / unp_externalize() local
1543 int nfds, error; unp_internalize() local
[all...]
H A Dsys_epoll.c557 epoll_recover_watch_tree(struct epoll_edge *edges, size_t nedges, size_t nfds) { in epoll_recover_watch_tree() argument
562 for (i = 0; i < nfds && (edges == NULL || nedges_so_far < nedges); i++) in epoll_recover_watch_tree()
645 size_t nedges, nfds, seen_size; in epoll_check_loop_and_depth() local
657 nfds = l->l_proc->p_fd->fd_lastfile + 1; in epoll_check_loop_and_depth()
664 nedges = 1 + epoll_recover_watch_tree(NULL, 0, nfds); in epoll_check_loop_and_depth()
668 epoll_recover_watch_tree(edges + 1, nedges - 1, nfds); in epoll_check_loop_and_depth()
673 seen_size = __BITMAP_SIZE(char, nfds); in epoll_check_loop_and_depth()
676 error = epoll_dfs(edges, nedges, seen, nfds, epfd, 0); in epoll_check_loop_and_depth()
/netbsd-src/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-src/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-src/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()
/netbsd-src/lib/libc/sys/
H A Dppoll.c40 ppoll(struct pollfd * restrict fds, nfds_t nfds, in ppoll() argument
45 return pollts(fds, nfds, timeout_ts, sigmask); in ppoll()

12345