Home
last modified time | relevance | path

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

123

/trueos/lib/libnv/
HDmsgio.c240 fd_package_send(int sock, const int *fds, size_t nfds) in fd_package_send() argument
251 PJDLOG_ASSERT(nfds > 0); in fd_package_send()
264 msg.msg_controllen = nfds * CMSG_SPACE(sizeof(int)); in fd_package_send()
271 for (i = 0, cmsg = CMSG_FIRSTHDR(&msg); i < nfds && cmsg != NULL; in fd_package_send()
289 fd_package_recv(int sock, int *fds, size_t nfds) in fd_package_recv() argument
299 PJDLOG_ASSERT(nfds > 0); in fd_package_recv()
314 msg.msg_controllen = nfds * CMSG_SPACE(sizeof(int)); in fd_package_recv()
324 for (i = 0, cmsg = CMSG_FIRSTHDR(&msg); i < nfds && cmsg != NULL; in fd_package_recv()
331 if (cmsg != NULL || i < nfds) { in fd_package_recv()
357 fd_recv(int sock, int *fds, size_t nfds) in fd_recv() argument
[all …]
HDmsgio.h44 int fd_send(int sock, const int *fds, size_t nfds);
45 int fd_recv(int sock, int *fds, size_t nfds);
/trueos/tests/sys/kqueue/
HDvnode.c97 int nfds; in test_kevent_vnode_note_attrib() local
108 nfds = kevent(kqfd, NULL, 0, &kev, 1, NULL); in test_kevent_vnode_note_attrib()
109 if (nfds < 1) in test_kevent_vnode_note_attrib()
125 int nfds; in test_kevent_vnode_note_rename() local
136 nfds = kevent(kqfd, NULL, 0, &kev, 1, NULL); in test_kevent_vnode_note_rename()
137 if (nfds < 1) in test_kevent_vnode_note_rename()
171 int nfds; in test_kevent_vnode_disable_and_enable() local
196 nfds = kevent(kqfd, NULL, 0, &kev, 1, NULL); in test_kevent_vnode_disable_and_enable()
197 if (nfds < 1) in test_kevent_vnode_disable_and_enable()
214 int nfds; in test_kevent_vnode_dispatch() local
[all …]
HDmain.c41 int nfds; in test_no_kevents() local
47 nfds = kevent(kqfd, NULL, 0, &kev, 1, &timeo); in test_no_kevents()
48 if (nfds != 0) { in test_no_kevents()
51 errx(1, "%d event(s) pending, but none expected:", nfds); in test_no_kevents()
59 int nfds; in kevent_get() local
65 nfds = kevent(kqfd, NULL, 0, kev, 1, NULL); in kevent_get()
66 if (nfds < 1) in kevent_get()
/trueos/contrib/pf/libevent/
HDpoll.c61 int nfds; /* Size of event_* */ member
141 for (i = 0; i < pop->nfds; ++i) { in poll_check_ok()
153 int res, i, sec, nfds; in poll_dispatch() local
158 nfds = pop->nfds; in poll_dispatch()
159 res = poll(pop->event_set, nfds, sec); in poll_dispatch()
177 for (i = 0; i < nfds; i++) { in poll_dispatch()
227 if (pop->nfds + 1 >= pop->event_count) { in poll_add()
293 i = pop->nfds++; in poll_add()
355 --pop->nfds; in poll_del()
356 if (i != pop->nfds) { in poll_del()
[all …]
/trueos/usr.sbin/ppp/
HDmain.c543 int i, nfds, nothing_done; in DoLoop() local
564 nfds = 0; in DoLoop()
570 descriptor_UpdateSet(&bundle->desc, rfds, wfds, efds, &nfds); in DoLoop()
573 descriptor_UpdateSet(&server.desc, rfds, NULL, NULL, &nfds); in DoLoop()
591 i = select(nfds, rfds, wfds, efds, NULL); in DoLoop()
598 for (i = 0; i <= nfds; i++) { in DoLoop()
603 if (select(nfds, rfds, wfds, efds, &t) != -1) { in DoLoop()
612 if (select(nfds, rfds, wfds, efds, &t) != -1) { in DoLoop()
621 if (select(nfds, rfds, wfds, efds, &t) != -1) { in DoLoop()
638 for (i = 0; i <= nfds; i++) in DoLoop()
[all …]
/trueos/lib/libkse/thread/
HDthr_poll.c47 int __poll(struct pollfd *fds, unsigned int nfds, int timeout);
52 __poll(struct pollfd *fds, unsigned int nfds, int timeout) in __poll() argument
58 ret = __sys_poll(fds, nfds, timeout); in __poll()
/trueos/sys/compat/svr4/
HDsvr4_filio.c68 if (uap->nfds > maxfilesperproc && uap->nfds > FD_SETSIZE)
72 pa.nfds = uap->nfds;
75 siz = uap->nfds * sizeof(struct pollfd);
85 for (idx = 0; idx < uap->nfds; idx++) {
/trueos/crypto/openssh/openbsd-compat/
HDbsd-poll.c43 poll(struct pollfd *fds, nfds_t nfds, int timeout) in poll() argument
51 for (i = 0; i < nfds; i++) { in poll()
70 for (i = 0; i < nfds; i++) { in poll()
95 for (i = 0; i < nfds; i++) { in poll()
/trueos/contrib/apr/network_io/unix/
HDsocket_util.c24 apr_int32_t nfds; in apr_socket_atreadeof() local
36 rv = apr_poll(&pfds[0], 1, &nfds, 0); in apr_socket_atreadeof()
50 else if (nfds == 1 && (pfds[0].rtnevents & APR_POLLIN) == APR_POLLIN) { in apr_socket_atreadeof()
/trueos/usr.bin/rsh/
HDrsh.c245 int nfds, srval; in talk() local
260 nfds = rem + 1; in talk()
261 if (select(nfds, 0, &rembits, 0, 0) < 0) { in talk()
293 nfds = MAX(rfd2+1, rem+1); in talk()
297 srval = select(nfds, &ready, 0, 0, &tvtimeout); in talk()
299 srval = select(nfds, &ready, 0, 0, 0); in talk()
/trueos/contrib/llvm/tools/lldb/source/Core/
HDConnectionFileDescriptor.cpp749 const int nfds = std::max<int>(data_fd, pipe_fd) + 1; in BytesAvailable() local
751 read_fds.resize((nfds/FD_SETSIZE) + 1); in BytesAvailable()
767 this, nfds, data_fd, pipe_fd, tv_ptr); in BytesAvailable()
770 this, nfds, data_fd, tv_ptr); in BytesAvailable()
773 const int num_set_fds = ::select (nfds, read_fds.data(), NULL, NULL, tv_ptr); in BytesAvailable()
783 … this, nfds, data_fd, pipe_fd, tv_ptr, num_set_fds, error.AsCString()); in BytesAvailable()
786 this, nfds, data_fd, tv_ptr, num_set_fds, error.AsCString()); in BytesAvailable()
918 const int nfds = std::max<int>(data_fd, pipe_fd) + 1; in BytesAvailable() local
926 this, nfds, data_fd, pipe_fd, tv_ptr); in BytesAvailable()
929 this, nfds, data_fd, tv_ptr); in BytesAvailable()
[all …]
/trueos/lib/libc/sys/
HDpoll.c44 poll(struct pollfd pfd[], nfds_t nfds, int timeout) in poll() argument
48 __libc_interposing[INTERPOS_poll])(pfd, nfds, timeout)); in poll()
HDppoll.c44 ppoll(struct pollfd pfd[], nfds_t nfds, const struct timespec *__restrict in ppoll() argument
49 const sigset_t *)) __libc_interposing[INTERPOS_ppoll])(pfd, nfds, in ppoll()
/trueos/sys/sys/
HDnvlist_impl.h41 size_t nfds);
45 const unsigned char *ptr, size_t nfds, bool *isbep, size_t *leftp);
/trueos/lib/libusb/
HDlibusb10_io.c104 nfds_t nfds; in libusb10_handle_events_sub() local
111 nfds = 0; in libusb10_handle_events_sub()
114 nfds++; in libusb10_handle_events_sub()
116 fds = alloca(sizeof(*fds) * nfds); in libusb10_handle_events_sub()
120 ppdev = alloca(sizeof(*ppdev) * nfds); in libusb10_handle_events_sub()
140 err = poll(fds, nfds, timeout); in libusb10_handle_events_sub()
149 for (i = 0; i != (int)nfds; i++) { in libusb10_handle_events_sub()
158 for (i = 0; i != (int)nfds; i++) { in libusb10_handle_events_sub()
/trueos/lib/libtacplus/
HDtaclib.c259 int nfds; in conn_server() local
269 nfds = select(h->fd + 1, NULL, &wfds, NULL, &tv); in conn_server()
270 if (nfds == -1) { in conn_server()
276 if (nfds == 0) { in conn_server()
501 int nfds; in read_timed() local
517 nfds = in read_timed()
519 if (nfds == -1) { in read_timed()
525 nfds = 0; in read_timed()
526 if (nfds == 0) { in read_timed()
653 int nfds; in send_msg() local
[all …]
/trueos/sbin/nos-tun/
HDnos-tun.c261 int nfds; /* Return from select() */ in main() local
355 nfds = select(lastfd+1,&rfds,NULL,NULL,NULL); in main()
356 if(nfds < 0) { in main()
361 if(nfds == 0) { /* Impossible ? */ in main()
/trueos/lib/libc/gen/
HDftw.c34 int nfds) in ftw() argument
42 if (nfds < 1) { in ftw()
HDnftw.c34 struct FTW *), int nfds, int ftwflags) in nftw() argument
43 if (nfds < 1) { in nftw()
/trueos/sbin/dhclient/
HDdispatch.c147 int count, live_interfaces, i, to_msec, nfds = 0; in dispatch() local
153 nfds++; in dispatch()
155 fds = malloc(nfds * sizeof(struct pollfd)); in dispatch()
208 count = poll(fds, nfds, to_msec); in dispatch()
/trueos/usr.sbin/IPXrouted/
HDmain.c105 int nfds; local
236 nfds = 1 + max(sapsock, ripsock);
251 if(select(nfds, &fdvar, (fd_set *)NULL, (fd_set *)NULL,
/trueos/lib/libthr/thread/
HDthr_syscalls.c311 __thr_poll(struct pollfd *fds, unsigned int nfds, int timeout) in __thr_poll() argument
318 ret = __sys_poll(fds, nfds, timeout); in __thr_poll()
330 __thr_ppoll(struct pollfd pfd[], nfds_t nfds, const struct timespec * in __thr_ppoll() argument
338 ret = __sys_ppoll(pfd, nfds, timeout, newsigmask); in __thr_ppoll()
/trueos/sys/kern/
HDsubr_nvlist.c883 nvlist_unpack_header(nvlist_t *nvl, const unsigned char *ptr, size_t nfds, in nvlist_unpack_header() argument
902 if (nvlhdr.nvlh_descriptors > nfds) in nvlist_unpack_header()
923 nvlist_xunpack(const void *buf, size_t size, const int *fds, size_t nfds) in nvlist_xunpack() argument
939 ptr = nvlist_unpack_header(nvl, ptr, nfds, &isbe, &left); in nvlist_xunpack()
967 ptr = nvpair_unpack_nvlist(isbe, nvp, ptr, &left, nfds, in nvlist_xunpack()
974 fds, nfds); in nvlist_xunpack()
1015 size_t datasize, nfds; in nvlist_send() local
1026 fds = nvlist_descriptors(nvl, &nfds); in nvlist_send()
1041 if (nfds > 0) { in nvlist_send()
1042 if (fd_send(sock, fds, nfds) == -1) in nvlist_send()
[all …]
/trueos/contrib/bmake/
HDjob.c348 static int nfds = 0; variable
2087 nready = poll(fds + 1 - wantToken, nfds - 1 + wantToken, POLL_MSEC); in Job_CatchOutput()
2117 for (i = 2; i < nfds; i++) { in Job_CatchOutput()
2795 fds[nfds].fd = job->inPipe; in watchfd()
2796 fds[nfds].events = POLLIN; in watchfd()
2797 jobfds[nfds] = job; in watchfd()
2798 job->inPollfd = &fds[nfds]; in watchfd()
2799 nfds++; in watchfd()
2809 nfds--; in clearfd()
2813 if (nfds != i) { in clearfd()
[all …]

123