Home
last modified time | relevance | path

Searched refs:bev (Results 1 – 25 of 63) sorted by relevance

123

/freebsd/contrib/ntp/sntp/libevent/
H A Dbufferevent_async.c131 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); in upcast()
165 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_write() local
176 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_read() local
187 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_write() local
198 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_read() local
211 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_writing() local
257 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_reading() local
437 struct bufferevent *bev = &bev_a->bev.bev; in connect_complete() local
465 struct bufferevent *bev = &bev_a->bev.bev; in read_complete() local
504 struct bufferevent *bev = &bev_a->bev.bev; in write_complete() local
[all …]
H A Dbufferevent_ratelim.c238 bufferevent_suspend_write_(&bev->bev, in bufferevent_get_rlim_max_()
241 bufferevent_suspend_read_(&bev->bev, in bufferevent_get_rlim_max_()
365 bufferevent_suspend_read_(&bev->bev, in bev_group_suspend_reading_()
383 bufferevent_suspend_write_(&bev->bev, in bev_group_suspend_writing_()
400 BEV_LOCK(&bev->bev); in bev_refill_callback_()
402 BEV_UNLOCK(&bev->bev); in bev_refill_callback_()
438 BEV_UNLOCK(&bev->bev); in bev_refill_callback_()
477 for (bev = first; bev != LIST_END(&g->members); \
481 for (bev = LIST_FIRST(&g->members); bev && bev != first; \
496 bufferevent_unsuspend_read_(&bev->bev, in bev_group_unsuspend_reading_()
[all …]
H A Dbufferevent_openssl.c390 struct bufferevent *bev = &bev_ssl->bev.bev; in start_reading() local
413 struct bufferevent *bev = &bev_ssl->bev.bev; in start_writing() local
431 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_reading() local
445 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_writing() local
471 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_rbow() local
485 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_wbor() local
586 struct bufferevent *bev = &bev_ssl->bev.bev; in do_read() local
657 struct bufferevent *bev = &bev_ssl->bev.bev; in do_write() local
741 struct evbuffer *input = bev->bev.bev.input; in bytes_to_read()
752 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
[all …]
H A Dbufferevent_filter.c105 evutil_offsetof(struct bufferevent_filtered, bev.bev),
124 evutil_offsetof(struct bufferevent_filtered, bev.bev)); in upcast()
125 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev)); in upcast()
129 #define downcast(bev_f) (&(bev_f)->bev.bev)
490 BEV_LOCK(bev); in bufferevent_filtered_inbuf_cb()
509 BEV_UNLOCK(bev); in bufferevent_filtered_inbuf_cb()
519 BEV_LOCK(bev); in be_filter_readcb()
523 BEV_UNLOCK(bev); in be_filter_readcb()
536 BEV_LOCK(bev); in be_filter_writecb()
546 BEV_UNLOCK(bev); in be_filter_writecb()
[all …]
H A Dbufferevent_pair.c59 if (!BEV_IS_PAIR(bev)) in upcast()
61 bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev); in upcast()
62 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev)); in upcast()
66 #define downcast(bev_pair) (&(bev_pair)->bev.bev)
104 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
109 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev); in bufferevent_pair_elt_new()
317 incref_and_lock(bev); in be_pair_flush()
335 decref_and_unlock(bev); in be_pair_flush()
344 bev_p = upcast(bev); in bufferevent_pair_get_partner()
348 incref_and_lock(bev); in bufferevent_pair_get_partner()
[all …]
H A Dbufferevent.c127 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
870 BEV_LOCK(bev); in bufferevent_setfd()
872 res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d); in bufferevent_setfd()
885 BEV_LOCK(bev); in bufferevent_getfd()
887 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d); in bufferevent_getfd()
900 BEV_LOCK(bev); in bufferevent_get_options_()
912 BEV_LOCK(bev); in bufferevent_cancel_all_()
914 bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d); in bufferevent_cancel_all_()
963 event_assign(&bev->ev_read, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
977 r1 = event_add(&bev->ev_read, &bev->timeout_read); in bufferevent_generic_adj_timeouts_()
[all …]
H A Dbufferevent_sock.c363 bufev = &bufev_p->bev; in bufferevent_socket_new()
392 fd = bufferevent_getfd(bev); in bufferevent_socket_connect()
422 if (BEV_IS_ASYNC(bev)) { in bufferevent_socket_connect()
423 event_assign(&bev->ev_write, bev->ev_base, fd, in bufferevent_socket_connect()
427 bufferevent_setfd(bev, fd); in bufferevent_socket_connect()
463 BEV_LOCK(bev); in bufferevent_connect_getaddrinfo_cb()
513 BEV_LOCK(bev); in bufferevent_socket_connect_hostname()
519 bufferevent_incref_(bev); in bufferevent_socket_connect_hostname()
522 BEV_UNLOCK(bev); in bufferevent_socket_connect_hostname()
533 BEV_LOCK(bev); in bufferevent_socket_get_dns_error()
[all …]
H A Dbufferevent-internal.h156 struct bufferevent bev; member
458 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ argument
460 if (evutil_timerisset(&(bev)->timeout_read)) \
461 event_add(&(bev)->ev_read, &(bev)->timeout_read); \
465 #define BEV_RESET_GENERIC_WRITE_TIMEOUT(bev) \ argument
467 if (evutil_timerisset(&(bev)->timeout_write)) \
468 event_add(&(bev)->ev_write, &(bev)->timeout_write); \
470 #define BEV_DEL_GENERIC_READ_TIMEOUT(bev) \ argument
471 event_del(&(bev)->ev_read)
472 #define BEV_DEL_GENERIC_WRITE_TIMEOUT(bev) \ argument
[all …]
/freebsd/contrib/libevent/
H A Dbufferevent_async.c131 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); in upcast()
165 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_write() local
176 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_read() local
187 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_write() local
198 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_read() local
211 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_writing() local
257 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_reading() local
437 struct bufferevent *bev = &bev_a->bev.bev; in connect_complete() local
465 struct bufferevent *bev = &bev_a->bev.bev; in read_complete() local
504 struct bufferevent *bev = &bev_a->bev.bev; in write_complete() local
[all …]
H A Dbufferevent_ratelim.c238 bufferevent_suspend_write_(&bev->bev, in bufferevent_get_rlim_max_()
241 bufferevent_suspend_read_(&bev->bev, in bufferevent_get_rlim_max_()
365 bufferevent_suspend_read_(&bev->bev, in bev_group_suspend_reading_()
383 bufferevent_suspend_write_(&bev->bev, in bev_group_suspend_writing_()
400 BEV_LOCK(&bev->bev); in bev_refill_callback_()
402 BEV_UNLOCK(&bev->bev); in bev_refill_callback_()
438 BEV_UNLOCK(&bev->bev); in bev_refill_callback_()
477 for (bev = first; bev != LIST_END(&g->members); \
481 for (bev = LIST_FIRST(&g->members); bev && bev != first; \
496 bufferevent_unsuspend_read_(&bev->bev, in bev_group_unsuspend_reading_()
[all …]
H A Dbufferevent_openssl.c390 struct bufferevent *bev = &bev_ssl->bev.bev; in start_reading() local
413 struct bufferevent *bev = &bev_ssl->bev.bev; in start_writing() local
431 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_reading() local
445 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_writing() local
471 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_rbow() local
485 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_wbor() local
586 struct bufferevent *bev = &bev_ssl->bev.bev; in do_read() local
657 struct bufferevent *bev = &bev_ssl->bev.bev; in do_write() local
741 struct evbuffer *input = bev->bev.bev.input; in bytes_to_read()
752 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
[all …]
H A Dbufferevent_filter.c105 evutil_offsetof(struct bufferevent_filtered, bev.bev),
124 evutil_offsetof(struct bufferevent_filtered, bev.bev)); in upcast()
125 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev)); in upcast()
129 #define downcast(bev_f) (&(bev_f)->bev.bev)
490 BEV_LOCK(bev); in bufferevent_filtered_inbuf_cb()
509 BEV_UNLOCK(bev); in bufferevent_filtered_inbuf_cb()
519 BEV_LOCK(bev); in be_filter_readcb()
523 BEV_UNLOCK(bev); in be_filter_readcb()
536 BEV_LOCK(bev); in be_filter_writecb()
546 BEV_UNLOCK(bev); in be_filter_writecb()
[all …]
H A Dbufferevent_pair.c59 if (!BEV_IS_PAIR(bev)) in upcast()
61 bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev); in upcast()
62 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev)); in upcast()
66 #define downcast(bev_pair) (&(bev_pair)->bev.bev)
104 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
109 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev); in bufferevent_pair_elt_new()
317 incref_and_lock(bev); in be_pair_flush()
335 decref_and_unlock(bev); in be_pair_flush()
344 bev_p = upcast(bev); in bufferevent_pair_get_partner()
348 incref_and_lock(bev); in bufferevent_pair_get_partner()
[all …]
H A Dbufferevent.c127 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
870 BEV_LOCK(bev); in bufferevent_setfd()
872 res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d); in bufferevent_setfd()
885 BEV_LOCK(bev); in bufferevent_getfd()
887 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d); in bufferevent_getfd()
900 BEV_LOCK(bev); in bufferevent_get_options_()
912 BEV_LOCK(bev); in bufferevent_cancel_all_()
914 bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d); in bufferevent_cancel_all_()
963 event_assign(&bev->ev_read, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
977 r1 = event_add(&bev->ev_read, &bev->timeout_read); in bufferevent_generic_adj_timeouts_()
[all …]
H A Dbufferevent_sock.c363 bufev = &bufev_p->bev; in bufferevent_socket_new()
392 fd = bufferevent_getfd(bev); in bufferevent_socket_connect()
422 if (BEV_IS_ASYNC(bev)) { in bufferevent_socket_connect()
423 event_assign(&bev->ev_write, bev->ev_base, fd, in bufferevent_socket_connect()
427 bufferevent_setfd(bev, fd); in bufferevent_socket_connect()
463 BEV_LOCK(bev); in bufferevent_connect_getaddrinfo_cb()
513 BEV_LOCK(bev); in bufferevent_socket_connect_hostname()
519 bufferevent_incref_(bev); in bufferevent_socket_connect_hostname()
522 BEV_UNLOCK(bev); in bufferevent_socket_connect_hostname()
533 BEV_LOCK(bev); in bufferevent_socket_get_dns_error()
[all …]
H A Dbufferevent-internal.h156 struct bufferevent bev; member
458 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ argument
460 if (evutil_timerisset(&(bev)->timeout_read)) \
461 event_add(&(bev)->ev_read, &(bev)->timeout_read); \
465 #define BEV_RESET_GENERIC_WRITE_TIMEOUT(bev) \ argument
467 if (evutil_timerisset(&(bev)->timeout_write)) \
468 event_add(&(bev)->ev_write, &(bev)->timeout_write); \
470 #define BEV_DEL_GENERIC_READ_TIMEOUT(bev) \ argument
471 event_del(&(bev)->ev_read)
472 #define BEV_DEL_GENERIC_WRITE_TIMEOUT(bev) \ argument
[all …]
/freebsd/contrib/ntp/sntp/libevent/test/
H A Dregress_ssl.c315 bufferevent_free(bev); in free_on_cb()
399 bufferevent_free(bev); in eventcb()
409 bufferevent_free(bev); in eventcb()
419 bufferevent_free(bev); in eventcb()
582 struct bufferevent *bev; in acceptcb() local
594 tt_assert(bev); in acceptcb()
765 tt_assert(bev); in regress_bufferevent_openssl_connect()
876 ctx->bev = bev; in wm_acceptcb()
948 tt_assert(bev); in regress_bufferevent_openssl_wm()
957 tt_assert(bev); in regress_bufferevent_openssl_wm()
[all …]
H A Dtest-fdleak.c82 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb() argument
86 bufferevent_read(bev, &tmp, 1); in server_read_cb()
87 bufferevent_write(bev, &tmp, 1); in server_read_cb()
99 bufferevent_free(bev); in server_event_cb()
101 event_base_loopbreak(bufferevent_get_base(bev)); in server_event_cb()
115 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
178 bufferevent_read(bev, &tmp, 1); in client_read_cb()
183 bufferevent_free(bev); in client_read_cb()
197 bufferevent_write(bev, &tmp, 1); in client_event_cb()
203 bufferevent_enable(bev, EV_READ); in client_event_cb()
[all …]
H A Dregress_bufferevent.c394 evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); in wm_writecb()
622 bufferevent_free(bev); in sender_writecb()
649 tt_assert(bev); in listen_cb()
832 tt_assert(bev); in test_bufferevent_connect_fail_eventcb()
861 if (bev) in test_bufferevent_connect_fail_eventcb()
905 tt_assert(bev); in test_bufferevent_connect_fail()
928 if (bev) in test_bufferevent_connect_fail()
1184 tt_assert(bev); in test_bufferevent_trigger()
1198 if (bev) in test_bufferevent_trigger()
1209 tt_assert(bev); in test_bufferevent_socket_filter_inactive()
[all …]
/freebsd/contrib/libevent/test/
H A Dregress_ssl.c315 bufferevent_free(bev); in free_on_cb()
399 bufferevent_free(bev); in eventcb()
409 bufferevent_free(bev); in eventcb()
419 bufferevent_free(bev); in eventcb()
582 struct bufferevent *bev; in acceptcb() local
594 tt_assert(bev); in acceptcb()
765 tt_assert(bev); in regress_bufferevent_openssl_connect()
876 ctx->bev = bev; in wm_acceptcb()
948 tt_assert(bev); in regress_bufferevent_openssl_wm()
957 tt_assert(bev); in regress_bufferevent_openssl_wm()
[all …]
H A Dtest-fdleak.c82 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb() argument
86 bufferevent_read(bev, &tmp, 1); in server_read_cb()
87 bufferevent_write(bev, &tmp, 1); in server_read_cb()
99 bufferevent_free(bev); in server_event_cb()
101 event_base_loopbreak(bufferevent_get_base(bev)); in server_event_cb()
115 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
178 bufferevent_read(bev, &tmp, 1); in client_read_cb()
183 bufferevent_free(bev); in client_read_cb()
197 bufferevent_write(bev, &tmp, 1); in client_event_cb()
203 bufferevent_enable(bev, EV_READ); in client_event_cb()
[all …]
H A Dregress_bufferevent.c394 evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); in wm_writecb()
622 bufferevent_free(bev); in sender_writecb()
649 tt_assert(bev); in listen_cb()
832 tt_assert(bev); in test_bufferevent_connect_fail_eventcb()
861 if (bev) in test_bufferevent_connect_fail_eventcb()
905 tt_assert(bev); in test_bufferevent_connect_fail()
928 if (bev) in test_bufferevent_connect_fail()
1184 tt_assert(bev); in test_bufferevent_trigger()
1198 if (bev) in test_bufferevent_trigger()
1209 tt_assert(bev); in test_bufferevent_socket_filter_inactive()
[all …]
/freebsd/contrib/ntp/sntp/libevent/sample/
H A Dhello-world.c92 struct bufferevent *bev; in listener_cb() local
94 bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); in listener_cb()
95 if (!bev) { in listener_cb()
100 bufferevent_setcb(bev, NULL, conn_writecb, conn_eventcb, NULL); in listener_cb()
101 bufferevent_enable(bev, EV_WRITE); in listener_cb()
102 bufferevent_disable(bev, EV_READ); in listener_cb()
104 bufferevent_write(bev, MESSAGE, strlen(MESSAGE)); in listener_cb()
108 conn_writecb(struct bufferevent *bev, void *user_data) in conn_writecb() argument
110 struct evbuffer *output = bufferevent_get_output(bev); in conn_writecb()
113 bufferevent_free(bev); in conn_writecb()
[all …]
/freebsd/contrib/libevent/sample/
H A Dhello-world.c92 struct bufferevent *bev; in listener_cb() local
94 bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); in listener_cb()
95 if (!bev) { in listener_cb()
100 bufferevent_setcb(bev, NULL, conn_writecb, conn_eventcb, NULL); in listener_cb()
101 bufferevent_enable(bev, EV_WRITE); in listener_cb()
102 bufferevent_disable(bev, EV_READ); in listener_cb()
104 bufferevent_write(bev, MESSAGE, strlen(MESSAGE)); in listener_cb()
108 conn_writecb(struct bufferevent *bev, void *user_data) in conn_writecb() argument
110 struct evbuffer *output = bufferevent_get_output(bev); in conn_writecb()
113 bufferevent_free(bev); in conn_writecb()
[all …]
/freebsd/contrib/ntp/sntp/libevent/include/event2/
H A Dbufferevent.h135 typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
254 int bufferevent_socket_get_dns_error(struct bufferevent *bev);
274 struct event_base *bufferevent_get_base(struct bufferevent *bev);
808 int bufferevent_set_rate_limit(struct bufferevent *bev,
880 int bufferevent_add_to_rate_limit_group(struct bufferevent *bev,
909 ev_ssize_t bufferevent_get_max_single_read(struct bufferevent *bev);
913 ev_ssize_t bufferevent_get_max_single_write(struct bufferevent *bev);
927 ev_ssize_t bufferevent_get_read_limit(struct bufferevent *bev);
929 ev_ssize_t bufferevent_get_write_limit(struct bufferevent *bev);
933 ev_ssize_t bufferevent_get_max_to_read(struct bufferevent *bev);
[all …]

123