Lines Matching defs:bev
92 readcb(struct bufferevent *bev, void *arg)
94 if (evbuffer_get_length(bev->input) == 8333) {
99 bufferevent_read_buffer(bev, evbuf);
101 bufferevent_disable(bev, EV_READ);
112 writecb(struct bufferevent *bev, void *arg)
114 if (evbuffer_get_length(bev->output) == 0) {
120 errorcb(struct bufferevent *bev, short what, void *arg)
354 wm_readcb(struct bufferevent *bev, void *arg)
357 int len = (int)evbuffer_get_length(bev->input);
365 bufferevent_read_buffer(bev, evbuf);
369 bufferevent_disable(bev, EV_READ);
377 wm_writecb(struct bufferevent *bev, void *arg)
379 assert(evbuffer_get_length(bev->output) <= 100);
380 if (evbuffer_get_length(bev->output) == 0) {
381 evbuffer_drain(bev->output, evbuffer_get_length(bev->output));
387 wm_errorcb(struct bufferevent *bev, short what, void *arg)
604 sender_writecb(struct bufferevent *bev, void *ctx)
606 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {
607 bufferevent_disable(bev,EV_READ|EV_WRITE);
608 TT_BLATHER(("Flushed %d: freeing it.", (int)bufferevent_getfd(bev)));
609 bufferevent_free(bev);
614 sender_errorcb(struct bufferevent *bev, short what, void *ctx)
632 struct bufferevent *bev;
635 bev = bufferevent_socket_new(base, fd, bufferevent_connect_test_flags);
636 tt_assert(bev);
637 bufferevent_setcb(bev, NULL, sender_writecb, sender_errorcb, NULL);
638 bufferevent_write(bev, s, sizeof(s));
669 reader_eventcb(struct bufferevent *bev, short what, void *ctx)
678 TT_BLATHER(("connected on %d", (int)bufferevent_getfd(bev)));
679 bufferevent_enable(bev, EV_READ);
684 n = bufferevent_read(bev, buf, sizeof(buf)-1);
691 (int)bufferevent_getfd(bev), n_strings_read));
698 reader_eventcb_simple(struct bufferevent *bev, short what, void *ctx)
701 (int)bufferevent_getfd(bev)));
706 reader_readcb(struct bufferevent *bev, void *ctx)
708 TT_BLATHER(("Read invoked on %d.", (int)bufferevent_getfd(bev)));
795 struct bufferevent *bev = NULL;
805 bev = bufferevent_socket_new(data->base, -1, flags);
806 tt_assert(bev);
807 bufferevent_setcb(bev, reader_readcb, reader_readcb,
809 bufferevent_enable(bev, EV_READ|EV_WRITE);
813 bufferevent_socket_connect(bev, (struct sockaddr *)&localhost, slen);
823 if (bev)
824 bufferevent_free(bev);
830 want_fail_eventcb(struct bufferevent *bev, short what, void *ctx)
837 s = bufferevent_getfd(bev);
863 struct bufferevent *bev=NULL;
875 bev = bufferevent_socket_new(data->base, -1,
877 tt_assert(bev);
878 bufferevent_setcb(bev, NULL, NULL, want_fail_eventcb, data->base);
880 r = bufferevent_socket_connect(bev, (struct sockaddr *)&localhost, slen);
900 if (bev)
901 bufferevent_free(bev);
917 bev_timeout_write_cb(struct bufferevent *bev, void *arg)
924 bev_timeout_event_cb(struct bufferevent *bev, short what, void *arg)
1056 trigger_eventcb(struct bufferevent *bev, short what, void *ctx)
1064 reader_eventcb(bev, what, ctx);
1068 trigger_readcb_triggered(struct bufferevent *bev, void *ctx)
1072 bufferevent_trigger_event(bev, ~0, bufferevent_trigger_test_flags);
1076 trigger_readcb(struct bufferevent *bev, void *ctx)
1083 TT_BLATHER(("Read invoked on %d.", (int)bufferevent_getfd(bev)));
1086 bufferevent_setcb(bev, trigger_readcb_triggered, NULL, trigger_eventcb, ctx);
1088 bufferevent_getwatermark(bev, EV_READ, &low, &high);
1089 len = evbuffer_get_length(bufferevent_get_input(bev));
1091 bufferevent_setwatermark(bev, EV_READ, len + 1, 0);
1092 bufferevent_trigger(bev, EV_READ, bufferevent_trigger_test_flags);
1105 bufferevent_trigger(bev, EV_READ,
1109 bufferevent_setwatermark(bev, EV_READ, low, high);
1119 struct bufferevent *bev=NULL;
1156 bev = bufferevent_socket_new(data->base, -1, be_flags);
1157 tt_assert(bev);
1158 bufferevent_setcb(bev, trigger_readcb, NULL, trigger_eventcb, data->base);
1160 bufferevent_enable(bev, EV_READ);
1162 tt_want(!bufferevent_socket_connect(bev, sa, sizeof(localhost)));
1171 if (bev)
1172 bufferevent_free(bev);
1179 struct bufferevent *bev = NULL, *bevf = NULL;
1181 bev = bufferevent_socket_new(data->base, -1, 0);
1182 tt_assert(bev);
1183 bevf = bufferevent_filter_new(bev, NULL, NULL, 0, NULL, NULL);
1189 if (bev)
1190 bufferevent_free(bev);
1194 pair_flush_eventcb(struct bufferevent *bev, short what, void *ctx)
1236 bufferevent_filter_data_stuck_readcb(struct bufferevent *bev, void *arg)
1239 struct evbuffer *input = bufferevent_get_input(bev);