/external/libevent/sample/ |
H A D | hello-world.c | 93 struct bufferevent *bev; local 95 bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); 96 if (!bev) { 101 bufferevent_setcb(bev, NULL, conn_writecb, conn_eventcb, NULL); 102 bufferevent_enable(bev, EV_WRITE); 103 bufferevent_disable(bev, EV_READ); 105 bufferevent_write(bev, MESSAGE, strlen(MESSAGE)); 109 conn_writecb(struct bufferevent *bev, void *user_data) argument 111 struct evbuffer *output = bufferevent_get_output(bev); 114 bufferevent_free(bev); 119 conn_eventcb(struct bufferevent *bev, short events, void *user_data) argument [all...] |
H A D | https-client.c | 61 struct bufferevent *bev = (struct bufferevent *) ctx; local 68 while ((oslerr = bufferevent_get_openssl_error(bev))) { 203 struct bufferevent *bev; local 395 bev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE); 398 bev = bufferevent_openssl_socket_new(base, -1, ssl, 403 if (bev == NULL) { 408 bufferevent_openssl_set_allow_dirty_shutdown(bev, 1); 412 evcon = evhttp_connection_base_bufferevent_new(base, NULL, bev, 427 req = evhttp_request_new(http_request_done, bev);
|
H A D | le-proxy.c | 48 static void drained_writecb(struct bufferevent *bev, void *ctx); 49 static void eventcb(struct bufferevent *bev, short what, void *ctx); 52 readcb(struct bufferevent *bev, void *ctx) argument 57 src = bufferevent_get_input(bev); 71 eventcb, bev); 74 bufferevent_disable(bev, EV_READ); 79 drained_writecb(struct bufferevent *bev, void *ctx) argument 85 bufferevent_setcb(bev, readcb, NULL, eventcb, partner); 86 bufferevent_setwatermark(bev, EV_WRITE, 0, 0); 92 close_on_finished_writecb(struct bufferevent *bev, voi argument 102 eventcb(struct bufferevent *bev, short what, void *ctx) argument [all...] |
/external/libevent/test/ |
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 | 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 | regress_ssl.c | 235 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter) argument 237 tt_int_op(bufferevent_getfd(bev), !=, -1); 238 tt_int_op(bufferevent_setfd(bev, -1), ==, 0); 240 tt_int_op(bufferevent_getfd(bev), !=, -1); 242 tt_int_op(bufferevent_getfd(bev), ==, -1); 249 bufferevent_openssl_check_freed(struct bufferevent *bev) argument 251 tt_int_op(event_pending(&bev->ev_read, EVLIST_ALL, NULL), ==, 0); 252 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0); 259 respond_to_number(struct bufferevent *bev, void *ctx) argument 261 struct evbuffer *b = bufferevent_get_input(bev); 293 done_writing_cb(struct bufferevent *bev, void *ctx) argument 304 eventcb(struct bufferevent *bev, short what, void *ctx) argument 515 struct bufferevent *bev = arg; local 523 struct bufferevent *bev; local 670 struct bufferevent *bev; 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...] |
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 354 wm_readcb(struct bufferevent *bev, void *arg) argument 357 int len = (int)evbuffer_get_length(bev->input); 365 bufferevent_read_buffer(bev, evbu 377 wm_writecb(struct bufferevent *bev, void *arg) argument 387 wm_errorcb(struct bufferevent *bev, short what, void *arg) argument 604 sender_writecb(struct bufferevent *bev, void *ctx) argument 614 sender_errorcb(struct bufferevent *bev, short what, void *ctx) argument 632 struct bufferevent *bev; local 669 reader_eventcb(struct bufferevent *bev, short what, void *ctx) argument 698 reader_eventcb_simple(struct bufferevent *bev, short what, void *ctx) argument 706 reader_readcb(struct bufferevent *bev, void *ctx) argument 795 struct bufferevent *bev = NULL; local 830 want_fail_eventcb(struct bufferevent *bev, short what, void *ctx) argument 863 struct bufferevent *bev=NULL; local 917 bev_timeout_write_cb(struct bufferevent *bev, void *arg) argument 924 bev_timeout_event_cb(struct bufferevent *bev, short what, void *arg) argument 1056 trigger_eventcb(struct bufferevent *bev, short what, void *ctx) argument 1068 trigger_readcb_triggered(struct bufferevent *bev, void *ctx) argument 1076 trigger_readcb(struct bufferevent *bev, void *ctx) argument 1119 struct bufferevent *bev=NULL; local 1179 struct bufferevent *bev = NULL, *bevf = NULL; local 1194 pair_flush_eventcb(struct bufferevent *bev, short what, void *ctx) argument 1236 bufferevent_filter_data_stuck_readcb(struct bufferevent *bev, void *arg) argument [all...] |
H A D | regress_dns.c | 1165 be_connect_hostname_event_cb(struct bufferevent *bev, short what, void *ctx) argument 1174 if ((r = bufferevent_socket_get_dns_error(bev))) {
|
H A D | regress_http.c | 243 http_readcb(struct bufferevent *bev, void *arg) argument 248 if (evbuffer_contains(bufferevent_get_input(bev), what)) { 253 done = evhttp_parse_firstline_(req, bufferevent_get_input(bev)); 257 done = evhttp_parse_headers_(req, bufferevent_get_input(bev)); 268 bufferevent_disable(bev, EV_READ); 281 http_writecb(struct bufferevent *bev, void *arg) argument 283 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { 285 bufferevent_enable(bev, EV_READ); 291 http_errorcb(struct bufferevent *bev, short what, void *arg) argument 420 struct bufferevent *bev local 431 struct bufferevent *bev = NULL; local 459 struct bufferevent *bev = NULL; local 586 http_badreq_errorcb(struct bufferevent *bev, short what, void *arg) argument 593 http_badreq_readcb(struct bufferevent *bev, void *arg) argument 643 struct bufferevent *bev = NULL; local 764 struct bufferevent *bev; local 848 struct bufferevent *bev; local 886 http_allowed_methods_eventcb(struct bufferevent *bev, short what, void *arg) argument 1040 struct bufferevent *bev = bufferevent_openssl_socket_new( local 1627 struct bufferevent *bev; local 2171 http_failure_readcb(struct bufferevent *bev, void *arg) argument 2188 struct bufferevent *bev; local 2954 struct bufferevent *bev; local 3002 http_incomplete_readcb(struct bufferevent *bev, void *arg) argument 3009 http_incomplete_errorcb(struct bufferevent *bev, short what, void *arg) argument 3023 http_incomplete_writecb(struct bufferevent *bev, void *arg) argument 3040 struct bufferevent *bev; local 3105 http_chunked_readcb(struct bufferevent *bev, void *arg) argument 3111 http_chunked_errorcb(struct bufferevent *bev, short what, void *arg) argument 3213 http_chunked_writecb(struct bufferevent *bev, void *arg) argument 3256 struct bufferevent *bev; local 3339 struct bufferevent *bev; local 3536 struct bufferevent *bev; local 3610 struct bufferevent *bev; local 3653 struct bufferevent *bev; local 3846 struct bufferevent *bev= NULL; local 4160 struct bufferevent *bev; member in struct:terminate_state 4241 terminate_readcb(struct bufferevent *bev, void *arg) argument 4252 struct bufferevent *bev = NULL; local 4431 struct bufferevent *bev = arg; local 4445 struct bufferevent *bev = NULL; local [all...] |
/external/libevent/ |
H A D | bufferevent_filter.c | 81 struct bufferevent_private bev; member in struct:bufferevent_filtered 105 evutil_offsetof(struct bufferevent_filtered, bev.bev), 115 /* Given a bufferevent that's really the bev filter of a bufferevent_filtered, 118 upcast(struct bufferevent *bev) argument 121 if (bev->be_ops != &bufferevent_ops_filter) 123 bev_f = (void*)( ((char*)bev) - 124 evutil_offsetof(struct bufferevent_filtered, bev.bev)); 125 EVUTIL_ASSERT(bev_f->bev 229 be_filter_unlink(struct bufferevent *bev) argument 258 be_filter_destruct(struct bufferevent *bev) argument 273 be_filter_enable(struct bufferevent *bev, short event) argument 288 be_filter_disable(struct bufferevent *bev, short event) argument 307 struct bufferevent *bev = downcast(bevf); local 425 struct bufferevent *bev = downcast(bevf); local 488 struct bufferevent *bev = downcast(bevf); local 517 struct bufferevent *bev = downcast(bevf); local 532 struct bufferevent *bev = downcast(bevf); local 554 struct bufferevent *bev = downcast(bevf); local 598 be_filter_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, union bufferevent_ctrl_data *data) 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 340 bufferevent_pair_get_partner(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_sock.c | 89 evutil_offsetof(struct bufferevent_private, bev), 100 bufferevent_socket_get_conn_address_(struct bufferevent *bev) argument 103 EVUTIL_UPCAST(bev, struct bufferevent_private, bev); 131 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 150 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 232 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 362 bufev = &bufev_p->bev; 379 bufferevent_socket_connect(struct bufferevent *bev, argument 383 EVUTIL_UPCAST(bev, struc 465 struct bufferevent *bev = arg; local 500 bufferevent_socket_connect_hostname(struct bufferevent *bev, struct evdns_base *evdns_base, int family, const char *hostname, int port) argument 535 bufferevent_socket_get_dns_error(struct bufferevent *bev) argument 621 be_socket_flush(struct bufferevent *bev, short iotype, enum bufferevent_flush_mode mode) argument 704 be_socket_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, union bufferevent_ctrl_data *data) argument [all...] |
H A D | bufferevent-internal.h | 156 struct bufferevent bev; member in struct:bufferevent_private 262 struct bufferevent bev; 264 then mem_offset should be offsetof(struct bufferevent_x, bev) 411 void bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev); 416 int bufferevent_generic_adj_timeouts_(struct bufferevent *bev); 417 int bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev); 419 enum bufferevent_options bufferevent_get_options_(struct bufferevent *bev); 422 bufferevent_socket_get_conn_address_(struct bufferevent *bev); 426 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ 428 if (evutil_timerisset(&(bev) [all...] |
H A D | bufferevent.c | 63 static void bufferevent_cancel_all_(struct bufferevent *bev); 70 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 82 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 94 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 106 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 137 struct bufferevent *bufev = &bufev_private->bev; 170 struct bufferevent *bufev = &bufev_private->bev; 214 (bevp)->bev.ev_base, \ 216 bufferevent_incref_(&(bevp)->bev); \ 225 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 846 bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd) argument 859 bufferevent_getfd(struct bufferevent *bev) argument 872 bufferevent_get_options_(struct bufferevent *bev) argument 886 bufferevent_cancel_all_(struct bufferevent *bev) argument 907 bufferevent_get_underlying(struct bufferevent *bev) argument 922 struct bufferevent *bev = ctx; local 931 struct bufferevent *bev = ctx; local 939 bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev) argument 948 bufferevent_generic_adj_timeouts_(struct bufferevent *bev) argument 972 bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev) argument 1006 bufferevent_lock(struct bufferevent *bev) argument 1012 bufferevent_unlock(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_openssl.c | 291 struct bufferevent_private bev; member in struct:bufferevent_openssl 341 evutil_offsetof(struct bufferevent_openssl, bev.bev), 354 upcast(struct bufferevent *bev) argument 357 if (bev->be_ops != &bufferevent_ops_openssl) 359 bev_o = (void*)( ((char*)bev) - 360 evutil_offsetof(struct bufferevent_openssl, bev.bev)); 361 EVUTIL_ASSERT(bev_o->bev.bev 389 struct bufferevent *bev = &bev_ssl->bev.bev; local 412 struct bufferevent *bev = &bev_ssl->bev.bev; local 430 struct bufferevent *bev = &bev_ssl->bev.bev; local 444 struct bufferevent *bev = &bev_ssl->bev.bev; local 470 struct bufferevent *bev = &bev_ssl->bev.bev; local 484 struct bufferevent *bev = &bev_ssl->bev.bev; local 582 struct bufferevent *bev = &bev_ssl->bev.bev; local 653 struct bufferevent *bev = &bev_ssl->bev.bev; local 735 bytes_to_read(struct bufferevent_openssl *bev) argument 836 struct bufferevent *bev = &bev_ssl->bev.bev; local 861 struct bufferevent *bev = &bev_ssl->bev.bev; local 970 struct bufferevent *bev = &bev_ssl->bev.bev; local 987 struct bufferevent *bev = &bev_ssl->bev.bev; local 1096 struct bufferevent *bev = &bev_ssl->bev.bev; local 1116 bufferevent_ssl_renegotiate(struct bufferevent *bev) argument 1153 be_openssl_enable(struct bufferevent *bev, short events) argument 1178 be_openssl_disable(struct bufferevent *bev, short events) argument 1197 be_openssl_unlink(struct bufferevent *bev) argument 1225 be_openssl_destruct(struct bufferevent *bev) argument 1243 be_openssl_adj_timeouts(struct bufferevent *bev) argument 1291 be_openssl_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, union bufferevent_ctrl_data *data) argument 1465 bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev) argument 1478 bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev, int allow_dirty_shutdown) argument 1490 bufferevent_get_openssl_error(struct bufferevent *bev) argument [all...] |
H A D | buffer.c | 447 evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev) argument 450 buf->parent = bev;
|
H A D | http.c | 2338 evhttp_connection_base_bufferevent_new(struct event_base *base, struct evdns_base *dnsbase, struct bufferevent* bev, argument 2364 if (bev == NULL) { 2365 if (!(bev = bufferevent_socket_new(base, -1, 0))) { 2371 bufferevent_setcb(bev, evhttp_read_cb, evhttp_write_cb, evhttp_error_cb, evcon); 2372 evcon->bufev = bev; 2382 if (bufferevent_get_base(bev) != base) 2388 bufferevent_get_priority(bev), 4170 struct bufferevent* bev = NULL; local 4184 bev = (*http->bevcb)(http->base, http->bevcbarg); 4187 http->base, NULL, bev, hostnam [all...] |