70 static int be_filter_flush(struct bufferevent *bufev,
150 	struct bufferevent *bufev = downcast(bevf);  in be_readbuf_full()  local
152 	    bufev->wm_read.high &&  in be_readbuf_full()
153 	    evbuffer_get_length(bufev->input) >= bufev->wm_read.high;  in be_readbuf_full()
347 	struct bufferevent *bufev = downcast(bevf);  in be_filter_process_output()  local
356 		if (!(bufev->enabled & EV_WRITE) ||  in be_filter_process_output()
358 		    !evbuffer_get_length(bufev->output))  in be_filter_process_output()
364 	evbuffer_cb_clear_flags(bufev->output, bevf->outbuf_cb,  in be_filter_process_output()
389 			(bufev->enabled & EV_WRITE) &&  in be_filter_process_output()
392 			evbuffer_get_length(bufev->output) &&  in be_filter_process_output()
398 			bufferevent_trigger_nolock_(bufev, EV_WRITE, 0);  in be_filter_process_output()
401 			    (bufev->enabled & EV_WRITE) &&  in be_filter_process_output()
402 			    evbuffer_get_length(bufev->output) &&  in be_filter_process_output()
410 	evbuffer_cb_set_flags(bufev->output,bevf->outbuf_cb,  in be_filter_process_output()
414 		BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev);  in be_filter_process_output()
443 	struct bufferevent *bufev = downcast(bevf);  in be_filter_read_nolock_()  local
444 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in be_filter_read_nolock_()
466 			bufferevent_trigger_nolock_(bufev, EV_READ, 0);  in be_filter_read_nolock_()
474 				evbuffer_cb_set_flags(bufev->input, bevf->inbuf_cb,  in be_filter_read_nolock_()
573 be_filter_flush(struct bufferevent *bufev,  in be_filter_flush()  argument
576 	struct bufferevent_filtered *bevf = upcast(bufev);  in be_filter_flush()
580 	bufferevent_incref_and_lock_(bufev);  in be_filter_flush()
592 	bufferevent_decref_and_unlock_(bufev);  in be_filter_flush()