Home
last modified time | relevance | path

Searched refs:reqbody_queue (Results 1 – 18 of 18) sorted by relevance

/lighttpd1.4/src/
H A Dmod_echo.c34 chunkqueue * const cq = &r->reqbody_queue; in mod_echo_request_body()
77 chunkqueue * const cq = &r->reqbody_queue; in SUBREQUEST_FUNC()
107 chunkqueue * const cq = &r->reqbody_queue; in SUBREQUEST_FUNC()
H A Dreqpool.c50 chunkqueue_init(&r->reqbody_queue); in request_init_data()
141 chunkqueue_reset(&r->reqbody_queue); in request_reset()
207 chunkqueue_reset(&r->reqbody_queue); in request_free_data()
H A Dmod_cgi.c457 chunkqueue_set_tempdirs(&r->reqbody_queue, /* reset sz */ in cgi_connection_close_callback()
458 r->reqbody_queue.tempdirs, 0); in cgi_connection_close_callback()
488 chunkqueue *cq = &r->reqbody_queue; in cgi_process_wr_revents()
547 chunkqueue *cq = &r->reqbody_queue; in cgi_response_headers()
671 chunkqueue *cq = &r->reqbody_queue; in cgi_write_request()
780 chunkqueue * const cq = &r->reqbody_queue; in cgi_create_env()
947 chunkqueue * const cq = &r->reqbody_queue; in cgi_create_env()
1019 r->reqbody_queue.upload_temp_file_size = in URIHANDLER_FUNC()
1112 chunkqueue * const cq = &r->reqbody_queue; in SUBREQUEST_FUNC()
H A Dhttp_cgi.c71 if (r->reqbody_length != r->reqbody_queue.bytes_in) in http_cgi_local_redir()
74 chunkqueue_reset(&r->reqbody_queue); in http_cgi_local_redir()
H A Dmod_wstunnel.c353 chunkqueue_append_chunkqueue(&r->reqbody_queue, &r->read_queue); in wstunnel_create_env()
669 chunkqueue *cq = &r->reqbody_queue; in get_key3()
858 chunkqueue *cq = &r->reqbody_queue; in mod_wstunnel_handshake_create_response()
935 chunkqueue *cq = &r->reqbody_queue; in recv_ietf_00()
1123 chunkqueue *cq = &r->reqbody_queue; in recv_rfc_6455()
H A Dh2.c432 if (r->reqbody_length == r->reqbody_queue.bytes_in) { in h2_send_refused_stream()
964 chunkqueue * const reqbody_queue = &r->reqbody_queue; in h2_recv_end_data() local
969 r->reqbody_length = reqbody_queue->bytes_in + (off_t)alen; in h2_recv_end_data()
970 else if (r->reqbody_length != reqbody_queue->bytes_in + (off_t)alen) { in h2_recv_end_data()
971 if (0 == reqbody_queue->bytes_out) { in h2_recv_end_data()
1085 chunkqueue * const dst = &r->reqbody_queue; in h2_recv_data()
2974 swap(&r->reqbody_queue,&h2r->reqbody_queue);/*currently always empty queue*/ in h2_con_upgrade_h2c()
H A Drequest.h198 struct chunkqueue reqbody_queue; /*(might use tempfiles)*/ member
H A Dgw_backend.c1876 if (chunkqueue_is_empty(&r->reqbody_queue)) in gw_write_refill_wb()
1883 const chunk * const c = r->reqbody_queue.last; in gw_write_refill_wb()
1884 const off_t qlen = chunkqueue_length(&r->reqbody_queue); in gw_write_refill_wb()
1888 if (c != r->reqbody_queue.first) in gw_write_refill_wb()
1889 chunkqueue_steal(&hctx->wb, &r->reqbody_queue, in gw_write_refill_wb()
1892 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in gw_write_refill_wb()
1896 &r->reqbody_queue, qlen, r->conf.errh)) in gw_write_refill_wb()
1900 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in gw_write_refill_wb()
2228 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in gw_handle_subrequest()
H A Dresponse.c100 && r->reqbody_length != r->reqbody_queue.bytes_in in http_response_write_header()
901 if (r->reqbody_length != r->reqbody_queue.bytes_in) in http_response_call_error_handler()
904 chunkqueue_reset(&r->reqbody_queue); in http_response_call_error_handler()
H A Dconnections.c192 if (r->reqbody_length != r->reqbody_queue.bytes_in in connection_handle_response_end_state()
1074 r->reqbody_length = r->reqbody_queue.bytes_in; in connection_revents_err()
1380 if (rr->reqbody_length != rr->reqbody_queue.bytes_in) { in connection_check_timeout()
1838 || 0 != r->reqbody_queue.bytes_in in connection_check_expect_100()
1859 chunkqueue * const dst_cq = &r->reqbody_queue; in connection_handle_read_post_state()
H A Dmod_magnet.c2344 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody_add()
2394 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody()
2406 lua_pushinteger(L, r->reqbody_queue.bytes_in); in magnet_reqbody()
2410 lua_pushinteger(L, r->reqbody_queue.bytes_out); in magnet_reqbody()
2416 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody()
2442 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody()
2461 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody()
2464 chunkqueue_reset(&r->reqbody_queue); in magnet_reqbody()
H A Dmod_scgi.c239 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in scgi_create_env()
H A Dmod_webdav.c3845 chunkqueue * const cq = &r->reqbody_queue; in webdav_parse_chunkqueue()
4671 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put_prep()
4706 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put_linkat_rename()
4824 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put_range()
4862 mod_webdav_write_cq(r, &r->reqbody_queue, fd); in mod_webdav_put_range()
4909 int first_read = chunkqueue_is_empty(&r->reqbody_queue); in mod_webdav_put()
4943 chunkqueue * const cq = &r->reqbody_queue; in mod_webdav_put()
6108 chunkqueue_set_tempdirs(&r->reqbody_queue, /* reset sz */ in REQUEST_FUNC()
6109 r->reqbody_queue.tempdirs, 0); in REQUEST_FUNC()
H A Dmod_proxy.c800 chunkqueue * const req_cq = &hctx->r->reqbody_queue; in proxy_stdin_append()
1033 chunkqueue_append_chunkqueue(&hctx->gw.wb, &r->reqbody_queue); in proxy_create_env()
H A Dmod_fastcgi.c191 chunkqueue * const req_cq = &hctx->r->reqbody_queue; in fcgi_stdin_append()
H A Dmod_status.c180 ? r->reqbody_queue.bytes_in in mod_status_html_rtable_r()
H A Dmod_ajp13.c212 chunkqueue * const req_cq = &hctx->r->reqbody_queue; in ajp13_stdin_append()
H A Dserver.c526 r->reqbody_length = r->reqbody_queue.bytes_in; in server_oneshot_handle_fdevent()