Lines Matching refs:bev
243 http_readcb(struct bufferevent *bev, void *arg) in http_readcb() argument
248 if (evbuffer_contains(bufferevent_get_input(bev), what)) { in http_readcb()
253 done = evhttp_parse_firstline_(req, bufferevent_get_input(bev)); in http_readcb()
257 done = evhttp_parse_headers_(req, bufferevent_get_input(bev)); in http_readcb()
268 bufferevent_disable(bev, EV_READ); in http_readcb()
281 http_writecb(struct bufferevent *bev, void *arg) in http_writecb() argument
283 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_writecb()
285 bufferevent_enable(bev, EV_READ); in http_writecb()
291 http_errorcb(struct bufferevent *bev, short what, void *arg) in http_errorcb() argument
420 struct bufferevent *bev = arg; in http_complete_write() local
424 bufferevent_write(bev, http_request, strlen(http_request)); in http_complete_write()
431 struct bufferevent *bev = NULL; in create_bev() local
434 bev = bufferevent_socket_new(base, fd, flags); in create_bev()
441 bev = bufferevent_openssl_filter_new( in create_bev()
444 bev = bufferevent_openssl_socket_new( in create_bev()
447 bufferevent_openssl_set_allow_dirty_shutdown(bev, 1); in create_bev()
451 return bev; in create_bev()
459 struct bufferevent *bev = NULL; in http_basic_test_impl() local
478 bev = create_bev(data->base, fd, ssl); in http_basic_test_impl()
479 bufferevent_setcb(bev, http_readcb, http_writecb, in http_basic_test_impl()
487 bufferevent_write(bev, http_request, strlen(http_request)); in http_basic_test_impl()
491 -1, EV_TIMEOUT, http_complete_write, bev, &tv); in http_basic_test_impl()
498 bufferevent_free(bev); in http_basic_test_impl()
504 bev = create_bev(data->base, fd, ssl); in http_basic_test_impl()
505 bufferevent_setcb(bev, http_readcb, http_writecb, in http_basic_test_impl()
514 bufferevent_write(bev, http_request, strlen(http_request)); in http_basic_test_impl()
521 bufferevent_free(bev); in http_basic_test_impl()
527 bev = create_bev(data->base, fd, ssl); in http_basic_test_impl()
528 bufferevent_setcb(bev, http_readcb, http_writecb, in http_basic_test_impl()
537 bufferevent_write(bev, http_request, strlen(http_request)); in http_basic_test_impl()
545 if (bev) in http_basic_test_impl()
546 bufferevent_free(bev); in http_basic_test_impl()
586 http_badreq_errorcb(struct bufferevent *bev, short what, void *arg) in http_badreq_errorcb() argument
593 http_badreq_readcb(struct bufferevent *bev, void *arg) in http_badreq_readcb() argument
598 if (evbuffer_contains(bufferevent_get_input(bev), bad_request)) { in http_badreq_readcb()
600 bufferevent_disable(bev, EV_READ); in http_badreq_readcb()
605 if (evbuffer_contains(bufferevent_get_input(bev), what)) { in http_badreq_readcb()
610 done = evhttp_parse_firstline_(req, bufferevent_get_input(bev)); in http_badreq_readcb()
614 done = evhttp_parse_headers_(req, bufferevent_get_input(bev)); in http_badreq_readcb()
625 evbuffer_drain(bufferevent_get_input(bev), evbuffer_get_length(bufferevent_get_input(bev))); in http_badreq_readcb()
628 shutdown(bufferevent_getfd(bev), EVUTIL_SHUT_WR); in http_badreq_readcb()
643 struct bufferevent *bev = NULL; in http_bad_request_test() local
661 bev = bufferevent_socket_new(data->base, fd, 0); in http_bad_request_test()
662 bufferevent_setcb(bev, http_badreq_readcb, http_writecb, in http_bad_request_test()
664 bufferevent_enable(bev, EV_READ); in http_bad_request_test()
669 bufferevent_write(bev, http_request, strlen(http_request)); in http_bad_request_test()
674 event_base_once(data->base, -1, EV_TIMEOUT, http_badreq_successcb, bev, &tv); in http_bad_request_test()
678 bufferevent_free(bev); in http_bad_request_test()
692 bev = bufferevent_socket_new(data->base, fd, 0); in http_bad_request_test()
693 bufferevent_setcb(bev, http_badreq_readcb, http_writecb, in http_bad_request_test()
695 bufferevent_enable(bev, EV_READ); in http_bad_request_test()
703 bufferevent_write(bev, http_request, strlen(http_request)); in http_bad_request_test()
707 event_base_once(data->base, -1, EV_TIMEOUT, http_badreq_successcb, bev, &tv); in http_bad_request_test()
715 if (bev) in http_bad_request_test()
716 bufferevent_free(bev); in http_bad_request_test()
764 struct bufferevent *bev; in http_delete_test() local
778 bev = bufferevent_socket_new(data->base, fd, 0); in http_delete_test()
779 bufferevent_setcb(bev, http_readcb, http_writecb, in http_delete_test()
788 bufferevent_write(bev, http_request, strlen(http_request)); in http_delete_test()
792 bufferevent_free(bev); in http_delete_test()
848 struct bufferevent *bev; in http_on_complete_test() local
861 bev = bufferevent_socket_new(data->base, fd, 0); in http_on_complete_test()
862 bufferevent_setcb(bev, http_readcb, http_writecb, in http_on_complete_test()
871 bufferevent_write(bev, http_request, strlen(http_request)); in http_on_complete_test()
875 bufferevent_free(bev); in http_on_complete_test()
886 http_allowed_methods_eventcb(struct bufferevent *bev, short what, void *arg) in http_allowed_methods_eventcb() argument
892 n = evbuffer_remove(bufferevent_get_input(bev), buf, in http_allowed_methods_eventcb()
1040 struct bufferevent *bev = bufferevent_openssl_socket_new( in http_connection_test_() local
1043 bufferevent_openssl_set_allow_dirty_shutdown(bev, 1); in http_connection_test_()
1045 evcon = evhttp_connection_base_bufferevent_new(data->base, dnsbase, bev, address, port); in http_connection_test_()
1627 struct bufferevent *bev; in http_virtual_host_test() local
1749 bev = bufferevent_socket_new(data->base, fd, 0); in http_virtual_host_test()
1750 bufferevent_setcb(bev, http_readcb, http_writecb, in http_virtual_host_test()
1760 bufferevent_write(bev, http_request, strlen(http_request)); in http_virtual_host_test()
1766 bufferevent_free(bev); in http_virtual_host_test()
2171 http_failure_readcb(struct bufferevent *bev, void *arg) in http_failure_readcb() argument
2174 if (evbuffer_contains(bufferevent_get_input(bev), what)) { in http_failure_readcb()
2176 bufferevent_disable(bev, EV_READ); in http_failure_readcb()
2188 struct bufferevent *bev; in http_failure_test() local
2200 bev = bufferevent_socket_new(data->base, fd, 0); in http_failure_test()
2201 bufferevent_setcb(bev, http_failure_readcb, http_writecb, in http_failure_test()
2206 bufferevent_write(bev, http_request, strlen(http_request)); in http_failure_test()
2210 bufferevent_free(bev); in http_failure_test()
2954 struct bufferevent *bev; in http_base_test() local
2969 bev = bufferevent_socket_new(base, fd, 0); in http_base_test()
2970 bufferevent_setcb(bev, http_readcb, http_writecb, in http_base_test()
2972 bufferevent_base_set(base, bev); in http_base_test()
2980 bufferevent_write(bev, http_request, strlen(http_request)); in http_base_test()
2984 bufferevent_free(bev); in http_base_test()
3002 http_incomplete_readcb(struct bufferevent *bev, void *arg) in http_incomplete_readcb() argument
3009 http_incomplete_errorcb(struct bufferevent *bev, short what, void *arg) in http_incomplete_errorcb() argument
3023 http_incomplete_writecb(struct bufferevent *bev, void *arg) in http_incomplete_writecb() argument
3030 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_incomplete_writecb()
3032 bufferevent_enable(bev, EV_READ); in http_incomplete_writecb()
3040 struct bufferevent *bev; in http_incomplete_test_() local
3056 bev = create_bev(data->base, fd, ssl); in http_incomplete_test_()
3057 bufferevent_setcb(bev, in http_incomplete_test_()
3065 bufferevent_write(bev, http_request, strlen(http_request)); in http_incomplete_test_()
3074 bufferevent_free(bev); in http_incomplete_test_()
3105 http_chunked_readcb(struct bufferevent *bev, void *arg) in http_chunked_readcb() argument
3111 http_chunked_errorcb(struct bufferevent *bev, short what, void *arg) in http_chunked_errorcb() argument
3130 done = evhttp_parse_firstline_(req, bufferevent_get_input(bev)); in http_chunked_errorcb()
3134 done = evhttp_parse_headers_(req, bufferevent_get_input(bev)); in http_chunked_errorcb()
3146 header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); in http_chunked_errorcb()
3156 if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 13), in http_chunked_errorcb()
3160 evbuffer_drain(bufferevent_get_input(bev), 13 + 2); in http_chunked_errorcb()
3162 header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); in http_chunked_errorcb()
3170 if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 18), in http_chunked_errorcb()
3174 evbuffer_drain(bufferevent_get_input(bev), 18 + 2); in http_chunked_errorcb()
3176 header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); in http_chunked_errorcb()
3186 if (strncmp((char *)evbuffer_pullup(bufferevent_get_input(bev), 8), in http_chunked_errorcb()
3190 evbuffer_drain(bufferevent_get_input(bev), 8 + 2); in http_chunked_errorcb()
3192 header = evbuffer_readln(bufferevent_get_input(bev), NULL, EVBUFFER_EOL_CRLF); in http_chunked_errorcb()
3213 http_chunked_writecb(struct bufferevent *bev, void *arg) in http_chunked_writecb() argument
3215 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_chunked_writecb()
3217 bufferevent_enable(bev, EV_READ); in http_chunked_writecb()
3256 struct bufferevent *bev; in http_chunk_out_test_impl() local
3272 bev = create_bev(data->base, fd, ssl); in http_chunk_out_test_impl()
3273 bufferevent_setcb(bev, in http_chunk_out_test_impl()
3283 bufferevent_write(bev, http_request, strlen(http_request)); in http_chunk_out_test_impl()
3289 bufferevent_free(bev); in http_chunk_out_test_impl()
3299 bev = create_bev(data->base, -1, ssl); in http_chunk_out_test_impl()
3301 data->base, NULL, bev, "127.0.0.1", port); in http_chunk_out_test_impl()
3339 struct bufferevent *bev; in http_stream_out_test_impl() local
3345 bev = create_bev(data->base, -1, ssl); in http_stream_out_test_impl()
3347 data->base, NULL, bev, "127.0.0.1", port); in http_stream_out_test_impl()
3536 struct bufferevent *bev; in http_connection_fail_test_impl() local
3545 bev = create_bev(data->base, -1, ssl); in http_connection_fail_test_impl()
3549 data->base, NULL, bev, "239.10.20.30", 80); in http_connection_fail_test_impl()
3610 struct bufferevent *bev; in http_simple_test_impl() local
3617 bev = create_bev(data->base, -1, ssl); in http_simple_test_impl()
3619 bufferevent_openssl_set_allow_dirty_shutdown(bev, dirty); in http_simple_test_impl()
3623 data->base, NULL, bev, "127.0.0.1", hs.port); in http_simple_test_impl()
3653 struct bufferevent *bev; in http_connection_retry_test_basic() local
3663 bev = create_bev(data->base, -1, ssl); in http_connection_retry_test_basic()
3664 evcon = evhttp_connection_base_bufferevent_new(data->base, dns_base, bev, addr, hs.port); in http_connection_retry_test_basic()
3846 struct bufferevent *bev= NULL; in http_multi_line_header_test() local
3862 bev = bufferevent_socket_new(data->base, fd, 0); in http_multi_line_header_test()
3863 tt_ptr_op(bev, !=, NULL); in http_multi_line_header_test()
3864 bufferevent_setcb(bev, http_readcb, http_writecb, in http_multi_line_header_test()
3879 bufferevent_write(bev, http_start_request, strlen(http_start_request)); in http_multi_line_header_test()
3888 if (bev) in http_multi_line_header_test()
3889 bufferevent_free(bev); in http_multi_line_header_test()
4160 struct bufferevent *bev; member
4236 bufferevent_free(state->bev); in terminate_chunked_client()
4241 terminate_readcb(struct bufferevent *bev, void *arg) in terminate_readcb() argument
4244 evbuffer_drain(bufferevent_get_input(bev), -1); in terminate_readcb()
4252 struct bufferevent *bev = NULL; in http_terminate_chunked_test_impl() local
4269 bev = bufferevent_socket_new(data->base, fd, 0); in http_terminate_chunked_test_impl()
4270 bufferevent_setcb(bev, terminate_readcb, http_writecb, in http_terminate_chunked_test_impl()
4276 terminate_state.bev = bev; in http_terminate_chunked_test_impl()
4285 bufferevent_write(bev, http_request, strlen(http_request)); in http_terminate_chunked_test_impl()
4431 struct bufferevent *bev = arg; in http_write_during_read() local
4434 bufferevent_write(bev, "foobar", strlen("foobar")); in http_write_during_read()
4445 struct bufferevent *bev = NULL; in http_write_during_read_test_impl() local
4455 bev = create_bev(data->base, fd, 0); in http_write_during_read_test_impl()
4456 bufferevent_setcb(bev, NULL, NULL, NULL, data->base); in http_write_during_read_test_impl()
4457 bufferevent_disable(bev, EV_READ); in http_write_during_read_test_impl()
4464 bufferevent_write(bev, http_request, strlen(http_request)); in http_write_during_read_test_impl()
4467 event_base_once(data->base, -1, EV_TIMEOUT, http_write_during_read, bev, &tv); in http_write_during_read_test_impl()
4471 if (bev) in http_write_during_read_test_impl()
4472 bufferevent_free(bev); in http_write_during_read_test_impl()