Lines Matching defs:bev
65 static void bufferevent_cancel_all_(struct bufferevent *bev);
123 static void bufferevent_inbuf_wm_check(struct bufferevent *bev)
125 if (!bev->wm_read.high)
127 if (!(bev->enabled & EV_READ))
129 if (evbuffer_get_length(bev->input) < bev->wm_read.high)
132 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS);
157 struct bufferevent *bufev = &bufev_private->bev;
191 struct bufferevent *bufev = &bufev_private->bev;
236 (bevp)->bev.ev_base, \
238 bufferevent_incref_(&(bevp)->bev); \
316 struct bufferevent *bufev = &bufev_private->bev;
867 bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd)
872 BEV_LOCK(bev);
873 if (bev->be_ops->ctrl)
874 res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d);
876 event_debug(("%s: cannot set fd for %p to "EV_SOCK_FMT, __func__, bev, fd));
877 BEV_UNLOCK(bev);
882 bufferevent_getfd(struct bufferevent *bev)
887 BEV_LOCK(bev);
888 if (bev->be_ops->ctrl)
889 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d);
891 event_debug(("%s: cannot get fd for %p", __func__, bev));
892 BEV_UNLOCK(bev);
897 bufferevent_get_options_(struct bufferevent *bev)
899 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
902 BEV_LOCK(bev);
904 BEV_UNLOCK(bev);
910 bufferevent_cancel_all_(struct bufferevent *bev)
914 BEV_LOCK(bev);
915 if (bev->be_ops->ctrl)
916 bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d);
917 BEV_UNLOCK(bev);
931 bufferevent_get_underlying(struct bufferevent *bev)
936 BEV_LOCK(bev);
937 if (bev->be_ops->ctrl)
938 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_UNDERLYING, &d);
939 BEV_UNLOCK(bev);
946 struct bufferevent *bev = ctx;
947 bufferevent_incref_and_lock_(bev);
948 bufferevent_disable(bev, EV_READ);
949 bufferevent_run_eventcb_(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_READING, 0);
950 bufferevent_decref_and_unlock_(bev);
955 struct bufferevent *bev = ctx;
956 bufferevent_incref_and_lock_(bev);
957 bufferevent_disable(bev, EV_WRITE);
958 bufferevent_run_eventcb_(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_WRITING, 0);
959 bufferevent_decref_and_unlock_(bev);
963 bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev)
965 event_assign(&bev->ev_read, bev->ev_base, -1, EV_FINALIZE,
966 bufferevent_generic_read_timeout_cb, bev);
967 event_assign(&bev->ev_write, bev->ev_base, -1, EV_FINALIZE,
968 bufferevent_generic_write_timeout_cb, bev);
972 bufferevent_generic_adj_timeouts_(struct bufferevent *bev)
974 const short enabled = bev->enabled;
975 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
978 evutil_timerisset(&bev->timeout_read))
979 r1 = event_add(&bev->ev_read, &bev->timeout_read);
981 r1 = event_del(&bev->ev_read);
984 evutil_timerisset(&bev->timeout_write) &&
985 evbuffer_get_length(bev->output))
986 r2 = event_add(&bev->ev_write, &bev->timeout_write);
988 r2 = event_del(&bev->ev_write);
995 bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev)
998 if (event_pending(&bev->ev_read, EV_READ, NULL)) {
999 if (evutil_timerisset(&bev->timeout_read)) {
1000 if (bufferevent_add_event_(&bev->ev_read, &bev->timeout_read) < 0)
1003 event_remove_timer(&bev->ev_read);
1006 if (event_pending(&bev->ev_write, EV_WRITE, NULL)) {
1007 if (evutil_timerisset(&bev->timeout_write)) {
1008 if (bufferevent_add_event_(&bev->ev_write, &bev->timeout_write) < 0)
1011 event_remove_timer(&bev->ev_write);
1029 bufferevent_lock(struct bufferevent *bev)
1031 bufferevent_incref_and_lock_(bev);
1035 bufferevent_unlock(struct bufferevent *bev)
1037 bufferevent_decref_and_unlock_(bev);
Indexes created Mon Mar 30 00:23:01 UTC 2026