69 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_suspend_read_()  local
71 	if (!bufev_private->read_suspended)  in bufferevent_suspend_read_()
73 	bufev_private->read_suspended |= what;  in bufferevent_suspend_read_()
80 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_unsuspend_read_()  local
82 	bufev_private->read_suspended &= ~what;  in bufferevent_unsuspend_read_()
83 	if (!bufev_private->read_suspended && (bufev->enabled & EV_READ))  in bufferevent_unsuspend_read_()
91 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_suspend_write_()  local
93 	if (!bufev_private->write_suspended)  in bufferevent_suspend_write_()
95 	bufev_private->write_suspended |= what;  in bufferevent_suspend_write_()
102 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_unsuspend_write_()  local
104 	bufev_private->write_suspended &= ~what;  in bufferevent_unsuspend_write_()
105 	if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE))  in bufferevent_unsuspend_write_()
154 	struct bufferevent_private *bufev_private = arg;  in bufferevent_run_deferred_callbacks_locked()  local
155 	struct bufferevent *bufev = &bufev_private->bev;  in bufferevent_run_deferred_callbacks_locked()
158 	if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) &&  in bufferevent_run_deferred_callbacks_locked()
162 		bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED;  in bufferevent_run_deferred_callbacks_locked()
165 	if (bufev_private->readcb_pending && bufev->readcb) {  in bufferevent_run_deferred_callbacks_locked()
166 		bufev_private->readcb_pending = 0;  in bufferevent_run_deferred_callbacks_locked()
170 	if (bufev_private->writecb_pending && bufev->writecb) {  in bufferevent_run_deferred_callbacks_locked()
171 		bufev_private->writecb_pending = 0;  in bufferevent_run_deferred_callbacks_locked()
174 	if (bufev_private->eventcb_pending && bufev->errorcb) {  in bufferevent_run_deferred_callbacks_locked()
175 		short what = bufev_private->eventcb_pending;  in bufferevent_run_deferred_callbacks_locked()
176 		int err = bufev_private->errno_pending;  in bufferevent_run_deferred_callbacks_locked()
177 		bufev_private->eventcb_pending = 0;  in bufferevent_run_deferred_callbacks_locked()
178 		bufev_private->errno_pending = 0;  in bufferevent_run_deferred_callbacks_locked()
188 	struct bufferevent_private *bufev_private = arg;  in bufferevent_run_deferred_callbacks_unlocked()  local
189 	struct bufferevent *bufev = &bufev_private->bev;  in bufferevent_run_deferred_callbacks_unlocked()
195 	if ((bufev_private->eventcb_pending & BEV_EVENT_CONNECTED) &&  in bufferevent_run_deferred_callbacks_unlocked()
201 		bufev_private->eventcb_pending &= ~BEV_EVENT_CONNECTED;  in bufferevent_run_deferred_callbacks_unlocked()
204 	if (bufev_private->readcb_pending && bufev->readcb) {  in bufferevent_run_deferred_callbacks_unlocked()
207 		bufev_private->readcb_pending = 0;  in bufferevent_run_deferred_callbacks_unlocked()
211 	if (bufev_private->writecb_pending && bufev->writecb) {  in bufferevent_run_deferred_callbacks_unlocked()
214 		bufev_private->writecb_pending = 0;  in bufferevent_run_deferred_callbacks_unlocked()
217 	if (bufev_private->eventcb_pending && bufev->errorcb) {  in bufferevent_run_deferred_callbacks_unlocked()
220 		short what = bufev_private->eventcb_pending;  in bufferevent_run_deferred_callbacks_unlocked()
221 		int err = bufev_private->errno_pending;  in bufferevent_run_deferred_callbacks_unlocked()
222 		bufev_private->eventcb_pending = 0;  in bufferevent_run_deferred_callbacks_unlocked()
223 		bufev_private->errno_pending = 0;  in bufferevent_run_deferred_callbacks_unlocked()
309 bufferevent_init_common_(struct bufferevent_private *bufev_private,  in bufferevent_init_common_()  argument
314 	struct bufferevent *bufev = &bufev_private->bev;  in bufferevent_init_common_()
326 	bufev_private->refcnt = 1;  in bufferevent_init_common_()
335 	if (bufferevent_ratelim_init_(bufev_private))  in bufferevent_init_common_()
358 		    &bufev_private->deferred,  in bufferevent_init_common_()
361 		    bufev_private);  in bufferevent_init_common_()
364 		    &bufev_private->deferred,  in bufferevent_init_common_()
367 		    bufev_private);  in bufferevent_init_common_()
369 	bufev_private->options = options;  in bufferevent_init_common_()
484 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_enable()  local
489 	if (bufev_private->read_suspended)  in bufferevent_enable()
491 	if (bufev_private->write_suspended)  in bufferevent_enable()
559 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_disable_hard_()  local
564 	bufev_private->connecting = 0;  in bufferevent_disable_hard_()
597 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_setwatermark()  local
614 			if (bufev_private->read_watermarks_cb == NULL) {  in bufferevent_setwatermark()
615 				bufev_private->read_watermarks_cb =  in bufferevent_setwatermark()
621 				      bufev_private->read_watermarks_cb,  in bufferevent_setwatermark()
630 			if (bufev_private->read_watermarks_cb)  in bufferevent_setwatermark()
632 				    bufev_private->read_watermarks_cb,  in bufferevent_setwatermark()
682 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_incref_and_lock_()  local
684 	++bufev_private->refcnt;  in bufferevent_incref_and_lock_()
708 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_decref_and_unlock_()  local
713 	EVUTIL_ASSERT(bufev_private->refcnt > 0);  in bufferevent_decref_and_unlock_()
715 	if (--bufev_private->refcnt) {  in bufferevent_decref_and_unlock_()
727 	cbs[2] = &bufev_private->deferred;  in bufferevent_decref_and_unlock_()
729 	if (bufev_private->rate_limiting) {  in bufferevent_decref_and_unlock_()
730 		struct event *e = &bufev_private->rate_limiting->refill_bucket_event;  in bufferevent_decref_and_unlock_()
751 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_finalize_cb_()  local
767 	if (bufev_private->rate_limiting) {  in bufferevent_finalize_cb_()
768 		if (bufev_private->rate_limiting->group)  in bufferevent_finalize_cb_()
770 		mm_free(bufev_private->rate_limiting);  in bufferevent_finalize_cb_()
771 		bufev_private->rate_limiting = NULL;  in bufferevent_finalize_cb_()
777 	if (bufev_private->own_lock)  in bufferevent_finalize_cb_()
778 		EVTHREAD_FREE_LOCK(bufev_private->lock,  in bufferevent_finalize_cb_()
817 	struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);  in bufferevent_incref()  local
824 	++bufev_private->refcnt;  in bufferevent_incref()