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