256 http_readcb(struct bufferevent *bev, void *arg)  in http_readcb()  argument
261 	if (evbuffer_contains(bufferevent_get_input(bev), what)) {  in http_readcb()
266 		done = evhttp_parse_firstline_(req, bufferevent_get_input(bev));  in http_readcb()
270 		done = evhttp_parse_headers_(req, bufferevent_get_input(bev));  in http_readcb()
281 		bufferevent_disable(bev, EV_READ);  in http_readcb()
294 http_writecb(struct bufferevent *bev, void *arg)  in http_writecb()  argument
296 	if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {  in http_writecb()
298 		bufferevent_enable(bev, EV_READ);  in http_writecb()
304 http_errorcb(struct bufferevent *bev, short what, void *arg)  in http_errorcb()  argument
467 	struct bufferevent *bev = NULL;  in create_bev()  local
470 		bev = bufferevent_socket_new(base, fd, flags);  in create_bev()
477 			bev = bufferevent_openssl_filter_new(  in create_bev()
480 			bev = bufferevent_openssl_socket_new(  in create_bev()
483 		bufferevent_openssl_set_allow_dirty_shutdown(bev, 1);  in create_bev()
487 	return bev;  in create_bev()
491 http_half_writecb(struct bufferevent *bev, void *arg)  in http_half_writecb()  argument
493 	if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {  in http_half_writecb()
498 			bufferevent_write(bev, http_request, strlen(http_request));  in http_half_writecb()
501 		bufferevent_enable(bev, EV_READ);  in http_half_writecb()
510 	struct bufferevent *bev = NULL;  in http_basic_test_impl()  local
529 	bev = create_bev(data->base, fd, ssl, BEV_OPT_CLOSE_ON_FREE);  in http_basic_test_impl()
530 	bufferevent_setcb(bev, http_readcb, http_half_writecb,  in http_basic_test_impl()
532 	out = bufferevent_get_output(bev);  in http_basic_test_impl()
544 	bufferevent_free(bev);  in http_basic_test_impl()
549 	bev = create_bev(data->base, fd, ssl, BEV_OPT_CLOSE_ON_FREE);  in http_basic_test_impl()
550 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_basic_test_impl()
552 	out = bufferevent_get_output(bev);  in http_basic_test_impl()
565 	bufferevent_free(bev);  in http_basic_test_impl()
570 	bev = create_bev(data->base, fd, ssl, BEV_OPT_CLOSE_ON_FREE);  in http_basic_test_impl()
571 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_basic_test_impl()
580 	bufferevent_write(bev, http_request, strlen(http_request));  in http_basic_test_impl()
588 	if (bev)  in http_basic_test_impl()
589 		bufferevent_free(bev);  in http_basic_test_impl()
631 http_badreq_errorcb(struct bufferevent *bev, short what, void *arg)  in http_badreq_errorcb()  argument
638 http_badreq_readcb(struct bufferevent *bev, void *arg)  in http_badreq_readcb()  argument
643 	if (evbuffer_contains(bufferevent_get_input(bev), bad_request)) {  in http_badreq_readcb()
645 		bufferevent_disable(bev, EV_READ);  in http_badreq_readcb()
650 	if (evbuffer_contains(bufferevent_get_input(bev), what)) {  in http_badreq_readcb()
655 		done = evhttp_parse_firstline_(req, bufferevent_get_input(bev));  in http_badreq_readcb()
659 		done = evhttp_parse_headers_(req, bufferevent_get_input(bev));  in http_badreq_readcb()
670 		evbuffer_drain(bufferevent_get_input(bev), evbuffer_get_length(bufferevent_get_input(bev)));  in http_badreq_readcb()
673 	shutdown(bufferevent_getfd(bev), EVUTIL_SHUT_WR);  in http_badreq_readcb()
688 	struct bufferevent *bev = NULL;  in http_bad_request_test()  local
706 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_bad_request_test()
707 	bufferevent_setcb(bev, http_badreq_readcb, http_writecb,  in http_bad_request_test()
709 	bufferevent_enable(bev, EV_READ);  in http_bad_request_test()
714 	bufferevent_write(bev, http_request, strlen(http_request));  in http_bad_request_test()
719 	event_base_once(data->base, -1, EV_TIMEOUT, http_badreq_successcb, bev, &tv);  in http_bad_request_test()
723 	bufferevent_free(bev);  in http_bad_request_test()
738 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_bad_request_test()
739 	bufferevent_setcb(bev, http_badreq_readcb, http_writecb,  in http_bad_request_test()
741 	bufferevent_enable(bev, EV_READ);  in http_bad_request_test()
749 	bufferevent_write(bev, http_request, strlen(http_request));  in http_bad_request_test()
753 	event_base_once(data->base, -1, EV_TIMEOUT, http_badreq_successcb, bev, &tv);  in http_bad_request_test()
761 	if (bev)  in http_bad_request_test()
762 		bufferevent_free(bev);  in http_bad_request_test()
810 	struct bufferevent *bev;  in http_delete_test()  local
824 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_delete_test()
825 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_delete_test()
834 	bufferevent_write(bev, http_request, strlen(http_request));  in http_delete_test()
838 	bufferevent_free(bev);  in http_delete_test()
894 	struct bufferevent *bev;  in http_on_complete_test()  local
907 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_on_complete_test()
908 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_on_complete_test()
917 	bufferevent_write(bev, http_request, strlen(http_request));  in http_on_complete_test()
921 	bufferevent_free(bev);  in http_on_complete_test()
932 http_allowed_methods_eventcb(struct bufferevent *bev, short what, void *arg)  in http_allowed_methods_eventcb()  argument
938 		n = evbuffer_remove(bufferevent_get_input(bev), buf,  in http_allowed_methods_eventcb()
1086 		struct bufferevent *bev = bufferevent_openssl_socket_new(  in http_connection_test_()  local
1089 		bufferevent_openssl_set_allow_dirty_shutdown(bev, 1);  in http_connection_test_()
1091 		evcon = evhttp_connection_base_bufferevent_new(data->base, dnsbase, bev, address, port);  in http_connection_test_()
1670 	struct bufferevent *bev;  in http_virtual_host_test()  local
1793 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_virtual_host_test()
1794 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_virtual_host_test()
1804 	bufferevent_write(bev, http_request, strlen(http_request));  in http_virtual_host_test()
1810 	bufferevent_free(bev);  in http_virtual_host_test()
2215 http_failure_readcb(struct bufferevent *bev, void *arg)  in http_failure_readcb()  argument
2218 	if (evbuffer_contains(bufferevent_get_input(bev), what)) {  in http_failure_readcb()
2220 		bufferevent_disable(bev, EV_READ);  in http_failure_readcb()
2232 	struct bufferevent *bev;  in http_failure_test()  local
2244 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_failure_test()
2245 	bufferevent_setcb(bev, http_failure_readcb, http_writecb,  in http_failure_test()
2250 	bufferevent_write(bev, http_request, strlen(http_request));  in http_failure_test()
2254 	bufferevent_free(bev);  in http_failure_test()
3019 	struct bufferevent *bev;  in http_base_test()  local
3034 	bev = bufferevent_socket_new(base, fd, 0);  in http_base_test()
3035 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_base_test()
3037 	bufferevent_base_set(base, bev);  in http_base_test()
3045 	bufferevent_write(bev, http_request, strlen(http_request));  in http_base_test()
3049 	bufferevent_free(bev);  in http_base_test()
3067 http_incomplete_readcb(struct bufferevent *bev, void *arg)  in http_incomplete_readcb()  argument
3074 http_incomplete_errorcb(struct bufferevent *bev, short what, void *arg)  in http_incomplete_errorcb()  argument
3088 http_incomplete_writecb(struct bufferevent *bev, void *arg)  in http_incomplete_writecb()  argument
3095 	if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {  in http_incomplete_writecb()
3097 		bufferevent_enable(bev, EV_READ);  in http_incomplete_writecb()
3105 	struct bufferevent *bev;  in http_incomplete_test_()  local
3121 	bev = create_bev(data->base, fd, ssl, 0);  in http_incomplete_test_()
3122 	bufferevent_setcb(bev,  in http_incomplete_test_()
3130 	bufferevent_write(bev, http_request, strlen(http_request));  in http_incomplete_test_()
3139 	bufferevent_free(bev);  in http_incomplete_test_()
3170 http_chunked_readcb(struct bufferevent *bev, void *arg)  in http_chunked_readcb()  argument
3176 http_chunked_errorcb(struct bufferevent *bev, short what, void *arg)  in http_chunked_errorcb()  argument
3195 		done = evhttp_parse_firstline_(req, bufferevent_get_input(bev));  in http_chunked_errorcb()
3199 		done = evhttp_parse_headers_(req, bufferevent_get_input(bev));  in http_chunked_errorcb()
3211 		header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF);  in http_chunked_errorcb()
3221 		if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 13),  in http_chunked_errorcb()
3225 		evbuffer_drain(bufferevent_get_input(bev), 13 + 2);  in http_chunked_errorcb()
3227 		header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF);  in http_chunked_errorcb()
3235 		if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 18),  in http_chunked_errorcb()
3239 		evbuffer_drain(bufferevent_get_input(bev), 18 + 2);  in http_chunked_errorcb()
3241 		header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF);  in http_chunked_errorcb()
3251 		if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 8),  in http_chunked_errorcb()
3255 		evbuffer_drain(bufferevent_get_input(bev), 8 + 2);  in http_chunked_errorcb()
3257 		header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF);  in http_chunked_errorcb()
3278 http_chunked_writecb(struct bufferevent *bev, void *arg)  in http_chunked_writecb()  argument
3280 	if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {  in http_chunked_writecb()
3282 		bufferevent_enable(bev, EV_READ);  in http_chunked_writecb()
3321 	struct bufferevent *bev = NULL;  in http_chunk_out_test_impl()  local
3338 	bev = create_bev(data->base, fd, ssl, BEV_OPT_CLOSE_ON_FREE);  in http_chunk_out_test_impl()
3339 	bufferevent_setcb(bev,  in http_chunk_out_test_impl()
3349 	bufferevent_write(bev, http_request, strlen(http_request));  in http_chunk_out_test_impl()
3355 	bufferevent_free(bev);  in http_chunk_out_test_impl()
3356 	bev = NULL;  in http_chunk_out_test_impl()
3366 	bev = create_bev(data->base, -1, ssl, BEV_OPT_CLOSE_ON_FREE);  in http_chunk_out_test_impl()
3368 		data->base, NULL, bev, "127.0.0.1", port);  in http_chunk_out_test_impl()
3405 	struct bufferevent *bev;  in http_stream_out_test_impl()  local
3411 	bev = create_bev(data->base, -1, ssl, 0);  in http_stream_out_test_impl()
3413 		data->base, NULL, bev, "127.0.0.1", port);  in http_stream_out_test_impl()
3602 	struct bufferevent *bev;  in http_connection_fail_test_impl()  local
3611 	bev = create_bev(data->base, -1, ssl, 0);  in http_connection_fail_test_impl()
3615 		data->base, NULL, bev, "239.10.20.30", 80);  in http_connection_fail_test_impl()
3676 	struct bufferevent *bev;  in http_simple_test_impl()  local
3683 	bev = create_bev(data->base, -1, ssl, 0);  in http_simple_test_impl()
3685 	bufferevent_openssl_set_allow_dirty_shutdown(bev, dirty);  in http_simple_test_impl()
3689 		data->base, NULL, bev, "127.0.0.1", hs.port);  in http_simple_test_impl()
3720 	struct bufferevent *bev;  in http_connection_retry_test_basic()  local
3730 	bev = create_bev(data->base, -1, ssl, 0);  in http_connection_retry_test_basic()
3731 	evcon = evhttp_connection_base_bufferevent_new(data->base, dns_base, bev, addr, hs.port);  in http_connection_retry_test_basic()
3913 	struct bufferevent *bev= NULL;  in http_multi_line_header_test()  local
3928 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_multi_line_header_test()
3929 	tt_ptr_op(bev, !=, NULL);  in http_multi_line_header_test()
3930 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_multi_line_header_test()
3945 	bufferevent_write(bev, http_start_request, strlen(http_start_request));  in http_multi_line_header_test()
3954 	if (bev)  in http_multi_line_header_test()
3955 		bufferevent_free(bev);  in http_multi_line_header_test()
4221 	struct bufferevent *bev;  member
4297 	bufferevent_free(state->bev);  in terminate_chunked_client()
4302 terminate_readcb(struct bufferevent *bev, void *arg)  in terminate_readcb()  argument
4305 	evbuffer_drain(bufferevent_get_input(bev), -1);  in terminate_readcb()
4313 	struct bufferevent *bev = NULL;  in http_terminate_chunked_test_impl()  local
4331 	bev = bufferevent_socket_new(data->base, fd, 0);  in http_terminate_chunked_test_impl()
4332 	bufferevent_setcb(bev, terminate_readcb, http_writecb,  in http_terminate_chunked_test_impl()
4338 	terminate_state.bev = bev;  in http_terminate_chunked_test_impl()
4347 	bufferevent_write(bev, http_request, strlen(http_request));  in http_terminate_chunked_test_impl()
4493 	struct bufferevent *bev = arg;  in http_write_during_read()  local
4496 	bufferevent_write(bev, "foobar", strlen("foobar"));  in http_write_during_read()
4507 	struct bufferevent *bev = NULL;  in http_write_during_read_test_impl()  local
4518 	bev = create_bev(data->base, fd, 0, 0);  in http_write_during_read_test_impl()
4519 	bufferevent_setcb(bev, NULL, NULL, NULL, data->base);  in http_write_during_read_test_impl()
4520 	bufferevent_disable(bev, EV_READ);  in http_write_during_read_test_impl()
4527 	bufferevent_write(bev, http_request, strlen(http_request));  in http_write_during_read_test_impl()
4530 	event_base_once(data->base, -1, EV_TIMEOUT, http_write_during_read, bev, &tv);  in http_write_during_read_test_impl()
4535 	if (bev)  in http_write_during_read_test_impl()
4536 		bufferevent_free(bev);  in http_write_during_read_test_impl()
4581 	struct bufferevent *bev = NULL;  in http_run_bev_request()  local
4590 	bev = create_bev(base, fd, 0, 0);  in http_run_bev_request()
4591 	bufferevent_setcb(bev, http_readcb, http_writecb,  in http_run_bev_request()
4593 	out = bufferevent_get_output(bev);  in http_run_bev_request()
4602 	if (bev)  in http_run_bev_request()
4603 		bufferevent_free(bev);  in http_run_bev_request()
4609 	struct bufferevent *bev = NULL;  in http_request_extra_body_test()  local
4647 	if (bev)  in http_request_extra_body_test()
4648 		bufferevent_free(bev);  in http_request_extra_body_test()