Lines Matching refs:bev

128 loud_writecb(struct bufferevent *bev, void *ctx)  in loud_writecb()  argument
131 struct evbuffer *output = bufferevent_get_output(bev); in loud_writecb()
142 discard_readcb(struct bufferevent *bev, void *ctx) in discard_readcb() argument
145 struct evbuffer *input = bufferevent_get_input(bev); in discard_readcb()
152 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) in write_on_connectedcb() argument
155 loud_writecb(bev, ctx); in write_on_connectedcb()
157 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
162 echo_readcb(struct bufferevent *bev, void *ctx) in echo_readcb() argument
164 struct evbuffer *input = bufferevent_get_input(bev); in echo_readcb()
165 struct evbuffer *output = bufferevent_get_output(bev); in echo_readcb()
169 bufferevent_disable(bev, EV_READ); in echo_readcb()
173 echo_writecb(struct bufferevent *bev, void *ctx) in echo_writecb() argument
175 struct evbuffer *output = bufferevent_get_output(bev); in echo_writecb()
177 bufferevent_enable(bev, EV_READ); in echo_writecb()
181 echo_eventcb(struct bufferevent *bev, short what, void *ctx) in echo_eventcb() argument
185 bufferevent_free(bev); in echo_eventcb()
195 struct bufferevent *bev; in echo_listenercb() local
197 bev = bufferevent_socket_new(base, newsock, flags); in echo_listenercb()
198 bufferevent_setcb(bev, echo_readcb, echo_writecb, echo_eventcb, NULL); in echo_listenercb()
201 event_new(base, -1, EV_PERSIST, check_bucket_levels_cb, bev); in echo_listenercb()
202 bufferevent_set_rate_limit(bev, conn_bucket_cfg); in echo_listenercb()
204 assert(bufferevent_get_token_bucket_cfg(bev) != NULL); in echo_listenercb()
208 bufferevent_add_to_rate_limit_group(bev, ratelim_group); in echo_listenercb()
210 bufferevent_enable(bev, EV_READ|EV_WRITE); in echo_listenercb()
217 struct bufferevent *bev = arg; in check_bucket_levels_cb() local
219 ev_ssize_t r = bufferevent_get_read_limit(bev); in check_bucket_levels_cb()
220 ev_ssize_t w = bufferevent_get_write_limit(bev); in check_bucket_levels_cb()
221 ev_ssize_t rm = bufferevent_get_max_to_read(bev); in check_bucket_levels_cb()
222 ev_ssize_t wm = bufferevent_get_max_to_write(bev); in check_bucket_levels_cb()
240 event_free(event_base_get_running_event(bufferevent_get_base(bev))); in check_bucket_levels_cb()