| /openbsd-src/regress/sys/kern/kqueue/ |
| H A D | kqueue-timer.c | 38 struct kevent ev; in do_timer() local 46 memset(&ev, 0, sizeof(ev)); in do_timer() 47 ev.filter = EVFILT_TIMER; in do_timer() 48 ev.flags = EV_ADD | EV_ENABLE | EV_ONESHOT; in do_timer() 49 ev.data = 500; /* 1/2 second in ms */ in do_timer() 51 n = kevent(kq, &ev, 1, NULL, 0, NULL); in do_timer() 57 n = kevent(kq, NULL, 0, &ev, 1, &ts); in do_timer() 62 memset(&ev, 0, sizeof(ev)); in do_timer() 63 ev.filter = EVFILT_TIMER; in do_timer() 64 ev.flags = EV_ADD | EV_ENABLE; in do_timer() [all …]
|
| H A D | kqueue-pty.c | 20 pty_check(int kq, struct kevent *ev, int n, int rm, int rs, int wm, int ws) in pty_check() argument 27 if ((n = kevent(kq, NULL, 0, ev, n, &ts)) < 0) in pty_check() 32 for (i = 0; i < n; i++, ev++) { in pty_check() 33 if (ev->filter == EVFILT_READ) { in pty_check() 34 ASSX(ev->ident != -rm); in pty_check() 35 ASSX(ev->ident != -rs); in pty_check() 36 if (ev->ident == rm) in pty_check() 38 if (ev->ident == rs) in pty_check() 40 } else if (ev->filter == EVFILT_WRITE) { in pty_check() 41 ASSX(ev->ident != -wm); in pty_check() [all …]
|
| /openbsd-src/usr.sbin/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 | 293 struct event *ev = (struct event*)calloc(1, sizeof(struct event)); in ub_event_new() local 295 if (!ev) in ub_event_new() 299 event_set(ev, fd, NATIVE_BITS(bits), NATIVE_BITS_CB(cb), arg); in ub_event_new() 300 if (event_base_set(AS_EVENT_BASE(base), ev) != 0) { in ub_event_new() 301 free(ev); in ub_event_new() 305 if (event_assign(ev, AS_EVENT_BASE(base), fd, bits, cb, arg) != 0) { in ub_event_new() 306 free(ev); in ub_event_new() 310 return AS_UB_EVENT(ev); in ub_event_new() 317 struct event *ev = (struct event*)calloc(1, sizeof(struct event)); in ub_signal_new() local 319 if (!ev) in ub_signal_new() [all …]
|
| /openbsd-src/sbin/unwind/libunbound/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 …]
|
| /openbsd-src/lib/libevent/ |
| H A D | event.c | 150 struct event *ev; in event_base_free() local 160 for (ev = TAILQ_FIRST(&base->eventqueue); ev; ) { in event_base_free() 161 struct event *next = TAILQ_NEXT(ev, ev_next); in event_base_free() 162 if (!(ev->ev_flags & EVLIST_INTERNAL)) { in event_base_free() 163 event_del(ev); in event_base_free() 166 ev = next; in event_base_free() 168 while ((ev = min_heap_top(&base->timeheap)) != NULL) { in event_base_free() 169 event_del(ev); in event_base_free() 174 for (ev = TAILQ_FIRST(base->activequeues[i]); ev; ) { in event_base_free() 175 struct event *next = TAILQ_NEXT(ev, ev_active_next); in event_base_free() [all …]
|
| H A D | event.h | 222 #define EVENT_SIGNAL(ev) (int)(ev)->ev_fd argument 223 #define EVENT_FD(ev) (int)(ev)->ev_fd argument 437 #define evtimer_add(ev, tv) event_add(ev, tv) argument 447 #define evtimer_set(ev, cb, arg) event_set(ev, -1, 0, cb, arg) argument 455 #define evtimer_del(ev) event_del(ev) argument 456 #define evtimer_pending(ev, tv) event_pending(ev, EV_TIMEOUT, tv) argument 457 #define evtimer_initialized(ev) ((ev)->ev_flags & EVLIST_INIT) argument 473 #define timeout_add(ev, tv) event_add(ev, tv) argument 483 #define timeout_set(ev, cb, arg) event_set(ev, -1, 0, cb, arg) argument 491 #define timeout_del(ev) event_del(ev) argument [all …]
|
| H A D | kqueue.c | 189 struct event *ev; in kq_dispatch() local 270 TAILQ_FOREACH(ev, head, ev_signal_next) { in kq_dispatch() 271 event_active(ev, which, events[i].data); in kq_dispatch() 274 ev = (struct event *)events[i].udata; in kq_dispatch() 276 if (!(ev->ev_events & EV_PERSIST)) in kq_dispatch() 277 ev->ev_flags &= ~EVLIST_X_KQINKERNEL; in kq_dispatch() 279 event_active(ev, which, 1); in kq_dispatch() 288 kq_add(void *arg, struct event *ev) in kq_add() argument 293 if (ev->ev_events & EV_SIGNAL) { in kq_add() 294 int nsignal = EVENT_SIGNAL(ev); in kq_add() [all …]
|
| H A D | poll.c | 100 struct event *ev; in poll_check_ok() local 108 ev = pop->event_r_back[idx]; in poll_check_ok() 109 assert(ev); in poll_check_ok() 110 assert(ev->ev_events & EV_READ); in poll_check_ok() 111 assert(ev->ev_fd == i); in poll_check_ok() 114 ev = pop->event_w_back[idx]; in poll_check_ok() 115 assert(ev); in poll_check_ok() 116 assert(ev->ev_events & EV_WRITE); in poll_check_ok() 117 assert(ev->ev_fd == i); in poll_check_ok() 199 poll_add(void *arg, struct event *ev) in poll_add() argument [all …]
|
| H A D | signal.c | 154 evsignal_add(struct event *ev) in evsignal_add() argument 157 struct event_base *base = ev->ev_base; in evsignal_add() 158 struct evsignal_info *sig = &ev->ev_base->sig; in evsignal_add() 160 if (ev->ev_events & (EV_READ|EV_WRITE)) in evsignal_add() 162 evsignal = EVENT_SIGNAL(ev); in evsignal_add() 165 event_debug(("%s: %p: changing signal handler", __func__, ev)); in evsignal_add() 181 TAILQ_INSERT_TAIL(&sig->evsigevents[evsignal], ev, ev_signal_next); in evsignal_add() 206 evsignal_del(struct event *ev) in evsignal_del() argument 208 struct event_base *base = ev->ev_base; in evsignal_del() 210 int evsignal = EVENT_SIGNAL(ev); in evsignal_del() [all …]
|
| H A D | select.c | 246 select_add(void *arg, struct event *ev) in select_add() argument 250 if (ev->ev_events & EV_SIGNAL) in select_add() 251 return (evsignal_add(ev)); in select_add() 258 if (sop->event_fds < ev->ev_fd) { in select_add() 265 (howmany(ev->ev_fd + 1, NFDBITS) * sizeof(fd_mask))) in select_add() 275 sop->event_fds = ev->ev_fd; in select_add() 278 if (ev->ev_events & EV_READ) { in select_add() 279 FD_SET(ev->ev_fd, sop->event_readset_in); in select_add() 280 sop->event_r_by_fd[ev->ev_fd] = ev; in select_add() 282 if (ev->ev_events & EV_WRITE) { in select_add() [all …]
|
| /openbsd-src/usr.sbin/nsd/ |
| H A D | mini_event.c | 323 event_set(struct event* ev, int fd, short bits, in event_set() argument 326 ev->node.key = ev; in event_set() 327 ev->ev_fd = fd; in event_set() 328 ev->ev_flags = bits; in event_set() 329 ev->ev_callback = cb; in event_set() 330 ev->ev_arg = arg; in event_set() 331 ev->added = 0; in event_set() 336 event_base_set(struct event_base* base, struct event* ev) in event_base_set() argument 338 ev->ev_base = base; in event_base_set() 339 ev->added = 0; in event_base_set() [all …]
|
| /openbsd-src/sys/dev/wscons/ |
| H A D | wsevent.c | 94 struct wseventvar *ev = arg; 96 if((ev->ws_flags & WSEVENT_MPSAFE) == 0) 98 MUTEX_ASSERT_LOCKED(&ev->ws_mtx); 104 struct wseventvar *ev = arg; in wsevent_init() 106 if((ev->ws_flags & WSEVENT_MPSAFE) == 0) in wsevent_init() 108 mtx_enter(&ev->ws_mtx); in wsevent_init() 116 struct wseventvar *ev = arg; in wsevent_init() 118 mtx_leave(&ev->ws_mtx); in wsevent_init() 119 if ((ev->ws_flags & WSEVENT_MPSAFE) == 0) in wsevent_init() 142 wsevent_init_flags(struct wseventvar *ev, in in wsevent_fini() 100 wsevent_init(struct wseventvar * ev) wsevent_init() argument 127 wsevent_fini(struct wseventvar * ev) wsevent_fini() argument 148 wsevent_read(struct wseventvar * ev,struct uio * uio,int flags) wsevent_read() argument 205 wsevent_kqfilter(struct wseventvar * ev,struct knote * kn) wsevent_kqfilter() argument 232 struct wseventvar *ev = kn->kn_hook; filt_wseventdetach() local 244 struct wseventvar *ev = kn->kn_hook; filt_wseventread() local [all...] |
| /openbsd-src/sys/dev/pci/drm/amd/amdkfd/ |
| H A D | kfd_events.c | 95 struct kfd_event *ev, in allocate_event_notification_slot() argument 109 id = idr_alloc(&p->event_idr, ev, *restore_id, *restore_id + 1, in allocate_event_notification_slot() 118 id = idr_alloc(&p->event_idr, ev, 0, p->signal_mapped_size / 8, in allocate_event_notification_slot() 124 ev->event_id = id; in allocate_event_notification_slot() 159 struct kfd_event *ev; in lookup_signaled_event_by_partial_id() local 177 for (ev = NULL; id < KFD_SIGNAL_EVENT_LIMIT && !ev; id += 1U << bits) { in lookup_signaled_event_by_partial_id() 181 ev = idr_find(&p->event_idr, id); in lookup_signaled_event_by_partial_id() 184 return ev; in lookup_signaled_event_by_partial_id() 188 struct kfd_event *ev, const int *restore_id) in create_signal_event() argument 201 ret = allocate_event_notification_slot(p, ev, restore_id); in create_signal_event() [all …]
|
| /openbsd-src/lib/libedit/ |
| H A D | history.c | 112 #define HNEXT(h, ev) (*(h)->h_next)((h)->h_ref, ev) argument 113 #define HFIRST(h, ev) (*(h)->h_first)((h)->h_ref, ev) argument 114 #define HPREV(h, ev) (*(h)->h_prev)((h)->h_ref, ev) argument 115 #define HLAST(h, ev) (*(h)->h_last)((h)->h_ref, ev) argument 116 #define HCURR(h, ev) (*(h)->h_curr)((h)->h_ref, ev) argument 117 #define HSET(h, ev, n) (*(h)->h_set)((h)->h_ref, ev, n) argument 118 #define HCLEAR(h, ev) (*(h)->h_clear)((h)->h_ref, ev) argument 119 #define HENTER(h, ev, str) (*(h)->h_enter)((h)->h_ref, ev, str) argument 120 #define HADD(h, ev, str) (*(h)->h_add)((h)->h_ref, ev, str) argument 121 #define HDEL(h, ev, n) (*(h)->h_del)((h)->h_ref, ev, n) argument [all …]
|
| /openbsd-src/gnu/llvm/libcxx/src/ |
| H A D | system_error.cpp | 44 error_category::default_error_condition(int ev) const noexcept in default_error_condition() 46 return error_condition(ev, *this); in default_error_condition() 67 string do_strerror_r(int ev); 70 string do_strerror_r(int ev) { in do_strerror_r() argument 72 if (::strerror_s(buffer, strerror_buff_size, ev) == 0) in do_strerror_r() 74 std::snprintf(buffer, strerror_buff_size, "unknown error %d", ev); in do_strerror_r() 114 string do_strerror_r(int ev) { in do_strerror_r() argument 120 ::strerror_r(ev, buffer, strerror_buff_size), buffer); in do_strerror_r() 123 std::snprintf(buffer, strerror_buff_size, "Unknown error %d", ev); in do_strerror_r() 134 __do_message::message(int ev) const in message() [all …]
|
| /openbsd-src/sbin/isakmpd/ |
| H A D | timer.c | 88 struct event *ev = malloc(sizeof *ev); in timer_add_event() local 92 if (!ev) in timer_add_event() 94 ev->name = name; in timer_add_event() 95 ev->func = func; in timer_add_event() 96 ev->arg = arg; in timer_add_event() 98 memcpy(&ev->expiration, expiration, sizeof *expiration); in timer_add_event() 108 TAILQ_INSERT_BEFORE(n, ev, link); in timer_add_event() 113 TAILQ_INSERT_TAIL(&events, ev, link); in timer_add_event() 115 return ev; in timer_add_event() 119 timer_remove_event(struct event *ev) in timer_remove_event() argument [all …]
|
| /openbsd-src/lib/libcurses/tty/ |
| H A D | lib_twait.c | 129 _nc_event *ev = evl->events[n]; in _nc_eventlist_timeout() local 131 if (ev->type == _NC_EVENT_TIMEOUT_MSEC) { in _nc_eventlist_timeout() 132 event_delay = (int) ev->data.timeout_msec; in _nc_eventlist_timeout() 266 _nc_event *ev = evl->events[n]; in _nc_timed_wait() local 268 if (ev->type == _NC_EVENT_FILE in _nc_timed_wait() 269 && (ev->data.fev.flags & _NC_EVENT_FILE_READABLE)) { in _nc_timed_wait() 270 fds[count].fd = ev->data.fev.fd; in _nc_timed_wait() 288 _nc_event *ev = evl->events[n]; in _nc_timed_wait() local 290 if (ev->type == _NC_EVENT_FILE in _nc_timed_wait() 291 && (ev->data.fev.flags & _NC_EVENT_FILE_READABLE)) { in _nc_timed_wait() [all …]
|
| /openbsd-src/regress/lib/libevent/ |
| H A D | event_regress.c | 134 struct event *ev = arg; in multiple_write_cb() local 145 event_del(ev); in multiple_write_cb() 154 event_del(ev); in multiple_write_cb() 159 if (event_add(ev, NULL) == -1) in multiple_write_cb() 167 struct event *ev = arg; in multiple_read_cb() local 175 event_del(ev); in multiple_read_cb() 181 if (event_add(ev, NULL) == -1) in multiple_read_cb() 216 struct event *ev = arg; in signal_cb() local 218 signal_del(ev); in signal_cb() 224 struct event ev; member [all …]
|
| /openbsd-src/gnu/llvm/compiler-rt/lib/tsan/tests/rtl/ |
| H A D | tsan_test_util_posix.cpp | 238 void send(Event *ev); 239 void HandleEvent(Event *ev); 242 void ScopedThread::Impl::HandleEvent(Event *ev) { in HandleEvent() argument 244 expect_report = ev->expect_report; in HandleEvent() 246 expect_report_type = ev->report_type; in HandleEvent() 247 switch (ev->type) { in HandleEvent() 251 if (ev->type == Event::READ) { in HandleEvent() 252 switch (ev->arg /*size*/) { in HandleEvent() 270 switch (ev->arg /*size*/) { in HandleEvent() 295 tsan_mop(ev->ptr, (void *)ev->arg2); in HandleEvent() [all …]
|
| /openbsd-src/gnu/usr.bin/perl/cpan/bignum/t/ |
| H A D | bigexp.t | 14 my $ev = exp($ln_ev); 15 is(sprintf('%0.5f', $ev), '1.00000', '($ev) is approx. 1'); 16 is(sprintf('%0.5f', 1 - $ev), '0.00000', '(1-$ev) is approx. 0'); 17 is(sprintf('%0.5f', 1 - "$ev"), '0.00000', '(1-"$ev") is approx. 0'); 19 cmp_ok($ev, '!=', 0, '$ev should not equal 0');
|