Searched refs:bufev (Results 1 - 11 of 11) sorted by relevance

/external/libevent/
H A Dbufferevent.c66 bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) argument
69 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
70 BEV_LOCK(bufev);
72 bufev->be_ops->disable(bufev, EV_READ);
74 BEV_UNLOCK(bufev);
78 bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) argument
81 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
82 BEV_LOCK(bufev);
84 if (!bufev_private->read_suspended && (bufev
90 bufferevent_suspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what) argument
102 bufferevent_unsuspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what) argument
121 struct bufferevent *bufev = arg; local
136 struct bufferevent *bufev = &bufev_private->bev; local
169 struct bufferevent *bufev = &bufev_private->bev; local
220 _bufferevent_run_readcb(struct bufferevent *bufev) argument
237 _bufferevent_run_writecb(struct bufferevent *bufev) argument
254 _bufferevent_run_eventcb(struct bufferevent *bufev, short what) argument
277 struct bufferevent *bufev = &bufev_private->bev; local
344 bufferevent_setcb(struct bufferevent *bufev, bufferevent_data_cb readcb, bufferevent_data_cb writecb, bufferevent_event_cb eventcb, void *cbarg) argument
359 bufferevent_get_input(struct bufferevent *bufev) argument
365 bufferevent_get_output(struct bufferevent *bufev) argument
371 bufferevent_get_base(struct bufferevent *bufev) argument
377 bufferevent_write(struct bufferevent *bufev, const void *data, size_t size) argument
386 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument
395 bufferevent_read(struct bufferevent *bufev, void *data, size_t size) argument
401 bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument
407 bufferevent_enable(struct bufferevent *bufev, short event) argument
430 bufferevent_set_timeouts(struct bufferevent *bufev, const struct timeval *tv_read, const struct timeval *tv_write) argument
457 bufferevent_settimeout(struct bufferevent *bufev, int timeout_read, int timeout_write) argument
480 bufferevent_disable_hard(struct bufferevent *bufev, short event) argument
498 bufferevent_disable(struct bufferevent *bufev, short event) argument
517 bufferevent_setwatermark(struct bufferevent *bufev, short events, size_t lowmark, size_t highmark) argument
565 bufferevent_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument
578 _bufferevent_incref_and_lock(struct bufferevent *bufev) argument
605 _bufferevent_decref_and_unlock(struct bufferevent *bufev) argument
669 bufferevent_decref(struct bufferevent *bufev) argument
676 bufferevent_free(struct bufferevent *bufev) argument
685 bufferevent_incref(struct bufferevent *bufev) argument
696 bufferevent_enable_locking(struct bufferevent *bufev, void *lock) argument
769 bufferevent_get_enabled(struct bufferevent *bufev) argument
[all...]
H A Dbufferevent_sock.c106 struct bufferevent *bufev = arg; local
108 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
111 (bufev->enabled & EV_WRITE) &&
112 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
116 if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) == -1) {
125 struct bufferevent *bufev = arg; local
127 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
133 _bufferevent_incref_and_lock(bufev);
143 input = bufev
204 struct bufferevent *bufev = arg; local
321 struct bufferevent *bufev; local
539 struct bufferevent *bufev; local
551 be_socket_enable(struct bufferevent *bufev, short event) argument
565 be_socket_disable(struct bufferevent *bufev, short event) argument
582 be_socket_destruct(struct bufferevent *bufev) argument
599 be_socket_adj_timeouts(struct bufferevent *bufev) argument
621 be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd) argument
642 bufferevent_priority_set(struct bufferevent *bufev, int priority) argument
663 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev) argument
[all...]
H A Dbufferevent-internal.h275 /** For internal use: temporarily stop all reads on bufev, until the conditions
277 void bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what);
278 /** For internal use: clear the conditions 'what' on bufev, and re-enable
280 void bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what);
282 /** For internal use: temporarily stop all writes on bufev, until the conditions
284 void bufferevent_suspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what);
285 /** For internal use: clear the conditions 'what' on bufev, and re-enable
287 void bufferevent_unsuspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what);
301 @param bufev the bufferevent to be disabled
306 int bufferevent_disable_hard(struct bufferevent *bufev, shor
[all...]
H A Dbufferevent_pair.c94 struct bufferevent_pair *bufev; local
95 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair))))
97 if (bufferevent_init_common(&bufev->bev, base, &bufferevent_ops_pair,
99 mm_free(bufev);
102 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) {
103 bufferevent_free(downcast(bufev));
107 _bufferevent_init_generic_timeout_cbs(&bufev->bev.bev);
109 return bufev;
230 be_pair_enable(struct bufferevent *bufev, shor argument
246 be_pair_transfer(downcast(partner), bufev, 0); local
[all...]
H A Dbufferevent_filter.c67 static int be_filter_flush(struct bufferevent *bufev,
141 struct bufferevent *bufev = downcast(bevf); local
143 bufev->wm_read.high &&
144 evbuffer_get_length(bufev->input) >= bufev->wm_read.high;
322 struct bufferevent *bufev = downcast(bevf); local
331 if (!(bufev->enabled & EV_WRITE) ||
333 !evbuffer_get_length(bufev->output))
339 evbuffer_cb_set_flags(bufev->output, bevf->outbuf_cb, 0);
363 (bufev
419 struct bufferevent *bufev = downcast(bevf); local
471 be_filter_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument
[all...]
H A Dhttp.c195 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg);
389 bufferevent_setcb(evcon->bufev,
395 bufferevent_enable(evcon->bufev, EV_WRITE);
401 bufferevent_disable(evcon->bufev, EV_WRITE);
408 bufferevent_enable(evcon->bufev, EV_WRITE);
409 evbuffer_add_printf(bufferevent_get_output(evcon->bufev),
414 bufferevent_setcb(evcon->bufev,
454 evbuffer_add_printf(bufferevent_get_output(evcon->bufev),
541 evbuffer_add_printf(bufferevent_get_output(evcon->bufev),
596 struct evbuffer *output = bufferevent_get_output(evcon->bufev);
754 evhttp_write_cb(struct bufferevent *bufev, void *arg) argument
1044 evhttp_read_cb(struct bufferevent *bufev, void *arg) argument
1323 evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) argument
1387 evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) argument
[all...]
H A Dbufferevent_openssl.c159 struct bufferevent *bufev = b->ptr; local
168 output = bufferevent_get_output(bufev);
173 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) {
174 if (bufev->wm_write.high <= outlen) {
179 inlen = bufev->wm_write.high - outlen;
191 struct bufferevent *bufev = b->ptr; local
202 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0;
205 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0;
330 static int be_openssl_flush(struct bufferevent *bufev,
1234 be_openssl_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument
1280 bufferevent_openssl_get_ssl(struct bufferevent *bufev) argument
[all...]
H A Dhttp-internal.h68 struct bufferevent *bufev; member in struct:evhttp_connection
/external/libevent/include/event2/
H A Dbufferevent.h199 @param bufev an existing bufferevent allocated with
212 @param bufev An existing bufferevent allocated with bufferevent_socket_new()
253 @param bufev a bufferevent struct returned by bufferevent_new()
258 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
270 @param bufev a bufferevent struct
274 int bufferevent_priority_set(struct bufferevent *bufev, int pri);
280 @param bufev the bufferevent structure to be freed.
282 void bufferevent_free(struct bufferevent *bufev);
288 @param bufev the bufferevent object for which to change callbacks
299 void bufferevent_setcb(struct bufferevent *bufev,
[all...]
H A Dbufferevent_compat.h82 @param bufev the bufferevent to be modified
86 void bufferevent_settimeout(struct bufferevent *bufev,
H A Dbufferevent_ssl.h93 bufferevent_openssl_get_ssl(struct bufferevent *bufev);

Completed in 247 milliseconds