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.c81 struct bufferevent_private bev; member
94 evutil_offsetof(struct bufferevent_async, bev.bev),
105 be_async_run_eventcb(struct bufferevent *bev, short what, int options) in be_async_run_eventcb() argument
106 { bufferevent_run_eventcb_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); } in be_async_run_eventcb()
109 be_async_trigger_nolock(struct bufferevent *bev, short what, int options) in be_async_trigger_nolock() argument
110 { bufferevent_trigger_nolock_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); } in be_async_trigger_nolock()
126 upcast(struct bufferevent *bev) in upcast() argument
129 if (!BEV_IS_ASYNC(bev)) in upcast()
131 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); in upcast()
140 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_connect()
[all …]
H A Dbufferevent_ratelim.c114 bufferevent_update_buckets(struct bufferevent_private *bev) in bufferevent_update_buckets() argument
119 event_base_gettimeofday_cached(bev->bev.ev_base, &now); in bufferevent_update_buckets()
120 tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg); in bufferevent_update_buckets()
121 if (tick != bev->rate_limiting->limit.last_updated) in bufferevent_update_buckets()
122 ev_token_bucket_update_(&bev->rate_limiting->limit, in bufferevent_update_buckets()
123 bev->rate_limiting->cfg, tick); in bufferevent_update_buckets()
198 bufferevent_get_rlim_max_(struct bufferevent_private *bev, int is_write) in bufferevent_get_rlim_max_() argument
201 ev_ssize_t max_so_far = is_write?bev->max_single_write:bev->max_single_read; in bufferevent_get_rlim_max_()
216 if (!bev->rate_limiting) in bufferevent_get_rlim_max_()
224 if (bev->rate_limiting->cfg) { in bufferevent_get_rlim_max_()
[all …]
H A Dbufferevent_openssl.c292 struct bufferevent_private bev; member
342 evutil_offsetof(struct bufferevent_openssl, bev.bev),
355 upcast(struct bufferevent *bev) in upcast() argument
358 if (!BEV_IS_OPENSSL(bev)) in upcast()
360 bev_o = (void*)( ((char*)bev) - in upcast()
361 evutil_offsetof(struct bufferevent_openssl, bev.bev)); in upcast()
362 EVUTIL_ASSERT(BEV_IS_OPENSSL(&bev_o->bev.bev)); in upcast()
390 struct bufferevent *bev = &bev_ssl->bev.bev; in start_reading() local
392 r = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read); in start_reading()
394 r = bufferevent_add_event_(&bev->ev_write, in start_reading()
[all …]
H A Dbufferevent_filter.c81 struct bufferevent_private bev; member
105 evutil_offsetof(struct bufferevent_filtered, bev.bev),
118 upcast(struct bufferevent *bev) in upcast() argument
121 if (!BEV_IS_FILTER(bev)) in upcast()
123 bev_f = (void*)( ((char*)bev) - in upcast()
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)
192 if (bufferevent_init_common_(&bufev_f->bev, underlying->ev_base, in bufferevent_filter_new()
229 be_filter_unlink(struct bufferevent *bev) in be_filter_unlink() argument
[all …]
H A Dbufferevent_pair.c46 struct bufferevent_private bev; member
56 upcast(struct bufferevent *bev) in upcast() argument
59 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)
99 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair, in bufferevent_pair_elt_new()
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()
135 bufferevent_enable_locking_(downcast(bufev2), bufev1->bev.lock); in bufferevent_pair_new()
[all …]
H A Dbufferevent.c63 static void bufferevent_cancel_all_(struct bufferevent *bev);
121 static void bufferevent_inbuf_wm_check(struct bufferevent *bev) in bufferevent_inbuf_wm_check() argument
123 if (!bev->wm_read.high) in bufferevent_inbuf_wm_check()
125 if (!(bev->enabled & EV_READ)) in bufferevent_inbuf_wm_check()
127 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
130 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS); in bufferevent_inbuf_wm_check()
155 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_locked()
189 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_unlocked()
234 (bevp)->bev.ev_base, \
236 bufferevent_incref_(&(bevp)->bev); \
[all …]
H A Dbufferevent_sock.c89 evutil_offsetof(struct bufferevent_private, bev),
100 bufferevent_socket_get_conn_address_(struct bufferevent *bev) in bufferevent_socket_get_conn_address_() argument
102 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_get_conn_address_()
107 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, in bufferevent_socket_set_conn_address_fd_() argument
110 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_set_conn_address_fd_()
120 bufferevent_socket_set_conn_address_(struct bufferevent *bev, in bufferevent_socket_set_conn_address_() argument
123 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_set_conn_address_()
363 bufev = &bufev_p->bev; in bufferevent_socket_new()
380 bufferevent_socket_connect(struct bufferevent *bev, in bufferevent_socket_connect() argument
383 struct bufferevent_private *bufev_p = BEV_UPCAST(bev); in bufferevent_socket_connect()
[all …]
H A Dbufferevent-internal.h156 struct bufferevent bev; member
430 void bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev);
436 int bufferevent_generic_adj_timeouts_(struct bufferevent *bev);
438 int bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev);
441 enum bufferevent_options bufferevent_get_options_(struct bufferevent *bev);
445 bufferevent_socket_get_conn_address_(struct bufferevent *bev);
449 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, evutil_socket_t fd);
453 bufferevent_socket_set_conn_address_(struct bufferevent *bev, struct sockaddr *addr, size_t addrlen…
458 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ argument
460 if (evutil_timerisset(&(bev)->timeout_read)) \
[all …]
/freebsd/contrib/libevent/
H A Dbufferevent_async.c81 struct bufferevent_private bev; member
94 evutil_offsetof(struct bufferevent_async, bev.bev),
105 be_async_run_eventcb(struct bufferevent *bev, short what, int options) in be_async_run_eventcb() argument
106 { bufferevent_run_eventcb_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); } in be_async_run_eventcb()
109 be_async_trigger_nolock(struct bufferevent *bev, short what, int options) in be_async_trigger_nolock() argument
110 { bufferevent_trigger_nolock_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); } in be_async_trigger_nolock()
126 upcast(struct bufferevent *bev) in upcast() argument
129 if (!BEV_IS_ASYNC(bev)) in upcast()
131 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); in upcast()
140 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_connect()
[all …]
H A Dbufferevent_ratelim.c114 bufferevent_update_buckets(struct bufferevent_private *bev) in bufferevent_update_buckets() argument
119 event_base_gettimeofday_cached(bev->bev.ev_base, &now); in bufferevent_update_buckets()
120 tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg); in bufferevent_update_buckets()
121 if (tick != bev->rate_limiting->limit.last_updated) in bufferevent_update_buckets()
122 ev_token_bucket_update_(&bev->rate_limiting->limit, in bufferevent_update_buckets()
123 bev->rate_limiting->cfg, tick); in bufferevent_update_buckets()
198 bufferevent_get_rlim_max_(struct bufferevent_private *bev, int is_write) in bufferevent_get_rlim_max_() argument
201 ev_ssize_t max_so_far = is_write?bev->max_single_write:bev->max_single_read; in bufferevent_get_rlim_max_()
216 if (!bev->rate_limiting) in bufferevent_get_rlim_max_()
224 if (bev->rate_limiting->cfg) { in bufferevent_get_rlim_max_()
[all …]
H A Dbufferevent_openssl.c292 struct bufferevent_private bev; member
342 evutil_offsetof(struct bufferevent_openssl, bev.bev),
355 upcast(struct bufferevent *bev) in upcast() argument
358 if (!BEV_IS_OPENSSL(bev)) in upcast()
360 bev_o = (void*)( ((char*)bev) - in upcast()
361 evutil_offsetof(struct bufferevent_openssl, bev.bev)); in upcast()
362 EVUTIL_ASSERT(BEV_IS_OPENSSL(&bev_o->bev.bev)); in upcast()
390 struct bufferevent *bev = &bev_ssl->bev.bev; in start_reading() local
392 r = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read); in start_reading()
394 r = bufferevent_add_event_(&bev->ev_write, in start_reading()
[all …]
H A Dbufferevent_filter.c81 struct bufferevent_private bev; member
105 evutil_offsetof(struct bufferevent_filtered, bev.bev),
118 upcast(struct bufferevent *bev) in upcast() argument
121 if (!BEV_IS_FILTER(bev)) in upcast()
123 bev_f = (void*)( ((char*)bev) - in upcast()
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)
192 if (bufferevent_init_common_(&bufev_f->bev, underlying->ev_base, in bufferevent_filter_new()
229 be_filter_unlink(struct bufferevent *bev) in be_filter_unlink() argument
[all …]
H A Dbufferevent_pair.c46 struct bufferevent_private bev; member
56 upcast(struct bufferevent *bev) in upcast() argument
59 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)
99 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair, in bufferevent_pair_elt_new()
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()
135 bufferevent_enable_locking_(downcast(bufev2), bufev1->bev.lock); in bufferevent_pair_new()
[all …]
H A Dbufferevent.c63 static void bufferevent_cancel_all_(struct bufferevent *bev);
121 static void bufferevent_inbuf_wm_check(struct bufferevent *bev) in bufferevent_inbuf_wm_check() argument
123 if (!bev->wm_read.high) in bufferevent_inbuf_wm_check()
125 if (!(bev->enabled & EV_READ)) in bufferevent_inbuf_wm_check()
127 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
130 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS); in bufferevent_inbuf_wm_check()
155 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_locked()
189 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_unlocked()
234 (bevp)->bev.ev_base, \
236 bufferevent_incref_(&(bevp)->bev); \
[all …]
H A Dbufferevent_sock.c89 evutil_offsetof(struct bufferevent_private, bev),
100 bufferevent_socket_get_conn_address_(struct bufferevent *bev) in bufferevent_socket_get_conn_address_() argument
102 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_get_conn_address_()
107 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, in bufferevent_socket_set_conn_address_fd_() argument
110 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_set_conn_address_fd_()
120 bufferevent_socket_set_conn_address_(struct bufferevent *bev, in bufferevent_socket_set_conn_address_() argument
123 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_set_conn_address_()
363 bufev = &bufev_p->bev; in bufferevent_socket_new()
380 bufferevent_socket_connect(struct bufferevent *bev, in bufferevent_socket_connect() argument
383 struct bufferevent_private *bufev_p = BEV_UPCAST(bev); in bufferevent_socket_connect()
[all …]
H A Dbufferevent-internal.h156 struct bufferevent bev; member
430 void bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev);
436 int bufferevent_generic_adj_timeouts_(struct bufferevent *bev);
438 int bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev);
441 enum bufferevent_options bufferevent_get_options_(struct bufferevent *bev);
445 bufferevent_socket_get_conn_address_(struct bufferevent *bev);
449 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, evutil_socket_t fd);
453 bufferevent_socket_set_conn_address_(struct bufferevent *bev, struct sockaddr *addr, size_t addrlen…
458 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ argument
460 if (evutil_timerisset(&(bev)->timeout_read)) \
[all …]
/freebsd/contrib/ntp/sntp/libevent/test/
H A Dregress_ssl.c288 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter) in bufferevent_openssl_check_fd() argument
290 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
291 tt_fd_op(bufferevent_setfd(bev, EVUTIL_INVALID_SOCKET), ==, 0); in bufferevent_openssl_check_fd()
293 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
295 tt_fd_op(bufferevent_getfd(bev), ==, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
302 bufferevent_openssl_check_freed(struct bufferevent *bev) in bufferevent_openssl_check_freed() argument
304 tt_int_op(event_pending(&bev->ev_read, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
305 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
312 free_on_cb(struct bufferevent *bev, void *ctx) in free_on_cb() argument
314 TT_BLATHER(("free_on_cb: %p", bev)); in free_on_cb()
[all …]
H A Dtest-fdleak.c82 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb() argument
84 while (evbuffer_get_length(bufferevent_get_input(bev))) { in server_read_cb()
86 bufferevent_read(bev, &tmp, 1); in server_read_cb()
87 bufferevent_write(bev, &tmp, 1); in server_read_cb()
93 server_event_cb(struct bufferevent *bev, short events, void *ctx) in server_event_cb() argument
99 bufferevent_free(bev); in server_event_cb()
101 event_base_loopbreak(bufferevent_get_base(bev)); in server_event_cb()
112 struct bufferevent *bev = bufferevent_socket_new(base, sock, in listener_accept_cb() local
114 bufferevent_setcb(bev, server_read_cb, NULL, server_event_cb, NULL); in listener_accept_cb()
115 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
[all …]
H A Dregress_bufferevent.c105 readcb(struct bufferevent *bev, void *arg) in readcb() argument
107 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
112 bufferevent_read_buffer(bev, evbuf); in readcb()
114 bufferevent_disable(bev, EV_READ); in readcb()
125 writecb(struct bufferevent *bev, void *arg) in writecb() argument
127 if (evbuffer_get_length(bev->output) == 0) { in writecb()
133 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb() argument
367 wm_readcb(struct bufferevent *bev, void *arg) in wm_readcb() argument
370 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
378 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
[all …]
/freebsd/contrib/libevent/test/
H A Dregress_ssl.c288 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter) in bufferevent_openssl_check_fd() argument
290 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
291 tt_fd_op(bufferevent_setfd(bev, EVUTIL_INVALID_SOCKET), ==, 0); in bufferevent_openssl_check_fd()
293 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
295 tt_fd_op(bufferevent_getfd(bev), ==, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
302 bufferevent_openssl_check_freed(struct bufferevent *bev) in bufferevent_openssl_check_freed() argument
304 tt_int_op(event_pending(&bev->ev_read, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
305 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
312 free_on_cb(struct bufferevent *bev, void *ctx) in free_on_cb() argument
314 TT_BLATHER(("free_on_cb: %p", bev)); in free_on_cb()
[all …]
H A Dtest-fdleak.c82 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb() argument
84 while (evbuffer_get_length(bufferevent_get_input(bev))) { in server_read_cb()
86 bufferevent_read(bev, &tmp, 1); in server_read_cb()
87 bufferevent_write(bev, &tmp, 1); in server_read_cb()
93 server_event_cb(struct bufferevent *bev, short events, void *ctx) in server_event_cb() argument
99 bufferevent_free(bev); in server_event_cb()
101 event_base_loopbreak(bufferevent_get_base(bev)); in server_event_cb()
112 struct bufferevent *bev = bufferevent_socket_new(base, sock, in listener_accept_cb() local
114 bufferevent_setcb(bev, server_read_cb, NULL, server_event_cb, NULL); in listener_accept_cb()
115 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
[all …]
H A Dregress_bufferevent.c105 readcb(struct bufferevent *bev, void *arg) in readcb() argument
107 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
112 bufferevent_read_buffer(bev, evbuf); in readcb()
114 bufferevent_disable(bev, EV_READ); in readcb()
125 writecb(struct bufferevent *bev, void *arg) in writecb() argument
127 if (evbuffer_get_length(bev->output) == 0) { in writecb()
133 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb() argument
367 wm_readcb(struct bufferevent *bev, void *arg) in wm_readcb() argument
370 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
378 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
[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);
154 typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx);
254 int bufferevent_socket_get_dns_error(struct bufferevent *bev);
274 struct event_base *bufferevent_get_base(struct bufferevent *bev);
749 struct bufferevent *bufferevent_pair_get_partner(struct bufferevent *bev);
808 int bufferevent_set_rate_limit(struct bufferevent *bev,
880 int bufferevent_add_to_rate_limit_group(struct bufferevent *bev,
885 int bufferevent_remove_from_rate_limit_group(struct bufferevent *bev);
895 int bufferevent_set_max_single_read(struct bufferevent *bev, size_t size);
905 int bufferevent_set_max_single_write(struct bufferevent *bev, size_t size);
[all …]

123