| /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...] |
