| /dports/net/haproxy17/haproxy-1.7.14/src/ |
| H A D | ev_kqueue.c | 32 static int kqueue_fd; variable
153 kqueue_fd = kqueue(); in _do_init()
154 if (kqueue_fd < 0) in _do_init()
165 close(kqueue_fd); in _do_init()
166 kqueue_fd = -1; in _do_init()
180 if (kqueue_fd >= 0) { in _do_term()
181 close(kqueue_fd); in _do_term()
182 kqueue_fd = -1; in _do_term()
211 kqueue_fd = kqueue(); in _do_fork()
212 if (kqueue_fd < 0) in _do_fork()
[all …]
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/polling-2.0.2/src/ |
| H A D | kqueue.rs | 15 kqueue_fd: RawFd, field
26 let kqueue_fd = syscall!(kqueue())?; in new() localVariable
27 syscall!(fcntl(kqueue_fd, libc::F_SETFD, libc::FD_CLOEXEC))?; in new()
35 kqueue_fd, in new()
50 kqueue_fd, in new()
102 self.kqueue_fd, in modify()
145 self.kqueue_fd, in wait()
156 log::trace!("new events: kqueue_fd={}, res={}", self.kqueue_fd, res); in wait()
174 log::trace!("notify: kqueue_fd={}", self.kqueue_fd); in notify()
182 log::trace!("drop: kqueue_fd={}", self.kqueue_fd); in drop()
[all …]
|
| /dports/security/rustscan/RustScan-2.0.1/cargo-crates/polling-2.0.2/src/ |
| H A D | kqueue.rs | 15 kqueue_fd: RawFd, field
26 let kqueue_fd = syscall!(kqueue())?; in new() localVariable
27 syscall!(fcntl(kqueue_fd, libc::F_SETFD, libc::FD_CLOEXEC))?; in new()
35 kqueue_fd, in new()
50 kqueue_fd, in new()
102 self.kqueue_fd, in modify()
145 self.kqueue_fd, in wait()
156 log::trace!("new events: kqueue_fd={}, res={}", self.kqueue_fd, res); in wait()
174 log::trace!("notify: kqueue_fd={}", self.kqueue_fd); in notify()
182 log::trace!("drop: kqueue_fd={}", self.kqueue_fd); in drop()
[all …]
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/polling-2.2.0/src/ |
| H A D | kqueue.rs | 15 kqueue_fd: RawFd,
26 let kqueue_fd = syscall!(kqueue())?;
27 syscall!(fcntl(kqueue_fd, libc::F_SETFD, libc::FD_CLOEXEC))?;
35 kqueue_fd,
50 kqueue_fd,
102 self.kqueue_fd,
145 self.kqueue_fd,
156 log::trace!("new events: kqueue_fd={}, res={}", self.kqueue_fd, res);
174 log::trace!("notify: kqueue_fd={}", self.kqueue_fd);
182 log::trace!("drop: kqueue_fd={}", self.kqueue_fd);
[all …]
|
| /dports/textproc/jql/jql-3.0.6/cargo-crates/polling-2.2.0/src/ |
| H A D | kqueue.rs | 15 kqueue_fd: RawFd, field
26 let kqueue_fd = syscall!(kqueue())?; in new() localVariable
27 syscall!(fcntl(kqueue_fd, libc::F_SETFD, libc::FD_CLOEXEC))?; in new()
35 kqueue_fd, in new()
50 kqueue_fd, in new()
102 self.kqueue_fd, in modify()
145 self.kqueue_fd, in wait()
156 log::trace!("new events: kqueue_fd={}, res={}", self.kqueue_fd, res); in wait()
174 log::trace!("notify: kqueue_fd={}", self.kqueue_fd); in notify()
182 log::trace!("drop: kqueue_fd={}", self.kqueue_fd); in drop()
[all …]
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/polling-2.2.0/src/ |
| H A D | kqueue.rs | 15 kqueue_fd: RawFd, field
26 let kqueue_fd = syscall!(kqueue())?; in new() localVariable
27 syscall!(fcntl(kqueue_fd, libc::F_SETFD, libc::FD_CLOEXEC))?; in new()
35 kqueue_fd, in new()
50 kqueue_fd, in new()
102 self.kqueue_fd, in modify()
145 self.kqueue_fd, in wait()
156 log::trace!("new events: kqueue_fd={}, res={}", self.kqueue_fd, res); in wait()
174 log::trace!("notify: kqueue_fd={}", self.kqueue_fd); in notify()
182 log::trace!("drop: kqueue_fd={}", self.kqueue_fd); in drop()
[all …]
|
| /dports/net/haproxy19/haproxy-1.9.16/src/ |
| H A D | ev_kqueue.c | 213 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
214 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
236 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
260 kqueue_fd[tid] = kqueue(); in _do_init()
261 if (kqueue_fd[tid] < 0) in _do_init()
282 if (kqueue_fd[tid] >= 0) { in _do_term()
283 close(kqueue_fd[tid]); in _do_term()
284 kqueue_fd[tid] = -1; in _do_term()
317 kqueue_fd[tid] = kqueue(); in _do_fork()
318 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/net/haproxy20/haproxy-2.0.26/src/ |
| H A D | ev_kqueue.c | 213 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
214 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
236 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
260 kqueue_fd[tid] = kqueue(); in _do_init()
261 if (kqueue_fd[tid] < 0) in _do_init()
282 if (kqueue_fd[tid] >= 0) { in _do_term()
283 close(kqueue_fd[tid]); in _do_term()
284 kqueue_fd[tid] = -1; in _do_term()
317 kqueue_fd[tid] = kqueue(); in _do_fork()
318 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/net/haproxy/haproxy-2.4.10/src/ |
| H A D | ev_kqueue.c | 232 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
233 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
255 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
278 kqueue_fd[tid] = kqueue(); in _do_init()
279 if (kqueue_fd[tid] < 0) in _do_init()
299 if (kqueue_fd[tid] >= 0) { in _do_term()
300 close(kqueue_fd[tid]); in _do_term()
301 kqueue_fd[tid] = -1; in _do_term()
333 kqueue_fd[tid] = kqueue(); in _do_fork()
334 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/net/haproxy22/haproxy-2.2.19/src/ |
| H A D | ev_kqueue.c | 232 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
233 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
255 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
279 kqueue_fd[tid] = kqueue(); in _do_init()
280 if (kqueue_fd[tid] < 0) in _do_init()
301 if (kqueue_fd[tid] >= 0) { in _do_term()
302 close(kqueue_fd[tid]); in _do_term()
303 kqueue_fd[tid] = -1; in _do_term()
336 kqueue_fd[tid] = kqueue(); in _do_fork()
337 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/net/haproxy23/haproxy-2.3.16/src/ |
| H A D | ev_kqueue.c | 232 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
233 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
255 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
279 kqueue_fd[tid] = kqueue(); in _do_init()
280 if (kqueue_fd[tid] < 0) in _do_init()
301 if (kqueue_fd[tid] >= 0) { in _do_term()
302 close(kqueue_fd[tid]); in _do_term()
303 kqueue_fd[tid] = -1; in _do_term()
336 kqueue_fd[tid] = kqueue(); in _do_fork()
337 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/net/haproxy21/haproxy-2.1.12/src/ |
| H A D | ev_kqueue.c | 230 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
231 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
253 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
277 kqueue_fd[tid] = kqueue(); in _do_init()
278 if (kqueue_fd[tid] < 0) in _do_init()
299 if (kqueue_fd[tid] >= 0) { in _do_term()
300 close(kqueue_fd[tid]); in _do_term()
301 kqueue_fd[tid] = -1; in _do_term()
334 kqueue_fd[tid] = kqueue(); in _do_fork()
335 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/net/nuster/nuster-5.0.4.21/src/ |
| H A D | ev_kqueue.c | 230 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
231 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
253 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
277 kqueue_fd[tid] = kqueue(); in _do_init()
278 if (kqueue_fd[tid] < 0) in _do_init()
299 if (kqueue_fd[tid] >= 0) { in _do_term()
300 close(kqueue_fd[tid]); in _do_term()
301 kqueue_fd[tid] = -1; in _do_term()
334 kqueue_fd[tid] = kqueue(); in _do_fork()
335 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/net/haproxy18/haproxy-1.8.30/src/ |
| H A D | ev_kqueue.c | 222 kqueue_fd[tid] = kqueue(); in init_kqueue_per_thread()
223 if (kqueue_fd[tid] < 0) in init_kqueue_per_thread()
247 close(kqueue_fd[tid]); in deinit_kqueue_per_thread()
271 kqueue_fd[tid] = kqueue(); in _do_init()
272 if (kqueue_fd[tid] < 0) in _do_init()
293 if (kqueue_fd[tid] >= 0) { in _do_term()
294 close(kqueue_fd[tid]); in _do_term()
295 kqueue_fd[tid] = -1; in _do_term()
328 kqueue_fd[tid] = kqueue(); in _do_fork()
329 if (kqueue_fd[tid] < 0) in _do_fork()
[all …]
|
| /dports/devel/ivykis/ivykis-0.42.4/src/ |
| H A D | iv_fd_kqueue.c | 43 int kqueue_fd; in iv_fd_kqueue_init() local
45 kqueue_fd = kqueue(); in iv_fd_kqueue_init()
46 if (kqueue_fd < 0) in iv_fd_kqueue_init()
49 iv_fd_set_cloexec(kqueue_fd); in iv_fd_kqueue_init()
52 st->u.kqueue.kqueue_fd = kqueue_fd; in iv_fd_kqueue_init()
109 if (__kevent_retry(st->u.kqueue.kqueue_fd, changelist, nchanges) < 0) in kevent_retry()
181 ret = kevent(st->u.kqueue.kqueue_fd, kev, num, in iv_fd_kqueue_poll()
267 ret = __kevent_retry(st->u.kqueue.kqueue_fd, &kev, 1); in iv_fd_kqueue_notify_fd_sync()
278 ret = __kevent_retry(st->u.kqueue.kqueue_fd, &kev, 1); in iv_fd_kqueue_notify_fd_sync()
290 close(st->u.kqueue.kqueue_fd); in iv_fd_kqueue_deinit()
[all …]
|
| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/lib/ivykis/src/ |
| H A D | iv_fd_kqueue.c | 43 int kqueue_fd; in iv_fd_kqueue_init() local
45 kqueue_fd = kqueue(); in iv_fd_kqueue_init()
46 if (kqueue_fd < 0) in iv_fd_kqueue_init()
49 iv_fd_set_cloexec(kqueue_fd); in iv_fd_kqueue_init()
52 st->u.kqueue.kqueue_fd = kqueue_fd; in iv_fd_kqueue_init()
109 if (__kevent_retry(st->u.kqueue.kqueue_fd, changelist, nchanges) < 0) in kevent_retry()
181 ret = kevent(st->u.kqueue.kqueue_fd, kev, num, in iv_fd_kqueue_poll()
267 ret = __kevent_retry(st->u.kqueue.kqueue_fd, &kev, 1); in iv_fd_kqueue_notify_fd_sync()
278 ret = __kevent_retry(st->u.kqueue.kqueue_fd, &kev, 1); in iv_fd_kqueue_notify_fd_sync()
290 close(st->u.kqueue.kqueue_fd); in iv_fd_kqueue_deinit()
[all …]
|
| /dports/devel/libmowgli2/libmowgli-2-2.1.3/src/libmowgli/eventloop/ |
| H A D | kqueue_pollops.c | 30 int kqueue_fd; member
44 priv->kqueue_fd = kqueue(); in mowgli_kqueue_eventloop_pollsetup()
48 fcntl(priv->kqueue_fd, F_SETFD, FD_CLOEXEC); in mowgli_kqueue_eventloop_pollsetup()
62 close(priv->kqueue_fd); in mowgli_kqueue_eventloop_pollshutdown()
82 if (kevent(priv->kqueue_fd, &event, 1, NULL, 0, in mowgli_kqueue_eventloop_destroy()
137 if (kevent(priv->kqueue_fd, &event, 1, NULL, 0, in mowgli_kqueue_eventloop_setselect()
153 num = kevent(priv->kqueue_fd, NULL, 0, priv->events, priv->nevents, in mowgli_kqueue_eventloop_select()
|
| /dports/irc/atheme-services/atheme-7.2.9/libmowgli-2/src/libmowgli/eventloop/ |
| H A D | kqueue_pollops.c | 30 int kqueue_fd; member
44 priv->kqueue_fd = kqueue(); in mowgli_kqueue_eventloop_pollsetup()
48 fcntl(priv->kqueue_fd, F_SETFD, FD_CLOEXEC); in mowgli_kqueue_eventloop_pollsetup()
62 close(priv->kqueue_fd); in mowgli_kqueue_eventloop_pollshutdown()
82 if (kevent(priv->kqueue_fd, &event, 1, NULL, 0, in mowgli_kqueue_eventloop_destroy()
137 if (kevent(priv->kqueue_fd, &event, 1, NULL, 0, in mowgli_kqueue_eventloop_setselect()
153 num = kevent(priv->kqueue_fd, NULL, 0, priv->events, priv->nevents, in mowgli_kqueue_eventloop_select()
|
| /dports/lang/mono/mono-5.10.1.57/mono/metadata/ |
| H A D | threadpool-io-kqueue.c | 18 static gint kqueue_fd; variable
26 return kevent (kqueue_fd, &event, 1, NULL, 0, NULL); in KQUEUE_INIT_FD()
32 kqueue_fd = kqueue (); in kqueue_init()
33 if (kqueue_fd == -1) { in kqueue_init()
40 close (kqueue_fd); in kqueue_init()
88 ready = kevent (kqueue_fd, NULL, 0, kqueue_events, KQUEUE_NEVENTS, NULL); in kqueue_event_wait()
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/apr/poll/unix/ |
| H A D | kqueue.c | 42 int kqueue_fd; member
63 close(pollset->kqueue_fd); in backend_cleanup()
98 (*pollset)->kqueue_fd = kqueue(); in apr_pollset_create()
100 if ((*pollset)->kqueue_fd == -1) { in apr_pollset_create()
150 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_add()
159 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_add()
197 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_remove()
206 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_remove()
250 ret = kevent(pollset->kqueue_fd, NULL, 0, pollset->ke_set, pollset->nalloc, in apr_pollset_poll()
|
| /dports/games/genact/genact-0.10.0/cargo-crates/polling-0.1.4/src/ |
| H A D | kqueue.rs | 16 kqueue_fd: RawFd, field
27 let kqueue_fd = syscall!(kqueue())?; in new() localVariable
28 syscall!(fcntl(kqueue_fd, libc::F_SETFD, libc::FD_CLOEXEC))?; in new()
35 kqueue_fd, in new()
97 self.kqueue_fd, in interest()
145 self.kqueue_fd, in remove()
175 self.kqueue_fd, in wait()
211 let _ = syscall!(close(self.kqueue_fd)); in drop()
|
| /dports/devel/apr1/apr-1.7.0/poll/unix/ |
| H A D | kqueue.c | 67 int kqueue_fd; member
87 close(pollset->p->kqueue_fd); in impl_pollset_cleanup()
127 pollset->p->kqueue_fd = kqueue(); in impl_pollset_create()
129 if (pollset->p->kqueue_fd == -1) { in impl_pollset_create()
137 if ((flags = fcntl(pollset->p->kqueue_fd, F_GETFD)) == -1) { in impl_pollset_create()
139 close(pollset->p->kqueue_fd); in impl_pollset_create()
145 if (fcntl(pollset->p->kqueue_fd, F_SETFD, flags) == -1) { in impl_pollset_create()
147 close(pollset->p->kqueue_fd); in impl_pollset_create()
191 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_add()
200 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_add()
[all …]
|
| /dports/sysutils/cmogstored/cmogstored-1.8.1/ |
| H A D | queue_kqueue.c | 14 int kqueue_fd = kqueue(); in mog_queue_new() local
16 if (kqueue_fd < 0) in mog_queue_new()
19 return mog_queue_init(kqueue_fd); in mog_queue_new()
96 static int add_event(int kqueue_fd, struct kevent *event) in add_event() argument
101 rc = kevent(kqueue_fd, event, 1, NULL, 0, NULL); in add_event()
|
| /dports/net/libzmq2/zeromq-2.2.0/src/ |
| H A D | kqueue.cpp | 52 kqueue_fd = kqueue (); in kqueue_t()
53 errno_assert (kqueue_fd != -1); in kqueue_t()
59 close (kqueue_fd); in ~kqueue_t()
67 int rc = kevent (kqueue_fd, &ev, 1, NULL, 0, NULL); in kevent_add()
76 int rc = kevent (kqueue_fd, &ev, 1, NULL, 0, NULL); in kevent_delete()
165 int n = kevent (kqueue_fd, NULL, 0, &ev_buf [0], max_io_events, in loop()
|
| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | kqueue.cpp | 61 kqueue_fd = kqueue (); in kqueue_t()
62 errno_assert (kqueue_fd != -1); in kqueue_t()
71 close (kqueue_fd); in ~kqueue_t()
80 int rc = kevent (kqueue_fd, &ev, 1, NULL, 0, NULL); in kevent_add()
89 int rc = kevent (kqueue_fd, &ev, 1, NULL, 0, NULL); in kevent_delete()
190 int n = kevent (kqueue_fd, NULL, 0, &ev_buf[0], max_io_events, in loop()
|