Lines Matching defs:underlying
78 struct bufferevent *underlying;
81 /** True iff we have received an EOF callback from the underlying
122 /** Return 1 iff bevf's underlying bufferevent's output buffer is at or
129 struct bufferevent *u = bevf->underlying;
161 bufferevent_filter_new(struct bufferevent *underlying,
171 if (!underlying)
183 if (bufferevent_init_common(&bufev_f->bev, underlying->ev_base,
192 bufev_f->underlying = underlying;
199 bufferevent_setcb(bufev_f->underlying,
206 bufferevent_incref(underlying);
208 bufferevent_enable(underlying, EV_READ|EV_WRITE);
209 bufferevent_suspend_read(underlying, BEV_SUSPEND_FILT_READ);
225 * underlying for the first time. This decref is an
228 if (BEV_UPCAST(bevf->underlying)->refcnt < 2) {
232 bufferevent_free(bevf->underlying);
235 if (bevf->underlying) {
236 if (bevf->underlying->errorcb == be_filter_eventcb)
237 bufferevent_setcb(bevf->underlying,
239 bufferevent_unsuspend_read(bevf->underlying,
256 bufferevent_unsuspend_read(bevf->underlying,
270 bufferevent_suspend_read(bevf->underlying,
298 res = bevf->process_in(bevf->underlying->input,
305 evbuffer_get_length(bevf->underlying->input) &&
327 * filter unless we're writing data, and the underlying
348 bevf->underlying->wm_write.high)
349 limit = bevf->underlying->wm_write.high -
350 evbuffer_get_length(bevf->underlying->output);
353 bevf->underlying->output,
367 /* Or if we have filled the underlying output buffer. */
412 /* Called when the underlying socket has read. */
414 be_filter_readcb(struct bufferevent *underlying, void *_me)
443 /* Called when the underlying socket has drained enough that we can write to
446 be_filter_writecb(struct bufferevent *underlying, void *_me)
457 /* Called when the underlying socket has given us an error */
459 be_filter_eventcb(struct bufferevent *underlying, short what, void *_me)
488 bufferevent_flush(bevf->underlying, iotype, mode);
503 data->ptr = bevf->underlying;