| /external/libevent/ |
| 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...] |
| 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.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...] |
| http-internal.h | 68 struct bufferevent *bufev; member in struct:evhttp_connection
|
| 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...] |
