Lines Matching refs:bevf
131 /** Return 1 iff bevf's underlying bufferevent's output buffer is at or
135 be_underlying_writebuf_full(struct bufferevent_filtered *bevf,
138 struct bufferevent *u = bevf->underlying;
147 be_readbuf_full(struct bufferevent_filtered *bevf,
150 struct bufferevent *bufev = downcast(bevf);
231 struct bufferevent_filtered *bevf = upcast(bev);
232 EVUTIL_ASSERT(bevf);
234 if (bevf->bev.options & BEV_OPT_CLOSE_ON_FREE) {
240 if (BEV_UPCAST(bevf->underlying)->refcnt < 2) {
244 bufferevent_free(bevf->underlying);
247 if (bevf->underlying) {
248 if (bevf->underlying->errorcb == be_filter_eventcb)
249 bufferevent_setcb(bevf->underlying,
251 bufferevent_unsuspend_read_(bevf->underlying,
260 struct bufferevent_filtered *bevf = upcast(bev);
261 EVUTIL_ASSERT(bevf);
262 if (bevf->free_context)
263 bevf->free_context(bevf->context);
265 if (bevf->inbuf_cb)
266 evbuffer_remove_cb_entry(bev->input, bevf->inbuf_cb);
268 if (bevf->outbuf_cb)
269 evbuffer_remove_cb_entry(bev->output, bevf->outbuf_cb);
275 struct bufferevent_filtered *bevf = upcast(bev);
281 bufferevent_unsuspend_read_(bevf->underlying,
290 struct bufferevent_filtered *bevf = upcast(bev);
295 bufferevent_suspend_read_(bevf->underlying,
302 be_filter_process_input(struct bufferevent_filtered *bevf,
307 struct bufferevent *bev = downcast(bevf);
313 be_readbuf_full(bevf, state))
323 res = bevf->process_in(bevf->underlying->input,
324 bev->input, limit, state, bevf->context);
330 evbuffer_get_length(bevf->underlying->input) &&
331 !be_readbuf_full(bevf, state));
341 be_filter_process_output(struct bufferevent_filtered *bevf,
347 struct bufferevent *bufev = downcast(bevf);
357 be_underlying_writebuf_full(bevf, state) ||
364 evbuffer_cb_clear_flags(bufev->output, bevf->outbuf_cb,
374 bevf->underlying->wm_write.high)
375 limit = bevf->underlying->wm_write.high -
376 evbuffer_get_length(bevf->underlying->output);
378 res = bevf->process_out(downcast(bevf)->output,
379 bevf->underlying->output,
382 bevf->context);
394 !be_underlying_writebuf_full(bevf,state));
403 !be_underlying_writebuf_full(bevf, state)) {
410 evbuffer_cb_set_flags(bufev->output,bevf->outbuf_cb,
424 struct bufferevent_filtered *bevf = arg;
425 struct bufferevent *bev = downcast(bevf);
432 be_filter_process_output(bevf, BEV_NORMAL, &processed_any);
440 struct bufferevent_filtered *bevf = me_;
443 struct bufferevent *bufev = downcast(bevf);
453 if (bevf->got_eof)
459 res = be_filter_process_input(bevf, state, &processed_any);
468 be_readbuf_full(bevf, state)) {
474 evbuffer_cb_set_flags(bufev->input, bevf->inbuf_cb,
486 struct bufferevent_filtered *bevf = arg;
488 struct bufferevent *bev = downcast(bevf);
492 if (bevf->got_eof)
498 if (!be_readbuf_full(bevf, state)) {
503 evbuffer_cb_clear_flags(bev->input, bevf->inbuf_cb,
505 if (evbuffer_get_length(bevf->underlying->input) > 0)
506 be_filter_read_nolock_(bevf->underlying, bevf);
516 struct bufferevent_filtered *bevf = me_;
517 struct bufferevent *bev = downcast(bevf);
531 struct bufferevent_filtered *bevf = me_;
532 struct bufferevent *bev = downcast(bevf);
543 be_filter_process_output(bevf, BEV_NORMAL, &processed_any);
553 struct bufferevent_filtered *bevf = me_;
554 struct bufferevent *bev = downcast(bevf);
576 struct bufferevent_filtered *bevf = upcast(bufev);
578 EVUTIL_ASSERT(bevf);
583 be_filter_process_input(bevf, mode, &processed_any);
586 be_filter_process_output(bevf, mode, &processed_any);
590 bufferevent_flush(bevf->underlying, iotype, mode);
601 struct bufferevent_filtered *bevf;
604 bevf = upcast(bev);
605 data->ptr = bevf->underlying;
608 bevf = upcast(bev);
610 if (bevf->underlying &&
611 bevf->underlying->be_ops &&
612 bevf->underlying->be_ops->ctrl) {
613 return (bevf->underlying->be_ops->ctrl)(bevf->underlying, op, data);