Lines Matching refs:req
76 static void http_basic_cb(struct evhttp_request *req, void *arg);
77 static void http_timeout_cb(struct evhttp_request *req, void *arg);
78 static void http_large_cb(struct evhttp_request *req, void *arg);
79 static void http_chunked_cb(struct evhttp_request *req, void *arg);
80 static void http_post_cb(struct evhttp_request *req, void *arg);
81 static void http_put_cb(struct evhttp_request *req, void *arg);
82 static void http_delete_cb(struct evhttp_request *req, void *arg);
83 static void http_delay_cb(struct evhttp_request *req, void *arg);
84 static void http_large_delay_cb(struct evhttp_request *req, void *arg);
85 static void http_badreq_cb(struct evhttp_request *req, void *arg);
86 static void http_dispatcher_cb(struct evhttp_request *req, void *arg);
87 static void http_on_complete_cb(struct evhttp_request *req, void *arg);
262 struct evhttp_request *req = evhttp_request_new(NULL, NULL); in http_readcb() local
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()
275 evhttp_find_header(evhttp_request_get_input_headers(req), in http_readcb()
280 evhttp_request_free(req); in http_readcb()
317 http_basic_cb(struct evhttp_request *req, void *arg) in http_basic_cb() argument
321 int empty = evhttp_find_header(evhttp_request_get_input_headers(req), "Empty") != NULL; in http_basic_cb()
326 evcon = evhttp_request_get_connection(req); in http_basic_cb()
350 evhttp_find_header(evhttp_request_get_input_headers(req),"X-Multi"); in http_basic_cb()
355 if (evhttp_find_header(evhttp_request_get_input_headers(req), "X-Last")) in http_basic_cb()
361 evhttp_find_header(evhttp_request_get_input_headers(req),"X-Multi-Extra-WS"); in http_basic_cb()
369 if (evhttp_find_header(evhttp_request_get_input_headers(req), "X-Negative")) in http_basic_cb()
370 evhttp_add_header(evhttp_request_get_output_headers(req), in http_basic_cb()
374 evhttp_send_reply(req, HTTP_OK, "Everything is fine", in http_basic_cb()
383 struct evhttp_request *req = arg; in http_timeout_reply_cb() local
384 evhttp_send_reply(req, HTTP_OK, "Everything is fine", NULL); in http_timeout_reply_cb()
388 http_timeout_cb(struct evhttp_request *req, void *arg) in http_timeout_cb() argument
392 http_timeout_reply_cb, req, &when); in http_timeout_cb()
396 http_large_cb(struct evhttp_request *req, void *arg) in http_large_cb() argument
404 evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb); in http_large_cb()
416 struct evhttp_request *req; member
428 evhttp_send_reply_chunk(state->req, evb); in http_chunked_trickle_cb()
435 evhttp_send_reply_end(state->req); in http_chunked_trickle_cb()
441 http_chunked_cb(struct evhttp_request *req, void *arg) in http_chunked_cb() argument
448 state->req = req; in http_chunked_cb()
451 if (strcmp(evhttp_request_get_uri(req), "/streamed") == 0) { in http_chunked_cb()
452 evhttp_add_header(evhttp_request_get_output_headers(req), "Content-Length", "39"); in http_chunked_cb()
456 evhttp_send_reply_start(req, HTTP_OK, "Everything is fine"); in http_chunked_cb()
600 struct evhttp_request *req = arg; in http_delay_reply() local
602 evhttp_send_reply(req, HTTP_OK, "Everything is fine", NULL); in http_delay_reply()
608 http_delay_cb(struct evhttp_request *req, void *arg) in http_delay_cb() argument
615 event_base_once(arg, -1, EV_TIMEOUT, http_delay_reply, req, &tv); in http_delay_cb()
619 http_badreq_cb(struct evhttp_request *req, void *arg) in http_badreq_cb() argument
623 …evhttp_add_header(evhttp_request_get_output_headers(req), "Content-Type", "text/xml; charset=UTF-8… in http_badreq_cb()
626 evhttp_send_reply(req, HTTP_OK, "OK", buf); in http_badreq_cb()
651 struct evhttp_request *req = evhttp_request_new(NULL, NULL); in http_badreq_readcb() local
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()
664 evhttp_find_header(evhttp_request_get_input_headers(req), in http_badreq_readcb()
669 evhttp_request_free(req); in http_badreq_readcb()
770 http_large_delay_cb(struct evhttp_request *req, void *arg) in http_large_delay_cb() argument
776 event_base_once(arg, -1, EV_TIMEOUT, http_delay_reply, req, &tv); in http_large_delay_cb()
785 http_delete_cb(struct evhttp_request *req, void *arg) in http_delete_cb() argument
788 int empty = evhttp_find_header(evhttp_request_get_input_headers(req), "Empty") != NULL; in http_delete_cb()
791 if (evhttp_request_get_command(req) != EVHTTP_REQ_DELETE) { in http_delete_cb()
800 evhttp_send_reply(req, HTTP_OK, "Everything is fine", in http_delete_cb()
851 http_sent_cb(struct evhttp_request *req, void *arg) in http_sent_cb() argument
861 b = evhttp_request_get_output_buffer(req); in http_sent_cb()
873 http_on_complete_cb(struct evhttp_request *req, void *arg) in http_on_complete_cb() argument
877 evhttp_request_set_on_complete_cb(req, http_sent_cb, (void *)0xDEADBEEF); in http_on_complete_cb()
883 evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb); in http_on_complete_cb()
1066 struct evhttp_request *req = NULL; in http_connection_test_() local
1111 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_connection_test_()
1114 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_connection_test_()
1117 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_connection_test_()
1129 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_connection_test_()
1132 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_connection_test_()
1139 evhttp_add_header(evhttp_request_get_output_headers(req), "Connection", "close"); in http_connection_test_()
1142 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_connection_test_()
1151 req = evhttp_request_new(http_request_empty_done, data->base); in http_connection_test_()
1154 evhttp_add_header(evhttp_request_get_output_headers(req), "Empty", "itis"); in http_connection_test_()
1157 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_connection_test_()
1192 struct evhttp_request *req = NULL; in http_connection_async_test() local
1219 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_connection_async_test()
1222 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_connection_async_test()
1225 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_connection_async_test()
1237 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_connection_async_test()
1240 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_connection_async_test()
1246 evhttp_add_header(evhttp_request_get_output_headers(req), "Connection", "close"); in http_connection_async_test()
1249 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_connection_async_test()
1258 req = evhttp_request_new(http_request_empty_done, data->base); in http_connection_async_test()
1261 evhttp_add_header(evhttp_request_get_output_headers(req), "Empty", "itis"); in http_connection_async_test()
1264 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_connection_async_test()
1286 struct evhttp_request *req[2] = { NULL }; in http_autofree_connection_test() local
1299 req[0] = evhttp_request_new(http_request_empty_done, data->base); in http_autofree_connection_test()
1300 req[1] = evhttp_request_new(http_request_empty_done, data->base); in http_autofree_connection_test()
1303 for (i = 0; i < ARRAY_SIZE(req); ++i) { in http_autofree_connection_test()
1304 evhttp_add_header(evhttp_request_get_output_headers(req[i]), "Host", "somehost"); in http_autofree_connection_test()
1305 evhttp_add_header(evhttp_request_get_output_headers(req[i]), "Connection", "close"); in http_autofree_connection_test()
1306 evhttp_add_header(evhttp_request_get_output_headers(req[i]), "Empty", "itis"); in http_autofree_connection_test()
1308 if (evhttp_make_request(evcon, req[i], EVHTTP_REQ_GET, "/test") == -1) { in http_autofree_connection_test()
1321 for (i = 0; i < ARRAY_SIZE(req); ++i) in http_autofree_connection_test()
1335 http_request_never_call(struct evhttp_request *req, void *arg) in http_request_never_call() argument
1341 http_failed_request_done(struct evhttp_request *req, void *arg) in http_failed_request_done() argument
1343 tt_assert(!req); in http_failed_request_done()
1349 http_timed_out_request_done(struct evhttp_request *req, void *arg) in http_timed_out_request_done() argument
1351 tt_assert(req); in http_timed_out_request_done()
1352 tt_int_op(evhttp_request_get_response_code(req), !=, HTTP_OK); in http_timed_out_request_done()
1378 struct evhttp_request *req = arg; in http_do_cancel() local
1379 evhttp_cancel_request(req); in http_do_cancel()
1410 struct evhttp_request *req; in http_fill_backlog() local
1416 req = evhttp_request_new(http_request_never_call, NULL); in http_fill_backlog()
1417 tt_assert(req); in http_fill_backlog()
1418 tt_int_op(evhttp_make_request(evcon[i], req, EVHTTP_REQ_GET, "/delay"), !=, -1); in http_fill_backlog()
1456 struct evhttp_request *req = NULL; in http_cancel_test() local
1525 req = evhttp_request_new(http_request_never_call, NULL); in http_cancel_test()
1526 evhttp_request_set_error_cb(req, http_request_error_cb_with_cancel); in http_cancel_test()
1529 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_cancel_test()
1532 tt_int_op(evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/delay"), in http_cancel_test()
1539 event_base_once(data->base, -1, EV_TIMEOUT, http_do_cancel, req, &tv); in http_cancel_test()
1555 req = http_cancel_test_bad_request_new(type, data->base); in http_cancel_test()
1556 if (!req) in http_cancel_test()
1557 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_cancel_test()
1560 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_cancel_test()
1563 tt_int_op(evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test"), in http_cancel_test()
1575 req = http_cancel_test_bad_request_new(type, data->base); in http_cancel_test()
1576 if (!req) in http_cancel_test()
1577 req = evhttp_request_new(http_request_empty_done, data->base); in http_cancel_test()
1580 evhttp_add_header(evhttp_request_get_output_headers(req), "Empty", "itis"); in http_cancel_test()
1583 tt_int_op(evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test"), in http_cancel_test()
1606 http_request_no_action_done(struct evhttp_request *req, void *arg) in http_request_no_action_done() argument
1613 http_request_done(struct evhttp_request *req, void *arg) in http_request_done() argument
1617 if (!req) { in http_request_done()
1622 if (evhttp_request_get_response_code(req) != HTTP_OK) { in http_request_done()
1627 if (evhttp_find_header(evhttp_request_get_input_headers(req), "Content-Type") == NULL) { in http_request_done()
1632 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_request_done()
1637 if (evbuffer_datacmp(evhttp_request_get_input_buffer(req), what) != 0) { in http_request_done()
1648 http_request_expect_error(struct evhttp_request *req, void *arg) in http_request_expect_error() argument
1650 if (evhttp_request_get_response_code(req) == HTTP_OK) { in http_request_expect_error()
1667 struct evhttp_request *req = NULL; in http_virtual_host_test() local
1698 req = evhttp_request_new(http_request_expect_error, data->base); in http_virtual_host_test()
1701 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_virtual_host_test()
1704 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_virtual_host_test()
1716 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_virtual_host_test()
1719 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "foo.com"); in http_virtual_host_test()
1722 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_virtual_host_test()
1735 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_virtual_host_test()
1738 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "bar.magic.foo.com"); in http_virtual_host_test()
1741 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_virtual_host_test()
1753 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_virtual_host_test()
1756 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "manolito.info"); in http_virtual_host_test()
1759 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_virtual_host_test()
1771 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_virtual_host_test()
1774 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "bonkers.org:8000"); in http_virtual_host_test()
1777 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_virtual_host_test()
1824 http_request_empty_done(struct evhttp_request *req, void *arg) in http_request_empty_done() argument
1826 if (!req) { in http_request_empty_done()
1831 if (evhttp_request_get_response_code(req) != HTTP_OK) { in http_request_empty_done()
1836 if (evhttp_find_header(evhttp_request_get_input_headers(req), "Date") == NULL) { in http_request_empty_done()
1842 if (evhttp_find_header(evhttp_request_get_input_headers(req), "Content-Length") == NULL) { in http_request_empty_done()
1847 if (strcmp(evhttp_find_header(evhttp_request_get_input_headers(req), "Content-Length"), in http_request_empty_done()
1853 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_request_empty_done()
1868 http_dispatcher_cb(struct evhttp_request *req, void *arg) in http_dispatcher_cb() argument
1875 evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb); in http_dispatcher_cb()
1881 http_dispatcher_test_done(struct evhttp_request *req, void *arg) in http_dispatcher_test_done() argument
1886 if (!req) { in http_dispatcher_test_done()
1891 if (evhttp_request_get_response_code(req) != HTTP_OK) { in http_dispatcher_test_done()
1896 if (evhttp_find_header(evhttp_request_get_input_headers(req), "Content-Type") == NULL) { in http_dispatcher_test_done()
1901 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_dispatcher_test_done()
1903 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(wh… in http_dispatcher_test_done()
1907 if (evbuffer_datacmp(evhttp_request_get_input_buffer(req), what) != 0) { in http_dispatcher_test_done()
1922 struct evhttp_request *req = NULL; in http_dispatcher_test() local
1938 req = evhttp_request_new(http_dispatcher_test_done, data->base); in http_dispatcher_test()
1939 tt_assert(req); in http_dispatcher_test()
1942 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_dispatcher_test()
1944 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/?arg=val") == -1) { in http_dispatcher_test()
1971 struct evhttp_request *req = NULL; in http_post_test() local
1984 req = evhttp_request_new(http_postrequest_done, data->base); in http_post_test()
1985 tt_assert(req); in http_post_test()
1988 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_post_test()
1989 evbuffer_add_printf(evhttp_request_get_output_buffer(req), POST_DATA); in http_post_test()
1991 if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/postit") == -1) { in http_post_test()
2001 req = evhttp_request_new(http_postrequest_done, data->base); in http_post_test()
2002 tt_assert(req); in http_post_test()
2007 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_post_test()
2008 evhttp_add_header(evhttp_request_get_output_headers(req), "Expect", "100-continue"); in http_post_test()
2009 evbuffer_add_printf(evhttp_request_get_output_buffer(req), POST_DATA); in http_post_test()
2011 if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/postit") == -1) { in http_post_test()
2027 http_post_cb(struct evhttp_request *req, void *arg) in http_post_cb() argument
2033 if (evhttp_request_get_command(req) != EVHTTP_REQ_POST) { in http_post_cb()
2038 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(POST_DATA)) { in http_post_cb()
2040 …(unsigned long) evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long) strlen(… in http_post_cb()
2044 if (evbuffer_datacmp(evhttp_request_get_input_buffer(req), POST_DATA) != 0) { in http_post_cb()
2046 fprintf(stdout, "Got :%s\n", evbuffer_pullup(evhttp_request_get_input_buffer(req),-1)); in http_post_cb()
2054 evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb); in http_post_cb()
2060 http_postrequest_done(struct evhttp_request *req, void *arg) in http_postrequest_done() argument
2065 if (req == NULL) { in http_postrequest_done()
2070 if (evhttp_request_get_response_code(req) != HTTP_OK) { in http_postrequest_done()
2076 if (evhttp_find_header(evhttp_request_get_input_headers(req), "Content-Type") == NULL) { in http_postrequest_done()
2081 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_postrequest_done()
2083 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(wh… in http_postrequest_done()
2087 if (evbuffer_datacmp(evhttp_request_get_input_buffer(req), what) != 0) { in http_postrequest_done()
2110 struct evhttp_request *req = NULL; in http_put_test() local
2122 req = evhttp_request_new(http_putrequest_done, data->base); in http_put_test()
2123 tt_assert(req); in http_put_test()
2126 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "someotherhost"); in http_put_test()
2127 evbuffer_add_printf(evhttp_request_get_output_buffer(req), PUT_DATA); in http_put_test()
2129 if (evhttp_make_request(evcon, req, EVHTTP_REQ_PUT, "/putit") == -1) { in http_put_test()
2144 http_put_cb(struct evhttp_request *req, void *arg) in http_put_cb() argument
2150 if (evhttp_request_get_command(req) != EVHTTP_REQ_PUT) { in http_put_cb()
2155 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(PUT_DATA)) { in http_put_cb()
2157 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(PU… in http_put_cb()
2161 if (evbuffer_datacmp(evhttp_request_get_input_buffer(req), PUT_DATA) != 0) { in http_put_cb()
2163 fprintf(stdout, "Got :%s\n", evbuffer_pullup(evhttp_request_get_input_buffer(req),-1)); in http_put_cb()
2171 evhttp_send_reply(req, HTTP_OK, "Everything is great", evb); in http_put_cb()
2177 http_putrequest_done(struct evhttp_request *req, void *arg) in http_putrequest_done() argument
2182 if (req == NULL) { in http_putrequest_done()
2187 if (evhttp_request_get_response_code(req) != HTTP_OK) { in http_putrequest_done()
2193 if (evhttp_find_header(evhttp_request_get_input_headers(req), "Content-Type") == NULL) { in http_putrequest_done()
2198 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_putrequest_done()
2200 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(wh… in http_putrequest_done()
2205 if (evbuffer_datacmp(evhttp_request_get_input_buffer(req), what) != 0) { in http_putrequest_done()
2265 close_detect_done(struct evhttp_request *req, void *arg) in close_detect_done() argument
2268 tt_assert(req); in close_detect_done()
2269 tt_assert(evhttp_request_get_response_code(req) == HTTP_OK); in close_detect_done()
2284 struct evhttp_request *req; in close_detect_launch() local
2286 req = evhttp_request_new(close_detect_done, base); in close_detect_launch()
2289 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in close_detect_launch()
2292 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in close_detect_launch()
2298 close_detect_cb(struct evhttp_request *req, void *arg) in close_detect_cb() argument
2304 if (req != NULL && evhttp_request_get_response_code(req) != HTTP_OK) { in close_detect_cb()
2324 struct evhttp_request *req = NULL; in http_close_detection_() local
2347 req = evhttp_request_new(close_detect_cb, evcon); in http_close_detection_()
2350 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_close_detection_()
2354 req, EVHTTP_REQ_GET, with_delay ? "/largedelay" : "/test") == -1) { in http_close_detection_()
3178 struct evhttp_request *req = NULL; in http_chunked_errorcb() local
3192 req = evhttp_request_new(NULL, NULL); in http_chunked_errorcb()
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()
3203 header = evhttp_find_header(evhttp_request_get_input_headers(req), "Transfer-Encoding"); in http_chunked_errorcb()
3207 header = evhttp_find_header(evhttp_request_get_input_headers(req), "Connection"); in http_chunked_errorcb()
3271 if (req) in http_chunked_errorcb()
3272 evhttp_request_free(req); in http_chunked_errorcb()
3288 http_chunked_request_done(struct evhttp_request *req, void *arg) in http_chunked_request_done() argument
3290 if (evhttp_request_get_response_code(req) != HTTP_OK) { in http_chunked_request_done()
3295 if (evhttp_find_header(evhttp_request_get_input_headers(req), in http_chunked_request_done()
3301 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 13 + 18 + 8) { in http_chunked_request_done()
3306 if (strncmp((char *)evbuffer_pullup(evhttp_request_get_input_buffer(req), 13 + 18 + 8), in http_chunked_request_done()
3327 struct evhttp_request *req = NULL; in http_chunk_out_test_impl() local
3374 req = evhttp_request_new(http_chunked_request_done, data->base); in http_chunk_out_test_impl()
3377 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_chunk_out_test_impl()
3380 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/chunked") == -1) { in http_chunk_out_test_impl()
3404 struct evhttp_request *req = NULL; in http_stream_out_test_impl() local
3421 req = evhttp_request_new(http_request_done, in http_stream_out_test_impl()
3425 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_stream_out_test_impl()
3428 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/streamed") in http_stream_out_test_impl()
3445 http_stream_in_chunk(struct evhttp_request *req, void *arg) in http_stream_in_chunk() argument
3449 if (evhttp_request_get_response_code(req) != HTTP_OK) { in http_stream_in_chunk()
3454 evbuffer_add_buffer(reply, evhttp_request_get_input_buffer(req)); in http_stream_in_chunk()
3458 http_stream_in_done(struct evhttp_request *req, void *arg) in http_stream_in_done() argument
3460 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_stream_in_done()
3477 struct evhttp_request *req = NULL; in http_stream_in_test_() local
3486 req = evhttp_request_new(http_stream_in_done, reply); in http_stream_in_test_()
3487 evhttp_request_set_chunked_cb(req, http_stream_in_chunk); in http_stream_in_test_()
3490 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, url) == -1) { in http_stream_in_test_()
3528 http_stream_in_cancel_chunk(struct evhttp_request *req, void *arg) in http_stream_in_cancel_chunk() argument
3530 tt_int_op(evhttp_request_get_response_code(req), ==, HTTP_OK); in http_stream_in_cancel_chunk()
3533 evhttp_cancel_request(req); in http_stream_in_cancel_chunk()
3538 http_stream_in_cancel_done(struct evhttp_request *req, void *arg) in http_stream_in_cancel_done() argument
3549 struct evhttp_request *req = NULL; in http_stream_in_cancel_test() local
3556 req = evhttp_request_new(http_stream_in_cancel_done, data->base); in http_stream_in_cancel_test()
3557 evhttp_request_set_chunked_cb(req, http_stream_in_cancel_chunk); in http_stream_in_cancel_test()
3560 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/chunked") == -1) { in http_stream_in_cancel_test()
3574 http_connection_fail_done(struct evhttp_request *req, void *arg) in http_connection_fail_done() argument
3583 tt_assert(!req); in http_connection_fail_done()
3601 struct evhttp_request *req = NULL; in http_connection_fail_test_impl() local
3623 req = evhttp_request_new(http_connection_fail_done, evcon); in http_connection_fail_test_impl()
3624 tt_assert(req); in http_connection_fail_test_impl()
3626 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/") == -1) { in http_connection_fail_test_impl()
3641 http_connection_retry_done(struct evhttp_request *req, void *arg) in http_connection_retry_done() argument
3643 tt_assert(req); in http_connection_retry_done()
3644 tt_int_op(evhttp_request_get_response_code(req), !=, HTTP_OK); in http_connection_retry_done()
3645 if (evhttp_find_header(evhttp_request_get_input_headers(req), "Content-Type") != NULL) { in http_connection_retry_done()
3649 tt_uint_op(evbuffer_get_length(evhttp_request_get_input_buffer(req)), ==, 0); in http_connection_retry_done()
3675 struct evhttp_request *req = NULL; in http_simple_test_impl() local
3693 req = evhttp_request_new(http_request_done, (void*) BASIC_REQUEST_BODY); in http_simple_test_impl()
3694 tt_assert(req); in http_simple_test_impl()
3696 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, uri) == -1) in http_simple_test_impl()
3718 struct evhttp_request *req = NULL; in http_connection_retry_test_basic() local
3745 req = evhttp_request_new(http_connection_retry_done, data->base); in http_connection_retry_test_basic()
3746 tt_assert(req); in http_connection_retry_test_basic()
3749 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_connection_retry_test_basic()
3751 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_connection_retry_test_basic()
3780 req = evhttp_request_new(http_connection_retry_done, data->base); in http_connection_retry_test_basic()
3781 tt_assert(req); in http_connection_retry_test_basic()
3784 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_connection_retry_test_basic()
3786 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_connection_retry_test_basic()
3809 req = evhttp_request_new(http_dispatcher_test_done, data->base); in http_connection_retry_test_basic()
3810 tt_assert(req); in http_connection_retry_test_basic()
3813 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_connection_retry_test_basic()
3815 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in http_connection_retry_test_basic()
3963 http_request_bad(struct evhttp_request *req, void *arg) in http_request_bad() argument
3965 if (req != NULL) { in http_request_bad()
3980 struct evhttp_request *req = NULL; in http_negative_content_length_test() local
3993 req = evhttp_request_new(http_request_bad, data->base); in http_negative_content_length_test()
3996 evhttp_add_header(evhttp_request_get_output_headers(req), "X-Negative", "makeitso"); in http_negative_content_length_test()
3999 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_negative_content_length_test()
4014 http_data_length_constraints_test_done(struct evhttp_request *req, void *arg) in http_data_length_constraints_test_done() argument
4016 tt_assert(req); in http_data_length_constraints_test_done()
4017 tt_int_op(evhttp_request_get_response_code(req), ==, HTTP_BADREQUEST); in http_data_length_constraints_test_done()
4022 http_large_entity_test_done(struct evhttp_request *req, void *arg) in http_large_entity_test_done() argument
4024 tt_assert(req); in http_large_entity_test_done()
4025 tt_int_op(evhttp_request_get_response_code(req), ==, HTTP_ENTITYTOOLARGE); in http_large_entity_test_done()
4030 http_expectation_failed_done(struct evhttp_request *req, void *arg) in http_expectation_failed_done() argument
4032 tt_assert(req); in http_expectation_failed_done()
4033 tt_int_op(evhttp_request_get_response_code(req), ==, HTTP_EXPECTATIONFAILED); in http_expectation_failed_done()
4044 struct evhttp_request *req = NULL; in http_data_length_constraints_test_impl() local
4074 req = evhttp_request_new(http_data_length_constraints_test_done, data->base); in http_data_length_constraints_test_impl()
4075 tt_assert(req); in http_data_length_constraints_test_impl()
4076 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_data_length_constraints_test_impl()
4077 evhttp_add_header(evhttp_request_get_output_headers(req), "Longheader", long_str); in http_data_length_constraints_test_impl()
4079 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/?arg=val") == -1) { in http_data_length_constraints_test_impl()
4084 req = evhttp_request_new(http_data_length_constraints_test_done, data->base); in http_data_length_constraints_test_impl()
4085 tt_assert(req); in http_data_length_constraints_test_impl()
4086 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_data_length_constraints_test_impl()
4089 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, long_str) == -1) { in http_data_length_constraints_test_impl()
4099 req = evhttp_request_new(cb, data->base); in http_data_length_constraints_test_impl()
4100 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_data_length_constraints_test_impl()
4101 evbuffer_add_printf(evhttp_request_get_output_buffer(req), "%s", long_str); in http_data_length_constraints_test_impl()
4103 if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/") == -1) { in http_data_length_constraints_test_impl()
4108 req = evhttp_request_new(http_large_entity_test_done, data->base); in http_data_length_constraints_test_impl()
4109 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_data_length_constraints_test_impl()
4110 evhttp_add_header(evhttp_request_get_output_headers(req), "Expect", "100-continue"); in http_data_length_constraints_test_impl()
4111 evbuffer_add_printf(evhttp_request_get_output_buffer(req), "%s", long_str); in http_data_length_constraints_test_impl()
4113 if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/") == -1) { in http_data_length_constraints_test_impl()
4120 req = evhttp_request_new(http_dispatcher_test_done, data->base); in http_data_length_constraints_test_impl()
4121 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_data_length_constraints_test_impl()
4122 evhttp_add_header(evhttp_request_get_output_headers(req), "Expect", "100-continue"); in http_data_length_constraints_test_impl()
4123 evbuffer_add_printf(evhttp_request_get_output_buffer(req), "%s", long_str); in http_data_length_constraints_test_impl()
4125 if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/") == -1) { in http_data_length_constraints_test_impl()
4132 req = evhttp_request_new(cb, data->base); in http_data_length_constraints_test_impl()
4133 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_data_length_constraints_test_impl()
4134 evhttp_add_header(evhttp_request_get_output_headers(req), "Expect", "101-continue"); in http_data_length_constraints_test_impl()
4135 evbuffer_add_printf(evhttp_request_get_output_buffer(req), "%s", long_str); in http_data_length_constraints_test_impl()
4137 if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/") == -1) { in http_data_length_constraints_test_impl()
4162 struct evhttp_request *req = NULL; in http_lingering_close_test_impl() local
4191 req = evhttp_request_new(cb, data->base); in http_lingering_close_test_impl()
4192 tt_assert(req); in http_lingering_close_test_impl()
4193 evhttp_add_header(evhttp_request_get_output_headers(req), "Host", "somehost"); in http_lingering_close_test_impl()
4194 evbuffer_add_printf(evhttp_request_get_output_buffer(req), "%s", long_str); in http_lingering_close_test_impl()
4195 if (evhttp_make_request(evcon, req, EVHTTP_REQ_POST, "/") == -1) { in http_lingering_close_test_impl()
4220 struct evhttp_request *req; member
4233 if (!state->req) { in terminate_chunked_trickle_cb()
4237 if (evhttp_request_get_connection(state->req) == NULL) { in terminate_chunked_trickle_cb()
4239 evhttp_request_free(state->req); in terminate_chunked_trickle_cb()
4246 evhttp_send_reply_chunk(state->req, evb); in terminate_chunked_trickle_cb()
4267 evhttp_request_free(state->req); in terminate_chunked_close_cb()
4268 state->req = NULL; in terminate_chunked_close_cb()
4274 terminate_chunked_cb(struct evhttp_request *req, void *arg) in terminate_chunked_cb() argument
4281 evhttp_request_get_connection(req), in terminate_chunked_cb()
4284 state->req = req; in terminate_chunked_cb()
4286 evhttp_send_reply_start(req, HTTP_OK, "OK"); in terminate_chunked_cb()
4441 struct evhttp_request *req = NULL; in http_get_addr_test() local
4456 req = evhttp_request_new(http_request_done, (void *)BASIC_REQUEST_BODY); in http_get_addr_test()
4459 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_get_addr_test()
4549 struct evhttp_request *req = NULL; in http_request_own_test() local
4560 req = evhttp_request_new(http_request_no_action_done, NULL); in http_request_own_test()
4562 if (evhttp_make_request(evcon, req, EVHTTP_REQ_GET, "/test") == -1) { in http_request_own_test()
4565 evhttp_request_own(req); in http_request_own_test()
4572 if (req) in http_request_own_test()
4573 evhttp_request_free(req); in http_request_own_test()