/freebsd-11-stable/contrib/ntp/sntp/libevent/test/ |
H A D | regress_ssl.c | 200 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 D | regress_bufferevent.c | 92 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 D | regress_dns.c | 1127 be_connect_hostname_event_cb(struct bufferevent *bev, short what, void *ctx) argument 1136 if ((r = bufferevent_socket_get_dns_error(bev))) {
|
H A D | regress_http.c | 229 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 D | regress_iocp.c | 297 async_readcb(struct bufferevent *bev, void *arg) argument 300 bufferevent_disable(bev, EV_READ);
|
H A D | regress_zlib.c | 243 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 D | test-fdleak.c | 82 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 D | test-ratelim.c | 112 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 D | buffer.c | 447 evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev) argument 450 buf->parent = bev;
|
H A D | bufferevent-internal.h | 145 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 D | bufferevent.c | 64 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 D | bufferevent_async.c | 80 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 D | bufferevent_filter.c | 78 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 D | bufferevent_openssl.c | 293 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 D | bufferevent_pair.c | 46 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 D | bufferevent_ratelim.c | 114 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 D | bufferevent_sock.c | 90 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 D | evbuffer-internal.h | 337 /** Set the parent bufferevent object for buf to bev */ 338 void evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev);
|
H A D | http.c | 2250 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 D | iocp-internal.h | 192 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 D | ratelim-internal.h | 87 int bufferevent_remove_from_rate_limit_group_internal_(struct bufferevent *bev,
|
/freebsd-11-stable/contrib/ntp/sntp/libevent/include/event2/ |
H A D | bufferevent.h | 132 @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 D | bufferevent_ssl.h | 110 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 D | http.h | 501 * @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);
|