/external/libevent/sample/ |
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) 111 struct evbuffer *output = bufferevent_get_output(bev); 114 bufferevent_free(bev); [all...] |
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);
|
/external/libevent/test/ |
test-fdleak.c | 82 server_read_cb(struct bufferevent *bev, void *ctx) 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) 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, void *ctx 207 struct bufferevent *bev = bufferevent_socket_new(base, -1, local [all...] |
regress_ssl.c | 235 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter) 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) 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) 261 struct evbuffer *b = bufferevent_get_input(bev); 515 struct bufferevent *bev = arg; local 523 struct bufferevent *bev; local 670 struct bufferevent *bev; local [all...] |
test-ratelim.c | 112 loud_writecb(struct bufferevent *bev, void *ctx) 115 struct evbuffer *output = bufferevent_get_output(bev); 126 discard_readcb(struct bufferevent *bev, void *ctx) 129 struct evbuffer *input = bufferevent_get_input(bev); 136 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) 139 loud_writecb(bev, ctx); 141 bufferevent_enable(bev, EV_READ|EV_WRITE); 146 echo_readcb(struct bufferevent *bev, void *ctx) 148 struct evbuffer *input = bufferevent_get_input(bev); 149 struct evbuffer *output = bufferevent_get_output(bev); 179 struct bufferevent *bev; local 201 struct bufferevent *bev = arg; local [all...] |
regress_bufferevent.c | 92 readcb(struct bufferevent *bev, void *arg) 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) 114 if (evbuffer_get_length(bev->output) == 0) { 120 errorcb(struct bufferevent *bev, short what, void *arg) 354 wm_readcb(struct bufferevent *bev, void *arg) 357 int len = (int)evbuffer_get_length(bev->input); 365 bufferevent_read_buffer(bev, evbuf) 632 struct bufferevent *bev; local 795 struct bufferevent *bev = NULL; local 863 struct bufferevent *bev=NULL; local 1119 struct bufferevent *bev=NULL; local 1179 struct bufferevent *bev = NULL, *bevf = NULL; local [all...] |
regress_http.c | 243 http_readcb(struct bufferevent *bev, void *arg) 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) 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) 420 struct bufferevent *bev = arg local 431 struct bufferevent *bev = NULL; local 459 struct bufferevent *bev = NULL; local 643 struct bufferevent *bev = NULL; local 764 struct bufferevent *bev; local 848 struct bufferevent *bev; local 1040 struct bufferevent *bev = bufferevent_openssl_socket_new( local 1627 struct bufferevent *bev; local 2188 struct bufferevent *bev; local 2954 struct bufferevent *bev; local 3040 struct bufferevent *bev; local 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 4252 struct bufferevent *bev = NULL; local 4431 struct bufferevent *bev = arg; local 4445 struct bufferevent *bev = NULL; local [all...] |
/external/libevent/ |
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) 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.bev [all...] |
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) 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 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 [all...] |
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) 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.bev.be_ops == &bufferevent_ops_filter) 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 [all...] |
bufferevent_sock.c | 89 evutil_offsetof(struct bufferevent_private, bev), 100 bufferevent_socket_get_conn_address_(struct bufferevent *bev) 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, 383 EVUTIL_UPCAST(bev, struct bufferevent_private, bev) 465 struct bufferevent *bev = arg; local [all...] |
bufferevent_ratelim.c | 114 bufferevent_update_buckets(struct bufferevent_private *bev) 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) 200 /* needs lock on bev. * 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 [all...] |
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)->timeout_read)) [all...] |
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); 922 struct bufferevent *bev = ctx; local 931 struct bufferevent *bev = ctx; local [all...] |
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) 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.be_ops == &bufferevent_ops_openssl) 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 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 [all...] |
http.c | 4170 struct bufferevent* bev = NULL; local [all...] |