Home
last modified time | relevance | path

Searched refs:EVFILT_WRITE (Results 1 – 25 of 5062) sorted by relevance

12345678910>>...203

/dports/net/pen/pen-0.34.1/
H A Dkqueue.c31 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 Dkqueue.rs51 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 Dsocketengine_kqueue.cpp134 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 DModKqueue.cc89 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 Dthreadpool-io-kqueue.c60 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 Dmio_kqueue.h26 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 Dkqueue.c50 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 Dkqueue_reactor.ipp120 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 Dkqueue_reactor.ipp120 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 Dkqueue_reactor.ipp118 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 Dkqueue_reactor.ipp120 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 Dkqueue_reactor.ipp116 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 Dkqueue_reactor.ipp116 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 Dkqueue_reactor.ipp116 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 Dev_kqueue.c53 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 DKQueueSelectorImpl.java41 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 DKQueueSelectorImpl.java41 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 Dbsd.c145 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 DKQueueSelectorImpl.java41 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 DKQueueSelectorImpl.java41 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 DKQueueSelectorImpl.java41 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 DKQueueSelectorImpl.java41 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 Dfdwatch_kqueue.c162 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 DKQueueSelectorImpl.java41 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 DKQueueSelectorImpl.java41 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()

12345678910>>...203