Lines Matching refs:bev
112 loud_writecb(struct bufferevent *bev, void *ctx) in loud_writecb() argument
115 struct evbuffer *output = bufferevent_get_output(bev); in loud_writecb()
126 discard_readcb(struct bufferevent *bev, void *ctx) in discard_readcb() argument
129 struct evbuffer *input = bufferevent_get_input(bev); in discard_readcb()
136 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) in write_on_connectedcb() argument
139 loud_writecb(bev, ctx); in write_on_connectedcb()
141 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
146 echo_readcb(struct bufferevent *bev, void *ctx) in echo_readcb() argument
148 struct evbuffer *input = bufferevent_get_input(bev); in echo_readcb()
149 struct evbuffer *output = bufferevent_get_output(bev); in echo_readcb()
153 bufferevent_disable(bev, EV_READ); in echo_readcb()
157 echo_writecb(struct bufferevent *bev, void *ctx) in echo_writecb() argument
159 struct evbuffer *output = bufferevent_get_output(bev); in echo_writecb()
161 bufferevent_enable(bev, EV_READ); in echo_writecb()
165 echo_eventcb(struct bufferevent *bev, short what, void *ctx) in echo_eventcb() argument
169 bufferevent_free(bev); in echo_eventcb()
179 struct bufferevent *bev; in echo_listenercb() local
181 bev = bufferevent_socket_new(base, newsock, flags); in echo_listenercb()
182 bufferevent_setcb(bev, echo_readcb, echo_writecb, echo_eventcb, NULL); in echo_listenercb()
185 event_new(base, -1, EV_PERSIST, check_bucket_levels_cb, bev); in echo_listenercb()
186 bufferevent_set_rate_limit(bev, conn_bucket_cfg); in echo_listenercb()
188 assert(bufferevent_get_token_bucket_cfg(bev) != NULL); in echo_listenercb()
192 bufferevent_add_to_rate_limit_group(bev, ratelim_group); in echo_listenercb()
194 bufferevent_enable(bev, EV_READ|EV_WRITE); in echo_listenercb()
201 struct bufferevent *bev = arg; in check_bucket_levels_cb() local
203 ev_ssize_t r = bufferevent_get_read_limit(bev); in check_bucket_levels_cb()
204 ev_ssize_t w = bufferevent_get_write_limit(bev); in check_bucket_levels_cb()
205 ev_ssize_t rm = bufferevent_get_max_to_read(bev); in check_bucket_levels_cb()
206 ev_ssize_t wm = bufferevent_get_max_to_write(bev); in check_bucket_levels_cb()
224 event_free(event_base_get_running_event(bufferevent_get_base(bev))); in check_bucket_levels_cb()