Home
last modified time | relevance | path

Searched refs:EV_WRITE (Results 1 – 25 of 77) sorted by relevance

1234

/netbsd-src/external/bsd/libevent/dist/
H A Dbufferevent_sock.c140 (bufev->enabled & EV_WRITE) && in bufferevent_socket_outbuf_cb()
141 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb()
283 if (!(bufev->enabled & EV_WRITE) || in bufferevent_writecb()
327 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0); in bufferevent_writecb()
339 bufferevent_disable(bufev, EV_WRITE); in bufferevent_writecb()
372 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev); in bufferevent_socket_new()
427 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bev); in bufferevent_socket_connect()
432 if (! be_socket_enable(bev, EV_WRITE)) { in bufferevent_socket_connect()
441 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS); in bufferevent_socket_connect()
446 bufferevent_disable(bev, EV_WRITE|EV_READ); in bufferevent_socket_connect()
[all …]
H A Dbufferevent_pair.c191 bufferevent_trigger_nolock_(src, EV_WRITE, 0); in be_pair_transfer()
201 return (downcast(src)->enabled & EV_WRITE) && in be_pair_wants_to_talk()
238 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
247 if ((events & EV_WRITE) && partner && in be_pair_enable()
261 if (events & EV_WRITE) { in be_pair_disable()
327 if ((iotype & EV_WRITE) != 0) in be_pair_flush()
334 if (iotype & EV_WRITE) in be_pair_flush()
H A Devport.c102 #define FDI_HAS_WRITE(fdi) ((fdi)->fdi_what & EV_WRITE)
345 res = EV_READ | EV_WRITE; in evport_dispatch()
350 res |= EV_WRITE; in evport_dispatch()
357 res |= EV_READ|EV_WRITE; in evport_dispatch()
407 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
426 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
H A Devmap.c307 old |= EV_WRITE; in evmap_io_add_()
315 if (ev->ev_events & EV_WRITE) { in evmap_io_add_()
317 res |= EV_WRITE; in evmap_io_add_()
385 old |= EV_WRITE; in evmap_io_del_()
394 if (ev->ev_events & EV_WRITE) { in evmap_io_del_()
396 res |= EV_WRITE; in evmap_io_del_()
625 events |= EV_WRITE;
890 if (events & EV_WRITE)
935 if (events & EV_WRITE) {
936 if (!(change->old_events & EV_WRITE))
[all …]
H A Dbufferevent_filter.c225 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new()
279 if (event & EV_WRITE) in be_filter_enable()
294 if (event & EV_WRITE) in be_filter_disable()
359 if (!(bufev->enabled & EV_WRITE) || in be_filter_process_output()
392 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
401 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0); in be_filter_process_output()
404 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
588 if (iotype & EV_WRITE) { in be_filter_flush()
H A Dpoll.c220 res |= EV_WRITE; in poll_dispatch()
241 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_add()
280 if (events & EV_WRITE) in poll_add()
304 if (!(events & (EV_READ|EV_WRITE|EV_CLOSED))) in poll_del()
316 if (events & EV_WRITE) in poll_del()
H A Ddevpoll.c217 which |= EV_WRITE; in devpoll_dispatch()
247 if (events & EV_WRITE) in devpoll_add()
266 if (events & EV_WRITE) in devpoll_del()
285 if ((res & POLLIN) && (old & EV_WRITE)) { in devpoll_del()
H A Dbufferevent_openssl.c477 if (!(bev->enabled & EV_WRITE)) in clear_rbow()
493 if (bev->enabled & EV_WRITE) in clear_wbor()
730 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS); in do_write()
881 while ((bev_ssl->bev.bev.enabled & EV_WRITE) && in consider_writing()
899 !(bev_ssl->bev.bev.enabled & EV_WRITE)) { in consider_writing()
999 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); in set_open_callbacks()
1009 EV_WRITE|EV_PERSIST|EV_FINALIZE, in set_open_callbacks()
1114 EV_WRITE|EV_PERSIST|EV_FINALIZE, in set_handshake_callbacks()
1167 if (events & EV_WRITE) in be_openssl_enable()
1173 if (events & EV_WRITE) in be_openssl_enable()
[all …]
H A Dwin32select.c232 if (!(events & (EV_READ|EV_WRITE))) in win32_add()
240 if (events & EV_WRITE) { in win32_add()
258 if (events & EV_WRITE) in win32_del()
354 evmap_io_active_(base, s, EV_WRITE); in win32_dispatch()
364 evmap_io_active_(base, s, EV_WRITE); in win32_dispatch()
H A Dbufferevent.c98 bufev->be_ops->disable(bufev, EV_WRITE); in bufferevent_suspend_write_()
109 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE)) in bufferevent_unsuspend_write_()
110 bufev->be_ops->enable(bufev, EV_WRITE); in bufferevent_unsuspend_write_()
347 bufev->enabled = EV_WRITE; in bufferevent_init_common_()
496 impl_events &= ~EV_WRITE; in bufferevent_enable()
604 if (events & EV_WRITE) { in bufferevent_setwatermark()
648 if (events == EV_WRITE) { in bufferevent_getwatermark()
959 bufferevent_disable(bev, EV_WRITE); in bufferevent_generic_write_timeout_cb()
985 if ((enabled & EV_WRITE) && !bev_p->write_suspended && in bufferevent_generic_adj_timeouts_()
1008 if (event_pending(&bev->ev_write, EV_WRITE, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
H A Depoll.c385 if (events & EV_WRITE) in epoll_nochangelist_add()
406 if (events & EV_WRITE) in epoll_nochangelist_del()
493 ev = EV_READ | EV_WRITE; in epoll_dispatch()
495 ev = EV_READ | EV_WRITE; in epoll_dispatch()
500 ev |= EV_WRITE; in epoll_dispatch()
H A Dselect.c202 res |= EV_WRITE; in select_dispatch()
290 if (events & EV_WRITE) in select_add()
318 if (events & EV_WRITE) in select_del()
H A Dbufferevent_async.c220 if (!beva->ok || !(bev->enabled&EV_WRITE) || in bev_async_consider_writing()
362 if (what & EV_WRITE) in be_async_enable()
370 if (what & EV_WRITE) in be_async_enable()
387 if (what & EV_WRITE) { in be_async_disable()
529 be_async_trigger_nolock(bev, EV_WRITE, 0); in write_complete()
/netbsd-src/external/bsd/unbound/dist/util/
H A Dwinsock_event.c351 bits |= EV_WRITE; in handle_select()
358 bits |= EV_WRITE; in handle_select()
371 bits |= EV_WRITE; in handle_select()
377 (eventlist[i]->old_events&EV_WRITE)?"EV_WRITE":""); in handle_select()
389 (eventlist[i]->old_events&EV_WRITE)?"EV_WRITE":""); in handle_select()
403 (bits&EV_WRITE)?" EV_WRITE":"", in handle_select()
416 (eventlist[i]->old_events&EV_WRITE)?"EV_WRITE":""); in handle_select()
497 (ev->ev_events&EV_WRITE)?" EV_WRITE":"", in event_add()
506 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add()
518 if( (ev->ev_events&EV_WRITE) ) in event_add()
[all …]
H A Dmini_event.c216 bits |= EV_WRITE; in handle_select()
301 if( (ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add()
306 if(ev->ev_events&EV_WRITE) { in event_add()
337 if((ev->ev_events&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_del()
H A Dub_event.c70 UB_EV_WRITE != EV_WRITE || UB_EV_SIGNAL != EV_SIGNAL || \
76 | (((b) & UB_EV_WRITE ) ? EV_WRITE : 0) \
83 | (((b) & EV_WRITE ) ? UB_EV_WRITE : 0) \
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/
H A Devport.c101 #define FDI_HAS_WRITE(fdi) ((fdi)->fdi_what & EV_WRITE)
344 res = EV_READ | EV_WRITE; in evport_dispatch()
349 res |= EV_WRITE; in evport_dispatch()
356 res |= EV_READ|EV_WRITE; in evport_dispatch()
406 fdi->fdi_what &= ~(events &(EV_READ|EV_WRITE)); in evport_del()
425 if ((fdi->fdi_what & (EV_READ|EV_WRITE)) == 0) { in evport_del()
H A Ddevpoll.c216 which |= EV_WRITE; in devpoll_dispatch()
246 if (events & EV_WRITE) in devpoll_add()
265 if (events & EV_WRITE) in devpoll_del()
284 if ((res & POLLIN) && (old & EV_WRITE)) { in devpoll_del()
/netbsd-src/external/bsd/libevent/dist/test/
H A Dregress_ssl.c351 bufferevent_enable(bev, EV_WRITE); in respond_to_number()
362 bufferevent_disable(bev, EV_WRITE); in done_writing_cb()
527 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
528 bufferevent_enable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
549 bufferevent_enable(bev1, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
550 bufferevent_disable(bev2, EV_READ|EV_WRITE); in regress_bufferevent_openssl()
577 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb_deferred()
605 bufferevent_disable(bev, EV_READ|EV_WRITE); in acceptcb()
607 bufferevent_enable(bev, EV_READ|EV_WRITE); in acceptcb()
791 bufferevent_enable(bev, EV_READ|EV_WRITE); in regress_bufferevent_openssl_connect()
[all …]
H A Dregress_bufferevent.c185 tt_int_op(bufferevent_get_enabled(bev1), ==, EV_WRITE); in test_bufferevent_impl()
186 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ); in test_bufferevent_impl()
193 tt_int_op(bufferevent_flush(bev1, EV_WRITE, flush), >=, 0); in test_bufferevent_impl()
437 bufferevent_getwatermark(bev2, EV_WRITE, &low, NULL); in test_bufferevent_watermarks_impl()
452 bufferevent_setwatermark(bev1, EV_WRITE, 100, 2000); in test_bufferevent_watermarks_impl()
454 bufferevent_getwatermark(bev1, EV_WRITE, &low, &high); in test_bufferevent_watermarks_impl()
459 int r = bufferevent_getwatermark(bev1, EV_WRITE | EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
471 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL)); in test_bufferevent_watermarks_impl()
624 bufferevent_disable(bev,EV_READ|EV_WRITE); in sender_writecb()
839 bufferevent_enable(bev, EV_READ|EV_WRITE); in test_bufferevent_connect_fail_eventcb()
[all …]
H A Dtest-dumpevents.c113 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL); in main()
115 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL); in main()
146 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
H A Dregress.c329 event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev); in test_simplewrite()
438 wev = event_new(base, pair2[1], EV_WRITE, record_event_cb, in test_simpleclose_rw()
454 tt_int_op(got_write_on_close, ==, EV_WRITE); in test_simpleclose_rw()
542 event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev); in test_multiple()
571 event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev); in test_persistent()
600 event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1); in test_combined()
602 event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2); in test_combined()
1469 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events()
1473 event_active(&ev1, EV_WRITE, 1); in test_manipulate_active_events()
1474 tt_int_op(event_pending(&ev1, EV_READ|EV_TIMEOUT|EV_WRITE, NULL), in test_manipulate_active_events()
[all …]
/netbsd-src/external/bsd/libevent/dist/sample/
H A Dle-proxy.c74 bufferevent_setwatermark(partner, EV_WRITE, MAX_OUTPUT/2, in readcb()
88 bufferevent_setwatermark(bev, EV_WRITE, 0, 0); in drained_writecb()
207 bufferevent_enable(b_in, EV_READ|EV_WRITE); in accept_cb()
208 bufferevent_enable(b_out, EV_READ|EV_WRITE); in accept_cb()
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/test/
H A Dtest-dumpevents.c112 ev[0] = event_new(base, pair1[0], EV_WRITE, callback1, NULL); in main()
114 ev[2] = event_new(base, pair2[0], EV_WRITE|EV_PERSIST, callback2, NULL); in main()
145 event_active(ev[11], EV_READ|EV_WRITE|EV_TIMEOUT, 1); in main()
/netbsd-src/external/bsd/nsd/dist/
H A Dmini_event.c234 bits |= EV_WRITE; in handle_select()
351 if( (ev->ev_flags&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_add()
356 if(ev->ev_flags&EV_WRITE) { in event_add()
388 if((ev->ev_flags&(EV_READ|EV_WRITE)) && ev->ev_fd != -1) { in event_del()

1234