62 static void _bufferevent_cancel_all(struct bufferevent *bev);
69 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_suspend_read()
81 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_unsuspend_read()
93 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_suspend_write()
105 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_unsuspend_write()
136 	struct bufferevent *bufev = &bufev_private->bev;  in bufferevent_run_deferred_callbacks_locked()
169 	struct bufferevent *bufev = &bufev_private->bev;  in bufferevent_run_deferred_callbacks_unlocked()
212 		bufferevent_incref(&(bevp)->bev);			\
214 			event_base_get_deferred_cb_queue((bevp)->bev.ev_base), \
224 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in _bufferevent_run_readcb()
241 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in _bufferevent_run_writecb()
258 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in _bufferevent_run_eventcb()
277 	struct bufferevent *bufev = &bufev_private->bev;  in bufferevent_init_common()
410 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_enable()
484 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_disable_hard()
521 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_setwatermark()
608 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in _bufferevent_decref_and_unlock()
688 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);  in bufferevent_incref()
732 bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd)  in bufferevent_setfd()  argument
737 	BEV_LOCK(bev);  in bufferevent_setfd()
738 	if (bev->be_ops->ctrl)  in bufferevent_setfd()
739 		res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d);  in bufferevent_setfd()
740 	BEV_UNLOCK(bev);  in bufferevent_setfd()
745 bufferevent_getfd(struct bufferevent *bev)  in bufferevent_getfd()  argument
750 	BEV_LOCK(bev);  in bufferevent_getfd()
751 	if (bev->be_ops->ctrl)  in bufferevent_getfd()
752 		res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d);  in bufferevent_getfd()
753 	BEV_UNLOCK(bev);  in bufferevent_getfd()
758 _bufferevent_cancel_all(struct bufferevent *bev)  in _bufferevent_cancel_all()  argument
762 	BEV_LOCK(bev);  in _bufferevent_cancel_all()
763 	if (bev->be_ops->ctrl)  in _bufferevent_cancel_all()
764 		bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d);  in _bufferevent_cancel_all()
765 	BEV_UNLOCK(bev);  in _bufferevent_cancel_all()
779 bufferevent_get_underlying(struct bufferevent *bev)  in bufferevent_get_underlying()  argument
784 	BEV_LOCK(bev);  in bufferevent_get_underlying()
785 	if (bev->be_ops->ctrl)  in bufferevent_get_underlying()
786 		res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_UNDERLYING, &d);  in bufferevent_get_underlying()
787 	BEV_UNLOCK(bev);  in bufferevent_get_underlying()
794 	struct bufferevent *bev = ctx;  in bufferevent_generic_read_timeout_cb()  local
795 	_bufferevent_incref_and_lock(bev);  in bufferevent_generic_read_timeout_cb()
796 	bufferevent_disable(bev, EV_READ);  in bufferevent_generic_read_timeout_cb()
797 	_bufferevent_run_eventcb(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_READING);  in bufferevent_generic_read_timeout_cb()
798 	_bufferevent_decref_and_unlock(bev);  in bufferevent_generic_read_timeout_cb()
803 	struct bufferevent *bev = ctx;  in bufferevent_generic_write_timeout_cb()  local
804 	_bufferevent_incref_and_lock(bev);  in bufferevent_generic_write_timeout_cb()
805 	bufferevent_disable(bev, EV_WRITE);  in bufferevent_generic_write_timeout_cb()
806 	_bufferevent_run_eventcb(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_WRITING);  in bufferevent_generic_write_timeout_cb()
807 	_bufferevent_decref_and_unlock(bev);  in bufferevent_generic_write_timeout_cb()
811 _bufferevent_init_generic_timeout_cbs(struct bufferevent *bev)  in _bufferevent_init_generic_timeout_cbs()  argument
813 	evtimer_assign(&bev->ev_read, bev->ev_base,  in _bufferevent_init_generic_timeout_cbs()
814 	    bufferevent_generic_read_timeout_cb, bev);  in _bufferevent_init_generic_timeout_cbs()
815 	evtimer_assign(&bev->ev_write, bev->ev_base,  in _bufferevent_init_generic_timeout_cbs()
816 	    bufferevent_generic_write_timeout_cb, bev);  in _bufferevent_init_generic_timeout_cbs()
820 _bufferevent_del_generic_timeout_cbs(struct bufferevent *bev)  in _bufferevent_del_generic_timeout_cbs()  argument
823 	r1 = event_del(&bev->ev_read);  in _bufferevent_del_generic_timeout_cbs()
824 	r2 = event_del(&bev->ev_write);  in _bufferevent_del_generic_timeout_cbs()
831 _bufferevent_generic_adj_timeouts(struct bufferevent *bev)  in _bufferevent_generic_adj_timeouts()  argument
833 	const short enabled = bev->enabled;  in _bufferevent_generic_adj_timeouts()
835 	    EVUTIL_UPCAST(bev, struct bufferevent_private, bev);  in _bufferevent_generic_adj_timeouts()
838 	    evutil_timerisset(&bev->timeout_read))  in _bufferevent_generic_adj_timeouts()
839 		r1 = event_add(&bev->ev_read, &bev->timeout_read);  in _bufferevent_generic_adj_timeouts()
841 		r1 = event_del(&bev->ev_read);  in _bufferevent_generic_adj_timeouts()
844 	    evutil_timerisset(&bev->timeout_write) &&  in _bufferevent_generic_adj_timeouts()
845 	    evbuffer_get_length(bev->output))  in _bufferevent_generic_adj_timeouts()
846 		r2 = event_add(&bev->ev_write, &bev->timeout_write);  in _bufferevent_generic_adj_timeouts()
848 		r2 = event_del(&bev->ev_write);  in _bufferevent_generic_adj_timeouts()
866 bufferevent_lock(struct bufferevent *bev)  in bufferevent_lock()  argument
868 	_bufferevent_incref_and_lock(bev);  in bufferevent_lock()
872 bufferevent_unlock(struct bufferevent *bev)  in bufferevent_unlock()  argument
874 	_bufferevent_decref_and_unlock(bev);  in bufferevent_unlock()