| /freebsd/usr.sbin/bluetooth/btpand/ |
| H A D | event.c | 52 #define __event_link(ev) \ argument
54 TAILQ_INSERT_TAIL(&pending, ev, next); \
55 ev->flags |= EV_PENDING; \
89 struct event *ev; in __event_dispatch() local
111 ev = TAILQ_FIRST(&pending); in __event_dispatch()
112 event_del(ev); in __event_dispatch()
114 if (ev->flags & EV_HAS_TIMEOUT) { in __event_dispatch()
115 if (tv_cmp(&now, &ev->expire) >= 0) in __event_dispatch()
118 t = ev->expire; in __event_dispatch()
126 if (ev->fd >= 0) { in __event_dispatch()
[all …]
|
| H A D | event.h | 80 #define event_set(ev, fd, flags, cb, cbarg) \ argument
81 _event_set(__FILE__, __LINE__, ev, fd, flags, cb, cbarg)
82 #define event_add(ev, timeout) \ argument
83 _event_add(__FILE__, __LINE__, ev, timeout)
84 #define event_del(ev) \ argument
85 _event_del(__FILE__, __LINE__, ev)
87 #define evtimer_set(ev, cb, cbarg) \ argument
88 _event_set(__FILE__, __LINE__, ev, -1, 0, cb, cbarg)
89 #define evtimer_add(ev, timeout) \ argument
90 _event_add(__FILE__, __LINE__, ev, timeout)
[all …]
|
| /freebsd/contrib/unbound/util/ |
| H A D | winsock_event.c | 203 static void handle_signal(struct event* ev) in handle_signal() argument
206 log_assert(ev->is_signal && ev->hEvent); in handle_signal()
208 ret = WSAWaitForMultipleEvents(1, &ev->hEvent, 0 /* any object */, in handle_signal()
221 if(!WSAResetEvent(ev->hEvent)) in handle_signal()
225 fptr_ok(fptr_whitelist_event(ev->ev_callback)); in handle_signal()
226 (*ev->ev_callback)(ev->ev_fd, ev->ev_events, ev->ev_arg); in handle_signal()
469 void event_set(struct event *ev, int fd, short bits, in event_set() argument
472 ev->node.key = ev; in event_set()
473 ev->ev_fd = fd; in event_set()
474 ev->ev_events = bits; in event_set()
[all …]
|
| H A D | ub_event_pluggable.c | 144 struct event ev; member
156 my_event_add_bits(struct ub_event* ev, short bits) in my_event_add_bits() argument
158 AS_MY_EVENT(ev)->ev.ev_events |= NATIVE_BITS(bits); in my_event_add_bits()
162 my_event_del_bits(struct ub_event* ev, short bits) in my_event_del_bits() argument
164 AS_MY_EVENT(ev)->ev.ev_events &= ~NATIVE_BITS(bits); in my_event_del_bits()
168 my_event_set_fd(struct ub_event* ev, int fd) in my_event_set_fd() argument
170 AS_MY_EVENT(ev)->ev.ev_fd = fd; in my_event_set_fd()
174 my_event_free(struct ub_event* ev) in my_event_free() argument
176 free(AS_MY_EVENT(ev)); in my_event_free()
180 my_event_add(struct ub_event* ev, struct timeval* tv) in my_event_add() argument
[all …]
|
| H A D | mini_event.c | 271 void event_set(struct event* ev, int fd, short bits, in event_set() argument
274 ev->node.key = ev; in event_set()
275 ev->ev_fd = fd; in event_set()
276 ev->ev_events = bits; in event_set()
277 ev->ev_callback = cb; in event_set()
278 fptr_ok(fptr_whitelist_event(ev->ev_callback)); in event_set()
279 ev->ev_arg = arg; in event_set()
280 ev->added = 0; in event_set()
284 int event_base_set(struct event_base* base, struct event* ev) in event_base_set() argument
286 ev->ev_base = base; in event_base_set()
[all …]
|
| H A D | ub_event.c | 328 assertion fails on signal handling ev that is not deleted in ub_signal_new()
352 struct event *ev = (struct event*)calloc(1, sizeof(struct event)); in ub_winsock_register_wsaevent()
354 if (!ev) in ub_winsock_register_wsaevent()
358 event_set(ev, fd, NATIVE_BITS(bits), NATIVE_BITS_CB(cb), arg); in ub_winsock_register_wsaevent()
359 if (event_base_set(AS_EVENT_BASE(base), ev) != 0) { in ub_winsock_register_wsaevent()
360 free(ev);
364 if (event_assign(ev, AS_EVENT_BASE(base), fd, bits, cb, arg) != 0) { in ub_event_add_bits()
365 free(ev); in ub_event_add_bits()
369 return AS_UB_EVENT(ev); in ub_event_del_bits()
376 struct event *ev in ub_event_set_fd()
293 struct event *ev = (struct event*)calloc(1, sizeof(struct event)); ub_event_new() local
317 struct event *ev = (struct event*)calloc(1, sizeof(struct event)); ub_signal_new() local
342 struct event *ev = (struct event*)calloc(1, sizeof(struct event)); ub_winsock_register_wsaevent() local
362 ub_event_add_bits(struct ub_event * ev,short bits) ub_event_add_bits() argument
368 ub_event_del_bits(struct ub_event * ev,short bits) ub_event_del_bits() argument
374 ub_event_set_fd(struct ub_event * ev,int fd) ub_event_set_fd() argument
380 ub_event_free(struct ub_event * ev) ub_event_free() argument
387 ub_event_add(struct ub_event * ev,struct timeval * tv) ub_event_add() argument
393 ub_event_del(struct ub_event * ev) ub_event_del() argument
399 ub_timer_add(struct ub_event * ev,struct ub_event_base * base,void (* cb)(int,short,void *),void * arg,struct timeval * tv) ub_timer_add() argument
409 ub_timer_del(struct ub_event * ev) ub_timer_del() argument
415 ub_signal_add(struct ub_event * ev,struct timeval * tv) ub_signal_add() argument
421 ub_signal_del(struct ub_event * ev) ub_signal_del() argument
427 ub_winsock_unregister_wsaevent(struct ub_event * ev) ub_winsock_unregister_wsaevent() argument
438 ub_winsock_tcp_wouldblock(struct ub_event * ev,int eventbits) ub_winsock_tcp_wouldblock() argument
[all...] |
| /freebsd/lib/libpmc/ |
| H A D | libpmc_json.cc | 73 startentry(struct pmclog_ev *ev) in startentry() argument
78 typenames[ev->pl_type], (uintmax_t)ev->pl_tsc); in startentry()
83 initialize_to_json(struct pmclog_ev *ev) in initialize_to_json() argument
88 startent = startentry(ev); in initialize_to_json()
92 startent.c_str(), ev->pl_u.pl_i.pl_version, ev->pl_u.pl_i.pl_arch, in initialize_to_json()
93 ev->pl_u.pl_i.pl_cpuid, (uintmax_t)ev->pl_u.pl_i.pl_tsc_freq, in initialize_to_json()
94 (uintmax_t)ev->pl_u.pl_i.pl_ts.tv_sec, (uintmax_t)ev->pl_u.pl_i.pl_ts.tv_nsec); in initialize_to_json()
99 pmcallocate_to_json(struct pmclog_ev *ev) in pmcallocate_to_json() argument
104 startent = startentry(ev); in pmcallocate_to_json()
108 startent.c_str(), ev->pl_u.pl_a.pl_pmcid, ev->pl_u.pl_a.pl_event, in pmcallocate_to_json()
[all …]
|
| H A D | pmclog.c | 255 struct pmclog_ev *ev) in pmclog_get_event() argument
268 ev->pl_state = PMCLOG_ERROR; in pmclog_get_event()
274 ev->pl_state = PMCLOG_REQUIRE_DATA; in pmclog_get_event()
279 ev->pl_data = le; in pmclog_get_event()
286 ev->pl_state = PMCLOG_ERROR; in pmclog_get_event()
291 ev->pl_tsc = ph->pl_tsc; in pmclog_get_event()
307 switch (ev->pl_type = PMCLOG_HEADER_TO_TYPE(h)) { in pmclog_get_event()
309 PMCLOG_READ32(le,ev->pl_u.pl_cc.pl_pid); in pmclog_get_event()
310 PMCLOG_READ32(le,ev->pl_u.pl_cc.pl_tid); in pmclog_get_event()
311 PMCLOG_READ32(le,ev->pl_u.pl_cc.pl_pmcid); in pmclog_get_event()
[all …]
|
| /freebsd/stand/libsa/ |
| H A D | environment.c | 45 struct env_var *ev; in env_getenv() local
47 for (ev = environ; ev != NULL; ev = ev->ev_next) in env_getenv()
48 if (!strcmp(ev->ev_name, name)) in env_getenv()
50 return (ev); in env_getenv()
65 struct env_var *ev, *curr, *last; in env_setenv() local
67 if ((ev = env_getenv(name)) != NULL) { in env_setenv()
77 ev->ev_flags &= ~EV_NOKENV; in env_setenv()
83 if ((ev->ev_sethook != NULL) && !(flags & EV_NOHOOK)) in env_setenv()
84 return (ev->ev_sethook(ev, flags, value)); in env_setenv()
87 if (ev->ev_value != NULL && (ev->ev_flags & EV_DYNAMIC) != 0) in env_setenv()
[all …]
|
| /freebsd/contrib/pf/libevent/ |
| H A D | event.c | 289 struct event *ev; in event_process_active() local
306 for (ev = TAILQ_FIRST(activeq); ev; ev = TAILQ_FIRST(activeq)) { in event_process_active()
307 event_queue_remove(base, ev, EVLIST_ACTIVE); in event_process_active()
310 ncalls = ev->ev_ncalls; in event_process_active()
311 ev->ev_pncalls = &ncalls; in event_process_active()
314 ev->ev_ncalls = ncalls; in event_process_active()
315 (*ev->ev_callback)((int)ev->ev_fd, ev->ev_res, ev->ev_arg); in event_process_active()
445 struct event ev; member
488 evtimer_set(&eonce->ev, event_once_cb, eonce); in event_once()
492 event_set(&eonce->ev, fd, events, event_once_cb, eonce); in event_once()
[all …]
|
| /freebsd/crypto/krb5/src/util/verto/ |
| H A D | verto.c | 77 verto_mod_ev *ev; member
486 verto_ev *ev = NULL; in make_ev() local
491 ev = vresize(NULL, sizeof(verto_ev)); in make_ev()
492 if (ev) { in make_ev()
493 memset(ev, 0, sizeof(verto_ev)); in make_ev()
494 ev->ctx = ctx; in make_ev()
495 ev->type = type; in make_ev()
496 ev->callback = callback; in make_ev()
497 ev->flags = flags; in make_ev()
500 return ev; in make_ev()
[all …]
|
| H A D | ev.h | 686 #define ev_init(ev,cb_) do { \
687 ((ev_watcher *)(void *)(ev))->active = \
688 ((ev_watcher *)(void *)(ev))->pending = 0; \
689 ev_set_priority ((ev), 0); \
690 ev_set_cb ((ev), cb_); \
693 #define ev_io_set(ev,fd_,events_) do { (ev)->fd = (fd_); (ev)->events = (events_) | EV__…
694 #define ev_timer_set(ev,after_,repeat_) do { ((ev_watcher_time *)(ev))->at = (after_); (ev)->r…
695 #define ev_periodic_set(ev,ofs_,ival_,rcb_) do { (ev)->offset = (ofs_); (ev)->interval = (ival_); …
696 #define ev_signal_set(ev,signum_) do { (ev)->signum = (signum_); } while (0)
697 #define ev_child_set(ev,pid_,trace_) do { (ev)->pid = (pid_); (ev)->flags = !!(trace_); } w…
[all …]
|
| /freebsd/contrib/ntp/sntp/libevent/test/ |
| H A D | test-dumpevents.c | 71 struct event *ev[N_EVENTS]; in main() local
110 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL); in main()
111 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
112 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL); in main()
113 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
116 ev[4] = evtimer_new(base, callback1, NULL); in main()
117 ev[5] = evtimer_new(base, callback1, NULL); in main()
118 ev[6] = evtimer_new(base, callback1, NULL); in main()
119 ev[7] = event_new(base, -1, EV_PERSIST, callback2, NULL); in main()
120 ev[8] = event_new(base, -1, EV_PERSIST, callback2, NULL); in main()
[all …]
|
| H A D | regress_finalize.c | 57 event_finalize_callback_1(struct event *ev, void *arg) in event_finalize_callback_1() argument
61 (void)ev; in event_finalize_callback_1()
78 struct event *ev; in test_fin_cb_invoked() local
87 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
89 event_free_finalize(0, ev, event_finalize_callback_1); in test_fin_cb_invoked()
102 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
105 event_active(ev, EV_TIMEOUT, 1); in test_fin_cb_invoked()
117 event_active(ev, EV_TIMEOUT, 1); in test_fin_cb_invoked()
119 event_free_finalize(0, ev, event_finalize_callback_1); in test_fin_cb_invoked()
132 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
[all …]
|
| /freebsd/contrib/libevent/test/ |
| H A D | test-dumpevents.c | 71 struct event *ev[N_EVENTS]; in main() local
110 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL); in main()
111 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
112 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL); in main()
113 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
116 ev[4] = evtimer_new(base, callback1, NULL); in main()
117 ev[5] = evtimer_new(base, callback1, NULL); in main()
118 ev[6] = evtimer_new(base, callback1, NULL); in main()
119 ev[7] = event_new(base, -1, EV_PERSIST, callback2, NULL); in main()
120 ev[8] = event_new(base, -1, EV_PERSIST, callback2, NULL); in main()
[all …]
|
| H A D | regress_finalize.c | 57 event_finalize_callback_1(struct event *ev, void *arg) in event_finalize_callback_1() argument
61 (void)ev; in event_finalize_callback_1()
78 struct event *ev; in test_fin_cb_invoked() local
87 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
89 event_free_finalize(0, ev, event_finalize_callback_1); in test_fin_cb_invoked()
102 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
105 event_active(ev, EV_TIMEOUT, 1); in test_fin_cb_invoked()
117 event_active(ev, EV_TIMEOUT, 1); in test_fin_cb_invoked()
119 event_free_finalize(0, ev, event_finalize_callback_1); in test_fin_cb_invoked()
132 ev = evtimer_new(base, timer_callback, &ev_called); in test_fin_cb_invoked()
[all …]
|
| /freebsd/contrib/ntp/sntp/libevent/ |
| H A D | event.c | 149 static int event_del_(struct event *ev, int blocking);
163 static inline void event_signal_closure(struct event_base *, struct event *ev);
164 static inline void event_persist_closure(struct event_base *, struct event *ev);
169 struct event *ev);
236 static void event_debug_note_setup_(const struct event *ev) in HT_PROTOTYPE()
243 find.ptr = ev; in HT_PROTOTYPE()
253 dent->ptr = ev; in HT_PROTOTYPE()
263 static void event_debug_note_teardown_(const struct event *ev) in event_debug_note_teardown_() argument
270 find.ptr = ev; in event_debug_note_teardown_()
281 static void event_debug_note_add_(const struct event *ev) in event_debug_note_add_() argument
[all …]
|
| /freebsd/contrib/libevent/ |
| H A D | event.c | 149 static int event_del_(struct event *ev, int blocking);
163 static inline void event_signal_closure(struct event_base *, struct event *ev);
164 static inline void event_persist_closure(struct event_base *, struct event *ev);
169 struct event *ev);
236 static void event_debug_note_setup_(const struct event *ev) in HT_PROTOTYPE()
243 find.ptr = ev; in HT_PROTOTYPE()
253 dent->ptr = ev; in HT_PROTOTYPE()
263 static void event_debug_note_teardown_(const struct event *ev) in event_debug_note_teardown_() argument
270 find.ptr = ev; in event_debug_note_teardown_()
281 static void event_debug_note_add_(const struct event *ev) in event_debug_note_add_() argument
[all …]
|
| /freebsd/contrib/ntp/sntp/libevent/include/event2/ |
| H A D | event_compat.h | 186 #define evtimer_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
187 #define evsignal_set(ev, x, cb, arg) \ argument
188 event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg))
198 #define timeout_add(ev, tv) event_add((ev), (tv)) argument
199 #define timeout_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
200 #define timeout_del(ev) event_del(ev) argument
201 #define timeout_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) argument
202 #define timeout_initialized(ev) event_initialized(ev) argument
212 #define signal_add(ev, tv) event_add((ev), (tv)) argument
213 #define signal_set(ev, x, cb, arg) \ argument
[all …]
|
| H A D | event.h | 964 #define evtimer_assign(ev, b, cb, arg) \ argument
965 event_assign((ev), (b), -1, 0, (cb), (arg))
967 #define evtimer_add(ev, tv) event_add((ev), (tv)) argument
968 #define evtimer_del(ev) event_del(ev) argument
969 #define evtimer_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) argument
970 #define evtimer_initialized(ev) event_initialized(ev) argument
979 #define evsignal_add(ev, tv) event_add((ev), (tv)) argument
980 #define evsignal_assign(ev, b, x, cb, arg) \ argument
981 event_assign((ev), (b), (x), EV_SIGNAL|EV_PERSIST, cb, (arg))
984 #define evsignal_del(ev) event_del(ev) argument
[all …]
|
| /freebsd/contrib/libevent/include/event2/ |
| H A D | event_compat.h | 186 #define evtimer_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
187 #define evsignal_set(ev, x, cb, arg) \ argument
188 event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg))
198 #define timeout_add(ev, tv) event_add((ev), (tv)) argument
199 #define timeout_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) argument
200 #define timeout_del(ev) event_del(ev) argument
201 #define timeout_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) argument
202 #define timeout_initialized(ev) event_initialized(ev) argument
212 #define signal_add(ev, tv) event_add((ev), (tv)) argument
213 #define signal_set(ev, x, cb, arg) \ argument
[all …]
|
| H A D | event.h | 964 #define evtimer_assign(ev, b, cb, arg) \ argument
965 event_assign((ev), (b), -1, 0, (cb), (arg))
967 #define evtimer_add(ev, tv) event_add((ev), (tv)) argument
968 #define evtimer_del(ev) event_del(ev) argument
969 #define evtimer_pending(ev, tv) event_pending((ev), EV_TIMEOUT, (tv)) argument
970 #define evtimer_initialized(ev) event_initialized(ev) argument
979 #define evsignal_add(ev, tv) event_add((ev), (tv)) argument
980 #define evsignal_assign(ev, b, x, cb, arg) \ argument
981 event_assign((ev), (b), (x), EV_SIGNAL|EV_PERSIST, cb, (arg))
984 #define evsignal_del(ev) event_del(ev) argument
[all …]
|
| /freebsd/contrib/libedit/ |
| H A D | history.c | 115 #define HNEXT(h, ev) (*(h)->h_next)((h)->h_ref, ev) argument
116 #define HFIRST(h, ev) (*(h)->h_first)((h)->h_ref, ev) argument
117 #define HPREV(h, ev) (*(h)->h_prev)((h)->h_ref, ev) argument
118 #define HLAST(h, ev) (*(h)->h_last)((h)->h_ref, ev) argument
119 #define HCURR(h, ev) (*(h)->h_curr)((h)->h_ref, ev) argument
120 #define HSET(h, ev, n) (*(h)->h_set)((h)->h_ref, ev, n) argument
121 #define HCLEAR(h, ev) (*(h)->h_clear)((h)->h_ref, ev) argument
122 #define HENTER(h, ev, str) (*(h)->h_enter)((h)->h_ref, ev, str) argument
123 #define HADD(h, ev, str) (*(h)->h_add)((h)->h_ref, ev, str) argument
124 #define HDEL(h, ev, n) (*(h)->h_del)((h)->h_ref, ev, n) argument
[all …]
|
| /freebsd/sys/dev/efidev/ |
| H A D | efidev.c | 108 struct efi_var_ioctl *ev = (struct efi_var_ioctl *)addr; in efidev_ioctl() local
112 data = malloc(ev->datasize, M_TEMP, M_WAITOK); in efidev_ioctl()
113 name = malloc(ev->namesize, M_TEMP, M_WAITOK); in efidev_ioctl()
114 error = copyin(ev->name, name, ev->namesize); in efidev_ioctl()
117 if (name[ev->namesize / sizeof(efi_char) - 1] != 0) { in efidev_ioctl()
122 error = efi_var_get(name, &ev->vendor, &ev->attrib, in efidev_ioctl()
123 &ev->datasize, data); in efidev_ioctl()
126 error = copyout(data, ev->data, ev->datasize); in efidev_ioctl()
134 ev->data = NULL; in efidev_ioctl()
144 struct efi_var_ioctl *ev = (struct efi_var_ioctl *)addr; in efidev_ioctl() local
[all …]
|
| /freebsd/usr.sbin/pmcstat/ |
| H A D | pmcstat_log.c | 470 struct pmclog_ev ev; in pmcstat_print_log() local
473 while (pmclog_read(args.pa_logparser, &ev) == 0) { in pmcstat_print_log()
474 assert(ev.pl_state == PMCLOG_OK); in pmcstat_print_log()
475 _pmcstat_current_tsc = ev.pl_tsc; in pmcstat_print_log()
476 switch (ev.pl_type) { in pmcstat_print_log()
479 "%d 0x%x %d %d %c", ev.pl_u.pl_cc.pl_pid, in pmcstat_print_log()
480 ev.pl_u.pl_cc.pl_pmcid, in pmcstat_print_log()
481 PMC_CALLCHAIN_CPUFLAGS_TO_CPU(ev.pl_u.pl_cc. \ in pmcstat_print_log()
482 pl_cpuflags), ev.pl_u.pl_cc.pl_npc, in pmcstat_print_log()
483 PMC_CALLCHAIN_CPUFLAGS_TO_USERMODE(ev.pl_u.pl_cc.\ in pmcstat_print_log()
[all …]
|