105 readcb(struct bufferevent *bev, void *arg)  in readcb()  argument
107 	if (evbuffer_get_length(bev->input) == 8333) {  in readcb()
112 		bufferevent_read_buffer(bev, evbuf);  in readcb()
114 		bufferevent_disable(bev, EV_READ);  in readcb()
125 writecb(struct bufferevent *bev, void *arg)  in writecb()  argument
127 	if (evbuffer_get_length(bev->output) == 0) {  in writecb()
133 errorcb(struct bufferevent *bev, short what, void *arg)  in errorcb()  argument
367 wm_readcb(struct bufferevent *bev, void *arg)  in wm_readcb()  argument
370 	int len = (int)evbuffer_get_length(bev->input);  in wm_readcb()
378 	bufferevent_read_buffer(bev, evbuf);  in wm_readcb()
382 		bufferevent_disable(bev, EV_READ);  in wm_readcb()
390 wm_writecb(struct bufferevent *bev, void *arg)  in wm_writecb()  argument
392 	assert(evbuffer_get_length(bev->output) <= 100);  in wm_writecb()
393 	if (evbuffer_get_length(bev->output) == 0) {  in wm_writecb()
394 		evbuffer_drain(bev->output, evbuffer_get_length(bev->output));  in wm_writecb()
400 wm_errorcb(struct bufferevent *bev, short what, void *arg)  in wm_errorcb()  argument
617 sender_writecb(struct bufferevent *bev, void *ctx)  in sender_writecb()  argument
619 	if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {  in sender_writecb()
620 		bufferevent_disable(bev,EV_READ|EV_WRITE);  in sender_writecb()
621 		TT_BLATHER(("Flushed %d: freeing it.", (int)bufferevent_getfd(bev)));  in sender_writecb()
622 		bufferevent_free(bev);  in sender_writecb()
627 sender_errorcb(struct bufferevent *bev, short what, void *ctx)  in sender_errorcb()  argument
645 	struct bufferevent *bev;  in listen_cb()  local
648 	bev = bufferevent_socket_new(base, fd, bufferevent_connect_test_flags);  in listen_cb()
649 	tt_assert(bev);  in listen_cb()
650 	bufferevent_setcb(bev, NULL, sender_writecb, sender_errorcb, NULL);  in listen_cb()
651 	bufferevent_write(bev, s, sizeof(s));  in listen_cb()
682 reader_eventcb(struct bufferevent *bev, short what, void *ctx)  in reader_eventcb()  argument
691 		TT_BLATHER(("connected on %d", (int)bufferevent_getfd(bev)));  in reader_eventcb()
692 		bufferevent_enable(bev, EV_READ);  in reader_eventcb()
697 		n = bufferevent_read(bev, buf, sizeof(buf)-1);  in reader_eventcb()
704 			(int)bufferevent_getfd(bev), n_strings_read));  in reader_eventcb()
711 reader_eventcb_simple(struct bufferevent *bev, short what, void *ctx)  in reader_eventcb_simple()  argument
714 		(int)bufferevent_getfd(bev)));  in reader_eventcb_simple()
719 reader_readcb(struct bufferevent *bev, void *ctx)  in reader_readcb()  argument
721 	TT_BLATHER(("Read invoked on %d.", (int)bufferevent_getfd(bev)));  in reader_readcb()
819 	struct bufferevent *bev = NULL;  in test_bufferevent_connect_fail_eventcb()  local
831 	bev = bufferevent_socket_new(data->base, -1, flags);  in test_bufferevent_connect_fail_eventcb()
832 	tt_assert(bev);  in test_bufferevent_connect_fail_eventcb()
833 	bufferevent_setcb(bev, reader_readcb, reader_readcb,  in test_bufferevent_connect_fail_eventcb()
835 	bufferevent_enable(bev, EV_READ|EV_WRITE);  in test_bufferevent_connect_fail_eventcb()
840 	r = bufferevent_socket_connect(bev, (struct sockaddr *)&localhost, slen);  in test_bufferevent_connect_fail_eventcb()
861 	if (bev)  in test_bufferevent_connect_fail_eventcb()
862 		bufferevent_free(bev);  in test_bufferevent_connect_fail_eventcb()
868 want_fail_eventcb(struct bufferevent *bev, short what, void *ctx)  in want_fail_eventcb()  argument
875 		s = bufferevent_getfd(bev);  in want_fail_eventcb()
891 	struct bufferevent *bev=NULL;  in test_bufferevent_connect_fail()  local
903 	bev = bufferevent_socket_new(data->base, -1,  in test_bufferevent_connect_fail()
905 	tt_assert(bev);  in test_bufferevent_connect_fail()
906 	bufferevent_setcb(bev, NULL, NULL, want_fail_eventcb, data->base);  in test_bufferevent_connect_fail()
908 	r = bufferevent_socket_connect(bev, (struct sockaddr *)&localhost, slen);  in test_bufferevent_connect_fail()
928 	if (bev)  in test_bufferevent_connect_fail()
929 		bufferevent_free(bev);  in test_bufferevent_connect_fail()
946 bev_timeout_read_cb(struct bufferevent *bev, void *arg)  in bev_timeout_read_cb()  argument
952 bev_timeout_write_cb(struct bufferevent *bev, void *arg)  in bev_timeout_write_cb()  argument
958 bev_timeout_event_cb(struct bufferevent *bev, short what, void *arg)  in bev_timeout_event_cb()  argument
1083 trigger_eventcb(struct bufferevent *bev, short what, void *ctx)  in trigger_eventcb()  argument
1091 	reader_eventcb(bev, what, ctx);  in trigger_eventcb()
1095 trigger_readcb_triggered(struct bufferevent *bev, void *ctx)  in trigger_readcb_triggered()  argument
1099 	bufferevent_trigger_event(bev, ~0, bufferevent_trigger_test_flags);  in trigger_readcb_triggered()
1103 trigger_readcb(struct bufferevent *bev, void *ctx)  in trigger_readcb()  argument
1110 	TT_BLATHER(("Read invoked on %d.", (int)bufferevent_getfd(bev)));  in trigger_readcb()
1113 	bufferevent_setcb(bev, trigger_readcb_triggered, NULL, trigger_eventcb, ctx);  in trigger_readcb()
1115 	bufferevent_getwatermark(bev, EV_READ, &low, &high);  in trigger_readcb()
1116 	len = evbuffer_get_length(bufferevent_get_input(bev));  in trigger_readcb()
1118 	bufferevent_setwatermark(bev, EV_READ, len + 1, 0);  in trigger_readcb()
1119 	bufferevent_trigger(bev, EV_READ, bufferevent_trigger_test_flags);  in trigger_readcb()
1132 	bufferevent_trigger(bev, EV_READ,  in trigger_readcb()
1136 	bufferevent_setwatermark(bev, EV_READ, low, high);  in trigger_readcb()
1146 	struct bufferevent *bev=NULL;  in test_bufferevent_trigger()  local
1183 	bev = bufferevent_socket_new(data->base, -1, be_flags);  in test_bufferevent_trigger()
1184 	tt_assert(bev);  in test_bufferevent_trigger()
1185 	bufferevent_setcb(bev, trigger_readcb, NULL, trigger_eventcb, data->base);  in test_bufferevent_trigger()
1187 	bufferevent_enable(bev, EV_READ);  in test_bufferevent_trigger()
1189 	tt_want(!bufferevent_socket_connect(bev, sa, sizeof(localhost)));  in test_bufferevent_trigger()
1198 	if (bev)  in test_bufferevent_trigger()
1199 		bufferevent_free(bev);  in test_bufferevent_trigger()
1206 	struct bufferevent *bev = NULL, *bevf = NULL;  in test_bufferevent_socket_filter_inactive()  local
1208 	bev = bufferevent_socket_new(data->base, -1, 0);  in test_bufferevent_socket_filter_inactive()
1209 	tt_assert(bev);  in test_bufferevent_socket_filter_inactive()
1210 	bevf = bufferevent_filter_new(bev, NULL, NULL, 0, NULL, NULL);  in test_bufferevent_socket_filter_inactive()
1216 	if (bev)  in test_bufferevent_socket_filter_inactive()
1217 		bufferevent_free(bev);  in test_bufferevent_socket_filter_inactive()
1221 pair_flush_eventcb(struct bufferevent *bev, short what, void *ctx)  in pair_flush_eventcb()  argument
1263 bufferevent_filter_data_stuck_readcb(struct bufferevent *bev, void *arg)  in bufferevent_filter_data_stuck_readcb()  argument
1266 	struct evbuffer *input = bufferevent_get_input(bev);  in bufferevent_filter_data_stuck_readcb()