Cross Reference: /src/external/bsd/libevent/dist/bufferevent.c

Lines Matching defs:bev
67 static void bufferevent_cancel_all_(struct bufferevent *bev);
125 static void bufferevent_inbuf_wm_check(struct bufferevent *bev)
127 	if (!bev->wm_read.high)
129 	if (!(bev->enabled & EV_READ))
131 	if (evbuffer_get_length(bev->input) < bev->wm_read.high)
134 	bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS);
159 	struct bufferevent *bufev = &bufev_private->bev;
193 	struct bufferevent *bufev = &bufev_private->bev;
238 			    (bevp)->bev.ev_base,			\
240 			bufferevent_incref_(&(bevp)->bev);		\
318 	struct bufferevent *bufev = &bufev_private->bev;
869 bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd)
874 	BEV_LOCK(bev);
875 	if (bev->be_ops->ctrl)
876 		res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d);
878 		event_debug(("%s: cannot set fd for %p to "EV_SOCK_FMT, __func__, bev, fd));
879 	BEV_UNLOCK(bev);
884 bufferevent_getfd(struct bufferevent *bev)
889 	BEV_LOCK(bev);
890 	if (bev->be_ops->ctrl)
891 		res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d);
893 		event_debug(("%s: cannot get fd for %p", __func__, bev));
894 	BEV_UNLOCK(bev);
899 bufferevent_get_options_(struct bufferevent *bev)
901 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
904 	BEV_LOCK(bev);
906 	BEV_UNLOCK(bev);
912 bufferevent_cancel_all_(struct bufferevent *bev)
916 	BEV_LOCK(bev);
917 	if (bev->be_ops->ctrl)
918 		bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d);
919 	BEV_UNLOCK(bev);
933 bufferevent_get_underlying(struct bufferevent *bev)
938 	BEV_LOCK(bev);
939 	if (bev->be_ops->ctrl)
940 		res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_UNDERLYING, &d);
941 	BEV_UNLOCK(bev);
948 	struct bufferevent *bev = ctx;
949 	bufferevent_incref_and_lock_(bev);
950 	bufferevent_disable(bev, EV_READ);
951 	bufferevent_run_eventcb_(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_READING, 0);
952 	bufferevent_decref_and_unlock_(bev);
957 	struct bufferevent *bev = ctx;
958 	bufferevent_incref_and_lock_(bev);
959 	bufferevent_disable(bev, EV_WRITE);
960 	bufferevent_run_eventcb_(bev, BEV_EVENT_TIMEOUT|BEV_EVENT_WRITING, 0);
961 	bufferevent_decref_and_unlock_(bev);
965 bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev)
967 	event_assign(&bev->ev_read, bev->ev_base, -1, EV_FINALIZE,
968 	    bufferevent_generic_read_timeout_cb, bev);
969 	event_assign(&bev->ev_write, bev->ev_base, -1, EV_FINALIZE,
970 	    bufferevent_generic_write_timeout_cb, bev);
974 bufferevent_generic_adj_timeouts_(struct bufferevent *bev)
976 	const short enabled = bev->enabled;
977 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
980 	    evutil_timerisset(&bev->timeout_read))
981 		r1 = event_add(&bev->ev_read, &bev->timeout_read);
983 		r1 = event_del(&bev->ev_read);
986 	    evutil_timerisset(&bev->timeout_write) &&
987 	    evbuffer_get_length(bev->output))
988 		r2 = event_add(&bev->ev_write, &bev->timeout_write);
990 		r2 = event_del(&bev->ev_write);
997 bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev)
1000 	if (event_pending(&bev->ev_read, EV_READ, NULL)) {
1001 		if (evutil_timerisset(&bev->timeout_read)) {
1002 			    if (bufferevent_add_event_(&bev->ev_read, &bev->timeout_read) < 0)
1005 			event_remove_timer(&bev->ev_read);
1008 	if (event_pending(&bev->ev_write, EV_WRITE, NULL)) {
1009 		if (evutil_timerisset(&bev->timeout_write)) {
1010 			if (bufferevent_add_event_(&bev->ev_write, &bev->timeout_write) < 0)
1013 			event_remove_timer(&bev->ev_write);
1031 bufferevent_lock(struct bufferevent *bev)
1033 	bufferevent_incref_and_lock_(bev);
1037 bufferevent_unlock(struct bufferevent *bev)
1039 	bufferevent_decref_and_unlock_(bev);
OpenGrok
