Home
last modified time | relevance | path

Searched refs:kq (Results 1 – 25 of 57) sorted by relevance

123

/NextBSD/sys/kern/
HDkern_event.c99 static int _kern_kevent_kq(struct thread *td, struct kqueue *kq, int nchanges, int nevents,
105 static int kqueue_register(struct kqueue *kq, struct kevent64_s *kev,
108 static void kqueue_release(struct kqueue *kq, int locked);
109 static void kqueue_destroy(struct kqueue *kq);
110 static void kqueue_drain(struct kqueue *kq, struct thread *td);
111 static int kqueue_expand(struct kqueue *kq, struct filterops *fops,
114 static int kqueue_scan(struct kqueue *kq, int maxevents,
118 static void kqueue_wakeup(struct kqueue *kq);
144 static int knote_attach(struct knote *kn, struct kqueue *kq);
215 #define KQ_LOCK(kq) do { \ argument
[all …]
/NextBSD/contrib/netbsd-tests/lib/libc/sys/
HDt_kevent.c68 int kq; in ATF_TC_BODY() local
70 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
72 ATF_REQUIRE(kevent(kq, &ev, 1, NULL, 0, NULL) != -1); in ATF_TC_BODY()
73 ATF_REQUIRE(kevent(kq, NULL, 0, &ev, 1, NULL) == 1); in ATF_TC_BODY()
86 int s[2], storage, status, kq; in ATF_TC_BODY() local
92 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
118 bcopy(CMSG_DATA(msg), &kq, sizeof(kq)); in ATF_TC_BODY()
119 printf("child (pid %d): received kq fd %d\n", getpid(), kq); in ATF_TC_BODY()
122 kq = *(int *)CMSG_DATA(msg); in ATF_TC_BODY()
123 printf("child (pid %d): received kq fd %d\n", getpid(), kq); in ATF_TC_BODY()
[all …]
/NextBSD/tools/regression/sockets/kqueue/
HDkqueue.c104 test_evfilt_read(int kq, int fd[2], const char *socktype) in test_evfilt_read() argument
113 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1) in test_evfilt_read()
122 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_read()
148 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_read()
173 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_read()
183 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1) in test_evfilt_read()
189 test_evfilt_write(int kq, int fd[2], const char *socktype) in test_evfilt_write() argument
198 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1) in test_evfilt_write()
207 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_write()
233 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_write()
[all …]
/NextBSD/contrib/netbsd-tests/kernel/kqueue/write/
HDt_pipe.c60 int kq, n; in ATF_TC_BODY() local
63 RL(kq = kqueue()); in ATF_TC_BODY()
67 ATF_REQUIRE_EQ_MSG((n = kevent(kq, event, 1, NULL, 0, NULL)), in ATF_TC_BODY()
84 int kq, n; in ATF_TC_BODY() local
89 RL(kq = kqueue()); in ATF_TC_BODY()
92 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
103 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
125 int kq; in ATF_TC_BODY() local
128 RL(kq = kqueue()); in ATF_TC_BODY()
131 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
HDt_fifo.c63 int kq, n, fd, status; in ATF_TC_BODY() local
67 RL(kq = kqueue()); in ATF_TC_BODY()
79 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
82 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
/NextBSD/contrib/openbsm/bin/auditdistd/
HDsubr.c190 int error, kq; in wait_for_dir_init() local
198 kq = kqueue(); in wait_for_dir_init()
199 if (kq == -1) { in wait_for_dir_init()
205 if (kevent(kq, &ev, 1, NULL, 0, NULL) == -1) { in wait_for_dir_init()
208 (void)close(kq); in wait_for_dir_init()
212 wait_for_dir_kq = kq; in wait_for_dir_init()
223 int error, kq; in wait_for_file_init() local
234 kq = kqueue(); in wait_for_file_init()
235 if (kq == -1) { in wait_for_file_init()
243 if (kevent(kq, ev, 2, NULL, 0, NULL) == -1) { in wait_for_file_init()
[all …]
/NextBSD/contrib/netbsd-tests/kernel/kqueue/
HDt_ioctl.c56 int i, kq; in ATF_TC_BODY() local
58 RL(kq = kqueue()); in ATF_TC_BODY()
65 RL(ioctl(kq, KFILTER_BYFILTER, &km)); in ATF_TC_BODY()
70 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYFILTER, &km), -1); in ATF_TC_BODY()
93 int kq; in ATF_TC_BODY() local
95 RL(kq = kqueue()); in ATF_TC_BODY()
101 RL(ioctl(kq, KFILTER_BYNAME, &km)); in ATF_TC_BODY()
106 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYNAME, &km), -1); in ATF_TC_BODY()
HDt_proc3.c60 int kq, status; in ATF_TC_BODY() local
64 RL(kq = kqueue()); in ATF_TC_BODY()
68 RL(kevent(kq, &ke, 1, NULL, 0, NULL)); in ATF_TC_BODY()
86 RL(kevent(kq, NULL, 0, &ke, 1, &timeout)); in ATF_TC_BODY()
87 RL(close(kq)); in ATF_TC_BODY()
HDt_proc2.c93 int kq, status; in ATF_TC_BODY() local
97 RL(kq = kqueue()); in ATF_TC_BODY()
111 RL(kevent(kq, &ke, 1, NULL, 0, &timeout)); in ATF_TC_BODY()
119 RL(kevent(kq, NULL, 0, &ke, 1, &timeout)); in ATF_TC_BODY()
120 RL(close(kq)); in ATF_TC_BODY()
HDt_sig.c67 int kq, n, num, status; in ATF_TC_BODY() local
85 RL(kq = kqueue()); in ATF_TC_BODY()
89 RL(ioctl(kq, KFILTER_BYNAME, &km)); in ATF_TC_BODY()
99 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
110 RL(n = kevent(kq, NULL, 0, event, 1, &timeout)); in ATF_TC_BODY()
HDt_proc1.c102 int kq, want, status; in ATF_TC_BODY() local
104 RL(kq = kqueue()); in ATF_TC_BODY()
121 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
125 RL(kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
/NextBSD/tests/sys/mqueue/
HDmqtest4.c34 int kq, status; in main() local
56 kq = kqueue(); in main()
61 status = kevent(kq, &kev, 1, NULL, 0, NULL); in main()
67 status = kevent(kq, NULL, 0, &kev, 1, NULL); in main()
91 kq = kqueue(); in main()
93 status = kevent(kq, &kev, 1, NULL, 0, NULL); in main()
102 status = kevent(kq, NULL, 0, &kev, 1, NULL); in main()
/NextBSD/contrib/ntp/sntp/libevent/
HDkqueue.c78 int kq; member
118 int kq = -1; in kq_init() local
126 if ((kq = kqueue()) == -1) { in kq_init()
131 kqueueop->kq = kq; in kq_init()
154 if (kevent(kq, in kq_init()
301 res = kevent(kqop->kq, changes, n_changes, in kq_dispatch()
424 if (kqop->kq >= 0 && kqop->pid == getpid()) in kqop_free()
425 close(kqop->kq); in kqop_free()
457 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_add()
491 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_del()
[all …]
/NextBSD/sys/compat/ndis/
HDsubr_ntoskrnl.c285 kdpc_queue *kq; local
332 kq = kq_queues + i;
333 kq->kq_cpu = i;
334 error = kproc_create(ntoskrnl_dpc_thread, kq, &p,
345 kq = wq_queues + i;
346 error = kproc_create(ntoskrnl_workitem_thread, kq, &p,
2735 kdpc_queue *kq; local
2740 kq = arg;
2742 InitializeListHead(&kq->kq_disp);
2743 kq->kq_td = curthread;
[all …]
/NextBSD/contrib/pf/libevent/
HDkqueue.c69 int kq; member
93 int kq; in kq_init() local
105 if ((kq = kqueue()) == -1) { in kq_init()
111 kqueueop->kq = kq; in kq_init()
136 if (kevent(kq, in kq_init()
144 close(kq); in kq_init()
220 res = kevent(kqop->kq, changes, kqop->nchanges, in kq_dispatch()
409 if (kqop->kq) in kq_dealloc()
410 close(kqop->kq); in kq_dealloc()
/NextBSD/bin/pwait/
HDpwait.c66 int kq; in main() local
90 kq = kqueue(); in main()
91 if (kq == -1) in main()
115 if (kevent(kq, e + nleft, 1, NULL, 0, NULL) == -1) in main()
123 n = kevent(kq, NULL, 0, e, nleft, NULL); in main()
/NextBSD/usr.sbin/autofs/
HDautounmountd.c230 do_wait(int kq, double sleep_time) in do_wait() argument
242 nevents = kevent(kq, NULL, 0, &unused, 1, &timeout); in do_wait()
245 nevents = kevent(kq, NULL, 0, &unused, 1, NULL); in do_wait()
265 int ch, debug = 0, error, kq; in main_autounmountd() local
322 kq = kqueue(); in main_autounmountd()
323 if (kq < 0) in main_autounmountd()
327 error = kevent(kq, &event, 1, NULL, 0, NULL); in main_autounmountd()
347 do_wait(kq, sleep_time); in main_autounmountd()
/NextBSD/usr.bin/mach-tests/bootstrap-kqueue/server/
HDbootstrap-kqueue-server.c31 int kq, r; in main() local
56 kq = kqueue(); in main()
57 syslog(LOG_ERR, "kqueue fd: %d", kq); in main()
61 if (kevent64(kq, &kev, 1, NULL, 0, 0, NULL) < 0) { in main()
70 r = kevent64(kq, NULL, 0, &kev, 1, 0, NULL); in main()
/NextBSD/usr.bin/mach-tests/bootstrap-kqueue/server-inline-receive/
HDbootstrap-inline-receive-server.c31 int kq, r; in main() local
56 kq = kqueue(); in main()
57 syslog(LOG_ERR, "kqueue fd: %d", kq); in main()
63 if (kevent64(kq, &kev, 1, NULL, 0, 0, NULL) < 0) { in main()
72 r = kevent64(kq, NULL, 0, &kev, 1, 0, NULL); in main()
/NextBSD/contrib/netbsd-tests/kernel/kqueue/read/
HDt_pipe.c56 int kq, n; in ATF_TC_BODY() local
59 RL(kq = kqueue()); in ATF_TC_BODY()
62 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
68 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
HDt_fifo.c60 int kq, n, fd; in ATF_TC_BODY() local
67 RL(kq = kqueue()); in ATF_TC_BODY()
70 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
78 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
HDt_file.c90 int fd, kq, n, num, status; in ATF_TC_BODY() local
104 RL(kq = kqueue()); in ATF_TC_BODY()
107 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
110 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in ATF_TC_BODY()
/NextBSD/crypto/openssl/crypto/dsa/
HDdsa_ossl.c226 BIGNUM k, kq, *K, *kinv = NULL, *r = NULL; in dsa_sign_setup() local
235 BN_init(&kq); in dsa_sign_setup()
264 if (!BN_copy(&kq, &k)) in dsa_sign_setup()
274 if (!BN_add(&kq, &kq, dsa->q)) in dsa_sign_setup()
276 if (BN_num_bits(&kq) <= BN_num_bits(dsa->q)) { in dsa_sign_setup()
277 if (!BN_add(&kq, &kq, dsa->q)) in dsa_sign_setup()
281 K = &kq; in dsa_sign_setup()
311 BN_clear_free(&kq); in dsa_sign_setup()
/NextBSD/sys/compat/mach/ipc/
HDipc_pset.c473 #define KQ_LOCK(kq) do { \ argument
474 mtx_lock(&(kq)->kq_lock); \
476 #define KQ_UNLOCK(kq) do { \ argument
477 mtx_unlock(&(kq)->kq_lock); \
483 struct kqueue *kq, *kq_prev; in ipc_pset_signal() local
493 kq = kq_prev = NULL; in ipc_pset_signal()
495 kq = kn->kn_kq; in ipc_pset_signal()
496 if (kq != kq_prev) { in ipc_pset_signal()
499 KQ_LOCK(kq); in ipc_pset_signal()
504 kq_prev = kq; in ipc_pset_signal()
[all …]
/NextBSD/tests/sys/aio/
HDlio_kqueue_test.c68 int kq; in main() local
78 kq = kqueue(); in main()
79 if (kq < 0) in main()
95 printf("Hello kq %d fd %d\n", kq, fd); in main()
121 sig.sigev_notify_kqueue = kq; in main()
159 result = kevent(kq, NULL, 0, in main()

123