Searched refs:bev (Results 1 - 24 of 24) sorted by last modified time

/freebsd-11-stable/contrib/ntp/sntp/libevent/test/
H A Dregress_ssl.c200 respond_to_number(struct bufferevent *bev, void *ctx) argument
202 struct evbuffer *b = bufferevent_get_input(bev);
215 bufferevent_free(bev); /* Should trigger close on other side. */
219 SSL_renegotiate(bufferevent_openssl_get_ssl(bev));
222 evbuffer_add_printf(bufferevent_get_output(bev),
225 bufferevent_enable(bev, EV_WRITE);
226 bufferevent_disable(bev, EV_READ);
230 done_writing_cb(struct bufferevent *bev, void *ctx) argument
232 struct evbuffer *b = bufferevent_get_output(bev);
236 bufferevent_disable(bev, EV_WRIT
241 eventcb(struct bufferevent *bev, short what, void *ctx) argument
394 struct bufferevent *bev; local
424 struct bufferevent *bev; local
[all...]
H A Dregress_bufferevent.c92 readcb(struct bufferevent *bev, void *arg) argument
94 if (evbuffer_get_length(bev->input) == 8333) {
99 bufferevent_read_buffer(bev, evbuf);
101 bufferevent_disable(bev, EV_READ);
112 writecb(struct bufferevent *bev, void *arg) argument
114 if (evbuffer_get_length(bev->output) == 0) {
120 errorcb(struct bufferevent *bev, short what, void *arg) argument
341 wm_readcb(struct bufferevent *bev, void *arg) argument
344 int len = (int)evbuffer_get_length(bev->input);
352 bufferevent_read_buffer(bev, evbu
364 wm_writecb(struct bufferevent *bev, void *arg) argument
374 wm_errorcb(struct bufferevent *bev, short what, void *arg) argument
577 sender_writecb(struct bufferevent *bev, void *ctx) argument
587 sender_errorcb(struct bufferevent *bev, short what, void *ctx) argument
604 struct bufferevent *bev; local
616 reader_eventcb(struct bufferevent *bev, short what, void *ctx) argument
645 reader_readcb(struct bufferevent *bev, void *ctx) argument
730 want_fail_eventcb(struct bufferevent *bev, short what, void *ctx) argument
763 struct bufferevent *bev=NULL; local
828 bev_timeout_write_cb(struct bufferevent *bev, void *arg) argument
835 bev_timeout_event_cb(struct bufferevent *bev, short what, void *arg) argument
967 trigger_eventcb(struct bufferevent *bev, short what, void *ctx) argument
979 trigger_readcb_triggered(struct bufferevent *bev, void *ctx) argument
987 trigger_readcb(struct bufferevent *bev, void *ctx) argument
1030 struct bufferevent *bev=NULL; local
[all...]
H A Dregress_dns.c1127 be_connect_hostname_event_cb(struct bufferevent *bev, short what, void *ctx) argument
1136 if ((r = bufferevent_socket_get_dns_error(bev))) {
H A Dregress_http.c229 http_readcb(struct bufferevent *bev, void *arg) argument
234 if (evbuffer_contains(bufferevent_get_input(bev), what)) {
239 done = evhttp_parse_firstline_(req, bufferevent_get_input(bev));
243 done = evhttp_parse_headers_(req, bufferevent_get_input(bev));
254 bufferevent_disable(bev, EV_READ);
267 http_writecb(struct bufferevent *bev, void *arg) argument
269 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {
271 bufferevent_enable(bev, EV_READ);
277 http_errorcb(struct bufferevent *bev, short what, void *arg) argument
394 struct bufferevent *bev local
406 struct bufferevent *bev = NULL; local
530 http_badreq_errorcb(struct bufferevent *bev, short what, void *arg) argument
545 http_badreq_readcb(struct bufferevent *bev, void *arg) argument
595 struct bufferevent *bev = NULL; local
717 struct bufferevent *bev; local
801 struct bufferevent *bev; local
839 http_allowed_methods_eventcb(struct bufferevent *bev, short what, void *arg) argument
1379 struct bufferevent *bev; local
1917 http_failure_readcb(struct bufferevent *bev, void *arg) argument
1934 struct bufferevent *bev; local
2701 struct bufferevent *bev; local
2748 http_incomplete_readcb(struct bufferevent *bev, void *arg) argument
2755 http_incomplete_errorcb(struct bufferevent *bev, short what, void *arg) argument
2765 http_incomplete_writecb(struct bufferevent *bev, void *arg) argument
2782 struct bufferevent *bev; local
2853 http_chunked_readcb(struct bufferevent *bev, void *arg) argument
2859 http_chunked_errorcb(struct bufferevent *bev, short what, void *arg) argument
2957 http_chunked_writecb(struct bufferevent *bev, void *arg) argument
3000 struct bufferevent *bev; local
3490 struct bufferevent *bev= NULL; local
3692 struct bufferevent *bev; member in struct:terminate_state
3759 terminate_readcb(struct bufferevent *bev, void *arg) argument
3770 struct bufferevent *bev = NULL; local
[all...]
H A Dregress_iocp.c297 async_readcb(struct bufferevent *bev, void *arg) argument
300 bufferevent_disable(bev, EV_READ);
H A Dregress_zlib.c243 readcb(struct bufferevent *bev, void *arg) argument
245 if (evbuffer_get_length(bufferevent_get_input(bev)) == 8333) {
250 bufferevent_read_buffer(bev, evbuf);
252 bufferevent_disable(bev, EV_READ);
263 writecb(struct bufferevent *bev, void *arg) argument
265 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {
271 errorcb(struct bufferevent *bev, short what, void *arg) argument
H A Dtest-fdleak.c82 server_read_cb(struct bufferevent *bev, void *ctx) argument
84 while (evbuffer_get_length(bufferevent_get_input(bev))) {
86 bufferevent_read(bev, &tmp, 1);
87 bufferevent_write(bev, &tmp, 1);
93 server_event_cb(struct bufferevent *bev, short events, void *ctx) argument
99 bufferevent_free(bev);
109 struct bufferevent *bev = bufferevent_socket_new(base, sock, local
112 bufferevent_setcb(bev, server_read_cb, NULL, server_event_cb, NULL);
113 bufferevent_enable(bev, EV_READ|EV_WRITE);
168 client_read_cb(struct bufferevent *bev, voi argument
190 client_event_cb(struct bufferevent *bev, short events, void *ctx) argument
207 struct bufferevent *bev = bufferevent_socket_new(base, -1, local
[all...]
H A Dtest-ratelim.c112 loud_writecb(struct bufferevent *bev, void *ctx) argument
115 struct evbuffer *output = bufferevent_get_output(bev);
126 discard_readcb(struct bufferevent *bev, void *ctx) argument
129 struct evbuffer *input = bufferevent_get_input(bev);
136 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) argument
139 loud_writecb(bev, ctx);
141 bufferevent_enable(bev, EV_READ|EV_WRITE);
146 echo_readcb(struct bufferevent *bev, void *ctx) argument
148 struct evbuffer *input = bufferevent_get_input(bev);
149 struct evbuffer *output = bufferevent_get_output(bev);
157 echo_writecb(struct bufferevent *bev, void *ctx) argument
165 echo_eventcb(struct bufferevent *bev, short what, void *ctx) argument
179 struct bufferevent *bev; local
201 struct bufferevent *bev = arg; local
[all...]
/freebsd-11-stable/contrib/ntp/sntp/libevent/
H A Dbuffer.c447 evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev) argument
450 buf->parent = bev;
H A Dbufferevent-internal.h145 struct bufferevent bev; member in struct:bufferevent_private
237 struct bufferevent bev;
239 then mem_offset should be offsetof(struct bufferevent_x, bev)
383 void bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev);
388 int bufferevent_generic_adj_timeouts_(struct bufferevent *bev);
390 enum bufferevent_options bufferevent_get_options_(struct bufferevent *bev);
394 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \
396 if (evutil_timerisset(&(bev)->timeout_read)) \
397 event_add(&(bev)->ev_read, &(bev)
[all...]
H A Dbufferevent.c64 static void bufferevent_cancel_all_(struct bufferevent *bev);
71 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
83 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
95 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
107 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
138 struct bufferevent *bufev = &bufev_private->bev;
171 struct bufferevent *bufev = &bufev_private->bev;
215 (bevp)->bev.ev_base, \
217 bufferevent_incref_(&(bevp)->bev); \
226 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
843 bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd) argument
856 bufferevent_getfd(struct bufferevent *bev) argument
869 bufferevent_get_options_(struct bufferevent *bev) argument
883 bufferevent_cancel_all_(struct bufferevent *bev) argument
904 bufferevent_get_underlying(struct bufferevent *bev) argument
919 struct bufferevent *bev = ctx; local
928 struct bufferevent *bev = ctx; local
936 bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev) argument
945 bufferevent_generic_adj_timeouts_(struct bufferevent *bev) argument
980 bufferevent_lock(struct bufferevent *bev) argument
986 bufferevent_unlock(struct bufferevent *bev) argument
[all...]
H A Dbufferevent_async.c80 struct bufferevent_private bev; member in struct:bufferevent_async
93 evutil_offsetof(struct bufferevent_async, bev.bev),
104 upcast(struct bufferevent *bev) argument
107 if (bev->be_ops != &bufferevent_ops_async)
109 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev);
118 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
143 struct bufferevent *bev = &beva->bev.bev; local
154 struct bufferevent *bev = &beva->bev.bev; local
165 struct bufferevent *bev = &beva->bev.bev; local
176 struct bufferevent *bev = &beva->bev.bev; local
189 struct bufferevent *bev = &beva->bev.bev; local
235 struct bufferevent *bev = &beva->bev.bev; local
289 struct bufferevent *bev = arg; local
308 struct bufferevent *bev = arg; local
351 be_async_disable(struct bufferevent *bev, short what) argument
371 be_async_destruct(struct bufferevent *bev) argument
394 bev_async_set_wsa_error(struct bufferevent *bev, struct event_overlapped *eo) argument
404 be_async_flush(struct bufferevent *bev, short what, enum bufferevent_flush_mode mode) argument
415 struct bufferevent *bev = &bev_a->bev.bev; local
444 struct bufferevent *bev = &bev_a->bev.bev; local
483 struct bufferevent *bev = &bev_a->bev.bev; local
526 struct bufferevent *bev; local
579 bufferevent_async_set_connected_(struct bufferevent *bev) argument
589 bufferevent_async_can_connect_(struct bufferevent *bev) argument
603 bufferevent_async_connect_(struct bufferevent *bev, evutil_socket_t fd, const struct sockaddr *sa, int socklen) argument
649 be_async_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, union bufferevent_ctrl_data *data) argument
[all...]
H A Dbufferevent_filter.c78 struct bufferevent_private bev; member in struct:bufferevent_filtered
100 evutil_offsetof(struct bufferevent_filtered, bev.bev),
110 /* Given a bufferevent that's really the bev filter of a bufferevent_filtered,
113 upcast(struct bufferevent *bev) argument
116 if (bev->be_ops != &bufferevent_ops_filter)
118 bev_f = (void*)( ((char*)bev) -
119 evutil_offsetof(struct bufferevent_filtered, bev.bev));
120 EVUTIL_ASSERT(bev_f->bev
219 be_filter_unlink(struct bufferevent *bev) argument
248 be_filter_destruct(struct bufferevent *bev) argument
257 be_filter_enable(struct bufferevent *bev, short event) argument
272 be_filter_disable(struct bufferevent *bev, short event) argument
291 struct bufferevent *bev = downcast(bevf); local
408 struct bufferevent *bev = downcast(bevf); local
464 struct bufferevent *bev = downcast(bevf); local
486 struct bufferevent *bev = downcast(bevf); local
530 be_filter_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, union bufferevent_ctrl_data *data) argument
[all...]
H A Dbufferevent_openssl.c293 struct bufferevent_private bev; member in struct:bufferevent_openssl
343 evutil_offsetof(struct bufferevent_openssl, bev.bev),
356 upcast(struct bufferevent *bev) argument
359 if (bev->be_ops != &bufferevent_ops_openssl)
361 bev_o = (void*)( ((char*)bev) -
362 evutil_offsetof(struct bufferevent_openssl, bev.bev));
363 EVUTIL_ASSERT(bev_o->bev.bev
391 struct bufferevent *bev = &bev_ssl->bev.bev; local
411 struct bufferevent *bev = &bev_ssl->bev.bev; local
429 struct bufferevent *bev = &bev_ssl->bev.bev; local
442 struct bufferevent *bev = &bev_ssl->bev.bev; local
468 struct bufferevent *bev = &bev_ssl->bev.bev; local
482 struct bufferevent *bev = &bev_ssl->bev.bev; local
578 struct bufferevent *bev = &bev_ssl->bev.bev; local
648 struct bufferevent *bev = &bev_ssl->bev.bev; local
729 bytes_to_read(struct bufferevent_openssl *bev) argument
830 struct bufferevent *bev = &bev_ssl->bev.bev; local
855 struct bufferevent *bev = &bev_ssl->bev.bev; local
969 struct bufferevent *bev = &bev_ssl->bev.bev; local
1075 struct bufferevent *bev = &bev_ssl->bev.bev; local
1099 bufferevent_ssl_renegotiate(struct bufferevent *bev) argument
1134 be_openssl_enable(struct bufferevent *bev, short events) argument
1162 be_openssl_disable(struct bufferevent *bev, short events) argument
1183 be_openssl_unlink(struct bufferevent *bev) argument
1211 be_openssl_destruct(struct bufferevent *bev) argument
1229 be_openssl_adj_timeouts(struct bufferevent *bev) argument
1265 be_openssl_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, union bufferevent_ctrl_data *data) argument
1468 bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev) argument
1481 bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev, int allow_dirty_shutdown) argument
1493 bufferevent_get_openssl_error(struct bufferevent *bev) argument
[all...]
H A Dbufferevent_pair.c46 struct bufferevent_private bev; member in struct:bufferevent_pair
53 /* Given a bufferevent that's really a bev part of a bufferevent_pair,
56 upcast(struct bufferevent *bev) argument
59 if (bev->be_ops != &bufferevent_ops_pair)
61 bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev);
62 EVUTIL_ASSERT(bev_p->bev.bev.be_ops == &bufferevent_ops_pair);
66 #define downcast(bev_pair) (&(bev_pair)->bev
253 be_pair_disable(struct bufferevent *bev, short events) argument
265 be_pair_unlink(struct bufferevent *bev) argument
278 be_pair_destruct(struct bufferevent *bev) argument
305 be_pair_flush(struct bufferevent *bev, short iotype, enum bufferevent_flush_mode mode) argument
333 bufferevent_pair_get_partner(struct bufferevent *bev) argument
[all...]
H A Dbufferevent_ratelim.c114 bufferevent_update_buckets(struct bufferevent_private *bev) argument
116 /* Must hold lock on bev. */
119 event_base_gettimeofday_cached(bev->bev.ev_base, &now);
120 tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg);
121 if (tick != bev->rate_limiting->limit.last_updated)
122 ev_token_bucket_update_(&bev->rate_limiting->limit,
123 bev->rate_limiting->cfg, tick);
198 bufferevent_get_rlim_max_(struct bufferevent_private *bev, int is_write) argument
200 /* needs lock on bev
261 bufferevent_get_read_max_(struct bufferevent_private *bev) argument
267 bufferevent_get_write_max_(struct bufferevent_private *bev) argument
273 bufferevent_decrement_read_buckets_(struct bufferevent_private *bev, ev_ssize_t bytes) argument
311 bufferevent_decrement_write_buckets_(struct bufferevent_private *bev, ev_ssize_t bytes) argument
353 struct bufferevent_private *bev; local
378 struct bufferevent_private *bev; local
398 struct bufferevent_private *bev = arg; local
449 struct bufferevent_private *bev; local
491 struct bufferevent_private *bev, *first; local
510 struct bufferevent_private *bev, *first; local
560 bufferevent_set_rate_limit(struct bufferevent *bev, struct ev_token_bucket_cfg *cfg) argument
736 bufferevent_add_to_rate_limit_group(struct bufferevent *bev, struct bufferevent_rate_limit_group *g) argument
783 bufferevent_remove_from_rate_limit_group(struct bufferevent *bev) argument
789 bufferevent_remove_from_rate_limit_group_internal_(struct bufferevent *bev, int unsuspend) argument
822 bufferevent_get_read_limit(struct bufferevent *bev) argument
841 bufferevent_get_write_limit(struct bufferevent *bev) argument
858 bufferevent_set_max_single_read(struct bufferevent *bev, size_t size) argument
872 bufferevent_set_max_single_write(struct bufferevent *bev, size_t size) argument
886 bufferevent_get_max_single_read(struct bufferevent *bev) argument
897 bufferevent_get_max_single_write(struct bufferevent *bev) argument
908 bufferevent_get_max_to_read(struct bufferevent *bev) argument
918 bufferevent_get_max_to_write(struct bufferevent *bev) argument
928 bufferevent_get_token_bucket_cfg(const struct bufferevent *bev) argument
972 bufferevent_decrement_read_limit(struct bufferevent *bev, ev_ssize_t decr) argument
999 bufferevent_decrement_write_limit(struct bufferevent *bev, ev_ssize_t decr) argument
1085 bufferevent_ratelim_init_(struct bufferevent_private *bev) argument
[all...]
H A Dbufferevent_sock.c90 evutil_offsetof(struct bufferevent_private, bev),
110 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
129 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
207 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
336 bufev = &bufev_p->bev;
353 bufferevent_socket_connect(struct bufferevent *bev, argument
357 EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
364 bufferevent_incref_and_lock_(bev);
369 fd = bufferevent_getfd(bev);
440 struct bufferevent *bev = arg; local
467 bufferevent_socket_connect_hostname(struct bufferevent *bev, struct evdns_base *evdns_base, int family, const char *hostname, int port) argument
510 bufferevent_socket_get_dns_error(struct bufferevent *bev) argument
619 be_socket_flush(struct bufferevent *bev, short iotype, enum bufferevent_flush_mode mode) argument
694 be_socket_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, union bufferevent_ctrl_data *data) argument
[all...]
H A Devbuffer-internal.h337 /** Set the parent bufferevent object for buf to bev */
338 void evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev);
H A Dhttp.c2250 evhttp_connection_base_bufferevent_new(struct event_base *base, struct evdns_base *dnsbase, struct bufferevent* bev, argument
2276 if (bev == NULL) {
2277 if (!(bev = bufferevent_socket_new(base, -1, 0))) {
2283 bufferevent_setcb(bev, evhttp_read_cb, evhttp_write_cb, evhttp_error_cb, evcon);
2284 evcon->bufev = bev;
2294 if (bufferevent_get_base(bev) != base)
2300 bufferevent_get_priority(bev),
4007 struct bufferevent* bev = NULL; local
4021 bev = (*http->bevcb)(http->base, http->bevcbarg);
4024 http->base, NULL, bev, hostnam
[all...]
H A Diocp-internal.h192 void bufferevent_async_set_connected_(struct bufferevent *bev);
193 int bufferevent_async_can_connect_(struct bufferevent *bev);
194 int bufferevent_async_connect_(struct bufferevent *bev, evutil_socket_t fd,
H A Dratelim-internal.h87 int bufferevent_remove_from_rate_limit_group_internal_(struct bufferevent *bev,
/freebsd-11-stable/contrib/ntp/sntp/libevent/include/event2/
H A Dbufferevent.h132 @param bev the bufferevent that triggered the callback
135 typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
146 @param bev the bufferevent for which the error condition was reached
154 typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx);
249 @param bev The bufferevent object.
254 int bufferevent_socket_get_dns_error(struct bufferevent *bev);
274 struct event_base *bufferevent_get_base(struct bufferevent *bev);
720 struct bufferevent *bufferevent_pair_get_partner(struct bufferevent *bev);
768 Set the rate-limit of a the bufferevent 'bev' to the one specified in
770 'bev'
[all...]
H A Dbufferevent_ssl.h110 int bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev);
112 void bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev,
122 int bufferevent_ssl_renegotiate(struct bufferevent *bev);
126 unsigned long bufferevent_get_openssl_error(struct bufferevent *bev);
H A Dhttp.h501 * @param bev a bufferevent to use for connecting to the server; if NULL, a
510 struct event_base *base, struct evdns_base *dnsbase, struct bufferevent* bev, const char *address, unsigned short port);

Completed in 129 milliseconds