92 readcb(struct bufferevent *bev, void *arg)  in readcb()  argument
94 	if (evbuffer_get_length(bev->input) == 8333) {  in readcb()
99 		bufferevent_read_buffer(bev, evbuf);  in readcb()
101 		bufferevent_disable(bev, EV_READ);  in readcb()
112 writecb(struct bufferevent *bev, void *arg)  in writecb()  argument
114 	if (evbuffer_get_length(bev->output) == 0) {  in writecb()
120 errorcb(struct bufferevent *bev, short what, void *arg)  in errorcb()  argument
341 wm_readcb(struct bufferevent *bev, void *arg)  in wm_readcb()  argument
344 	int len = (int)evbuffer_get_length(bev->input);  in wm_readcb()
352 	bufferevent_read_buffer(bev, evbuf);  in wm_readcb()
356 		bufferevent_disable(bev, EV_READ);  in wm_readcb()
364 wm_writecb(struct bufferevent *bev, void *arg)  in wm_writecb()  argument
366 	assert(evbuffer_get_length(bev->output) <= 100);  in wm_writecb()
367 	if (evbuffer_get_length(bev->output) == 0) {  in wm_writecb()
368 		evbuffer_drain(bev->output, evbuffer_get_length(bev->output));  in wm_writecb()
374 wm_errorcb(struct bufferevent *bev, short what, void *arg)  in wm_errorcb()  argument
577 sender_writecb(struct bufferevent *bev, void *ctx)  in sender_writecb()  argument
579 	if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {  in sender_writecb()
580 		bufferevent_disable(bev,EV_READ|EV_WRITE);  in sender_writecb()
581 		TT_BLATHER(("Flushed %d: freeing it.", (int)bufferevent_getfd(bev)));  in sender_writecb()
582 		bufferevent_free(bev);  in sender_writecb()
587 sender_errorcb(struct bufferevent *bev, short what, void *ctx)  in sender_errorcb()  argument
604 	struct bufferevent *bev;  in listen_cb()  local
607 	bev = bufferevent_socket_new(base, fd, bufferevent_connect_test_flags);  in listen_cb()
608 	tt_assert(bev);  in listen_cb()
609 	bufferevent_setcb(bev, NULL, sender_writecb, sender_errorcb, NULL);  in listen_cb()
610 	bufferevent_write(bev, s, sizeof(s));  in listen_cb()
616 reader_eventcb(struct bufferevent *bev, short what, void *ctx)  in reader_eventcb()  argument
625 		TT_BLATHER(("connected on %d", (int)bufferevent_getfd(bev)));  in reader_eventcb()
626 		bufferevent_enable(bev, EV_READ);  in reader_eventcb()
631 		n = bufferevent_read(bev, buf, sizeof(buf)-1);  in reader_eventcb()
638 			(int)bufferevent_getfd(bev), n_strings_read));  in reader_eventcb()
645 reader_readcb(struct bufferevent *bev, void *ctx)  in reader_readcb()  argument
647 	TT_BLATHER(("Read invoked on %d.", (int)bufferevent_getfd(bev)));  in reader_readcb()
730 want_fail_eventcb(struct bufferevent *bev, short what, void *ctx)  in want_fail_eventcb()  argument
737 		s = bufferevent_getfd(bev);  in want_fail_eventcb()
763 	struct bufferevent *bev=NULL;  in test_bufferevent_connect_fail()  local
786 	bev = bufferevent_socket_new(data->base, -1,  in test_bufferevent_connect_fail()
788 	tt_assert(bev);  in test_bufferevent_connect_fail()
789 	bufferevent_setcb(bev, NULL, NULL, want_fail_eventcb, data->base);  in test_bufferevent_connect_fail()
791 	r = bufferevent_socket_connect(bev, sa, slen);  in test_bufferevent_connect_fail()
811 	if (bev)  in test_bufferevent_connect_fail()
812 		bufferevent_free(bev);  in test_bufferevent_connect_fail()
828 bev_timeout_write_cb(struct bufferevent *bev, void *arg)  in bev_timeout_write_cb()  argument
835 bev_timeout_event_cb(struct bufferevent *bev, short what, void *arg)  in bev_timeout_event_cb()  argument
967 trigger_eventcb(struct bufferevent *bev, short what, void *ctx)  in trigger_eventcb()  argument
975 	reader_eventcb(bev, what, ctx);  in trigger_eventcb()
979 trigger_readcb_triggered(struct bufferevent *bev, void *ctx)  in trigger_readcb_triggered()  argument
983 	bufferevent_trigger_event(bev, ~0, bufferevent_trigger_test_flags);  in trigger_readcb_triggered()
987 trigger_readcb(struct bufferevent *bev, void *ctx)  in trigger_readcb()  argument
994 	TT_BLATHER(("Read invoked on %d.", (int)bufferevent_getfd(bev)));  in trigger_readcb()
997 	bufferevent_setcb(bev, trigger_readcb_triggered, NULL, trigger_eventcb, ctx);  in trigger_readcb()
999 	bufferevent_getwatermark(bev, EV_READ, &low, &high);  in trigger_readcb()
1000 	len = evbuffer_get_length(bufferevent_get_input(bev));  in trigger_readcb()
1002 	bufferevent_setwatermark(bev, EV_READ, len + 1, 0);  in trigger_readcb()
1003 	bufferevent_trigger(bev, EV_READ, bufferevent_trigger_test_flags);  in trigger_readcb()
1016 	bufferevent_trigger(bev, EV_READ,  in trigger_readcb()
1020 	bufferevent_setwatermark(bev, EV_READ, low, high);  in trigger_readcb()
1030 	struct bufferevent *bev=NULL;  in test_bufferevent_trigger()  local
1067 	bev = bufferevent_socket_new(data->base, -1, be_flags);  in test_bufferevent_trigger()
1068 	tt_assert(bev);  in test_bufferevent_trigger()
1069 	bufferevent_setcb(bev, trigger_readcb, NULL, trigger_eventcb, data->base);  in test_bufferevent_trigger()
1071 	bufferevent_enable(bev, EV_READ);  in test_bufferevent_trigger()
1073 	tt_want(!bufferevent_socket_connect(bev, sa, sizeof(localhost)));  in test_bufferevent_trigger()
1082 	if (bev)  in test_bufferevent_trigger()
1083 		bufferevent_free(bev);  in test_bufferevent_trigger()