Home | History | Annotate | Download | only in test

Lines Matching defs:bev

129 loud_writecb(struct bufferevent *bev, void *ctx)
132 	struct evbuffer *output = bufferevent_get_output(bev);
143 discard_readcb(struct bufferevent *bev, void *ctx)
146 	struct evbuffer *input = bufferevent_get_input(bev);
153 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx)
156 		loud_writecb(bev, ctx);
158 		bufferevent_enable(bev, EV_READ|EV_WRITE);
163 echo_readcb(struct bufferevent *bev, void *ctx)
165 	struct evbuffer *input = bufferevent_get_input(bev);
166 	struct evbuffer *output = bufferevent_get_output(bev);
170 		bufferevent_disable(bev, EV_READ);
174 echo_writecb(struct bufferevent *bev, void *ctx)
176 	struct evbuffer *output = bufferevent_get_output(bev);
178 		bufferevent_enable(bev, EV_READ);
182 echo_eventcb(struct bufferevent *bev, short what, void *ctx)
186 		bufferevent_free(bev);
196 	struct bufferevent *bev;
198 	bev = bufferevent_socket_new(base, newsock, flags);
199 	bufferevent_setcb(bev, echo_readcb, echo_writecb, echo_eventcb, NULL);
202 		    event_new(base, -1, EV_PERSIST, check_bucket_levels_cb, bev);
203 		bufferevent_set_rate_limit(bev, conn_bucket_cfg);
205 		assert(bufferevent_get_token_bucket_cfg(bev) != NULL);
209 		bufferevent_add_to_rate_limit_group(bev, ratelim_group);
211 	bufferevent_enable(bev, EV_READ|EV_WRITE);
218 	struct bufferevent *bev = arg;
220 	ev_ssize_t r = bufferevent_get_read_limit(bev);
221 	ev_ssize_t w = bufferevent_get_write_limit(bev);
222 	ev_ssize_t rm = bufferevent_get_max_to_read(bev);
223 	ev_ssize_t wm = bufferevent_get_max_to_write(bev);
241 		event_free(event_base_get_running_event(bufferevent_get_base(bev)));