Lines Matching refs:bev
63 static void bufferevent_cancel_all_(struct bufferevent *bev);
121 static void bufferevent_inbuf_wm_check(struct bufferevent *bev) in bufferevent_inbuf_wm_check() argument
123 if (!bev->wm_read.high) in bufferevent_inbuf_wm_check()
125 if (!(bev->enabled & EV_READ)) in bufferevent_inbuf_wm_check()
127 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
130 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS); in bufferevent_inbuf_wm_check()
155 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_locked()
189 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_unlocked()
234 (bevp)->bev.ev_base, \
236 bufferevent_incref_(&(bevp)->bev); \
314 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_init_common_()
865 bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd) in bufferevent_setfd() argument
870 BEV_LOCK(bev); in bufferevent_setfd()
871 if (bev->be_ops->ctrl) in bufferevent_setfd()
872 res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d); in bufferevent_setfd()
874 event_debug(("%s: cannot set fd for %p to "EV_SOCK_FMT, __func__, bev, fd)); in bufferevent_setfd()
875 BEV_UNLOCK(bev); in bufferevent_setfd()
880 bufferevent_getfd(struct bufferevent *bev) in bufferevent_getfd() argument
885 BEV_LOCK(bev); in bufferevent_getfd()
886 if (bev->be_ops->ctrl) in bufferevent_getfd()
887 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d); in bufferevent_getfd()
889 event_debug(("%s: cannot get fd for %p", __func__, bev)); in bufferevent_getfd()
890 BEV_UNLOCK(bev); in bufferevent_getfd()
895 bufferevent_get_options_(struct bufferevent *bev) in bufferevent_get_options_() argument
897 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_get_options_()
900 BEV_LOCK(bev); in bufferevent_get_options_()
902 BEV_UNLOCK(bev); in bufferevent_get_options_()
908 bufferevent_cancel_all_(struct bufferevent *bev) in bufferevent_cancel_all_() argument
912 BEV_LOCK(bev); in bufferevent_cancel_all_()
913 if (bev->be_ops->ctrl) in bufferevent_cancel_all_()
914 bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d); in bufferevent_cancel_all_()
915 BEV_UNLOCK(bev); in bufferevent_cancel_all_()
929 bufferevent_get_underlying(struct bufferevent *bev) in bufferevent_get_underlying() argument
934 BEV_LOCK(bev); in bufferevent_get_underlying()
935 if (bev->be_ops->ctrl) in bufferevent_get_underlying()
936 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_UNDERLYING, &d); in bufferevent_get_underlying()
937 BEV_UNLOCK(bev); in bufferevent_get_underlying()
944 struct bufferevent *bev = ctx; in bufferevent_generic_read_timeout_cb() local
945 bufferevent_incref_and_lock_(bev); in bufferevent_generic_read_timeout_cb()
946 bufferevent_disable(bev, EV_READ); in bufferevent_generic_read_timeout_cb()
947 bufferevent_run_eventcb_(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_READING, 0); in bufferevent_generic_read_timeout_cb()
948 bufferevent_decref_and_unlock_(bev); in bufferevent_generic_read_timeout_cb()
953 struct bufferevent *bev = ctx; in bufferevent_generic_write_timeout_cb() local
954 bufferevent_incref_and_lock_(bev); in bufferevent_generic_write_timeout_cb()
955 bufferevent_disable(bev, EV_WRITE); in bufferevent_generic_write_timeout_cb()
956 bufferevent_run_eventcb_(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_WRITING, 0); in bufferevent_generic_write_timeout_cb()
957 bufferevent_decref_and_unlock_(bev); in bufferevent_generic_write_timeout_cb()
961 bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev) in bufferevent_init_generic_timeout_cbs_() argument
963 event_assign(&bev->ev_read, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
964 bufferevent_generic_read_timeout_cb, bev); in bufferevent_init_generic_timeout_cbs_()
965 event_assign(&bev->ev_write, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
966 bufferevent_generic_write_timeout_cb, bev); in bufferevent_init_generic_timeout_cbs_()
970 bufferevent_generic_adj_timeouts_(struct bufferevent *bev) in bufferevent_generic_adj_timeouts_() argument
972 const short enabled = bev->enabled; in bufferevent_generic_adj_timeouts_()
973 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_generic_adj_timeouts_()
976 evutil_timerisset(&bev->timeout_read)) in bufferevent_generic_adj_timeouts_()
977 r1 = event_add(&bev->ev_read, &bev->timeout_read); in bufferevent_generic_adj_timeouts_()
979 r1 = event_del(&bev->ev_read); in bufferevent_generic_adj_timeouts_()
982 evutil_timerisset(&bev->timeout_write) && in bufferevent_generic_adj_timeouts_()
983 evbuffer_get_length(bev->output)) in bufferevent_generic_adj_timeouts_()
984 r2 = event_add(&bev->ev_write, &bev->timeout_write); in bufferevent_generic_adj_timeouts_()
986 r2 = event_del(&bev->ev_write); in bufferevent_generic_adj_timeouts_()
993 bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev) in bufferevent_generic_adj_existing_timeouts_() argument
996 if (event_pending(&bev->ev_read, EV_READ, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
997 if (evutil_timerisset(&bev->timeout_read)) { in bufferevent_generic_adj_existing_timeouts_()
998 if (bufferevent_add_event_(&bev->ev_read, &bev->timeout_read) < 0) in bufferevent_generic_adj_existing_timeouts_()
1001 event_remove_timer(&bev->ev_read); in bufferevent_generic_adj_existing_timeouts_()
1004 if (event_pending(&bev->ev_write, EV_WRITE, NULL)) { in bufferevent_generic_adj_existing_timeouts_()
1005 if (evutil_timerisset(&bev->timeout_write)) { in bufferevent_generic_adj_existing_timeouts_()
1006 if (bufferevent_add_event_(&bev->ev_write, &bev->timeout_write) < 0) in bufferevent_generic_adj_existing_timeouts_()
1009 event_remove_timer(&bev->ev_write); in bufferevent_generic_adj_existing_timeouts_()
1027 bufferevent_lock(struct bufferevent *bev) in bufferevent_lock() argument
1029 bufferevent_incref_and_lock_(bev); in bufferevent_lock()
1033 bufferevent_unlock(struct bufferevent *bev) in bufferevent_unlock() argument
1035 bufferevent_decref_and_unlock_(bev); in bufferevent_unlock()