Searched refs:kq (Results 1 - 25 of 41) sorted by relevance

12

/freebsd-10.3-release/contrib/netbsd-tests/kernel/kqueue/
H A Dt_ioctl.c56 int i, kq; local
58 RL(kq = kqueue());
65 RL(ioctl(kq, KFILTER_BYFILTER, &km));
70 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYFILTER, &km), -1);
93 int kq; local
95 RL(kq = kqueue());
101 RL(ioctl(kq, KFILTER_BYNAME, &km));
106 ATF_REQUIRE_EQ(ioctl(kq, KFILTER_BYNAME, &km), -1);
H A Dt_proc3.c60 int kq, status; local
64 RL(kq = kqueue());
68 RL(kevent(kq, &ke, 1, NULL, 0, NULL));
86 RL(kevent(kq, NULL, 0, &ke, 1, &timeout));
87 RL(close(kq));
H A Dt_proc2.c93 int kq, status; local
97 RL(kq = kqueue());
111 RL(kevent(kq, &ke, 1, NULL, 0, &timeout));
119 RL(kevent(kq, NULL, 0, &ke, 1, &timeout));
120 RL(close(kq));
H A Dt_proc1.c102 int kq, want, status; local
104 RL(kq = kqueue());
121 RL(kevent(kq, event, 1, NULL, 0, NULL));
125 RL(kevent(kq, NULL, 0, event, 1, NULL));
H A Dt_sig.c67 int kq, n, num, status; local
85 RL(kq = kqueue());
89 RL(ioctl(kq, KFILTER_BYNAME, &km));
99 RL(kevent(kq, event, 1, NULL, 0, NULL));
110 RL(n = kevent(kq, NULL, 0, event, 1, &timeout));
/freebsd-10.3-release/contrib/netbsd-tests/lib/libc/sys/
H A Dt_kevent.c68 int kq; local
70 ATF_REQUIRE((kq = kqueue()) != -1);
72 ATF_REQUIRE(kevent(kq, &ev, 1, NULL, 0, NULL) != -1);
73 ATF_REQUIRE(kevent(kq, NULL, 0, &ev, 1, NULL) == 1);
86 int s[2], storage, status, kq; local
92 ATF_REQUIRE((kq = kqueue()) != -1);
118 bcopy(CMSG_DATA(msg), &kq, sizeof(kq)); local
119 printf("child (pid %d): received kq fd %d\n", getpid(), kq);
178 int fd, kq; local
[all...]
/freebsd-10.3-release/sys/kern/
H A Dkern_event.c75 * This lock is used if multiple kq locks are required. This possibly
95 static int kqueue_register(struct kqueue *kq, struct kevent *kev,
98 static void kqueue_release(struct kqueue *kq, int locked);
99 static int kqueue_expand(struct kqueue *kq, struct filterops *fops,
102 static int kqueue_scan(struct kqueue *kq, int maxevents,
106 static void kqueue_wakeup(struct kqueue *kq);
133 static int knote_attach(struct knote *kn, struct kqueue *kq);
204 #define KQ_LOCK(kq) do { \
205 mtx_lock(&(kq)->kq_lock); \
207 #define KQ_FLUX_WAKEUP(kq) d
309 struct kqueue *kq = kn->kn_fp->f_data; local
324 struct kqueue *kq = kn->kn_fp->f_data; local
333 struct kqueue *kq = kn->kn_fp->f_data; local
457 struct kqueue *kq; local
742 struct kqueue *kq; local
898 struct kqueue *kq; local
1031 kqueue_register(struct kqueue *kq, struct kevent *kev, struct thread *td, int waitok) argument
1256 struct kqueue *kq; local
1276 kqueue_release(struct kqueue *kq, int locked) argument
1290 kqueue_schedtask(struct kqueue *kq) argument
1313 kqueue_expand(struct kqueue *kq, struct filterops *fops, uintptr_t ident, int waitok) argument
1378 struct kqueue *kq; local
1402 kqueue_scan(struct kqueue *kq, int maxevents, struct kevent_copyops *k_ops, const struct timespec *tsp, struct kevent *keva, struct thread *td) argument
1688 struct kqueue *kq; local
1732 struct kqueue *kq = fp->f_data; local
1837 kqueue_wakeup(struct kqueue *kq) argument
1868 struct kqueue *kq; local
2126 struct kqueue *kq; local
2187 struct kqueue *kq; local
2225 knote_attach(struct knote *kn, struct kqueue *kq) argument
2255 struct kqueue *kq; local
2288 struct kqueue *kq = kn->kn_kq; local
2302 struct kqueue *kq = kn->kn_kq; local
2341 struct kqueue *kq; local
[all...]
/freebsd-10.3-release/lib/libc/sys/
H A Dkevent.c45 kevent(int kq, const struct kevent *changelist, int nchanges, argument
51 __libc_interposing[INTERPOS_kevent])(kq, changelist, nchanges,
/freebsd-10.3-release/contrib/netbsd-tests/kernel/kqueue/write/
H A Dt_pipe.c60 int kq, n; local
63 RL(kq = kqueue());
67 ATF_REQUIRE_EQ_MSG((n = kevent(kq, event, 1, NULL, 0, NULL)),
84 int kq, n; local
89 RL(kq = kqueue());
92 RL(kevent(kq, event, 1, NULL, 0, NULL));
103 RL(n = kevent(kq, NULL, 0, event, 1, NULL));
125 int kq; local
128 RL(kq = kqueue());
131 RL(kevent(kq, even
[all...]
H A Dt_fifo.c63 int kq, n, fd, status; local
67 RL(kq = kqueue());
79 RL(kevent(kq, event, 1, NULL, 0, NULL));
82 RL(n = kevent(kq, NULL, 0, event, 1, NULL));
H A Dt_ttypty.c60 int status, kq, n; local
84 RL(kq = kqueue());
87 RL(kevent(kq, event, 1, NULL, 0, NULL));
89 RL(n = kevent(kq, NULL, 0, event, 1, NULL));
/freebsd-10.3-release/tools/regression/sockets/kqueue/
H A Dkqueue.c104 test_evfilt_read(int kq, int fd[2], const char *socktype) argument
113 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1)
122 i = kevent(kq, NULL, 0, &ke, 1, &ts);
148 i = kevent(kq, NULL, 0, &ke, 1, &ts);
173 i = kevent(kq, NULL, 0, &ke, 1, &ts);
183 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1)
189 test_evfilt_write(int kq, int fd[2], const char *socktype) argument
198 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1)
207 i = kevent(kq, NULL, 0, &ke, 1, &ts);
233 i = kevent(kq, NUL
255 int kq, sv[2]; local
[all...]
/freebsd-10.3-release/contrib/openbsm/bin/auditdistd/
H A Dsubr.c190 int error, kq; local
198 kq = kqueue();
199 if (kq == -1) {
205 if (kevent(kq, &ev, 1, NULL, 0, NULL) == -1) {
208 (void)close(kq);
212 wait_for_dir_kq = kq;
223 int error, kq; local
234 kq = kqueue();
235 if (kq == -1) {
243 if (kevent(kq, e
[all...]
/freebsd-10.3-release/contrib/netbsd-tests/kernel/kqueue/read/
H A Dt_file2.c56 int fd1, fd2, kq; local
66 RL(kq = kqueue());
69 RL(kevent(kq, event, 1, NULL, 0, NULL));
H A Dt_fifo.c60 int kq, n, fd; local
67 RL(kq = kqueue());
70 RL(kevent(kq, event, 1, NULL, 0, NULL));
78 RL(n = kevent(kq, NULL, 0, event, 1, NULL));
H A Dt_pipe.c56 int kq, n; local
59 RL(kq = kqueue());
62 RL(kevent(kq, event, 1, NULL, 0, NULL));
68 RL(n = kevent(kq, NULL, 0, event, 1, NULL));
H A Dt_file.c90 int fd, kq, n, num, status; local
104 RL(kq = kqueue());
107 RL(kevent(kq, event, 1, NULL, 0, NULL));
110 RL(n = kevent(kq, NULL, 0, event, 1, NULL));
H A Dt_ttypty.c58 int kq, n, status; local
98 RL(kq = kqueue());
101 RL(kevent(kq, event, 1, NULL, 0, NULL));
103 RL(n = kevent(kq, NULL, 0, event, 1, NULL));
/freebsd-10.3-release/tests/sys/mqueue/
H A Dmqtest4.c34 int kq, status; local
56 kq = kqueue();
61 status = kevent(kq, &kev, 1, NULL, 0, NULL);
67 status = kevent(kq, NULL, 0, &kev, 1, NULL);
91 kq = kqueue();
93 status = kevent(kq, &kev, 1, NULL, 0, NULL);
102 status = kevent(kq, NULL, 0, &kev, 1, NULL);
/freebsd-10.3-release/bin/pwait/
H A Dpwait.c66 int kq; local
90 kq = kqueue();
91 if (kq == -1)
115 if (kevent(kq, e + nleft, 1, NULL, 0, NULL) == -1)
123 n = kevent(kq, NULL, 0, e, nleft, NULL);
/freebsd-10.3-release/lib/libproc/
H A D_libproc.h40 int kq; /* Kernel event queue ID. */ member in struct:proc_handle
/freebsd-10.3-release/crypto/openssl/crypto/dsa/
H A Ddsa_ossl.c226 BIGNUM k, kq, *K, *kinv = NULL, *r = NULL; local
235 BN_init(&kq);
266 if (!BN_copy(&kq, &k))
269 BN_set_flags(&kq, BN_FLG_CONSTTIME);
278 if (!BN_add(&kq, &kq, dsa->q))
280 if (BN_num_bits(&kq) <= BN_num_bits(dsa->q)) {
281 if (!BN_add(&kq, &kq, dsa->q))
285 K = &kq;
[all...]
/freebsd-10.3-release/usr.sbin/autofs/
H A Dautounmountd.c230 do_wait(int kq, double sleep_time) argument
242 nevents = kevent(kq, NULL, 0, &unused, 1, &timeout);
245 nevents = kevent(kq, NULL, 0, &unused, 1, NULL);
265 int ch, debug = 0, error, kq; local
322 kq = kqueue();
323 if (kq < 0)
327 error = kevent(kq, &event, 1, NULL, 0, NULL);
347 do_wait(kq, sleep_time);
/freebsd-10.3-release/tests/sys/aio/
H A Daio_kqueue_test.c68 int failed = 0, fd, kq, pending, result, run; local
74 kq = kqueue();
75 if (kq < 0) {
111 iocb[i]->aio_sigevent.sigev_notify_kqueue = kq;
152 result = kevent(kq, NULL, 0,
/freebsd-10.3-release/contrib/pf/libevent/
H A Dkqueue.c69 int kq; member in struct:kqop
93 int kq; local
105 if ((kq = kqueue()) == -1) {
111 kqueueop->kq = kq;
136 if (kevent(kq,
144 close(kq);
220 res = kevent(kqop->kq, changes, kqop->nchanges,
409 if (kqop->kq)
410 close(kqop->kq);
[all...]

Completed in 298 milliseconds

12