/dports/net/libnfs/libnfs-libnfs-4.0.0/examples/ |
H A D | nfsclient-async.c | 240 struct pollfd pfds[2]; /* nfs:0 mount:1 */ in main() local 268 pfds[0].fd = nfs_get_fd(nfs); in main() 269 pfds[0].events = nfs_which_events(nfs); in main() 273 pfds[1].fd = rpc_get_fd(mount_context); in main() 274 pfds[1].events = rpc_which_events(mount_context); in main() 277 if (poll(&pfds[0], 2, -1) < 0) { in main() 282 if (rpc_service(mount_context, pfds[1].revents) < 0) { in main() 287 if (nfs_service(nfs, pfds[0].revents) < 0) { in main()
|
/dports/sysutils/freeipmi/freeipmi-1.6.8/ipmidetectd/ |
H A D | ipmidetectd.c | 484 _setup_pfds (struct pollfd *pfds) in _setup_pfds() argument 488 assert (pfds); in _setup_pfds() 492 pfds[i].fd = fds[i]; in _setup_pfds() 493 pfds[i].events = POLLIN; in _setup_pfds() 494 pfds[i].revents = 0; in _setup_pfds() 497 pfds[fds_count].fd = server_fd; in _setup_pfds() 498 pfds[fds_count].events = POLLIN; in _setup_pfds() 499 pfds[fds_count].revents = 0; in _setup_pfds() 645 struct pollfd *pfds = NULL; in _ipmidetectd_loop() local 675 _setup_pfds (pfds); in _ipmidetectd_loop() [all …]
|
/dports/audio/zrythm/zrythm-1.0.0-alpha.26.0.13/src/audio/ |
H A D | engine_alsa.c | 408 struct pollfd *pfds; 412 pfds = 417 self->playback_handle, pfds, 423 if (poll (pfds, (nfds_t) nfds, 1000) > 0) 427 while (pfds[l1].revents > 0) 467 struct pollfd *pfds; 471 pfds = 476 self->seq_handle, pfds, 481 if (poll (pfds, (nfds_t) seq_nfds, 1000) > 0) 485 if (pfds[l1].revents > 0)
|
/dports/science/opensim-core/opensim-core-4.1/OpenSim/Simulation/ |
H A D | MomentArmSolver.cpp | 99 const Array<PointForceDirection *> &pfds) const in solve() 113 int n = pfds.getSize(); in solve() 118 pfds[i]->frame().getMobilizedBodyIndex(), in solve() 119 pfds[i]->point(), pfds[i]->direction(), _bodyForces); in solve()
|
/dports/audio/musicpd/mpd-0.23.6/src/event/ |
H A D | MultiSocketMonitor.cxx | 85 MultiSocketMonitor::ReplaceSocketList(pollfd *pfds, unsigned n) noexcept in ReplaceSocketList() argument 91 pollfd *const end = pfds + n; in ReplaceSocketList() 93 UpdateSocketList([pfds, end](SocketDescriptor fd) -> unsigned { in ReplaceSocketList() 94 auto i = std::find_if(pfds, end, [fd](const struct pollfd &pfd){ in ReplaceSocketList() 103 for (auto i = pfds; i != end; ++i) in ReplaceSocketList()
|
/dports/sysutils/barrier/barrier-2.3.3/src/lib/platform/ |
H A D | XWindowsEventQueueBuffer.cpp | 131 struct pollfd pfds[2]; in waitForEvent() local 132 pfds[0].fd = ConnectionNumber(m_display); in waitForEvent() 133 pfds[0].events = POLLIN; in waitForEvent() 134 pfds[1].fd = m_pipefd[0]; in waitForEvent() 135 pfds[1].events = POLLIN; in waitForEvent() 181 … retval = poll(pfds, 2, TIMEOUT_DELAY); //16ms = 60hz, but we make it > to play nicely with the cpu in waitForEvent() 182 if (pfds[1].revents & POLLIN) { in waitForEvent()
|
/dports/net/nng/nng-1.5.2/src/platform/posix/ |
H A D | posix_pollq_poll.c | 190 nni_posix_pfd ** pfds = NULL; in nni_posix_poll_thr() local 209 NNI_FREE_STRUCTS(pfds, nalloc); in nni_posix_poll_thr() 212 if ((pfds = NNI_ALLOC_STRUCTS(pfds, n)) == NULL) { in nni_posix_poll_thr() 215 NNI_FREE_STRUCTS(pfds, n); in nni_posix_poll_thr() 228 pfds[0] = NULL; in nni_posix_poll_thr() 257 pfds[nfds] = pfd; in nni_posix_poll_thr() 282 pfd = pfds[i]; in nni_posix_poll_thr() 298 NNI_FREE_STRUCTS(pfds, nalloc); in nni_posix_poll_thr()
|
/dports/net-mgmt/nsca27-client/nsca-2.7.2/src/ |
H A D | nsca.c | 60 struct pollfd *pfds=NULL; variable 501 if(pfds[i].fd==fd){ in register_poll() 514 pfds=realloc(pfds, sizeof(struct pollfd) * maxpfds); in register_poll() 517 pfds[npfds].fd=fd; in register_poll() 518 pfds[npfds].events=events; in register_poll() 633 poll(pfds,npfds,-1); in handle_events() 635 if((pfds[i].events&POLLIN) && (pfds[i].revents&(POLLIN|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 644 … if((pfds[i].events&POLLOUT) && (pfds[i].revents&(POLLOUT|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 656 if(pfds[i].events==0){ in handle_events() 658 pfds[i].fd=pfds[npfds].fd; in handle_events() [all …]
|
/dports/net-mgmt/nsca27/nsca-2.7.2/src/ |
H A D | nsca.c | 60 struct pollfd *pfds=NULL; variable 501 if(pfds[i].fd==fd){ in register_poll() 514 pfds=realloc(pfds, sizeof(struct pollfd) * maxpfds); in register_poll() 517 pfds[npfds].fd=fd; in register_poll() 518 pfds[npfds].events=events; in register_poll() 633 poll(pfds,npfds,-1); in handle_events() 635 if((pfds[i].events&POLLIN) && (pfds[i].revents&(POLLIN|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 644 … if((pfds[i].events&POLLOUT) && (pfds[i].revents&(POLLOUT|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 656 if(pfds[i].events==0){ in handle_events() 658 pfds[i].fd=pfds[npfds].fd; in handle_events() [all …]
|
/dports/net/corosync2/corosync-2.4.5/qdevices/ |
H A D | corosync-qnetd.c | 175 PRPollDesc *pfds; in qnetd_poll() local 185 pfds = qnetd_pr_poll_array_create(instance); in qnetd_poll() 186 if (pfds == NULL) { in qnetd_poll() 190 if ((poll_res = PR_Poll(pfds, pr_poll_array_size(&instance->poll_array), in qnetd_poll() 219 pfds[i].out_flags & PR_POLL_READ) { in qnetd_poll() 239 pfds[i].out_flags & PR_POLL_WRITE) { in qnetd_poll() 266 !(pfds[i].out_flags & (PR_POLL_READ|PR_POLL_WRITE))) { in qnetd_poll() 270 if (pfds[i].out_flags != PR_POLL_NVAL) { in qnetd_poll() 276 "socket", pfds[i].out_flags); in qnetd_poll() 285 "Disconnecting.", pfds[i].out_flags); in qnetd_poll() [all …]
|
H A D | pr-poll-array.c | 107 pr_poll_array_add(struct pr_poll_array *poll_array, PRPollDesc **pfds, void **user_data) in pr_poll_array_add() argument 116 *pfds = &poll_array->array[pr_poll_array_size(poll_array)]; in pr_poll_array_add() 117 memset(*pfds, 0, sizeof(**pfds)); in pr_poll_array_add()
|
/dports/audio/alsa-utils/alsa-utils-1.2.2/axfer/ |
H A D | waiter-epoll.c | 41 .data.fd = waiter->pfds[i].fd, in epoll_prepare() 42 .events = waiter->pfds[i].events, in epoll_prepare() 70 if (waiter->pfds[i].fd == ev->data.fd) { in epoll_wait_event() 71 waiter->pfds[i].revents = ev->events; in epoll_wait_event() 87 int fd = waiter->pfds[i].fd; in epoll_release()
|
/dports/devel/libfaketime/libfaketime-da77808/src/ |
H A D | faketime.c | 163 int pfds[2]; in main() local 164 (void) (pipe(pfds) + 1); in main() 170 (void) (dup(pfds[1]) + 1); /* make stdout same as pfds[1] */ in main() 171 close(pfds[0]); /* we don't need this */ in main() 181 close(pfds[1]); /* we won't write to this */ in main() 182 (void) (read(pfds[0], buf, 256) + 1); in main() 193 close(pfds[0]); /* finished reading */ in main()
|
/dports/security/snort3/snort3-3.1.19.0/src/connectors/tcp_connector/ |
H A D | tcp_connector.cc | 160 struct pollfd pfds[1]; in process_receive() local 163 pfds[0].events = POLLIN; in process_receive() 164 pfds[0].fd = sock_fd; in process_receive() 165 rval = poll(pfds, 1, 1000); in process_receive() 173 … ErrorMessage("TcpC Input Thread: Error polling on socket %d: %s\n", pfds[0].fd, error_msg); in process_receive() 175 … ErrorMessage("TcpC Input Thread: Error polling on socket %d: (%d)\n", pfds[0].fd, errno); in process_receive() 179 else if ((pfds[0].revents & (POLLHUP|POLLERR|POLLNVAL)) != 0) in process_receive() 182 pfds[0].fd, pfds[0].revents); in process_receive() 185 else if (rval > 0 && pfds[0].revents & POLLIN) in process_receive()
|
/dports/sysutils/toybox/toybox-0.8.5/toys/pending/ |
H A D | telnet.c | 236 struct pollfd pfds[2]; in telnet_main() local 252 pfds[0].fd = 0; in telnet_main() 253 pfds[0].events = POLLIN; in telnet_main() 254 pfds[1].fd = TT.sock; in telnet_main() 255 pfds[1].events = POLLIN; in telnet_main() 257 if (poll(pfds, 2, -1) < 0) { in telnet_main() 261 if (pfds[0].revents) { in telnet_main() 265 if (pfds[1].revents) { in telnet_main()
|
/dports/net-mgmt/nsca/nsca-2.9.2/src/ |
H A D | nsca.c | 65 struct pollfd *pfds=NULL; variable 636 if(pfds[i].fd==fd){ in register_poll() 649 pfds=realloc(pfds, sizeof(struct pollfd) * maxpfds); in register_poll() 652 pfds[npfds].fd=fd; in register_poll() 653 pfds[npfds].events=events; in register_poll() 654 pfds[npfds].revents=0; in register_poll() 769 poll(pfds,npfds,-1); in handle_events() 771 if((pfds[i].events&POLLIN) && (pfds[i].revents&(POLLIN|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 781 … if((pfds[i].events&POLLOUT) && (pfds[i].revents&(POLLOUT|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 796 pfds[i].fd=pfds[npfds].fd; in handle_events() [all …]
|
/dports/net-mgmt/nsca-client/nsca-2.9.2/src/ |
H A D | nsca.c | 65 struct pollfd *pfds=NULL; variable 636 if(pfds[i].fd==fd){ in register_poll() 649 pfds=realloc(pfds, sizeof(struct pollfd) * maxpfds); in register_poll() 652 pfds[npfds].fd=fd; in register_poll() 653 pfds[npfds].events=events; in register_poll() 654 pfds[npfds].revents=0; in register_poll() 769 poll(pfds,npfds,-1); in handle_events() 771 if((pfds[i].events&POLLIN) && (pfds[i].revents&(POLLIN|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 781 … if((pfds[i].events&POLLOUT) && (pfds[i].revents&(POLLOUT|POLLERR|POLLHUP|POLLNVAL))){ in handle_events() 796 pfds[i].fd=pfds[npfds].fd; in handle_events() [all …]
|
/dports/audio/alsa-utils/alsa-utils-1.2.2/amidi/ |
H A D | amidi.c | 616 struct pollfd *pfds; in main() local 619 pfds = alloca(npfds * sizeof(struct pollfd)); in main() 622 pfds[0].fd = timerfd_create(CLOCK_MONOTONIC, 0); in main() 623 if (pfds[0].fd == -1) { in main() 627 pfds[0].events = POLLIN; in main() 629 pfds[0].fd = -1; in main() 632 snd_rawmidi_poll_descriptors(input, &pfds[1], npfds - 1); in main() 641 err = timerfd_settime(pfds[0].fd, 0, &itimerspec, NULL); in main() 652 err = poll(pfds, npfds, -1); in main() 668 if (pfds[0].revents & POLLIN) in main() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/android_webview/test/shell/src/org/chromium/android_webview/test/ |
H A D | TestContentProvider.java | 216 ParcelFileDescriptor[] pfds = null; in createResponse() local 220 pfds = ParcelFileDescriptor.createPipe(); in createResponse() 221 fileOut = new FileOutputStream(pfds[1].getFileDescriptor()); in createResponse() 224 return new AssetFileDescriptor(pfds[0], 0, -1); in createResponse() 227 if (pfds != null && pfds[1] != null) pfds[1].close(); in createResponse()
|
/dports/devel/android-tools-fastboot/platform_system_core-platform-tools-29.0.5/adb/ |
H A D | transport_fd.cpp | 65 adb_pollfd pfds[2] = { in Run() local 73 pfds[0].events |= POLLOUT; in Run() 77 int rc = adb_poll(pfds, 2, -1); in Run() 85 if (pfds[0].revents) { in Run() 86 if ((pfds[0].revents & POLLOUT)) { in Run() 94 if (pfds[0].revents & POLLIN) { in Run() 129 if (pfds[1].revents) { in Run()
|
/dports/misc/rump/buildrump.sh-b914579/src/sys/rump/net/lib/libsockin/ |
H A D | sockin.c | 344 struct pollfd *pfds = NULL, *npfds; in sockinworker() local 361 if (pfds) in sockinworker() 362 kmem_free(pfds, cursock*sizeof(*pfds)); in sockinworker() 363 pfds = npfds; in sockinworker() 369 pfds[i].fd = SO2S(su_iter->su_so); in sockinworker() 370 pfds[i].events = POLLIN; in sockinworker() 371 pfds[i].revents = 0; in sockinworker() 382 if (pfds[i].revents & POLLIN) { in sockinworker() 399 pfds[i].revents = 0; in sockinworker() 406 if (pfds[i].revents) { in sockinworker() [all …]
|
/dports/devel/notcurses/notcurses-3.0.1/src/lib/ |
H A D | fd.c | 38 struct pollfd pfds[2]; local 39 memset(pfds, 0, sizeof(pfds)); 41 pfds[0].fd = ncfp->fd; 42 pfds[0].events = NCPOLLEVENTS; 45 pfds[1].fd = pidfd; 46 pfds[1].events = NCPOLLEVENTS; 50 while(poll(pfds, fdcount, -1) >= 0 || errno == EINTR){ 52 while(WSAPoll(pfds, fdcount, -1) >= 0){ 54 if(pfds[0].revents){ 72 if(fdcount > 1 && pfds[1].revents){
|
/dports/mail/gmime26-sharp/gmime-2.6.23/gmime/ |
H A D | gmime-gpg-context.c | 1546 pfds[i].revents = 0; in poll() 1547 if (pfds[i].fd < 0) in poll() 1550 if (pfds[i].events & POLLIN) in poll() 1554 if (pfds[i].events != 0) in poll() 1556 if (pfds[i].fd > maxfd) in poll() 1557 maxfd = pfds[i].fd; in poll() 1565 if (pfds[i].fd < 0) in poll() 1575 if (pfds[i].revents != 0) in poll() 1601 pfds[n].events = 0; in gpg_ctx_op_step() 1602 pfds[n].fd = -1; in gpg_ctx_op_step() [all …]
|
/dports/mail/gmime26/gmime-2.6.23/gmime/ |
H A D | gmime-gpg-context.c | 1546 pfds[i].revents = 0; in poll() 1547 if (pfds[i].fd < 0) in poll() 1550 if (pfds[i].events & POLLIN) in poll() 1554 if (pfds[i].events != 0) in poll() 1556 if (pfds[i].fd > maxfd) in poll() 1557 maxfd = pfds[i].fd; in poll() 1565 if (pfds[i].fd < 0) in poll() 1575 if (pfds[i].revents != 0) in poll() 1601 pfds[n].events = 0; in gpg_ctx_op_step() 1602 pfds[n].fd = -1; in gpg_ctx_op_step() [all …]
|
/dports/audio/mumble/mumble-1.3.3/3rdparty/celt-0.11.0-src/tools/ |
H A D | alsa_device.h | 52 int alsa_device_capture_ready(AlsaDevice *dev, struct pollfd *pfds, unsigned int nfds); 54 int alsa_device_playback_ready(AlsaDevice *dev, struct pollfd *pfds, unsigned int nfds); 60 void alsa_device_getfds(AlsaDevice *dev, struct pollfd *pfds, unsigned int nfds);
|