/freebsd/tests/sys/kern/pipe/ |
H A D | pipe_kqueue_test.c | 55 struct kevent kev[32]; in ATF_TC_BODY() local 56 EV_SET(&kev[0], p[1], EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, 0); in ATF_TC_BODY() 58 ATF_REQUIRE(kevent(kq, kev, 1, NULL, 0, NULL) == 0); in ATF_TC_BODY() 62 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY() 64 ATF_REQUIRE(kev[0].ident == (uintptr_t)p[1]); in ATF_TC_BODY() 65 ATF_REQUIRE(kev[0].filter == EVFILT_WRITE); in ATF_TC_BODY() 66 ATF_REQUIRE(kev[0].flags == EV_CLEAR); in ATF_TC_BODY() 67 ATF_REQUIRE(kev[0].fflags == 0); in ATF_TC_BODY() 68 ATF_REQUIRE(kev[0].data == 16384); in ATF_TC_BODY() 69 ATF_REQUIRE(kev[0].udata == 0); in ATF_TC_BODY() [all …]
|
/freebsd/tests/sys/kqueue/libkqueue/ |
H A D | timer.c | 73 struct kevent kev; in test_kevent_timer_add() local 77 EV_SET(&kev, 1, EVFILT_TIMER, EV_ADD, 0, 1000, NULL); in test_kevent_timer_add() 78 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_timer_add() 88 struct kevent kev; in test_kevent_timer_del() local 92 EV_SET(&kev, 1, EVFILT_TIMER, EV_DELETE, 0, 0, NULL); in test_kevent_timer_del() 93 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_timer_del() 105 struct kevent kev; in test_kevent_timer_get() local 109 EV_SET(&kev, 1, EVFILT_TIMER, EV_ADD, 0, 1000, NULL); in test_kevent_timer_get() 110 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_timer_get() 113 kev.flags |= EV_CLEAR; in test_kevent_timer_get() [all …]
|
H A D | user.c | 24 struct kevent kev; in add_and_delete() local 28 kevent_add(kqfd, &kev, 1, EVFILT_USER, EV_ADD, 0, 0, NULL); in add_and_delete() 31 kevent_add(kqfd, &kev, 1, EVFILT_USER, EV_DELETE, 0, 0, NULL); in add_and_delete() 41 struct kevent kev; in event_wait() local 48 kevent_add(kqfd, &kev, 1, EVFILT_USER, EV_ADD | EV_CLEAR, 0, 0, NULL); in event_wait() 49 kevent_add(kqfd, &kev, 1, EVFILT_USER, 0, NOTE_TRIGGER, 0, NULL); in event_wait() 51 kev.fflags &= ~NOTE_FFCTRLMASK; in event_wait() 52 kev.fflags &= ~NOTE_TRIGGER; in event_wait() 53 kev.flags = EV_CLEAR; in event_wait() 54 kevent_cmp(&kev, kevent_get(kqfd)); in event_wait() [all …]
|
H A D | vnode.c | 26 struct kevent kev; in test_kevent_vnode_add() local 37 EV_SET(&kev, vnode_fd, EVFILT_VNODE, EV_ADD, in test_kevent_vnode_add() 39 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_vnode_add() 49 struct kevent kev; in test_kevent_vnode_note_delete() local 53 EV_SET(&kev, vnode_fd, EVFILT_VNODE, EV_ADD | EV_ONESHOT, NOTE_DELETE, 0, NULL); in test_kevent_vnode_note_delete() 54 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_vnode_note_delete() 60 kevent_cmp(&kev, kevent_get(kqfd)); in test_kevent_vnode_note_delete() 70 struct kevent kev; in test_kevent_vnode_note_delete_fifo() local 108 EV_SET(&kev, fd, EVFILT_VNODE, EV_ADD | EV_ONESHOT, NOTE_DELETE, 0, NULL); in test_kevent_vnode_note_delete_fifo() 109 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) { in test_kevent_vnode_note_delete_fifo() [all …]
|
H A D | read.c | 45 struct kevent kev; in test_kevent_socket_add() local 48 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD, 0, 0, &sockfd[0]); in test_kevent_socket_add() 49 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_add() 59 struct kevent kev; in test_kevent_socket_get() local 63 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD, 0, 0, &sockfd[0]); in test_kevent_socket_get() 64 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_get() 69 kev.data = 1; in test_kevent_socket_get() 70 kevent_cmp(&kev, kevent_get(kqfd)); in test_kevent_socket_get() 75 kev.flags = EV_DELETE; in test_kevent_socket_get() 76 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_get() [all …]
|
H A D | main.c | 32 struct kevent kev; in _test_no_kevents() local 37 nfds = kevent(kqfd, NULL, 0, &kev, 1, &timeo); in _test_no_kevents() 40 kev_str = kevent_to_str(&kev); in _test_no_kevents() 55 struct kevent kev; in test_no_kevents_quietly() local 59 nfds = kevent(kqfd, NULL, 0, &kev, 1, &timeo); in test_no_kevents_quietly() 62 kev_str = kevent_to_str(&kev); in test_no_kevents_quietly() 74 struct kevent *kev; in kevent_get() local 76 if ((kev = calloc(1, sizeof(*kev))) == NULL) in kevent_get() 79 nfds = kevent(fd, NULL, 0, kev, 1, NULL); in kevent_get() 83 return (kev); in kevent_get() [all …]
|
H A D | signal.c | 24 struct kevent kev; in test_kevent_signal_add() local 28 EV_SET(&kev, SIGUSR1, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); in test_kevent_signal_add() 29 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_add() 39 struct kevent kev; in test_kevent_signal_get() local 43 EV_SET(&kev, SIGUSR1, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); in test_kevent_signal_get() 44 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_get() 56 kev.flags |= EV_CLEAR; in test_kevent_signal_get() 57 kev.data = 1; in test_kevent_signal_get() 58 kevent_cmp(&kev, kevent_get(kqfd)); in test_kevent_signal_get() 67 struct kevent kev; in test_kevent_signal_disable() local [all …]
|
H A D | proc.c | 36 struct kevent kev; in add_and_delete() local 55 kevent_add(kqfd, &kev, pid, EVFILT_PROC, EV_ADD, 0, 0, NULL); in add_and_delete() 64 kevent_add(kqfd, &kev, pid, EVFILT_PROC, EV_DELETE, 0, 0, NULL); in add_and_delete() 78 struct kevent kev; in proc_track() local 135 kevent_add(kqfd, &kev, pid, EVFILT_PROC, EV_ADD | EV_ENABLE, in proc_track() 247 struct kevent kev; in event_trigger() local 262 kevent_add(kqfd, &kev, pid, EVFILT_PROC, EV_ADD, 0, 0, NULL); in event_trigger() 268 kevent_cmp(&kev, kevent_get(kqfd)); in event_trigger() 278 struct kevent kev; in test_kevent_signal_disable() local 282 EV_SET(&kev, SIGUSR1, EVFILT_SIGNAL, EV_DISABLE, 0, 0, NULL); in test_kevent_signal_disable() [all …]
|
H A D | common.h | 54 kevent_add(int kqfd, struct kevent *kev, 63 #define KEV_CMP(kev,_ident,_filter,_flags) do { \ argument 64 if (kev.ident != (_ident) || \ 65 kev.filter != (_filter) || \ 66 kev.flags != (_flags)) \ 69 (int)kev.ident, kev.filter, kev.flags);\
|
/freebsd/tests/sys/fifo/ |
H A D | fifo_kqueue.c | 58 struct kevent kev[32]; in ATF_TC_BODY() local 59 EV_SET(&kev[0], p[1], EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, 0); in ATF_TC_BODY() 60 EV_SET(&kev[1], p[1], EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, 0); in ATF_TC_BODY() 62 ATF_REQUIRE(kevent(kq, kev, 2, NULL, 0, NULL) == 0); in ATF_TC_BODY() 66 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY() 68 ATF_REQUIRE(kev[0].ident == (uintptr_t)p[1]); in ATF_TC_BODY() 69 ATF_REQUIRE(kev[0].filter == EVFILT_WRITE); in ATF_TC_BODY() 70 ATF_REQUIRE(kev[0].flags == EV_CLEAR); in ATF_TC_BODY() 71 ATF_REQUIRE(kev[0].fflags == 0); in ATF_TC_BODY() 72 ATF_REQUIRE(kev[0].data == 16384); in ATF_TC_BODY() [all …]
|
/freebsd/contrib/pf/libevent/ |
H A D | kqueue.c | 158 kq_insert(struct kqop *kqop, struct kevent *kev) in kq_insert() argument 192 memcpy(&kqop->changes[kqop->nchanges++], kev, sizeof(struct kevent)); in kq_insert() 195 __func__, kev->ident, in kq_insert() 196 kev->filter == EVFILT_READ ? "EVFILT_READ" : "EVFILT_WRITE", in kq_insert() 197 kev->flags == EV_DELETE ? " (del)" : "")); in kq_insert() 286 struct kevent kev; in kq_add() local 291 memset(&kev, 0, sizeof(kev)); in kq_add() 292 kev.ident = nsignal; in kq_add() 293 kev.filter = EVFILT_SIGNAL; in kq_add() 294 kev.flags = EV_ADD; in kq_add() [all …]
|
/freebsd/tools/test/stress2/misc/ |
H A D | kevent4.sh | 88 struct kevent kev; 90 bzero(&kev, sizeof(kev)); 91 kev.ident = pid; 92 kev.flags = EV_ADD | EV_ENABLE; 93 kev.filter = EVFILT_PROC; 94 kev.fflags = NOTE_EXIT | NOTE_FORK | NOTE_EXEC | NOTE_TRACK; 97 int res = kevent(kq, &kev, 1, NULL, 0, NULL); 117 struct kevent kev[10]; 122 bzero(&kev, sizeof(kev)); 123 int res = kevent(kq, NULL, 0, kev, [all …]
|
H A D | kevent12.sh | 94 struct kevent kev; 97 bzero(&kev, sizeof(kev)); 98 kev.ident = pid; 99 kev.flags = EV_ADD | EV_ENABLE; 100 kev.filter = EVFILT_PROC; 101 kev.fflags = NOTE_EXIT | NOTE_EXEC | NOTE_TRACK | NOTE_TRACKERR; 104 int res = kevent(kq, &kev, 1, NULL, 0, NULL); 123 struct kevent kev[10]; 130 bzero(&kev, sizeof(kev)); 135 int res = kevent(kq, NULL, 0, kev, [all …]
|
H A D | kevent16.sh | 45 struct kevent kev; 46 EV_SET(&kev, SIGUSR1, EVFILT_SIGNAL, EV_ADD, 0, 0, 0); 47 rv = kevent(skq, &kev, 1, NULL, 0, NULL); 53 EV_SET(&kev, skq, EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, 0); 54 rv = kevent(kq, &kev, 1, NULL, 0, NULL); 63 rv = kevent(kq, NULL, 0, &kev, 1, NULL); 65 rv = kevent(kq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 }); 68 rv = kevent(kq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 }); 71 rv = kevent(skq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 }); 73 rv = kevent(skq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 });
|
H A D | kevent13.sh | 77 struct kevent kev[2], ke[2]; 90 memset(&kev, 0, sizeof(kev)); 91 EV_SET(&kev[0], fd[0], EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, NULL); 92 EV_SET(&kev[1], fd[1], EVFILT_WRITE, EV_ADD | EV_CLEAR, 0, 0, NULL); 94 if (kevent(kq, kev, 2, ke, 2, &timeout) < 0)
|
/freebsd/tools/tools/so_splice/ |
H A D | proxy.c | 64 struct kevent kev[2]; in proxy_copy() local 72 EV_SET(&kev[0], cs, EVFILT_READ, EV_ADD, 0, 0, (void *)(uintptr_t)ts); in proxy_copy() 73 EV_SET(&kev[1], ts, EVFILT_READ, EV_ADD, 0, 0, (void *)(uintptr_t)cs); in proxy_copy() 74 if (kevent(kq, kev, 2, NULL, 0, NULL) == -1) in proxy_copy() 86 if (kevent(kq, NULL, 0, kev, 2, NULL) == -1) { in proxy_copy() 92 rs = (int)kev[0].ident; in proxy_copy() 93 ws = (int)(uintptr_t)kev[0].udata; in proxy_copy() 139 struct kevent kev[2]; in proxy_splice() local 150 EV_SET(&kev[0], cs, EVFILT_READ, EV_ADD, 0, 0, NULL); in proxy_splice() 151 EV_SET(&kev[1], ts, EVFILT_READ, EV_ADD, 0, 0, NULL); in proxy_splice() [all …]
|
/freebsd/contrib/ntp/sntp/libevent/ |
H A D | kqueue.c | 457 struct kevent kev; in kq_sig_add() local 463 memset(&kev, 0, sizeof(kev)); in kq_sig_add() 464 kev.ident = nsignal; in kq_sig_add() 465 kev.filter = EVFILT_SIGNAL; in kq_sig_add() 466 kev.flags = EV_ADD; in kq_sig_add() 471 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_add() 490 struct kevent kev; in kq_sig_del() local 497 memset(&kev, 0, sizeof(kev)); in kq_sig_del() 526 struct kevent kev; event_kq_add_notify_event_() local 557 struct kevent kev; event_kq_notify_base_() local [all...] |
/freebsd/contrib/libevent/ |
H A D | kqueue.c | 457 struct kevent kev; in kq_sig_add() local 463 memset(&kev, 0, sizeof(kev)); in kq_sig_add() 464 kev.ident = nsignal; in kq_sig_add() 465 kev.filter = EVFILT_SIGNAL; in kq_sig_add() 466 kev.flags = EV_ADD; in kq_sig_add() 471 if (kevent(kqop->kq, &kev, 1, NULL, 0, &timeout) == -1) in kq_sig_add() 490 struct kevent kev; in kq_sig_del() local 497 memset(&kev, 0, sizeof(kev)); in kq_sig_del() 498 kev.ident = nsignal; in kq_sig_del() 499 kev.filter = EVFILT_SIGNAL; in kq_sig_del() [all …]
|
/freebsd/tests/sys/kqueue/ |
H A D | kqueue_peek_signal.c | 55 struct kevent kev; in ATF_TC_BODY() local 56 EV_SET(&kev, SIGUSR1, EVFILT_SIGNAL, EV_ADD, 0, 0, 0); in ATF_TC_BODY() 57 rv = kevent(skq, &kev, 1, NULL, 0, NULL); in ATF_TC_BODY() 63 EV_SET(&kev, skq, EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, 0); in ATF_TC_BODY() 64 rv = kevent(kq, &kev, 1, NULL, 0, NULL); in ATF_TC_BODY() 80 rv = kevent(kq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 }); in ATF_TC_BODY() 84 rv = kevent(kq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 }); in ATF_TC_BODY() 87 rv = kevent(skq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 }); in ATF_TC_BODY() 89 rv = kevent(skq, NULL, 0, &kev, 1, &(struct timespec) { 0, 0 }); in ATF_TC_BODY()
|
/freebsd/usr.sbin/pmc/ |
H A D | cmd_pmc_stat.c | 319 struct kevent kev; in pmc_stat_internal() local 349 EV_SET(&kev, SIGINT, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); in pmc_stat_internal() 350 if (kevent(pmc_kq, &kev, 1, NULL, 0, NULL) < 0) in pmc_stat_internal() 353 EV_SET(&kev, SIGIO, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); in pmc_stat_internal() 354 if (kevent(pmc_kq, &kev, 1, NULL, 0, NULL) < 0) in pmc_stat_internal() 356 EV_SET(&kev, 0, EVFILT_TIMER, EV_ADD, 0, 1000, NULL); in pmc_stat_internal() 357 if (kevent(pmc_kq, &kev, 1, NULL, 0, NULL) < 0) in pmc_stat_internal() 382 EV_SET(&kev, SIGCHLD, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); in pmc_stat_internal() 383 if (kevent(pmc_kq, &kev, 1, NULL, 0, NULL) < 0) in pmc_stat_internal() 414 if ((c = kevent(pmc_kq, NULL, 0, &kev, 1, NULL)) <= 0) { in pmc_stat_internal() [all …]
|
/freebsd/tests/sys/mqueue/ |
H A D | mqtest4.c | 30 struct kevent kev; in main() local 59 EV_SET(&kev, mq_getfd_np(mq), EVFILT_READ, EV_ADD, 0, 0, 0); in main() 60 status = kevent(kq, &kev, 1, NULL, 0, NULL); in main() 66 status = kevent(kq, NULL, 0, &kev, 1, NULL); in main() 91 EV_SET(&kev, mq_getfd_np(mq), EVFILT_WRITE, EV_ADD, 0, 0, 0); in main() 92 status = kevent(kq, &kev, 1, NULL, 0, NULL); in main() 101 status = kevent(kq, NULL, 0, &kev, 1, NULL); in main()
|
/freebsd/sys/kern/ |
H A D | kern_event.c | 103 static int kqueue_register(struct kqueue *kq, struct kevent *kev, 167 static void filt_timertouch(struct knote *kn, struct kevent *kev, 174 static void filt_usertouch(struct knote *kn, struct kevent *kev, 533 struct kevent kev; in knote_fork() local 541 memset(&kev, 0, sizeof(kev)); in knote_fork() 579 kev.ident = pid; in knote_fork() 580 kev.filter = kn->kn_filter; in knote_fork() 581 kev.flags = kn->kn_flags | EV_ADD | EV_ENABLE | EV_ONESHOT | in knote_fork() 583 kev.fflags = kn->kn_sfflags; in knote_fork() 584 kev.data = kn->kn_id; /* parent */ in knote_fork() [all …]
|
/freebsd/tools/tools/fib_multibind/ |
H A D | sink.c | 165 struct kevent kev; in main() local 189 EV_SET(&kev, s, EVFILT_READ, EV_ADD, 0, 0, NULL); in main() 190 error = kevent(sc.kq, &kev, 1, NULL, 0, NULL); in main() 198 struct kevent kev; in main() local 202 n = kevent(sc.kq, NULL, 0, &kev, 1, NULL); in main() 209 error = getsockopt((int)kev.ident, SOL_SOCKET, SO_FIB, in main() 219 cs = accept((int)kev.ident, NULL, NULL); in main() 229 nb = recvfrom((int)kev.ident, buf, sizeof(buf), 0, in main()
|
/freebsd/usr.sbin/pmcstat/ |
H A D | pmcstat.c | 461 struct kevent kev; in main() local 1092 EV_SET(&kev, rfd, EVFILT_READ, EV_ADD, in main() 1094 if (kevent(pmcstat_kq, &kev, 1, NULL, 0, NULL) < 0) in main() 1116 EV_SET(&kev, pipefd[READPIPEFD], EVFILT_READ, EV_ADD, in main() 1119 if (kevent(pmcstat_kq, &kev, 1, NULL, 0, NULL) < 0) in main() 1195 EV_SET(&kev, SIGWINCH, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); in main() 1197 if (kevent(pmcstat_kq, &kev, 1, NULL, 0, NULL) < 0) in main() 1208 EV_SET(&kev, fileno(stdin), EVFILT_READ, EV_ADD, 0, 0, NULL); in main() 1209 if (kevent(pmcstat_kq, &kev, 1, NULL, 0, NULL) < 0) in main() 1213 EV_SET(&kev, SIGINT, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL); in main() [all …]
|
/freebsd/usr.bin/kdump/ |
H A D | kdump.c | 2275 ktrkevent(struct kevent *kev) in ktrkevent() argument 2279 switch (kev->filter) { in ktrkevent() 2287 printf("%ju", (uintmax_t)kev->ident); in ktrkevent() 2290 print_signal(kev->ident); in ktrkevent() 2293 printf("%p", (void *)kev->ident); in ktrkevent() 2296 print_integer_arg(sysdecode_kevent_filter, kev->filter); in ktrkevent() 2298 print_mask_arg0(sysdecode_kevent_flags, kev->flags); in ktrkevent() 2300 sysdecode_kevent_fflags(stdout, kev->filter, kev->fflags, in ktrkevent() 2302 printf(", data=%#jx, udata=%p }", (uintmax_t)kev->data, kev->udata); in ktrkevent() 2320 struct kevent kev; in ktrstructarray() local [all …]
|