Home
last modified time | relevance | path

Searched refs:ev_events (Results 1 – 14 of 14) sorted by relevance

/NextBSD/contrib/pf/libevent/
HDpoll.c131 assert(ev->ev_events & EV_READ); in poll_check_ok()
137 assert(ev->ev_events & EV_WRITE); in poll_check_ok()
199 if (r_ev && (res & r_ev->ev_events)) { in poll_dispatch()
200 if (!(r_ev->ev_events & EV_PERSIST)) in poll_dispatch()
202 event_active(r_ev, res & r_ev->ev_events, 1); in poll_dispatch()
204 if (w_ev && w_ev != r_ev && (res & w_ev->ev_events)) { in poll_dispatch()
205 if (!(w_ev->ev_events & EV_PERSIST)) in poll_dispatch()
207 event_active(w_ev, res & w_ev->ev_events, 1); in poll_dispatch()
221 if (ev->ev_events & EV_SIGNAL) in poll_add()
223 if (!(ev->ev_events & (EV_READ|EV_WRITE))) in poll_add()
[all …]
HDselect.c119 assert(sop->event_r_by_fd[i]->ev_events & EV_READ); in check_selectop()
126 assert(sop->event_w_by_fd[i]->ev_events & EV_WRITE); in check_selectop()
196 if (r_ev && (res & r_ev->ev_events)) { in select_dispatch()
197 if (!(r_ev->ev_events & EV_PERSIST)) in select_dispatch()
199 event_active(r_ev, res & r_ev->ev_events, 1); in select_dispatch()
201 if (w_ev && w_ev != r_ev && (res & w_ev->ev_events)) { in select_dispatch()
202 if (!(w_ev->ev_events & EV_PERSIST)) in select_dispatch()
204 event_active(w_ev, res & w_ev->ev_events, 1); in select_dispatch()
277 if (ev->ev_events & EV_SIGNAL) in select_add()
305 if (ev->ev_events & EV_READ) { in select_add()
[all …]
HDkqueue.c271 if (!(ev->ev_events & EV_PERSIST)) in kq_dispatch()
275 ev->ev_events & EV_SIGNAL ? events[i].data : 1); in kq_dispatch()
288 if (ev->ev_events & EV_SIGNAL) { in kq_add()
295 if (!(ev->ev_events & EV_PERSIST)) in kq_add()
309 if (ev->ev_events & EV_READ) { in kq_add()
318 if (!(ev->ev_events & EV_PERSIST)) in kq_add()
328 if (ev->ev_events & EV_WRITE) { in kq_add()
333 if (!(ev->ev_events & EV_PERSIST)) in kq_add()
355 if (ev->ev_events & EV_SIGNAL) { in kq_del()
373 if (ev->ev_events & EV_READ) { in kq_del()
[all …]
HDsignal.c116 if (ev->ev_events & (EV_READ|EV_WRITE)) in evsignal_add()
173 if (!(ev->ev_events & EV_PERSIST)) in evsignal_process()
HDevent.c518 ev->ev_events = events; in event_set()
569 flags |= (ev->ev_events & (EV_READ|EV_WRITE)); in event_pending()
601 ev->ev_events & EV_READ ? "EV_READ " : " ", in event_add()
602 ev->ev_events & EV_WRITE ? "EV_WRITE " : " ", in event_add()
640 if ((ev->ev_events & (EV_READ|EV_WRITE)) && in event_add()
645 } else if ((ev->ev_events & EV_SIGNAL) && in event_add()
HDevent.h89 short ev_events; member
/NextBSD/contrib/unbound/util/
HDwinsock_event.c195 p->ev_events &= ~EV_TIMEOUT; in handle_timeouts()
226 (*ev->ev_callback)(ev->ev_fd, ev->ev_events, ev->ev_arg); in handle_signal()
382 if((eventlist[i]->ev_events & bits)) { in handle_select()
390 if((bits & eventlist[i]->ev_events)) { in handle_select()
408 bits & eventlist[i]->ev_events, in handle_select()
476 ev->ev_events = bits; in event_set()
498 (ev->ev_events&EV_READ)?" EV_READ":"", in event_add()
499 (ev->ev_events&EV_WRITE)?" EV_WRITE":"", in event_add()
500 (ev->ev_events&EV_TIMEOUT)?" EV_TIMEOUT":""); in event_add()
508 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add()
[all …]
HDmini_event.c171 p->ev_events &= ~EV_TIMEOUT; in handle_timeouts()
216 bits &= base->fds[i]->ev_events; in handle_select()
279 ev->ev_events = bits; in event_set()
301 if( (ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add()
303 if(ev->ev_events&EV_READ) { in event_add()
306 if(ev->ev_events&EV_WRITE) { in event_add()
314 if(tv && (ev->ev_events&EV_TIMEOUT)) { in event_add()
335 if((ev->ev_events&EV_TIMEOUT)) in event_del()
337 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_del()
HDmini_event.h140 short ev_events; member
HDwinsock_event.h181 short ev_events; member
HDnetevent.c2016 c->ev->ev.ev_events |= EV_TIMEOUT;
2023 c->ev->ev.ev_events &= ~(EV_READ|EV_WRITE);
2025 c->ev->ev.ev_events |= EV_READ;
2026 else c->ev->ev.ev_events |= EV_WRITE;
2050 c->ev->ev.ev_events &= ~(EV_READ|EV_WRITE);
2051 if(rd) c->ev->ev.ev_events |= EV_READ;
2052 if(wr) c->ev->ev.ev_events |= EV_WRITE;
/NextBSD/contrib/ntp/sntp/libevent/
HDevmap.c300 if (ev->ev_events & EV_READ) { in evmap_io_add_()
304 if (ev->ev_events & EV_WRITE) { in evmap_io_add_()
308 if (ev->ev_events & EV_CLOSED) { in evmap_io_add_()
319 (old_ev->ev_events&EV_ET) != (ev->ev_events&EV_ET)) { in evmap_io_add_()
331 old, (ev->ev_events & EV_ET) | res, extra) == -1) in evmap_io_add_()
378 if (ev->ev_events & EV_READ) { in evmap_io_del_()
383 if (ev->ev_events & EV_WRITE) { in evmap_io_del_()
388 if (ev->ev_events & EV_CLOSED) { in evmap_io_del_()
427 if (ev->ev_events & events) in evmap_io_active_()
428 event_active_nolock_(ev, ev->ev_events & events, 1); in evmap_io_active_()
[all …]
HDevent.c264 __func__, (ev), (ev)->ev_events, \
285 __func__, (ev), (ev)->ev_events, \
304 __func__, (ev), (ev)->ev_events, \
323 __func__, (ev), (ev)->ev_events, \
1558 if (ev->ev_events & EV_PERSIST || ev->ev_flags & EVLIST_FINALIZING) in event_process_active_single_queue()
2032 ev->ev_events = events; in event_assign()
2291 flags |= (ev->ev_events & (EV_READ|EV_WRITE|EV_CLOSED|EV_SIGNAL)); in event_pending()
2331 *events_out = event->ev_events; in event_get_assignment()
2362 return ev->ev_events; in event_get_events()
2514 ev->ev_events & EV_READ ? "EV_READ " : " ", in event_add_nolock_()
[all …]
/NextBSD/contrib/ntp/sntp/libevent/include/event2/
HDevent_struct.h151 short ev_events; member