Home
last modified time | relevance | path

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

123

/netbsd/src/sys/kern/
Dkern_event.c391 #define KQ_FLUX_WAIT(kq) (void)cv_wait(&kq->kq_cv, &kq->kq_lock) argument
392 #define KQ_FLUX_WAKEUP(kq) cv_broadcast(&kq->kq_cv) argument
460 struct kqueue *kq = kn->kn_kq; in knote_detach_quiesce() local
461 filedesc_t *fdp = kq->kq_fdp; in knote_detach_quiesce()
465 mutex_spin_enter(&kq->kq_lock); in knote_detach_quiesce()
498 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
501 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
531 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
534 mutex_spin_exit(&kq->kq_lock); in knote_detach_quiesce()
870 struct kqueue *kq; in filt_kqdetach() local
[all …]
/netbsd/src/tests/lib/libc/sys/
Dt_kevent.c62 int kq; in ATF_TC_BODY() local
64 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
66 ATF_REQUIRE(kevent(kq, &ev, 1, NULL, 0, NULL) != -1); in ATF_TC_BODY()
67 ATF_REQUIRE(kevent(kq, NULL, 0, &ev, 1, NULL) == 1); in ATF_TC_BODY()
80 int s[2], storage, status, kq; in ATF_TC_BODY() local
86 ATF_REQUIRE((kq = kqueue()) != -1); in ATF_TC_BODY()
111 kq = *(int *)CMSG_DATA(msg); in ATF_TC_BODY()
112 printf("child (pid %d): received kq fd %d\n", getpid(), kq); in ATF_TC_BODY()
125 *(int *)CMSG_DATA(msg) = kq; in ATF_TC_BODY()
128 ATF_CHECK(kevent(kq, &ev, 1, NULL, 0, NULL) != -1); in ATF_TC_BODY()
[all …]
/netbsd/src/tests/kernel/kqueue/
Dt_timer.c91 int kq; in ATF_TC_BODY() local
93 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
98 ATF_REQUIRE(kevent(kq, event, 2, NULL, 0, NULL) == 0); in ATF_TC_BODY()
102 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, NULL) == 1); in ATF_TC_BODY()
120 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, in ATF_TC_BODY()
138 kevent(kq, event, 1, NULL, 0, NULL) == -1); in ATF_TC_BODY()
150 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &ts) == 0); in ATF_TC_BODY()
168 int kq; in ATF_TC_BODY() local
170 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
173 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
[all …]
Dt_vnode.c24 static int kq = -1; variable
47 kq = kqueue(); in init_kqueue()
48 if (kq < 0) { in init_kqueue()
55 return kevent(kq, eventlist, 1, NULL, 0, NULL); in init_kqueue()
80 (void)close(kq); in cleanup()
99 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
123 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
147 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
171 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
194 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
[all …]
Dt_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()
144 int kq; in ATF_TC_BODY() local
154 kq = kqueue(); in ATF_TC_BODY()
155 ATF_REQUIRE(kq >= 0); in ATF_TC_BODY()
163 ATF_REQUIRE(kevent(kq, events, 2, &events[2], 1, NULL) == 1); in ATF_TC_BODY()
186 kq = kqueue(); in ATF_TC_BODY()
[all …]
Dt_ioctl.c57 int kq; in ATF_TC_BODY() local
60 RL(kq = kqueue()); in ATF_TC_BODY()
67 RL(ioctl(kq, KFILTER_BYFILTER, &km)); in ATF_TC_BODY()
72 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYFILTER, &km), -1); in ATF_TC_BODY()
84 int kq; in ATF_TC_BODY() local
86 RL(kq = kqueue()); in ATF_TC_BODY()
92 RL(ioctl(kq, KFILTER_BYNAME, &km)); in ATF_TC_BODY()
97 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYNAME, &km), -1); in ATF_TC_BODY()
Dt_empty.c54 int kq, error, sndbufsize; in test_empty() local
58 ATF_REQUIRE((kq = kqueue()) >= 0); in test_empty()
61 ATF_REQUIRE(kevent(kq, &event, 1, NULL, 0, NULL) == 0); in test_empty()
65 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 1); in test_empty()
97 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 0); in test_empty()
122 if (kevent(kq, NULL, 0, &event, 1, &ts) == 1) { in test_empty()
129 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 1); in test_empty()
Dt_proc4.c86 int kq, status; in ATF_TC_BODY() local
91 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
96 ATF_REQUIRE(kevent(kq, &event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
113 rv = kevent(kq, NULL, 0, &event, 1, NULL); in ATF_TC_BODY()
160 ATF_REQUIRE(kevent(kq, NULL, 0, &event, 1, &ts) == 0); in ATF_TC_BODY()
162 (void)close(kq); in ATF_TC_BODY()
Dt_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()
Dt_proc2.c93 int kq, status; in ATF_TC_BODY() local
97 RL(kq = kqueue()); in ATF_TC_BODY()
112 RL(kevent(kq, &ke, 1, NULL, 0, &timeout)); in ATF_TC_BODY()
120 RL(kevent(kq, NULL, 0, &ke, 1, &timeout)); in ATF_TC_BODY()
121 RL(close(kq)); in ATF_TC_BODY()
Dt_oneshot.c54 int kq; in ATF_TC_BODY() local
56 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
60 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
62 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, NULL) == 1); in ATF_TC_BODY()
Dt_scan.c51 static int kq; variable
61 rv = kevent(kq, NULL, 0, &event, 1, &ts); in kevent_thread()
90 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
93 ATF_REQUIRE(kevent(kq, &event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
/netbsd/src/sys/rump/net/lib/libshmif/
Dshmif_user.c62 int rv, kq; in rumpcomp_shmif_watchsetup() local
64 kq = *kqp; in rumpcomp_shmif_watchsetup()
65 if (kq == -1) { in rumpcomp_shmif_watchsetup()
66 kq = kqueue(); in rumpcomp_shmif_watchsetup()
67 if (kq == -1) { in rumpcomp_shmif_watchsetup()
75 if (kevent(kq, &kev, 1, NULL, 0, NULL) == -1) { in rumpcomp_shmif_watchsetup()
79 *kqp = kq; in rumpcomp_shmif_watchsetup()
87 rumpcomp_shmif_watchwait(int kq) in rumpcomp_shmif_watchwait() argument
95 rv = kevent(kq, NULL, 0, &kev, 1, NULL); in rumpcomp_shmif_watchwait()
156 rumpcomp_shmif_watchwait(int kq) in rumpcomp_shmif_watchwait() argument
[all …]
/netbsd/src/tests/kernel/kqueue/write/
Dt_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()
Dt_fifo.c78 int rfd, wfd, kq; in ATF_TC_BODY() local
86 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
96 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
99 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
114 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
124 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
131 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
137 (void)close(kq); in ATF_TC_BODY()
/netbsd/src/tests/kernel/kqueue/read/
Dt_fifo.c78 int rfd, wfd, kq; in ATF_TC_BODY() local
86 ATF_REQUIRE((kq = kqueue()) >= 0); in ATF_TC_BODY()
96 ATF_REQUIRE(kevent(kq, event, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY()
99 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
105 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
114 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
118 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 1); in ATF_TC_BODY()
128 ATF_REQUIRE(kevent(kq, NULL, 0, event, 1, &to) == 0); in ATF_TC_BODY()
132 (void)close(kq); in ATF_TC_BODY()
Dt_ttypty.c59 int kq, n, status; in h_check() local
99 RL(kq = kqueue()); in h_check()
102 RL(kevent(kq, event, 1, NULL, 0, NULL)); in h_check()
104 RL(n = kevent(kq, NULL, 0, event, 1, NULL)); in h_check()
150 int kq, n; in ATF_TC_BODY() local
158 RL(kq = kqueue()); in ATF_TC_BODY()
161 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
165 RL(n = kevent(kq, NULL, 0, event, 1, &timeout)); in ATF_TC_BODY()
Dt_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()
Dt_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()
/netbsd/src/usr.bin/tail/
Dforward.c91 int kq=-1, action=USE_SLEEP; in forward() local
175 kq = kqueue(); in forward()
176 if (kq < 0) in forward()
211 if (kevent(kq, ev, n, NULL, 0, NULL) == -1) { in forward()
212 close(kq); in forward()
213 kq = -1; in forward()
221 if (kevent(kq, NULL, 0, ev, 1, NULL) == -1) in forward()
255 if (kq != -1) in forward()
257 } else if (kq != -1) in forward()
264 if (fflag && kq != -1) in forward()
[all …]
/netbsd/src/external/bsd/ntp/dist/sntp/libevent/
Dkqueue.c85 int kq; member
125 int kq = -1; in kq_init() local
133 if ((kq = kqueue()) == -1) { in kq_init()
138 kqueueop->kq = kq; in kq_init()
161 if (kevent(kq, in kq_init()
317 res = kevent(kqop->kq, changes, n_changes, in kq_dispatch()
440 if (kqop->kq >= 0 && kqop->pid == getpid()) in kqop_free()
441 close(kqop->kq); in kqop_free()
473 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_add()
507 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_del()
[all …]
/netbsd/src/external/bsd/libevent/dist/
Dkqueue.c86 int kq; member
126 int kq = -1; in kq_init() local
134 if ((kq = kqueue()) == -1) { in kq_init()
139 kqueueop->kq = kq; in kq_init()
162 if (kevent(kq, in kq_init()
318 res = kevent(kqop->kq, changes, n_changes, in kq_dispatch()
441 if (kqop->kq >= 0 && kqop->pid == getpid()) in kqop_free()
442 close(kqop->kq); in kqop_free()
474 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_add()
508 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_del()
[all …]
/netbsd/src/tests/lib/libpthread/
Dt_compat_cancel.c62 int kq; in cancelpoint_compat100_kevent() local
73 RL(kq = kqueue()); in cancelpoint_compat100_kevent()
74 RL(__kevent50(kq, &ev, 1, NULL, 1, &(const struct timespec){0,0})); in cancelpoint_compat100_kevent()
76 RL(__kevent50(kq, NULL, 0, &ev, 1, NULL)); in cancelpoint_compat100_kevent()
131 int kq; in cancelpoint_compat50_kevent() local
142 RL(kq = kqueue()); in cancelpoint_compat50_kevent()
143 RL(kevent(kq, &ev, 1, NULL, 1, &(const struct timespec50){0,0})); in cancelpoint_compat50_kevent()
145 RL(kevent(kq, NULL, 0, &ev, 1, NULL)); in cancelpoint_compat50_kevent()
/netbsd/src/regress/sys/kern/kqueue/vnode/
Dvnode.c51 int fd, kq, n, i; in main() local
70 kq = kqueue(); in main()
71 if (kq == -1) in main()
86 n = kevent(kq, event, i, NULL, 0, NULL); in main()
97 n = kevent(kq, NULL, 0, event, 1, &timeout); in main()
/netbsd/src/lib/libc/compat/sys/
Dcompat_kevent.c57 kevent(int kq, const struct kevent100 *changelist, size_t nchanges, in kevent() argument
66 return __kevent50(kq, changelist, nchanges, eventlist, nevents, tsp); in kevent()
70 __kevent50(int kq, const struct kevent100 *changelist100, size_t nchanges, in __kevent50() argument
91 retval = __kevent100(kq, changelist, nchanges, eventlist, nevents, tsp); in __kevent50()

123