| /external/libevent/ |
| bufferevent.c | 66 bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what)
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)
81 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
82 BEV_LOCK(bufev);
84 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)
121 struct bufferevent *bufev = arg; local
136 struct bufferevent *bufev = &bufev_private->bev; local
169 struct bufferevent *bufev = &bufev_private->bev; local
277 struct bufferevent *bufev = &bufev_private->bev; local
[all...] |
| bufferevent_sock.c | 106 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->input
204 struct bufferevent *bufev = arg; local
321 struct bufferevent *bufev; local
539 struct bufferevent *bufev; local
[all...] |
| bufferevent-internal.h | 275 /** 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, short event)
[all...] |
| bufferevent_pair.c | 94 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, short events
246 be_pair_transfer(downcast(partner), bufev, 0); local
[all...] |
| bufferevent_filter.c | 67 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->enabled & EV_WRITE) &
419 struct bufferevent *bufev = downcast(bevf); local
[all...] |
| http.c | 195 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);
[all...] |
| bufferevent_openssl.c | 159 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,
[all...] |
| http-internal.h | 68 struct bufferevent *bufev; member in struct:evhttp_connection
|
| /external/libevent/include/event2/ |
| bufferevent.h | 199 @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...] |
| bufferevent_compat.h | 82 @param bufev the bufferevent to be modified
86 void bufferevent_settimeout(struct bufferevent *bufev,
|
| bufferevent_ssl.h | 93 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
|
