| /external/libevent/ |
| D | bufferevent.c | 66 bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_suspend_read() argument
69 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); in bufferevent_suspend_read()
70 BEV_LOCK(bufev); in bufferevent_suspend_read()
72 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read()
74 BEV_UNLOCK(bufev); in bufferevent_suspend_read()
78 bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_unsuspend_read() argument
81 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); in bufferevent_unsuspend_read()
82 BEV_LOCK(bufev); in bufferevent_unsuspend_read()
84 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read()
85 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read()
[all …]
|
| D | bufferevent_sock.c | 106 struct bufferevent *bufev = arg; in bufferevent_socket_outbuf_cb() local
108 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); in bufferevent_socket_outbuf_cb()
111 (bufev->enabled & EV_WRITE) && in bufferevent_socket_outbuf_cb()
112 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb()
116 if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) == -1) { in bufferevent_socket_outbuf_cb()
125 struct bufferevent *bufev = arg; in bufferevent_readcb() local
127 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); in bufferevent_readcb()
133 _bufferevent_incref_and_lock(bufev); in bufferevent_readcb()
143 input = bufev->input; in bufferevent_readcb()
149 if (bufev->wm_read.high != 0) { in bufferevent_readcb()
[all …]
|
| D | bufferevent_filter.c | 67 static int be_filter_flush(struct bufferevent *bufev,
141 struct bufferevent *bufev = downcast(bevf); in be_readbuf_full() local
143 bufev->wm_read.high && in be_readbuf_full()
144 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
322 struct bufferevent *bufev = downcast(bevf); in be_filter_process_output() local
331 if (!(bufev->enabled & EV_WRITE) || in be_filter_process_output()
333 !evbuffer_get_length(bufev->output)) in be_filter_process_output()
339 evbuffer_cb_set_flags(bufev->output, bevf->outbuf_cb, 0); in be_filter_process_output()
363 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
366 evbuffer_get_length(bufev->output) && in be_filter_process_output()
[all …]
|
| D | bufferevent_pair.c | 94 struct bufferevent_pair *bufev; in bufferevent_pair_elt_new() local
95 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair)))) in bufferevent_pair_elt_new()
97 if (bufferevent_init_common(&bufev->bev, base, &bufferevent_ops_pair, in bufferevent_pair_elt_new()
99 mm_free(bufev); in bufferevent_pair_elt_new()
102 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
103 bufferevent_free(downcast(bufev)); in bufferevent_pair_elt_new()
107 _bufferevent_init_generic_timeout_cbs(&bufev->bev.bev); in bufferevent_pair_elt_new()
109 return bufev; in bufferevent_pair_elt_new()
230 be_pair_enable(struct bufferevent *bufev, short events) in be_pair_enable() argument
232 struct bufferevent_pair *bev_p = upcast(bufev); in be_pair_enable()
[all …]
|
| D | bufferevent-internal.h | 277 void bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what);
280 void bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what);
284 void bufferevent_suspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what);
287 void bufferevent_unsuspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what);
306 int bufferevent_disable_hard(struct bufferevent *bufev, short event);
310 int bufferevent_enable_locking(struct bufferevent *bufev, void *lock);
312 void bufferevent_incref(struct bufferevent *bufev);
315 void _bufferevent_incref_and_lock(struct bufferevent *bufev);
318 int bufferevent_decref(struct bufferevent *bufev);
321 int _bufferevent_decref_and_unlock(struct bufferevent *bufev);
[all …]
|
| D | http.c | 195 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg);
389 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
395 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_write_buffer()
401 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_send_continue_done()
408 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_send_continue()
409 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_send_continue()
414 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
454 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_request()
541 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_response()
596 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_make_header()
[all …]
|
| D | bufferevent_openssl.c | 159 struct bufferevent *bufev = b->ptr; in bio_bufferevent_write() local
168 output = bufferevent_get_output(bufev); in bio_bufferevent_write()
173 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { in bio_bufferevent_write()
174 if (bufev->wm_write.high <= outlen) { in bio_bufferevent_write()
179 inlen = bufev->wm_write.high - outlen; in bio_bufferevent_write()
191 struct bufferevent *bufev = b->ptr; in bio_bufferevent_ctrl() local
202 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
205 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; in bio_bufferevent_ctrl()
330 static int be_openssl_flush(struct bufferevent *bufev,
1234 be_openssl_flush(struct bufferevent *bufev, in be_openssl_flush() argument
[all …]
|
| D | http-internal.h | 68 struct bufferevent *bufev; member
|
| /external/libevent/include/event2/ |
| D | bufferevent.h | 258 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
274 int bufferevent_priority_set(struct bufferevent *bufev, int pri);
282 void bufferevent_free(struct bufferevent *bufev);
299 void bufferevent_setcb(struct bufferevent *bufev,
310 int bufferevent_setfd(struct bufferevent *bufev, evutil_socket_t fd);
316 evutil_socket_t bufferevent_getfd(struct bufferevent *bufev);
322 struct bufferevent *bufferevent_get_underlying(struct bufferevent *bufev);
337 int bufferevent_write(struct bufferevent *bufev,
350 int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf);
363 size_t bufferevent_read(struct bufferevent *bufev, void *data, size_t size);
[all …]
|
| D | bufferevent_compat.h | 86 void bufferevent_settimeout(struct bufferevent *bufev,
|
| D | bufferevent_ssl.h | 93 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
|