/dports/net/pen/pen-0.34.1/ |
H A D | kqueue.c | 31 EV_SET(&kev[nfds], fd, EVFILT_WRITE, EV_ADD|EV_ENABLE, 0, 0, 0); in kqueue_event_add() 33 EV_SET(&kev[nfds], fd, EVFILT_WRITE, EV_ADD|EV_DISABLE, 0, 0, 0); in kqueue_event_add() 48 EV_SET(&kev[nfds], fd, EVFILT_WRITE, EV_ENABLE, 0, 0, 0); in kqueue_event_arm() 50 EV_SET(&kev[nfds], fd, EVFILT_WRITE, EV_DISABLE, 0, 0, 0); in kqueue_event_arm() 87 if (kev_out[pindex].filter == EVFILT_WRITE) events |= EVENT_WRITE; in kqueue_event_fd()
|
/dports/x11/alacritty/alacritty-0.9.0/cargo-crates/calloop-0.6.5/src/sys/ |
H A D | kqueue.rs | 51 writable: event.filter() == EventFilter::EVFILT_WRITE, in poll() 72 EventFilter::EVFILT_WRITE, in register() 97 EventFilter::EVFILT_WRITE, in register() 144 EventFilter::EVFILT_WRITE, in reregister() 163 EventFilter::EVFILT_WRITE, in reregister() 197 EventFilter::EVFILT_WRITE, in unregister() 216 EventFilter::EVFILT_WRITE, in unregister()
|
/dports/irc/inspircd/inspircd-3.11.0/src/socketengines/ |
H A D | socketengine_kqueue.cpp | 134 EV_SET(ke, eh->GetFd(), EVFILT_WRITE, EV_DELETE, 0, 0, NULL); in DelFd() 151 EV_SET(ke, eh->GetFd(), EVFILT_WRITE, EV_ADD, 0, 0, udata_cast(eh)); in OnSetEvent() 157 EV_SET(ke, eh->GetFd(), EVFILT_WRITE, EV_DELETE, 0, 0, NULL); in OnSetEvent() 162 EV_SET(ke, eh->GetFd(), EVFILT_WRITE, EV_ADD | EV_ONESHOT, 0, 0, udata_cast(eh)); in OnSetEvent() 201 if (filter == EVFILT_WRITE) in DispatchEvents()
|
/dports/www/squid/squid-4.15/src/comm/ |
H A D | ModKqueue.cc | 89 case EVFILT_WRITE: in kq_update_events() 178 kq_update_events(fd, EVFILT_WRITE, handler); in SetSelect() 187 kq_update_events(fd, EVFILT_WRITE, handler); in SetSelect() 270 if (ke[i].filter == EVFILT_WRITE) { in DoSelect() 277 if (ke[i].filter != EVFILT_WRITE && ke[i].filter != EVFILT_READ) { in DoSelect()
|
/dports/lang/mono/mono-5.10.1.57/mono/metadata/ |
H A D | threadpool-io-kqueue.c | 60 if (KQUEUE_INIT_FD (fd, EVFILT_WRITE, EV_ADD | EV_ENABLE) == -1) in kqueue_register_fd() 63 if (KQUEUE_INIT_FD (fd, EVFILT_WRITE, EV_ADD | EV_DISABLE) == -1) in kqueue_register_fd() 74 if (KQUEUE_INIT_FD (fd, EVFILT_WRITE, EV_DELETE) == -1) in kqueue_remove_fd() 113 if (kqueue_events [i].filter == EVFILT_WRITE || (kqueue_events [i].flags & EV_ERROR) != 0) in kqueue_event_wait()
|
/dports/net-im/jabberd/jabberd-2.7.0/mio/ |
H A D | mio_kqueue.h | 26 EV_SET(&events[1], fd, EVFILT_WRITE, EV_ADD|EV_DISABLE, 0, 0, priv_fd); \ 94 EV_SET(&events[1], mfd->mio_fd.fd, EVFILT_WRITE, EV_DELETE, 0, 0, mfd); \ 116 EV_SET(&changelist, mfd->mio_fd.fd, EVFILT_WRITE, EV_ENABLE, 0, 0, mfd); \ 134 EV_SET(&changelist, mfd->mio_fd.fd, EVFILT_WRITE, EV_DISABLE, 0, 0, mfd); \ 147 #define MIO_CAN_WRITE(m, iter) (MIO((m))->events[(iter)].filter == EVFILT_WRITE)
|
/dports/net-p2p/btpd/btpd-0.16/evloop/ |
H A D | kqueue.c | 50 EV_SET(&kev[1], ev->fd, EVFILT_WRITE, EV_ADD, 0, 0, ev); in fdev_enable() 71 EV_SET(&kev[1], ev->fd, EVFILT_WRITE, EV_DELETE, 0, 0, ev); in fdev_disable() 115 case EVFILT_WRITE: in evloop() 131 case EVFILT_WRITE: in evloop()
|
/dports/emulators/mess/mame-mame0226/3rdparty/asio/include/asio/detail/impl/ |
H A D | kqueue_reactor.ipp | 120 EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, state); 228 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 251 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 306 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 351 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 399 case EVFILT_WRITE: 424 if (events[i].filter == EVFILT_WRITE 429 // EV_CLEAR with EVFILT_WRITE. Since we have no pending write 430 // operations we'll remove the EVFILT_WRITE registration here so that 434 descriptor_data->descriptor_, EVFILT_WRITE, EV_DELETE, 0, 0, 0); [all …]
|
/dports/emulators/mame/mame-mame0226/3rdparty/asio/include/asio/detail/impl/ |
H A D | kqueue_reactor.ipp | 120 EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, state); 228 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 251 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 306 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 351 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 399 case EVFILT_WRITE: 424 if (events[i].filter == EVFILT_WRITE 429 // EV_CLEAR with EVFILT_WRITE. Since we have no pending write 430 // operations we'll remove the EVFILT_WRITE registration here so that 434 descriptor_data->descriptor_, EVFILT_WRITE, EV_DELETE, 0, 0, 0); [all …]
|
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/modules/asio-standalone/asio/include/asio/detail/impl/ |
H A D | kqueue_reactor.ipp | 118 EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, state); 226 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 249 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 304 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 349 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 397 case EVFILT_WRITE: 422 if (events[i].filter == EVFILT_WRITE 427 // EV_CLEAR with EVFILT_WRITE. Since we have no pending write 428 // operations we'll remove the EVFILT_WRITE registration here so that 432 descriptor_data->descriptor_, EVFILT_WRITE, EV_DELETE, 0, 0, 0); [all …]
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/asio-master/asio/include/asio/detail/impl/ |
H A D | kqueue_reactor.ipp | 120 EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, state); 228 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 251 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 306 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 348 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 403 case EVFILT_WRITE: 428 if (events[i].filter == EVFILT_WRITE 433 // EV_CLEAR with EVFILT_WRITE. Since we have no pending write 434 // operations we'll remove the EVFILT_WRITE registration here so that 438 descriptor_data->descriptor_, EVFILT_WRITE, EV_DELETE, 0, 0, 0); [all …]
|
/dports/devel/rpclib/rpclib-2.2.1/dependencies/include/asio/detail/impl/ |
H A D | kqueue_reactor.ipp | 116 EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, state); 216 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 239 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 294 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 335 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 379 if (events[i].filter == EVFILT_WRITE 384 // EV_CLEAR with EVFILT_WRITE. Since we have no pending write 385 // operations we'll remove the EVFILT_WRITE registration here so that 389 descriptor_data->descriptor_, EVFILT_WRITE, EV_DELETE, 0, 0, 0); 401 { EVFILT_READ, EVFILT_WRITE, EVFILT_READ };
|
/dports/databases/galera/galera-release_25.3.35/asio/asio/detail/impl/ |
H A D | kqueue_reactor.ipp | 116 EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, state); 216 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 239 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 294 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 335 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 379 if (events[i].filter == EVFILT_WRITE 384 // EV_CLEAR with EVFILT_WRITE. Since we have no pending write 385 // operations we'll remove the EVFILT_WRITE registration here so that 389 descriptor_data->descriptor_, EVFILT_WRITE, EV_DELETE, 0, 0, 0); 401 { EVFILT_READ, EVFILT_WRITE, EVFILT_READ };
|
/dports/databases/galera26/galera-release_26.4.10/asio/asio/detail/impl/ |
H A D | kqueue_reactor.ipp | 116 EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, state); 216 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 239 ASIO_KQUEUE_EV_SET(&events[1], descriptor, EVFILT_WRITE, 294 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 335 EVFILT_WRITE, EV_DELETE, 0, 0, 0); 379 if (events[i].filter == EVFILT_WRITE 384 // EV_CLEAR with EVFILT_WRITE. Since we have no pending write 385 // operations we'll remove the EVFILT_WRITE registration here so that 389 descriptor_data->descriptor_, EVFILT_WRITE, EV_DELETE, 0, 0, 0); 401 { EVFILT_READ, EVFILT_WRITE, EVFILT_READ };
|
/dports/net/haproxy19/haproxy-1.9.16/src/ |
H A D | ev_kqueue.c | 53 EV_SET(&kev[changes++], fd, EVFILT_WRITE, EV_DELETE, 0, 0, NULL); in _update_fd() 65 EV_SET(&kev[changes++], fd, EVFILT_WRITE, EV_ADD, 0, 0, NULL); in _update_fd() 67 EV_SET(&kev[changes++], fd, EVFILT_WRITE, EV_DELETE, 0, 0, NULL); in _update_fd() 128 EV_SET(&kev[changes++], -1, EVFILT_WRITE, EV_DELETE, 0, 0, NULL); in _do_poll() 188 else if (kev[count].filter == EVFILT_WRITE) { in _do_poll()
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/macosx/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 173 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 176 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 218 } else if (filter == EVFILT_WRITE) { in processEvents() 265 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/bsd/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 173 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 176 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 218 } else if (filter == EVFILT_WRITE) { in processEvents() 265 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|
/dports/devel/kore/kore-4.1.0/src/ |
H A D | bsd.c | 145 if (events[i].filter == EVFILT_WRITE) in kore_platform_event_wait() 159 kore_platform_event_schedule(fd, EVFILT_WRITE, EV_ADD | EV_CLEAR, c); in kore_platform_event_all() 166 kore_platform_event_schedule(fd, EVFILT_WRITE, EV_ADD, c); in kore_platform_event_level_all() 230 kore_platform_event_schedule(fd, EVFILT_WRITE, EV_ADD | EV_CLEAR, data); in kore_platform_schedule_write() 242 kore_platform_event_schedule(fd, EVFILT_WRITE, EV_DELETE, NULL); in kore_platform_disable_write()
|
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.base/bsd/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 173 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 176 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 218 } else if (filter == EVFILT_WRITE) { in processEvents() 265 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/macosx/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 173 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 176 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 218 } else if (filter == EVFILT_WRITE) { in processEvents() 265 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/bsd/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 173 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 176 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 218 } else if (filter == EVFILT_WRITE) { in processEvents() 265 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.base/bsd/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 173 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 176 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 218 } else if (filter == EVFILT_WRITE) { in processEvents() 265 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|
/dports/games/pvpgn/pvpgn-1.8.5/src/common/ |
H A D | fdwatch_kqueue.c | 162 EV_SET(kqchanges + ridx, fdw_fd(cfd), EVFILT_WRITE, EV_ADD, 0, 0, (void*)idx); in fdw_kqueue_add_fd() 175 EV_SET(kqchanges + ridx, fdw_fd(cfd), EVFILT_WRITE, EV_DELETE, 0, 0, (void*)idx); in fdw_kqueue_add_fd() 209 if (kqchanges[nochanges].filter == EVFILT_WRITE && in fdw_kqueue_del_fd() 238 if (kqchanges[nochanges].filter == EVFILT_WRITE && in fdw_kqueue_del_fd() 280 if (fdw_rw(cfd) & fdwatch_type_write && kqevents[i].filter == EVFILT_WRITE) in fdw_kqueue_handle()
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/bsd/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 173 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 176 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 218 } else if (filter == EVFILT_WRITE) { in processEvents() 265 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/macosx/classes/sun/nio/ch/ |
H A D | KQueueSelectorImpl.java | 41 import static sun.nio.ch.KQueue.EVFILT_WRITE; 180 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in processUpdateQueue() 183 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_ADD); in processUpdateQueue() 225 } else if (filter == EVFILT_WRITE) { in processEvents() 272 KQueue.register(kqfd, fd, EVFILT_WRITE, EV_DELETE); in implDereg()
|