Lines Matching refs:underlying
84 struct bufferevent *underlying; member
138 struct bufferevent *u = bevf->underlying; in be_underlying_writebuf_full()
170 bufferevent_filter_new(struct bufferevent *underlying, in bufferevent_filter_new() argument
180 if (!underlying) in bufferevent_filter_new()
192 if (bufferevent_init_common_(&bufev_f->bev, underlying->ev_base, in bufferevent_filter_new()
201 bufev_f->underlying = underlying; in bufferevent_filter_new()
208 bufferevent_setcb(bufev_f->underlying, in bufferevent_filter_new()
220 bufferevent_incref_(underlying); in bufferevent_filter_new()
222 bufferevent_enable(underlying, EV_READ|EV_WRITE); in bufferevent_filter_new()
223 bufferevent_suspend_read_(underlying, BEV_SUSPEND_FILT_READ); in bufferevent_filter_new()
240 if (BEV_UPCAST(bevf->underlying)->refcnt < 2) { in be_filter_unlink()
244 bufferevent_free(bevf->underlying); in be_filter_unlink()
247 if (bevf->underlying) { in be_filter_unlink()
248 if (bevf->underlying->errorcb == be_filter_eventcb) in be_filter_unlink()
249 bufferevent_setcb(bevf->underlying, in be_filter_unlink()
251 bufferevent_unsuspend_read_(bevf->underlying, in be_filter_unlink()
281 bufferevent_unsuspend_read_(bevf->underlying, in be_filter_enable()
295 bufferevent_suspend_read_(bevf->underlying, in be_filter_disable()
323 res = bevf->process_in(bevf->underlying->input, in be_filter_process_input()
330 evbuffer_get_length(bevf->underlying->input) && in be_filter_process_input()
374 bevf->underlying->wm_write.high) in be_filter_process_output()
375 limit = bevf->underlying->wm_write.high - in be_filter_process_output()
376 evbuffer_get_length(bevf->underlying->output); in be_filter_process_output()
379 bevf->underlying->output, in be_filter_process_output()
438 be_filter_read_nolock_(struct bufferevent *underlying, void *me_) in be_filter_read_nolock_() argument
467 if (evbuffer_get_length(underlying->input) > 0 && in be_filter_read_nolock_()
505 if (evbuffer_get_length(bevf->underlying->input) > 0) in bufferevent_filtered_inbuf_cb()
506 be_filter_read_nolock_(bevf->underlying, bevf); in bufferevent_filtered_inbuf_cb()
514 be_filter_readcb(struct bufferevent *underlying, void *me_) in be_filter_readcb() argument
521 be_filter_read_nolock_(underlying, me_); in be_filter_readcb()
529 be_filter_writecb(struct bufferevent *underlying, void *me_) in be_filter_writecb() argument
551 be_filter_eventcb(struct bufferevent *underlying, short what, void *me_) in be_filter_eventcb() argument
590 bufferevent_flush(bevf->underlying, iotype, mode); in be_filter_flush()
605 data->ptr = bevf->underlying; in be_filter_ctrl()
611 if (bevf->underlying && in be_filter_ctrl()
612 bevf->underlying->be_ops && in be_filter_ctrl()
613 bevf->underlying->be_ops->ctrl) { in be_filter_ctrl()
614 return (bevf->underlying->be_ops->ctrl)(bevf->underlying, op, data); in be_filter_ctrl()