Searched refs:events (Results 26 - 50 of 454) sorted by relevance

1234567891011>>

/freebsd-current/contrib/ntp/sntp/libevent/test/
H A Dbench_cascade.c58 * events will fire subsequently until the last socket pair has been reached
64 static struct event *events; variable in typeref:struct:event
87 events = (struct event *)calloc(num_pipes, sizeof(struct event));
90 if (events == NULL || pipes == NULL) {
105 /* provide a default timeout for events */
111 event_set(&events[i], cp[0], EV_READ, read_cb,
113 event_add(&events[i], &tv_timeout);
128 event_del(&events[i]);
134 free(events);
H A Dbench.c72 static struct event *events; variable in typeref:struct:event
107 if (event_initialized(&events[i]))
108 event_del(&events[i]);
109 event_assign(&events[i], base, cp[0], EV_READ | EV_PERSIST, read_cb, (void *)(ev_intptr_t) i);
110 event_add(&events[i], NULL);
197 events = calloc(num_pipes, sizeof(struct event));
199 if (events == NULL || pipes == NULL) {
H A Dtest-fdleak.c93 server_event_cb(struct bufferevent *bev, short events, void *ctx) argument
95 if (events & BEV_EVENT_ERROR) {
98 } else if (events & BEV_EVENT_EOF) {
193 client_event_cb(struct bufferevent *bev, short events, void *ctx) argument
195 if (events & BEV_EVENT_CONNECTED) {
198 } else if (events & BEV_EVENT_ERROR) {
/freebsd-current/contrib/libevent/
H A Dkqueue.c81 struct kevent *events; member in struct:kqop
144 kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent));
145 if (kqueueop->events == NULL)
156 * stick an error in events[0]. If kqueue is broken, then
160 kqueueop->changes, 1, kqueueop->events, NEVENT, NULL) != 1 ||
161 (int)kqueueop->events[0].ident != -1 ||
162 !(kqueueop->events[0].flags & EV_ERROR)) {
254 newresult = mm_realloc(kqop->events,
258 kqop->events = newresult;
270 struct kevent *events local
454 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p) argument
487 kq_sig_del(struct event_base *base, int nsignal, short old, short events, void *p) argument
[all...]
H A Devmap.c56 /** An entry for an evmap_io list: notes all the events that want to read or
60 struct event_dlist events; member in struct:evmap_io
66 /* An entry for an evmap_signal list: notes all the events that want to know
69 struct event_dlist events; member in struct:evmap_signal
263 LIST_INIT(&entry->events);
320 event_warnx("Too many events reading or writing on fd %d",
325 (old_ev = LIST_FIRST(&ctx->events)) &&
328 " events on fd %d", (int)fd);
346 LIST_INSERT_HEAD(&ctx->events, ev, ev_io_next);
420 evmap_io_active_(struct event_base *base, evutil_socket_t fd, short events) argument
613 short events = 0; local
866 event_changelist_add_(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
896 event_changelist_del_(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
[all...]
H A Dselect.c89 static int select_add(struct event_base *, int, short old, short events, void*);
90 static int select_del(struct event_base *, int, short old, short events, void*);
252 select_add(struct event_base *base, int fd, short old, short events, void *p) argument
257 EVUTIL_ASSERT((events & EV_SIGNAL) == 0);
285 if (events & EV_READ)
287 if (events & EV_WRITE)
299 select_del(struct event_base *base, int fd, short old, short events, void *p) argument
304 EVUTIL_ASSERT((events & EV_SIGNAL) == 0);
312 if (events & EV_READ)
315 if (events
[all...]
/freebsd-current/contrib/libevent/test/
H A Dbench_cascade.c58 * events will fire subsequently until the last socket pair has been reached
64 static struct event *events; variable in typeref:struct:event
87 events = (struct event *)calloc(num_pipes, sizeof(struct event));
90 if (events == NULL || pipes == NULL) {
105 /* provide a default timeout for events */
111 event_set(&events[i], cp[0], EV_READ, read_cb,
113 event_add(&events[i], &tv_timeout);
128 event_del(&events[i]);
134 free(events);
H A Dbench.c72 static struct event *events; variable in typeref:struct:event
107 if (event_initialized(&events[i]))
108 event_del(&events[i]);
109 event_assign(&events[i], base, cp[0], EV_READ | EV_PERSIST, read_cb, (void *)(ev_intptr_t) i);
110 event_add(&events[i], NULL);
197 events = calloc(num_pipes, sizeof(struct event));
199 if (events == NULL || pipes == NULL) {
H A Dtest-fdleak.c93 server_event_cb(struct bufferevent *bev, short events, void *ctx) argument
95 if (events & BEV_EVENT_ERROR) {
98 } else if (events & BEV_EVENT_EOF) {
193 client_event_cb(struct bufferevent *bev, short events, void *ctx) argument
195 if (events & BEV_EVENT_CONNECTED) {
198 } else if (events & BEV_EVENT_ERROR) {
/freebsd-current/contrib/ntp/sntp/libevent/
H A Dkqueue.c81 struct kevent *events; member in struct:kqop
144 kqueueop->events = mm_calloc(NEVENT, sizeof(struct kevent));
145 if (kqueueop->events == NULL)
156 * stick an error in events[0]. If kqueue is broken, then
160 kqueueop->changes, 1, kqueueop->events, NEVENT, NULL) != 1 ||
161 (int)kqueueop->events[0].ident != -1 ||
162 !(kqueueop->events[0].flags & EV_ERROR)) {
254 newresult = mm_realloc(kqop->events,
258 kqop->events = newresult;
270 struct kevent *events local
454 kq_sig_add(struct event_base *base, int nsignal, short old, short events, void *p) argument
487 kq_sig_del(struct event_base *base, int nsignal, short old, short events, void *p) argument
[all...]
H A Devmap.c56 /** An entry for an evmap_io list: notes all the events that want to read or
60 struct event_dlist events; member in struct:evmap_io
66 /* An entry for an evmap_signal list: notes all the events that want to know
69 struct event_dlist events; member in struct:evmap_signal
263 LIST_INIT(&entry->events);
320 event_warnx("Too many events reading or writing on fd %d",
325 (old_ev = LIST_FIRST(&ctx->events)) &&
328 " events on fd %d", (int)fd);
346 LIST_INSERT_HEAD(&ctx->events, ev, ev_io_next);
420 evmap_io_active_(struct event_base *base, evutil_socket_t fd, short events) argument
613 short events = 0; local
866 event_changelist_add_(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
896 event_changelist_del_(struct event_base *base, evutil_socket_t fd, short old, short events, void *p) argument
[all...]
H A Dselect.c89 static int select_add(struct event_base *, int, short old, short events, void*);
90 static int select_del(struct event_base *, int, short old, short events, void*);
252 select_add(struct event_base *base, int fd, short old, short events, void *p) argument
257 EVUTIL_ASSERT((events & EV_SIGNAL) == 0);
285 if (events & EV_READ)
287 if (events & EV_WRITE)
299 select_del(struct event_base *base, int fd, short old, short events, void *p) argument
304 EVUTIL_ASSERT((events & EV_SIGNAL) == 0);
312 if (events & EV_READ)
315 if (events
[all...]
/freebsd-current/crypto/openssh/openbsd-compat/
H A Dbsd-poll.c39 * Only supports POLLIN, POLLOUT and POLLPRI flags in pfd.events and
62 /* populate event bit vectors for the events we're interested in */
70 if (fds[i].events & POLLIN)
72 if (fds[i].events & POLLOUT)
74 if (fds[i].events & POLLPRI)
86 if ((fds[i].events & POLLIN) && FD_ISSET(fd, &readfds))
88 if ((fds[i].events & POLLOUT) && FD_ISSET(fd, &writefds))
90 if ((fds[i].events & POLLPRI) && FD_ISSET(fd, &exceptfds))
/freebsd-current/contrib/wpa/src/drivers/
H A Ddriver_ndis.h17 void ndis_events_deinit(struct ndis_events_data *events);
55 struct ndis_events_data *events; member in struct:wpa_driver_ndis_data
/freebsd-current/lib/libpmc/
H A DMakefile.depend12 lib/libpmc/pmu-events.host \
/freebsd-current/sys/contrib/openzfs/tests/zfs-tests/tests/functional/cli_root/zpool_events/
H A Dzpool_events.kshlib20 # Wait to allow the kernel module to process ZFS events until we reach $eventnum
31 count=$(zpool events -H | wc -l)
H A Dzpool_events_follow.ksh22 # 'zpool events -f' should successfully follow new events.
25 # 1. Clear all ZFS events
26 # 2. Run 'zpool events -f' in background, saving its output to a temporary file
27 # 3. Generate some ZFS events
28 # 4. Verify 'zpool events -f' successfully recorded these new events
39 log_assert "'zpool events -f' should follow new events."
44 # 1. Clear all ZFS events
[all...]
/freebsd-current/sys/contrib/openzfs/module/lua/
H A Dltm.c50 const TValue *luaT_gettm (Table *events, TMS event, TString *ename) { argument
51 const TValue *tm = luaH_getstr(events, ename);
54 events->flags |= cast_byte(1u<<event); /* cache this fact */
/freebsd-current/sys/contrib/openzfs/tests/zfs-tests/tests/functional/replacement/
H A Dresilver_restart_002.ksh69 # clear events and start resilver
70 log_must zpool events -c
87 finish=$(zpool events | grep -cF "sysevent.fs.zfs.resilver_finish")
99 start=$(zpool events | grep -cF "sysevent.fs.zfs.resilver_start")
/freebsd-current/contrib/ofed/opensm/complib/
H A Dcl_threadpool.c63 while (!p_thread_pool->events)
66 p_thread_pool->events--;
93 p_thread_pool->events = 0;
138 p_thread_pool->events = 0;
146 p_thread_pool->events++;
/freebsd-current/sys/contrib/openzfs/tests/zfs-tests/tests/functional/events/
H A Dzed_slow_io_many_vdevs.ksh28 # Verify that delay events from multiple vdevs doesnt degrade
102 log_must zpool events -c
130 # count events available for processing
132 typeset -i events=0
134 events=$(zpool events | grep "ereport\.fs\.zfs.delay" | wc -l)
135 [[ $events -ge "50" ]] && break
139 log_note "$events delay events found"
140 if [[ $events
[all...]
H A Dzed_slow_io.ksh111 # inject 10 events over 2.5 seconds, should not degrade.
124 # give slow ZED a chance to process the delay events
131 log_fail "expecting no degrade events, found $degrades"
136 # change slow_io_n, slow_io_t to 5 events in 60 seconds
137 # fire more than 5 events, should degrade
154 # wait up to 60 seconds for kernel to produce at least 5 delay events
157 typeset -i events=0
159 events=$(zpool events | grep "ereport\.fs\.zfs.delay" | wc -l)
160 [[ $events
[all...]
/freebsd-current/contrib/wpa/src/common/
H A Dctrl_iface_common.h14 /* Events enable bits (wpa_ctrl_dst::events) */
29 u32 events; /* WPA_EVENT_* bitmap */ member in struct:wpa_ctrl_dst
/freebsd-current/contrib/ofed/opensm/include/complib/
H A Dcl_threadpool.h98 unsigned events; member in struct:_cl_thread_pool
114 * events
115 * events counter
/freebsd-current/contrib/ntp/sntp/libevent/sample/
H A Dhello-world.c118 conn_eventcb(struct bufferevent *bev, short events, void *user_data) argument
120 if (events & BEV_EVENT_EOF) {
122 } else if (events & BEV_EVENT_ERROR) {
126 /* None of the other events can happen here, since we haven't enabled
132 signal_cb(evutil_socket_t sig, short events, void *user_data) argument

Completed in 293 milliseconds

1234567891011>>