| /freebsd/tests/sys/kqueue/libkqueue/ |
| H A D | read.c | 45 struct kevent kev; 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()
64 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_get()
76 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_get()
86 struct kevent kev; in test_kevent_socket_clear()
93 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_clear()
110 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_clear()
120 struct kevent kev; in test_kevent_socket_disable_and_enable()
132 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_socket_disable_and_enable()
[all …]
|
| H A D | timer.c | 73 struct kevent kev; 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()
93 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_timer_del()
105 struct kevent kev; in test_kevent_timer_get()
110 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_timer_get()
118 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_timer_get()
128 struct kevent kev; in test_oneshot()
135 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_oneshot()
155 struct kevent kev; in test_periodic()
[all …]
|
| H A D | vnode.c | 26 struct kevent kev; 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()
54 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_vnode_note_delete()
70 struct kevent kev; in test_kevent_vnode_note_delete_fifo()
109 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) { in test_kevent_vnode_note_delete_fifo()
127 struct kevent kev; in test_kevent_vnode_note_write()
132 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_vnode_note_write()
151 struct kevent kev; in test_kevent_vnode_note_attrib()
157 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_vnode_note_attrib()
[all …]
|
| H A D | signal.c | 24 struct kevent kev; 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()
44 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_get()
67 struct kevent kev; in test_kevent_signal_disable()
72 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_disable()
93 struct kevent kev; in test_kevent_signal_enable()
98 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_enable()
120 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_enable()
130 struct kevent kev; in test_kevent_signal_del()
[all …]
|
| H A D | main.c | 32 struct kevent kev; in _test_no_kevents()
37 nfds = kevent(kqfd, NULL, 0, &kev, 1, &timeo); in _test_no_kevents()
55 struct kevent kev; in test_no_kevents_quietly()
59 nfds = kevent(kqfd, NULL, 0, &kev, 1, &timeo); in test_no_kevents_quietly()
70 struct kevent *
74 struct kevent *kev; in kevent_get()
79 nfds = kevent(fd, NULL, 0, kev, 1, NULL); in kevent_get()
87 struct kevent *
91 struct kevent *kev; in kevent_get_timeout()
97 nfds = kevent(fd, NULL, 0, kev, 1, &timeout); in kevent_get_timeout()
[all …]
|
| H A D | proc.c | 36 struct kevent kev; in add_and_delete()
78 struct kevent kev; in proc_track()
177 struct kevent *kevp; in proc_track()
247 struct kevent kev; in event_trigger()
278 struct kevent kev; in test_kevent_signal_disable()
283 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_disable()
304 struct kevent kev; in test_kevent_signal_enable()
309 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_enable()
331 if (kevent(kqfd, &kev, 1, NULL, 0, NULL) < 0) in test_kevent_signal_enable()
341 struct kevent kev; in test_kevent_signal_del()
[all …]
|
| H A D | common.h | 46 char * kevent_to_str(struct kevent *);
47 struct kevent * kevent_get(int);
48 struct kevent * kevent_get_timeout(int, int);
51 void _kevent_cmp(struct kevent *expected, struct kevent *got, const char *file, int line);
54 kevent_add(int kqfd, struct kevent *kev,
|
| /freebsd/contrib/netbsd-tests/kernel/kqueue/ |
| H A D | t_vnode.c | 45 struct kevent eventlist[1]; in init_kqueue()
55 return kevent(kq, eventlist, 1, NULL, 0, NULL); in init_kqueue()
93 struct kevent changelist[1]; in ATF_TC_BODY()
99 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
116 struct kevent changelist[1]; in ATF_TC_BODY()
123 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
140 struct kevent changelist[1]; in ATF_TC_BODY()
147 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
164 struct kevent changelist[1]; in ATF_TC_BODY()
171 ATF_REQUIRE(kevent(kq, NULL, 0, changelist, 1, &ts) != -1); in ATF_TC_BODY()
[all …]
|
| /freebsd/tests/sys/fifo/ |
| H A D | fifo_kqueue.c | 58 struct kevent kev[32]; 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()
84 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
93 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
100 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
116 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
132 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), NULL) == 1); in ATF_TC_BODY()
159 struct kevent kev[32]; in ATF_TC_BODY()
163 ATF_REQUIRE(kevent(kq, kev, 2, NULL, 0, NULL) == 0); in ATF_TC_BODY()
[all …]
|
| /freebsd/contrib/ntp/sntp/libevent/ |
| H A D | kqueue.c | 51 /* Some platforms apparently define the udata field of struct kevent as
55 #define PTR_TO_UDATA(x) ((typeof(((struct kevent *)0)->udata))(x))
56 #define INT_TO_UDATA(x) ((typeof(((struct kevent *)0)->udata))(intptr_t)(x))
78 struct kevent *changes;
81 struct kevent *events;
141 kqueueop->changes = mm_calloc(NEVENT, sizeof(struct kevent)); in kq_init()
144 kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent)); in kq_init()
155 * If kqueue works, then kevent will succeed, and it will in kq_init()
157 * kevent will fail. in kq_init()
159 if (kevent(k in kq_init()
[all...] |
| /freebsd/contrib/libevent/ |
| H A D | kqueue.c | 55 #define PTR_TO_UDATA(x) ((typeof(((struct kevent *)0)->udata))(x))
56 #define INT_TO_UDATA(x) ((typeof(((struct kevent *)0)->udata))(intptr_t)(x))
78 struct kevent *changes;
81 struct kevent *events;
141 kqueueop->changes = mm_calloc(NEVENT, sizeof(struct kevent)); in kq_init()
144 kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent)); in kq_init()
159 if (kevent(kq, in kq_init()
180 kq_setup_kevent(struct kevent *out, evutil_socket_t fd, int filter, short change) in kq_setup_kevent()
182 memset(out, 0, sizeof(struct kevent)); in kq_setup_kevent()
213 struct kevent *out_ch; in kq_build_changes_list()
[all …]
|
| /freebsd/contrib/pf/libevent/ |
| H A D | kqueue.c | 65 struct kevent *changes;
67 struct kevent *events;
77 int kq_insert (struct kqop *, struct kevent *);
114 kqueueop->changes = malloc(NEVENT * sizeof(struct kevent)); in kq_init()
119 kqueueop->events = malloc(NEVENT * sizeof(struct kevent)); in kq_init()
136 if (kevent(kq, in kq_init()
158 kq_insert(struct kqop *kqop, struct kevent *kev) in kq_insert()
163 struct kevent *newchange; in kq_insert()
164 struct kevent *newresult; in kq_insert()
169 nevents * sizeof(struct kevent)); in kq_insert()
[all …]
|
| /freebsd/tests/sys/kern/pipe/ |
| H A D | pipe_kqueue_test.c | 55 struct kevent kev[32]; 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()
80 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
89 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
96 r = kevent(kq, NULL, 0, kev, nitems(kev), &(struct timespec) { 0, 0 }); in ATF_TC_BODY()
112 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
128 ATF_REQUIRE(kevent(kq, NULL, 0, kev, nitems(kev), in ATF_TC_BODY()
155 struct kevent kev[32]; in ATF_TC_BODY()
166 ATF_REQUIRE(kevent(kq, kev, 2, kev, 2, NULL) == 2); in ATF_TC_BODY()
[all …]
|
| /freebsd/lib/libc/sys/ |
| H A D | kevent.c | 39 #pragma weak kevent macro
41 kevent(int kq, const struct kevent *changelist, int nchanges, in kevent() function
42 struct kevent *eventlist, int nevents, const struct timespec *timeout) in kevent()
44 return (INTERPOS_SYS(kevent, kq, changelist, nchanges, eventlist, in kevent()
|
| /freebsd/sys/compat/linux/ |
| H A D | linux_event.c | 80 struct epoll_event *l_event, struct kevent *kevent,
82 static void kevent_to_epoll(struct kevent *kevent, struct epoll_event *l_event);
83 static int epoll_kev_copyout(void *arg, struct kevent *kevp, int count);
84 static int epoll_kev_copyin(void *arg, struct kevent *kevp, int count);
93 struct kevent *changelist;
144 struct kevent *kevent, int *nkevents) in epoll_to_kevent() argument
163 EV_SET(kevent, fd, EVFILT_READ, kev_flags, 0, 0, 0); in epoll_to_kevent()
164 kevent->ext[0] = l_event->data; in epoll_to_kevent()
165 ++kevent; in epoll_to_kevent()
169 EV_SET(kevent, fd, EVFILT_WRITE, kev_flags, 0, 0, 0); in epoll_to_kevent()
[all …]
|
| /freebsd/tools/test/stress2/misc/ |
| H A D | kevent16.sh | 45 struct kevent kev;
47 rv = kevent(skq, &kev, 1, NULL, 0, NULL);
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 | kevent.sh | 36 sed '1,/^EOF/d' < $odir/$0 > kevent.c
37 mycc -o kevent -Wall kevent.c -pthread || exit 1
38 rm -f kevent.c
44 /tmp/kevent > /dev/null 2>&1 &
48 rm -f /tmp/kevent
75 struct kevent ev[3];
92 if (kevent(kq, ev, n, NULL, 0, NULL) < 0)
107 if (kevent(kq, ev, n, NULL, 0, NULL) < 0)
|
| H A D | kevent5.sh | 46 rm -f /tmp/kevent5 kevent.xxx kevent.yyy
76 struct kevent ev[2];
95 if (kevent(kq, ev, n, NULL, 0, &ts) < 0)
99 n = kevent(kq, NULL, 0, ev, 1, NULL);
103 /* Once the rendezvous file is gone create a new kevent */
116 if (kevent(kq, ev, n, NULL, 0, NULL) < 0)
120 n = kevent(kq, NULL, 0, ev, 1, &ts);
|
| H A D | kevent10.sh | 71 struct kevent changes;
72 struct kevent events;
79 memset(&changes, 0, sizeof(struct kevent));
80 memset(&events, 0, sizeof(struct kevent));
81 if (kevent(0, &changes, -1, &events, 1, 0) == -1)
|
| /freebsd/tests/sys/kqueue/ |
| H A D | kqueue_peek_signal.c | 55 struct kevent kev; in ATF_TC_BODY()
57 rv = kevent(skq, &kev, 1, NULL, 0, NULL); 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/nscd/ |
| H A D | nscdcli.c | 56 struct kevent eventlist; in safe_write()
69 nevents = kevent(connection->write_queue, NULL, 0, &eventlist, in safe_write()
93 struct kevent eventlist; in safe_read()
106 nevents = kevent(connection->read_queue, NULL, 0, &eventlist, 1, in safe_read()
136 struct kevent eventlist; in send_credentials()
157 kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL); in send_credentials()
159 nevents = kevent(connection->write_queue, NULL, 0, &eventlist, 1, NULL); in send_credentials()
164 kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL); in send_credentials()
177 struct kevent eventlist; in open_nscd_connection__()
211 res = kevent(retval->write_queue, &eventlist, 1, NULL, 0, NULL); in open_nscd_connection__()
[all …]
|
| /freebsd/sys/sys/ |
| H A D | event.h | 52 *(kevp_) = (struct kevent){ \
68 struct kevent *kevp = (kevp_); \
82 struct kevent { struct
273 void (*f_touch)(struct knote *kn, struct kevent *kev, u_long type);
293 struct kevent kn_kevent;
325 int (*k_copyout)(void *arg, struct kevent *kevp, int count);
326 int (*k_copyin)(void *arg, struct kevent *kevp, int count);
354 int kqfd_register(int fd, struct kevent *kev, struct thread *p,
369 int kevent(int kq, const struct kevent *changelist, int nchanges,
370 struct kevent *eventlist, int nevents,
|
| /freebsd/contrib/netbsd-tests/kernel/kqueue/write/ |
| H A D | t_pipe.c | 58 struct kevent event[1]; in ATF_TC_BODY()
67 ATF_REQUIRE_EQ_MSG((n = kevent(kq, event, 1, NULL, 0, NULL)), in ATF_TC_BODY()
81 struct kevent event[1]; 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()
123 struct kevent event[1]; in ATF_TC_BODY()
131 RL(kevent(kq, event, 1, NULL, 0, NULL)); in ATF_TC_BODY()
|
| /freebsd/tools/regression/sockets/kqueue/ |
| H A D | kqueue.c | 105 struct kevent ke; in test_evfilt_read()
111 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1) in test_evfilt_read()
120 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_read()
146 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_read()
171 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_read()
181 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1) in test_evfilt_read()
190 struct kevent ke; in test_evfilt_write()
196 if (kevent(kq, &ke, 1, NULL, 0, NULL) == -1) in test_evfilt_write()
205 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_write()
231 i = kevent(kq, NULL, 0, &ke, 1, &ts); in test_evfilt_write()
[all …]
|
| /freebsd/contrib/openbsm/bin/auditdistd/ |
| H A D | subr.c | 189 struct kevent ev; in wait_for_dir_init()
205 if (kevent(kq, &ev, 1, NULL, 0, NULL) == -1) { in wait_for_dir_init()
222 struct kevent ev[2]; in wait_for_file_init()
243 if (kevent(kq, ev, 2, NULL, 0, NULL) == -1) { in wait_for_file_init()
263 struct kevent ev; in wait_for_dir()
274 if (kevent(wait_for_dir_kq, NULL, 0, &ev, 1, NULL) == -1) { in wait_for_dir()
288 struct kevent ev[2]; in wait_for_file()
299 if (kevent(wait_for_file_kq, NULL, 0, ev, 2, NULL) == -1) { in wait_for_file()
|