Home
last modified time | relevance | path

Searched refs:ev_write (Results 1 – 16 of 16) sorted by relevance

/src/contrib/ntp/sntp/libevent/
H A Dbufferevent_sock.c138 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb()
142 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) { in bufferevent_socket_outbuf_cb()
262 event_del(&bufev->ev_write); in bufferevent_writecb()
271 event_del(&bufev->ev_write); in bufferevent_writecb()
282 event_del(&bufev->ev_write); in bufferevent_writecb()
316 event_del(&bufev->ev_write); in bufferevent_writecb()
331 event_del(&bufev->ev_write); in bufferevent_writecb()
368 event_assign(&bufev->ev_write, bufev->ev_base, fd, in bufferevent_socket_new()
423 event_assign(&bev->ev_write, bev->ev_base, fd, in bufferevent_socket_connect()
574 bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) in be_socket_enable()
[all …]
H A Dbufferevent_openssl.c394 r = bufferevent_add_event_(&bev->ev_write, in start_reading()
414 r = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write); in start_writing()
446 event_del(&bev->ev_write); in stop_writing()
894 event_del(&bev_ssl->bev.bev.ev_write); in consider_writing()
898 event_del(&bev_ssl->bev.bev.ev_write); in consider_writing()
996 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); in set_open_callbacks()
999 event_del(&bev->ev_write); in set_open_callbacks()
1005 event_assign(&bev->ev_write, bev->ev_base, fd, in set_open_callbacks()
1012 r2 = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write); in set_open_callbacks()
1104 event_del(&bev->ev_write); in set_handshake_callbacks()
[all …]
H A Dbufferevent.c726 cbs[1] = &bufev->ev_write.ev_evcallback; in bufferevent_decref_and_unlock_()
965 event_assign(&bev->ev_write, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
984 r2 = event_add(&bev->ev_write, &bev->timeout_write); in bufferevent_generic_adj_timeouts_()
986 r2 = event_del(&bev->ev_write); in bufferevent_generic_adj_timeouts_()
1004 if (event_pending(&bev->ev_write, EV_WRITE, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
1006 if (bufferevent_add_event_(&bev->ev_write, &bev->timeout_write) < 0) in bufferevent_generic_adj_existing_timeouts_()
1009 event_remove_timer(&bev->ev_write); in bufferevent_generic_adj_existing_timeouts_()
H A Dbufferevent-internal.h468 event_add(&(bev)->ev_write, &(bev)->timeout_write); \
473 event_del(&(bev)->ev_write)
/src/contrib/libevent/
H A Dbufferevent_sock.c138 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb()
142 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) { in bufferevent_socket_outbuf_cb()
262 event_del(&bufev->ev_write); in bufferevent_writecb()
271 event_del(&bufev->ev_write); in bufferevent_writecb()
282 event_del(&bufev->ev_write); in bufferevent_writecb()
316 event_del(&bufev->ev_write); in bufferevent_writecb()
331 event_del(&bufev->ev_write); in bufferevent_writecb()
368 event_assign(&bufev->ev_write, bufev->ev_base, fd, in bufferevent_socket_new()
423 event_assign(&bev->ev_write, bev->ev_base, fd, in bufferevent_socket_connect()
574 bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) in be_socket_enable()
[all …]
H A Dbufferevent_openssl.c394 r = bufferevent_add_event_(&bev->ev_write, in start_reading()
414 r = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write); in start_writing()
446 event_del(&bev->ev_write); in stop_writing()
894 event_del(&bev_ssl->bev.bev.ev_write); in consider_writing()
898 event_del(&bev_ssl->bev.bev.ev_write); in consider_writing()
996 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); in set_open_callbacks()
999 event_del(&bev->ev_write); in set_open_callbacks()
1005 event_assign(&bev->ev_write, bev->ev_base, fd, in set_open_callbacks()
1012 r2 = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write); in set_open_callbacks()
1104 event_del(&bev->ev_write); in set_handshake_callbacks()
[all …]
H A Dbufferevent.c726 cbs[1] = &bufev->ev_write.ev_evcallback; in bufferevent_decref_and_unlock_()
965 event_assign(&bev->ev_write, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
984 r2 = event_add(&bev->ev_write, &bev->timeout_write); in bufferevent_generic_adj_timeouts_()
986 r2 = event_del(&bev->ev_write); in bufferevent_generic_adj_timeouts_()
1004 if (event_pending(&bev->ev_write, EV_WRITE, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
1006 if (bufferevent_add_event_(&bev->ev_write, &bev->timeout_write) < 0) in bufferevent_generic_adj_existing_timeouts_()
1009 event_remove_timer(&bev->ev_write); in bufferevent_generic_adj_existing_timeouts_()
H A Dbufferevent-internal.h468 event_add(&(bev)->ev_write, &(bev)->timeout_write); \
473 event_del(&(bev)->ev_write)
/src/contrib/pf/libevent/
H A Devbuffer.c189 bufferevent_add(&bufev->ev_write, bufev->timeout_write); in bufferevent_writecb()
203 bufferevent_add(&bufev->ev_write, bufev->timeout_write); in bufferevent_writecb()
242 event_set(&bufev->ev_write, fd, EV_WRITE, bufferevent_writecb, bufev); in bufferevent_new()
265 if (event_priority_set(&bufev->ev_write, priority) == -1) in bufferevent_priority_set()
277 event_del(&bufev->ev_write); in bufferevent_free()
302 bufferevent_add(&bufev->ev_write, bufev->timeout_write); in bufferevent_write()
344 if (bufferevent_add(&bufev->ev_write, bufev->timeout_write) == -1) in bufferevent_enable()
360 if (event_del(&bufev->ev_write) == -1) in bufferevent_disable()
411 res = event_base_set(base, &bufev->ev_write); in bufferevent_base_set()
H A Devent.h241 struct event ev_write; member
/src/contrib/ntp/sntp/libevent/include/event2/
H A Dbufferevent_struct.h84 struct event ev_write; member
/src/contrib/libevent/include/event2/
H A Dbufferevent_struct.h84 struct event ev_write; member
/src/contrib/libevent/test/
H A Dregress_ssl.c305 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
H A Dregress_bufferevent.c467 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL)); in test_bufferevent_watermarks_impl()
/src/contrib/ntp/sntp/libevent/test/
H A Dregress_ssl.c305 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
H A Dregress_bufferevent.c467 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL)); in test_bufferevent_watermarks_impl()