Lines Matching refs:bev

81 	struct bufferevent_private bev;  member
105 evutil_offsetof(struct bufferevent_filtered, bev.bev),
118 upcast(struct bufferevent *bev) in upcast() argument
121 if (!BEV_IS_FILTER(bev)) in upcast()
123 bev_f = (void*)( ((char*)bev) - in upcast()
124 evutil_offsetof(struct bufferevent_filtered, bev.bev)); in upcast()
125 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev)); in upcast()
129 #define downcast(bev_f) (&(bev_f)->bev.bev)
192 if (bufferevent_init_common_(&bufev_f->bev, underlying->ev_base, in bufferevent_filter_new()
229 be_filter_unlink(struct bufferevent *bev) in be_filter_unlink() argument
231 struct bufferevent_filtered *bevf = upcast(bev); in be_filter_unlink()
234 if (bevf->bev.options & BEV_OPT_CLOSE_ON_FREE) { in be_filter_unlink()
258 be_filter_destruct(struct bufferevent *bev) in be_filter_destruct() argument
260 struct bufferevent_filtered *bevf = upcast(bev); in be_filter_destruct()
266 evbuffer_remove_cb_entry(bev->input, bevf->inbuf_cb); in be_filter_destruct()
269 evbuffer_remove_cb_entry(bev->output, bevf->outbuf_cb); in be_filter_destruct()
273 be_filter_enable(struct bufferevent *bev, short event) in be_filter_enable() argument
275 struct bufferevent_filtered *bevf = upcast(bev); in be_filter_enable()
277 BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); in be_filter_enable()
280 BEV_RESET_GENERIC_READ_TIMEOUT(bev); in be_filter_enable()
288 be_filter_disable(struct bufferevent *bev, short event) in be_filter_disable() argument
290 struct bufferevent_filtered *bevf = upcast(bev); in be_filter_disable()
292 BEV_DEL_GENERIC_WRITE_TIMEOUT(bev); in be_filter_disable()
294 BEV_DEL_GENERIC_READ_TIMEOUT(bev); in be_filter_disable()
307 struct bufferevent *bev = downcast(bevf); in be_filter_process_input() local
312 if (!(bev->enabled & EV_READ) || in be_filter_process_input()
319 if (state == BEV_NORMAL && bev->wm_read.high) in be_filter_process_input()
320 limit = bev->wm_read.high - in be_filter_process_input()
321 evbuffer_get_length(bev->input); in be_filter_process_input()
324 bev->input, limit, state, bevf->context); in be_filter_process_input()
329 (bev->enabled & EV_READ) && in be_filter_process_input()
334 BEV_RESET_GENERIC_READ_TIMEOUT(bev); in be_filter_process_input()
425 struct bufferevent *bev = downcast(bevf); in bufferevent_filtered_outbuf_cb() local
431 bufferevent_incref_and_lock_(bev); in bufferevent_filtered_outbuf_cb()
433 bufferevent_decref_and_unlock_(bev); in bufferevent_filtered_outbuf_cb()
488 struct bufferevent *bev = downcast(bevf); in bufferevent_filtered_inbuf_cb() local
490 BEV_LOCK(bev); in bufferevent_filtered_inbuf_cb()
503 evbuffer_cb_clear_flags(bev->input, bevf->inbuf_cb, in bufferevent_filtered_inbuf_cb()
509 BEV_UNLOCK(bev); in bufferevent_filtered_inbuf_cb()
517 struct bufferevent *bev = downcast(bevf); in be_filter_readcb() local
519 BEV_LOCK(bev); in be_filter_readcb()
523 BEV_UNLOCK(bev); in be_filter_readcb()
532 struct bufferevent *bev = downcast(bevf); in be_filter_writecb() local
533 struct bufferevent_private *bufev_private = BEV_UPCAST(bev); in be_filter_writecb()
536 BEV_LOCK(bev); in be_filter_writecb()
546 BEV_UNLOCK(bev); in be_filter_writecb()
554 struct bufferevent *bev = downcast(bevf); in be_filter_eventcb() local
555 struct bufferevent_private *bufev_private = BEV_UPCAST(bev); in be_filter_eventcb()
557 BEV_LOCK(bev); in be_filter_eventcb()
566 bufferevent_run_eventcb_(bev, what, 0); in be_filter_eventcb()
569 BEV_UNLOCK(bev); in be_filter_eventcb()
598 be_filter_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, in be_filter_ctrl() argument
604 bevf = upcast(bev); in be_filter_ctrl()
609 bevf = upcast(bev); in be_filter_ctrl()