Home
last modified time | relevance | path

Searched refs:EV_READ (Results 1 – 25 of 65) sorted by relevance

123

/freebsd-10-stable/contrib/ntp/sntp/libevent/test/
Dregress_et.c125 ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
176 ev_et = event_new(base, data->pair[0], EV_READ|EV_ET, read_cb, ev_et); in test_edgetriggered_mix_error()
178 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
184 tt_int_op(EV_READ, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
185 tt_int_op(0, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
191 tt_int_op(EV_READ, ==, event_pending(ev_lt, EV_READ, NULL)); in test_edgetriggered_mix_error()
192 tt_int_op(0, ==, event_pending(ev_et, EV_READ, NULL)); in test_edgetriggered_mix_error()
Dregress_bufferevent.c101 bufferevent_disable(bev, EV_READ); in readcb()
164 bufferevent_disable(bev1, EV_READ); in test_bufferevent_impl()
165 bufferevent_enable(bev2, EV_READ); in test_bufferevent_impl()
168 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ); in test_bufferevent_impl()
356 bufferevent_disable(bev, EV_READ); in wm_readcb()
401 bufferevent_disable(bev1, EV_READ); in test_bufferevent_watermarks_impl()
402 bufferevent_enable(bev2, EV_READ); in test_bufferevent_watermarks_impl()
405 bufferevent_getwatermark(bev1, EV_READ, &low, NULL); in test_bufferevent_watermarks_impl()
414 bufferevent_setwatermark(bev2, EV_READ, 10, 20); in test_bufferevent_watermarks_impl()
416 bufferevent_getwatermark(bev2, EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
[all …]
Dregress.c311 event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev); in test_simpleread()
356 event_set(&one, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
359 event_set(&two, pair[1], EV_READ, simpleread_multiple_cb, NULL); in test_simpleread_multiple()
433 rev = event_new(base, pair1[1], EV_READ, record_event_cb, in test_simpleclose()
451 tt_int_op(got_read_on_close, ==, EV_READ); in test_simpleclose()
493 event_set(&ev2, pair[1], EV_READ, multiple_read_cb, &ev2); in test_multiple()
522 event_set(&ev2, pair[1], EV_READ|EV_PERSIST, multiple_read_cb, &ev2); in test_persistent()
547 event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1); in test_combined()
549 event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2); in test_combined()
652 event_active(ev, EV_READ, 1); in activate_cb()
[all …]
Dtest-dumpevents.c111 ev[1] = event_new(base, pair1[1], EV_READ|EV_PERSIST, callback1, NULL); in main()
113 ev[3] = event_new(base, pair2[1], EV_READ, callback2, NULL); in main()
142 event_active(ev[10], EV_READ, 1); in main()
143 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
144 event_active(ev[1], EV_READ, 1); in main()
Dregress_ssl.c226 bufferevent_disable(bev, EV_READ); in respond_to_number()
237 bufferevent_enable(bev, EV_READ); in done_writing_cb()
371 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
372 bufferevent_enable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
410 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb()
463 bufferevent_enable(bev, EV_READ|EV_WRITE); in regress_bufferevent_openssl_connect()
Dtest-ratelim.c141 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
153 bufferevent_disable(bev, EV_READ); in echo_readcb()
161 bufferevent_enable(bev, EV_READ); in echo_writecb()
194 bufferevent_enable(bev, EV_READ|EV_WRITE); in echo_listenercb()
354 bufferevent_enable(bevs[i], EV_READ|EV_WRITE); in test_ratelimiting()
Dregress_zlib.c252 bufferevent_disable(bev, EV_READ); in readcb()
314 bufferevent_disable(bev1, EV_READ); in test_bufferevent_zlib()
317 bufferevent_enable(bev2, EV_READ); in test_bufferevent_zlib()
/freebsd-10-stable/contrib/unbound/util/
Dwinsock_event.c344 bits |= EV_READ; in handle_select()
356 bits |= EV_READ; in handle_select()
363 bits |= EV_READ; in handle_select()
369 bits |= EV_READ; in handle_select()
375 (eventlist[i]->old_events&EV_READ)?"EV_READ":"", in handle_select()
387 (eventlist[i]->old_events&EV_READ)?"EV_READ":"", in handle_select()
401 (bits&EV_READ)?" EV_READ":"", in handle_select()
414 (eventlist[i]->old_events&EV_READ)?"EV_READ":"", in handle_select()
498 (ev->ev_events&EV_READ)?" EV_READ":"", in event_add()
508 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add()
[all …]
Dmini_event.c209 bits |= EV_READ; in handle_select()
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()
337 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_del()
/freebsd-10-stable/contrib/ntp/sntp/libevent/
Devport.c98 #define FDI_HAS_READ(fdi) ((fdi)->fdi_what & EV_READ)
342 res = EV_READ | EV_WRITE; in evport_dispatch()
345 res |= EV_READ; in evport_dispatch()
354 res |= EV_READ|EV_WRITE; in evport_dispatch()
404 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
423 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
Dbufferevent_openssl.c473 if (bev->enabled & EV_READ) in clear_rbow()
485 if (!(bev->enabled & EV_READ)) in clear_wbor()
742 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
832 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_reading()
838 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
857 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_writing()
974 rpending = event_pending(&bev->ev_read, EV_READ, NULL); in set_open_callbacks()
980 EV_READ|EV_PERSIST|EV_FINALIZE, in set_open_callbacks()
1084 EV_READ|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks()
1142 if (events & EV_READ) in be_openssl_enable()
[all …]
Dbufferevent_pair.c187 bufferevent_trigger_nolock_(dst, EV_READ, 0); in be_pair_transfer()
199 (downcast(dst)->enabled & EV_READ) && in be_pair_wants_to_talk()
232 if (events & EV_READ) { in be_pair_enable()
239 if ((events & EV_READ) && partner && in be_pair_enable()
255 if (events & EV_READ) { in be_pair_disable()
319 if ((iotype & EV_READ) != 0) in be_pair_flush()
Devmap.c294 old |= EV_READ; in evmap_io_add_()
300 if (ev->ev_events & EV_READ) { in evmap_io_add_()
302 res |= EV_READ; in evmap_io_add_()
372 old |= EV_READ; in evmap_io_del_()
378 if (ev->ev_events & EV_READ) { in evmap_io_del_()
380 res |= EV_READ; in evmap_io_del_()
608 events |= EV_READ;
872 if (events & (EV_READ|EV_SIGNAL)) {
918 if (events & (EV_READ|EV_SIGNAL)) {
919 if (!(change->old_events & (EV_READ | EV_SIGNAL)))
[all …]
Dbufferevent_filter.c212 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new()
263 if (event & EV_READ) { in be_filter_enable()
277 if (event & EV_READ) { in be_filter_disable()
296 if (!(bev->enabled & EV_READ) || in be_filter_process_input()
313 (bev->enabled & EV_READ) && in be_filter_process_input()
452 bufferevent_trigger_nolock_(bufev, EV_READ, 0); in be_filter_readcb()
514 if (iotype & EV_READ) { in be_filter_flush()
Dpoll.c204 res |= EV_READ; in poll_dispatch()
225 if (!(events & (EV_READ|EV_WRITE))) in poll_add()
266 if (events & EV_READ) in poll_add()
286 if (!(events & (EV_READ|EV_WRITE))) in poll_del()
296 if (events & EV_READ) in poll_del()
Ddevpoll.c212 which |= EV_READ; in devpoll_dispatch()
242 if (events & EV_READ) in devpoll_add()
261 if (events & EV_READ) in devpoll_del()
285 } else if ((res & POLLOUT) && (old & EV_READ)) { in devpoll_del()
Dbufferevent_sock.c187 bufferevent_trigger_nolock_(bufev, EV_READ, 0); in bufferevent_readcb()
195 bufferevent_disable(bufev, EV_READ); in bufferevent_readcb()
340 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev); in bufferevent_socket_new()
553 if (event & EV_READ) { in be_socket_enable()
569 if (event & EV_READ) { in be_socket_disable()
599 if (event_pending(&bufev->ev_read, EV_READ, NULL)) { in be_socket_adj_timeouts()
636 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev); in be_socket_setfd()
Dbufferevent.c74 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
86 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read_()
87 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
470 impl_events &= ~EV_READ; in bufferevent_enable()
583 if (events & EV_READ) { in bufferevent_setwatermark()
632 if (events == EV_READ) { in bufferevent_getwatermark()
921 bufferevent_disable(bev, EV_READ); in bufferevent_generic_read_timeout_cb()
951 if ((enabled & EV_READ) && !bev_p->read_suspended && in bufferevent_generic_adj_timeouts_()
Dselect.c197 res |= EV_READ; in select_dispatch()
285 if (events & EV_READ) in select_add()
312 if (events & EV_READ) in select_del()
Depoll.c386 if (events & EV_READ) in epoll_nochangelist_add()
406 if (events & EV_READ) in epoll_nochangelist_del()
488 ev = EV_READ | EV_WRITE; in epoll_dispatch()
491 ev |= EV_READ; in epoll_dispatch()
/freebsd-10-stable/contrib/pf/libevent/
Dpoll.c131 assert(ev->ev_events & EV_READ); in poll_check_ok()
189 res |= EV_READ; in poll_dispatch()
223 if (!(ev->ev_events & (EV_READ|EV_WRITE))) in poll_add()
306 if (ev->ev_events & EV_READ) { in poll_add()
329 if (!(ev->ev_events & (EV_READ|EV_WRITE))) in poll_del()
339 if (ev->ev_events & EV_READ) { in poll_del()
Devbuffer.c83 if (bufev->enabled & EV_READ) in bufferevent_read_pressure_cb()
241 event_set(&bufev->ev_read, fd, EV_READ, bufferevent_readcb, bufev); in bufferevent_new()
339 if (event & EV_READ) { in bufferevent_enable()
355 if (event & EV_READ) { in bufferevent_disable()
387 if (events & EV_READ) { in bufferevent_setwatermark()
Dselect.c119 assert(sop->event_r_by_fd[i]->ev_events & EV_READ); in check_selectop()
190 res |= EV_READ; in select_dispatch()
305 if (ev->ev_events & EV_READ) { in select_add()
336 if (ev->ev_events & EV_READ) { in select_del()
Dsignal.c105 event_set(&ev_signal, ev_signal_pair[1], EV_READ, in evsignal_init()
116 if (ev->ev_events & (EV_READ|EV_WRITE)) in evsignal_add()
/freebsd-10-stable/usr.sbin/bluetooth/btpand/
Devent.c125 if (ev->flags & EV_READ) { in __event_dispatch()
174 (ev->flags & (EV_READ|EV_WRITE)), in __event_dispatch()
196 (ev->flags & (EV_READ|EV_WRITE)), in __event_dispatch()

123