Lines Matching defs:bev
89 readcb(struct bufferevent *bev, void *arg)
91 if (evbuffer_get_length(bev->input) == 8333) {
96 bufferevent_read_buffer(bev, evbuf);
98 bufferevent_disable(bev, EV_READ);
109 writecb(struct bufferevent *bev, void *arg)
111 if (evbuffer_get_length(bev->output) == 0) {
117 errorcb(struct bufferevent *bev, short what, void *arg)
189 wm_readcb(struct bufferevent *bev, void *arg)
192 int len = (int)evbuffer_get_length(bev->input);
200 bufferevent_read_buffer(bev, evbuf);
204 bufferevent_disable(bev, EV_READ);
212 wm_writecb(struct bufferevent *bev, void *arg)
214 assert(evbuffer_get_length(bev->output) <= 100);
215 if (evbuffer_get_length(bev->output) == 0) {
216 evbuffer_drain(bev->output, evbuffer_get_length(bev->output));
222 wm_errorcb(struct bufferevent *bev, short what, void *arg)
405 sender_writecb(struct bufferevent *bev, void *ctx)
407 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {
408 bufferevent_disable(bev,EV_READ|EV_WRITE);
409 bufferevent_free(bev);
414 sender_errorcb(struct bufferevent *bev, short what, void *ctx)
430 struct bufferevent *bev;
433 bev = bufferevent_socket_new(base, fd, bufferevent_connect_test_flags);
434 tt_assert(bev);
435 bufferevent_setcb(bev, NULL, sender_writecb, sender_errorcb, NULL);
436 bufferevent_write(bev, s, sizeof(s));
442 reader_eventcb(struct bufferevent *bev, short what, void *ctx)
451 bufferevent_enable(bev, EV_READ);
456 n = bufferevent_read(bev, buf, sizeof(buf)-1);
467 reader_readcb(struct bufferevent *bev, void *ctx)
551 want_fail_eventcb(struct bufferevent *bev, short what, void *ctx)
558 s = bufferevent_getfd(bev);
583 struct bufferevent *bev=NULL;
606 bev = bufferevent_socket_new(data->base, -1,
608 tt_assert(bev);
609 bufferevent_setcb(bev, NULL, NULL, want_fail_eventcb, data->base);
611 r = bufferevent_socket_connect(bev, sa, slen);
631 if (bev)
632 bufferevent_free(bev);
648 bev_timeout_write_cb(struct bufferevent *bev, void *arg)
655 bev_timeout_event_cb(struct bufferevent *bev, short what, void *arg)