Home
last modified time | relevance | path

Searched refs:bufferevent (Results 1 – 25 of 42) sorted by relevance

12

/external/libevent/include/event2/
Dbufferevent.h113 struct bufferevent struct
135 typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
154 typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx);
190 struct bufferevent *bufferevent_socket_new(struct event_base *base, evutil_socket_t fd, int options…
212 int bufferevent_socket_connect(struct bufferevent *, const struct sockaddr *, int);
242 int bufferevent_socket_connect_hostname(struct bufferevent *,
254 int bufferevent_socket_get_dns_error(struct bufferevent *bev);
268 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
274 struct event_base *bufferevent_get_base(struct bufferevent *bev);
286 int bufferevent_priority_set(struct bufferevent *bufev, int pri);
[all …]
Dbufferevent_ssl.h68 struct bufferevent *
70 struct bufferevent *underlying,
86 struct bufferevent *
110 int bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev);
112 void bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev,
118 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
122 int bufferevent_ssl_renegotiate(struct bufferevent *bev);
126 unsigned long bufferevent_get_openssl_error(struct bufferevent *bev);
Dbufferevent_compat.h75 struct bufferevent *bufferevent_new(evutil_socket_t fd,
86 void bufferevent_settimeout(struct bufferevent *bufev,
Dhttp.h41 struct bufferevent;
298 struct bufferevent *(*cb)(struct event_base *, void *), void *arg);
523 …struct event_base *base, struct evdns_base *dnsbase, struct bufferevent* bev, const char *address,…
529 struct bufferevent* evhttp_connection_get_bufferevent(struct evhttp_connection *evcon);
/external/libevent/
Dbufferevent-internal.h156 struct bufferevent bev;
272 int (*enable)(struct bufferevent *, short);
278 int (*disable)(struct bufferevent *, short);
282 void (*unlink)(struct bufferevent *);
288 void (*destruct)(struct bufferevent *);
291 int (*adj_timeouts)(struct bufferevent *);
294 int (*flush)(struct bufferevent *, short, enum bufferevent_flush_mode);
297 int (*ctrl)(struct bufferevent *, enum bufferevent_ctrl_op, union bufferevent_ctrl_data *);
321 void bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what);
324 void bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what);
[all …]
Dbufferevent.c63 static void bufferevent_cancel_all_(struct bufferevent *bev);
67 bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_suspend_read_()
79 bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_unsuspend_read_()
91 bufferevent_suspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_suspend_write_()
103 bufferevent_unsuspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_unsuspend_write_()
122 struct bufferevent *bufev = arg; in bufferevent_inbuf_wm_cb()
137 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_locked()
170 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_unlocked()
221 bufferevent_run_readcb_(struct bufferevent *bufev, int options) in bufferevent_run_readcb_()
237 bufferevent_run_writecb_(struct bufferevent *bufev, int options) in bufferevent_run_writecb_()
[all …]
Dbufferevent_filter.c62 static int be_filter_enable(struct bufferevent *, short);
63 static int be_filter_disable(struct bufferevent *, short);
64 static void be_filter_unlink(struct bufferevent *);
65 static void be_filter_destruct(struct bufferevent *);
67 static void be_filter_readcb(struct bufferevent *, void *);
68 static void be_filter_writecb(struct bufferevent *, void *);
69 static void be_filter_eventcb(struct bufferevent *, short, void *);
70 static int be_filter_flush(struct bufferevent *bufev,
72 static int be_filter_ctrl(struct bufferevent *, enum bufferevent_ctrl_op, union bufferevent_ctrl_da…
84 struct bufferevent *underlying;
[all …]
Dbufferevent_async.c73 static int be_async_enable(struct bufferevent *, short);
74 static int be_async_disable(struct bufferevent *, short);
75 static void be_async_destruct(struct bufferevent *);
76 static int be_async_flush(struct bufferevent *, short, enum bufferevent_flush_mode);
77 static int be_async_ctrl(struct bufferevent *, enum bufferevent_ctrl_op, union bufferevent_ctrl_dat…
104 upcast(struct bufferevent *bev) in upcast()
143 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_write()
154 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_read()
165 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_write()
176 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_read()
[all …]
Dbufferevent_openssl.c162 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_write()
194 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_ctrl()
254 BIO_new_bufferevent(struct bufferevent *bufferevent, int close_flag) in BIO_new_bufferevent() argument
257 if (!bufferevent) in BIO_new_bufferevent()
262 BIO_set_data(result, bufferevent); in BIO_new_bufferevent()
294 struct bufferevent *underlying;
330 static int be_openssl_enable(struct bufferevent *, short);
331 static int be_openssl_disable(struct bufferevent *, short);
332 static void be_openssl_unlink(struct bufferevent *);
333 static void be_openssl_destruct(struct bufferevent *);
[all …]
Dbufferevent_sock.c79 static int be_socket_enable(struct bufferevent *, short);
80 static int be_socket_disable(struct bufferevent *, short);
81 static void be_socket_destruct(struct bufferevent *);
82 static int be_socket_flush(struct bufferevent *, short, enum bufferevent_flush_mode);
83 static int be_socket_ctrl(struct bufferevent *, enum bufferevent_ctrl_op, union bufferevent_ctrl_da…
85 static void be_socket_setfd(struct bufferevent *, evutil_socket_t);
100 bufferevent_socket_get_conn_address_(struct bufferevent *bev) in bufferevent_socket_get_conn_address_()
129 struct bufferevent *bufev = arg; in bufferevent_socket_outbuf_cb()
148 struct bufferevent *bufev = arg; in bufferevent_readcb()
230 struct bufferevent *bufev = arg; in bufferevent_writecb()
[all …]
Dbufferevent_pair.c56 upcast(struct bufferevent *bev) in upcast()
69 incref_and_lock(struct bufferevent *b) in incref_and_lock()
79 decref_and_unlock(struct bufferevent *b) in decref_and_unlock()
116 struct bufferevent *pair[2]) in bufferevent_pair_new()
153 be_pair_transfer(struct bufferevent *src, struct bufferevent *dst, in be_pair_transfer()
225 be_pair_enable(struct bufferevent *bufev, short events) in be_pair_enable()
253 be_pair_disable(struct bufferevent *bev, short events) in be_pair_disable()
265 be_pair_unlink(struct bufferevent *bev) in be_pair_unlink()
278 be_pair_destruct(struct bufferevent *bev) in be_pair_destruct()
305 be_pair_flush(struct bufferevent *bev, short iotype, in be_pair_flush()
[all …]
Diocp-internal.h188 struct bufferevent *bufferevent_async_new_(struct event_base *base,
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,
Dbufferevent_ratelim.c560 bufferevent_set_rate_limit(struct bufferevent *bev, in bufferevent_set_rate_limit()
736 bufferevent_add_to_rate_limit_group(struct bufferevent *bev, in bufferevent_add_to_rate_limit_group()
783 bufferevent_remove_from_rate_limit_group(struct bufferevent *bev) in bufferevent_remove_from_rate_limit_group()
789 bufferevent_remove_from_rate_limit_group_internal_(struct bufferevent *bev, in bufferevent_remove_from_rate_limit_group_internal_()
822 bufferevent_get_read_limit(struct bufferevent *bev) in bufferevent_get_read_limit()
841 bufferevent_get_write_limit(struct bufferevent *bev) in bufferevent_get_write_limit()
858 bufferevent_set_max_single_read(struct bufferevent *bev, size_t size) in bufferevent_set_max_single_read()
872 bufferevent_set_max_single_write(struct bufferevent *bev, size_t size) in bufferevent_set_max_single_write()
886 bufferevent_get_max_single_read(struct bufferevent *bev) in bufferevent_get_max_single_read()
897 bufferevent_get_max_single_write(struct bufferevent *bev) in bufferevent_get_max_single_write()
[all …]
Devbuffer-internal.h78 struct bufferevent;
155 struct bufferevent *parent;
338 void evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev);
Dhttp-internal.h60 struct bufferevent *bufev;
171 struct bufferevent* (*bevcb)(struct event_base *, void *);
/external/libevent/test/
Dregress_bufferevent.c92 readcb(struct bufferevent *bev, void *arg) in readcb()
112 writecb(struct bufferevent *bev, void *arg) in writecb()
120 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb()
128 struct bufferevent *bev1 = NULL, *bev2 = NULL; in test_bufferevent_impl()
134 struct bufferevent *pair[2]; in test_bufferevent_impl()
336 struct bufferevent *pair[2]; in test_bufferevent_pair_release_lock()
354 wm_readcb(struct bufferevent *bev, void *arg) in wm_readcb()
377 wm_writecb(struct bufferevent *bev, void *arg) in wm_writecb()
387 wm_errorcb(struct bufferevent *bev, short what, void *arg) in wm_errorcb()
395 struct bufferevent *bev1 = NULL, *bev2 = NULL; in test_bufferevent_watermarks_impl()
[all …]
Dtest-fdleak.c82 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb()
93 server_event_cb(struct bufferevent *bev, short events, void *ctx) in server_event_cb()
109 struct bufferevent *bev = bufferevent_socket_new(base, sock, in listener_accept_cb()
168 client_read_cb(struct bufferevent *bev, void *ctx) in client_read_cb()
190 client_event_cb(struct bufferevent *bev, short events, void *ctx) in client_event_cb()
207 struct bufferevent *bev = bufferevent_socket_new(base, -1, in start_client()
Dregress_ssl.c235 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter) in bufferevent_openssl_check_fd()
249 bufferevent_openssl_check_freed(struct bufferevent *bev) in bufferevent_openssl_check_freed()
259 respond_to_number(struct bufferevent *bev, void *ctx) in respond_to_number()
293 done_writing_cb(struct bufferevent *bev, void *ctx) in done_writing_cb()
304 eventcb(struct bufferevent *bev, short what, void *ctx) in eventcb()
365 open_ssl_bufevs(struct bufferevent **bev1_out, struct bufferevent **bev2_out, in open_ssl_bufevs()
367 evutil_socket_t *fd_pair, struct bufferevent **underlying_pair, in open_ssl_bufevs()
399 struct bufferevent *bev1, *bev2; in regress_bufferevent_openssl()
404 struct bufferevent *bev_ll[2] = { NULL, NULL }; in regress_bufferevent_openssl()
515 struct bufferevent *bev = arg; in acceptcb_deferred()
[all …]
Dtest-ratelim.c105 struct bufferevent **bevs;
112 loud_writecb(struct bufferevent *bev, void *ctx) in loud_writecb()
126 discard_readcb(struct bufferevent *bev, void *ctx) in discard_readcb()
136 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) in write_on_connectedcb()
146 echo_readcb(struct bufferevent *bev, void *ctx) in echo_readcb()
157 echo_writecb(struct bufferevent *bev, void *ctx) in echo_writecb()
165 echo_eventcb(struct bufferevent *bev, short what, void *ctx) in echo_eventcb()
179 struct bufferevent *bev; in echo_listenercb()
201 struct bufferevent *bev = arg; in check_bucket_levels_cb()
343 bevs = calloc(cfg_n_connections, sizeof(struct bufferevent *)); in test_ratelimiting()
Dbench_httpclient.c69 static void readcb(struct bufferevent *b, void *arg);
70 static void errorcb(struct bufferevent *b, short what, void *arg);
73 readcb(struct bufferevent *b, void *arg) in readcb()
84 errorcb(struct bufferevent *b, short what, void *arg) in errorcb()
135 struct bufferevent *b; in launch_request()
Dregress_zlib.c243 readcb(struct bufferevent *bev, void *arg) in readcb()
263 writecb(struct bufferevent *bev, void *arg) in writecb()
271 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb()
279 struct bufferevent *bev1=NULL, *bev2=NULL; in test_bufferevent_zlib()
Dregress_http.c117 static struct bufferevent *
243 http_readcb(struct bufferevent *bev, void *arg) in http_readcb()
281 http_writecb(struct bufferevent *bev, void *arg) in http_writecb()
291 http_errorcb(struct bufferevent *bev, short what, void *arg) in http_errorcb()
420 struct bufferevent *bev = arg; in http_complete_write()
427 static struct bufferevent *
431 struct bufferevent *bev = NULL; in create_bev()
439 struct bufferevent *underlying = in create_bev()
459 struct bufferevent *bev = NULL; in http_basic_test_impl()
586 http_badreq_errorcb(struct bufferevent *bev, short what, void *arg) in http_badreq_errorcb()
[all …]
/external/libevent/sample/
Dle-proxy.c48 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) in readcb()
54 struct bufferevent *partner = ctx; in readcb()
79 drained_writecb(struct bufferevent *bev, void *ctx) in drained_writecb()
81 struct bufferevent *partner = ctx; in drained_writecb()
92 close_on_finished_writecb(struct bufferevent *bev, void *ctx) in close_on_finished_writecb()
102 eventcb(struct bufferevent *bev, short what, void *ctx) in eventcb()
104 struct bufferevent *partner = ctx; in eventcb()
161 struct bufferevent *b_out, *b_in; in accept_cb()
[all …]
Dhello-world.c34 static void conn_writecb(struct bufferevent *, void *);
35 static void conn_eventcb(struct bufferevent *, short, void *);
93 struct bufferevent *bev; in listener_cb()
109 conn_writecb(struct bufferevent *bev, void *user_data) in conn_writecb()
119 conn_eventcb(struct bufferevent *bev, short events, void *user_data) in conn_eventcb()
Dhttps-client.c61 struct bufferevent *bev = (struct bufferevent *) ctx; in http_request_done()
203 struct bufferevent *bev; in main()

12