Home
last modified time | relevance | path

Searched refs:write_queue (Results 1 – 22 of 22) sorted by relevance

/lighttpd1.4/src/
H A Dconnections.c197 if (&r->write_queue != con->write_queue) { /*(for HTTP/1.1)*/ in connection_handle_response_end_state()
198 chunkqueue_free(con->write_queue); in connection_handle_response_end_state()
199 con->write_queue = &r->write_queue; in connection_handle_response_end_state()
330 chunkqueue * const cq = con->write_queue; in connection_write_1xx_info()
347 if (cq == &r->write_queue) { in connection_write_1xx_info()
370 r->write_queue.bytes_in = r->write_queue.bytes_out = 0; in connection_write_1xx_info()
448 if (con->write_queue->bytes_out) in connection_handle_write()
509 con->write_queue = &r->write_queue; in connection_init()
523 if (con->write_queue != &r->write_queue) in connection_free()
524 chunkqueue_free(con->write_queue); in connection_free()
[all …]
H A Dhttp_chunk.c69 chunkqueue * const cq = &r->write_queue; in http_chunk_append_read_fd_range()
92 chunkqueue * const cq = &r->write_queue; in http_chunk_append_file_ref_range()
118 chunkqueue * const cq = &r->write_queue; in http_chunk_append_file_fd_range()
157 chunkqueue * const cq = &r->write_queue; in http_chunk_append_to_tempfile()
177 chunkqueue * const cq = &r->write_queue; in http_chunk_append_cq_to_tempfile()
214 chunkqueue * const cq = &r->write_queue; in http_chunk_append_buffer()
239 chunkqueue * const cq = &r->write_queue; in http_chunk_append_mem()
258 chunkqueue * const cq = &r->write_queue; in http_chunk_transfer_cqlen()
282 chunkqueue_append_mem(&r->write_queue, CONST_STR_LEN("0\r\n\r\n")); in http_chunk_close()
H A Dresponse.c76 chunkqueue * const cq = con->write_queue; in http_response_write_header_partial_1xx()
77 con->write_queue = &r->write_queue; in http_response_write_header_partial_1xx()
124 chunkqueue * const cq = &r->write_queue; in http_response_write_header()
127 if (cq != r->con->write_queue) in http_response_write_header()
688 chunkqueue_append_buffer_commit(&r->write_queue); in http_response_static_errdoc()
783 off_t qlen = chunkqueue_length(&r->write_queue); in http_response_write_prepare()
832 off_t qlen = chunkqueue_length(&r->write_queue); in http_response_write_prepare()
840 chunkqueue_append_mem(&r->write_queue, in http_response_write_prepare()
844 chunkqueue_append_mem(&r->write_queue, in http_response_write_prepare()
848 chunkqueue_append_mem(&r->write_queue, in http_response_write_prepare()
[all …]
H A Dmod_status.c190 buffer_append_int(b, r->write_queue.bytes_out); in mod_status_html_rtable_r()
192 buffer_append_int(b, r->write_queue.bytes_in); in mod_status_html_rtable_r()
264 buffer * const b = chunkqueue_append_buffer_open(&r->write_queue); in mod_status_handle_server_status_html()
530 chunkqueue_append_buffer_commit(&r->write_queue); in mod_status_handle_server_status_html()
548 buffer *b = chunkqueue_append_buffer_open(&r->write_queue); in mod_status_handle_server_status_text()
574 chunkqueue_append_buffer_commit(&r->write_queue); in mod_status_handle_server_status_text()
584 buffer *b = chunkqueue_append_buffer_open(&r->write_queue); in mod_status_handle_server_status_json()
642 chunkqueue_append_buffer_commit(&r->write_queue); in mod_status_handle_server_status_json()
670 chunkqueue_append_buffer_commit(&r->write_queue); in mod_status_handle_server_statistics()
734 buffer *b = chunkqueue_append_buffer_open(&r->write_queue); in mod_status_handle_server_config()
[all …]
H A Dh2.c292 chunkqueue_append_mem(con->write_queue, in h2_send_settings_ack()
2012 chunkqueue_append_mem(con->write_queue, in h2_init_con()
2096 chunkqueue_append_buffer_commit(con->write_queue); in h2_send_hpack()
2327 chunkqueue * const wq = &r->write_queue; in h2_send_headers()
2534 chunk * const c = r->write_queue.first;
2540 chunkqueue_mark_written(&r->write_queue, len);
2614 chunkqueue_append_buffer_commit(con->write_queue);
2834 con->write_queue->bytes_out -= r->write_queue.bytes_out; in h2_release_stream()
2878 if (!chunkqueue_is_empty(con->write_queue)) { in h2_retire_con()
2884 chunkqueue * const cq = con->write_queue; in h2_retire_con()
[all …]
H A Dhttp_range.c155 chunkqueue * const restrict cq = &r->write_queue; in http_range_single()
228 chunkqueue * const restrict cq = &r->write_queue; in http_range_multi()
293 const off_t content_length = chunkqueue_length(&r->write_queue); in http_range_process()
323 chunkqueue_length(&r->write_queue)); in http_range_process()
H A Dmod_deflate.c357 chunkqueue_reset(&r->write_queue); in mod_deflate_cache_file_finish()
1477 chunkqueue_reset(&hctx->r->write_queue); in mod_deflate_using_libdeflate_sm()
1695 chunkqueue * const cq = &r->write_queue; in deflate_compress_response()
1913 len = chunkqueue_length(&r->write_queue); in REQUEST_FUNC()
2032 && r->write_queue.first == r->write_queue.last in REQUEST_FUNC()
2033 && r->write_queue.first->type == FILE_CHUNK in REQUEST_FUNC()
2034 && r->write_queue.first->offset == 0 in REQUEST_FUNC()
2035 && !r->write_queue.first->file.is_temp in REQUEST_FUNC()
2048 chunkqueue_reset(&r->write_queue); in REQUEST_FUNC()
2091 && c == r->write_queue.last in REQUEST_FUNC()
[all …]
H A Dhttp-header-glue.c263 chunkqueue_reset(&r->write_queue); in http_response_body_clear()
708 len < 32768 && r->write_queue.last && r->write_queue.last->file.is_temp; in http_response_append_buffer_simple_accum()
759 && r->write_queue.last && r->write_queue.last->file.is_temp))) { in http_response_append_splice()
771 &r->write_queue, fd, toread, r->conf.errh) in http_response_append_splice()
773 &r->write_queue, fd, toread, r->conf.errh); in http_response_append_splice()
1294 off_t cqlen = chunkqueue_length(&r->write_queue); in http_response_read()
1418 if (chunkqueue_length(&r->write_queue) > 65536 - 4096) { in http_response_read()
H A Drequest.h196 struct chunkqueue write_queue; /* HTTP response queue [ file, mem ] */ member
256 ((r)->write_queue.bytes_out - (r)->bytes_written_ckpt)
H A Dreqpool.c48 chunkqueue_init(&r->write_queue); in request_init_data()
208 chunkqueue_reset(&r->write_queue); in request_free_data()
H A Dmod_echo.c39 if (chunkqueue_length(&r->write_queue) > 65536 - 4096) { in mod_echo_request_body()
H A Dbase.h36 …chunkqueue *write_queue; /* a large queue for low-level write ( HTTP response ) [ file, mem ]… member
H A Dmod_dirlisting.c602 chunkqueue * const cq = &r->write_queue; in http_list_directory_include_file()
846 chunkqueue * const cq = &r->write_queue; in http_list_directory_header()
946 chunkqueue * const cq = &r->write_queue; in http_list_directory_footer()
1150 chunkqueue * const cq = &r->write_queue; in http_list_directory()
1595 if (mod_dirlisting_write_cq(fd, &r->write_queue, r->conf.errh) in mod_dirlisting_cache_add()
H A Dmod_webdav.c769 chunkqueue * const cq = &r->write_queue; in webdav_xml_log_response()
1021 chunkqueue * const cq = &r->write_queue; in webdav_xml_doc_multistatus()
1044 chunkqueue * const cq = &r->write_queue; in webdav_xml_doc_multistatus_response()
1080 chunkqueue_append_buffer_open_sz(&r->write_queue, 1024); in webdav_xml_doc_lock_acquired()
1091 chunkqueue_append_buffer_commit(&r->write_queue); in webdav_xml_doc_lock_acquired()
1124 chunkqueue_append_buffer_open_sz(&r->write_queue, 256); in webdav_xml_doc_error_propfind_finite_depth()
1128 chunkqueue_append_buffer_commit(&r->write_queue); in webdav_xml_doc_error_propfind_finite_depth()
1141 chunkqueue_append_buffer_open_sz(&r->write_queue, 256); in webdav_xml_doc_error_lock_token_matches_request_uri()
1145 chunkqueue_append_buffer_commit(&r->write_queue); in webdav_xml_doc_error_lock_token_matches_request_uri()
1159 chunkqueue * const cq = &r->write_queue; in webdav_xml_doc_423_locked()
[all …]
H A Dmod_cgi.c572 const off_t bytes_in = r->write_queue.bytes_in; in cgi_recv_response()
576 if (r->write_queue.bytes_in > bytes_in) in cgi_recv_response()
1101 if (chunkqueue_length(&r->write_queue) > 65536 - 4096) { in SUBREQUEST_FUNC()
H A Dmod_ssi.c1533 chunkqueue_remove_empty_chunks(&r->write_queue); in mod_ssi_read_fd()
1551 chunkqueue_remove_empty_chunks(&r->write_queue); in mod_ssi_read_fd()
1610 chunkqueue_reset(&r->write_queue); in mod_ssi_handle_request()
H A Dmod_magnet.c2290 lua_pushinteger(L, r->write_queue.bytes_in); in magnet_respbody()
2294 lua_pushinteger(L, r->write_queue.bytes_out); in magnet_respbody()
2305 chunkqueue * const cq = &r->write_queue; in magnet_respbody()
2319 lua_pushinteger(L, chunkqueue_length(&r->write_queue)); in magnet_respbody()
3274 if (!chunkqueue_is_empty(&r->write_queue)) { in magnet_attract()
H A Dgw_backend.c2161 if (chunkqueue_length(&r->write_queue) > 65536 - 4096) { in gw_handle_subrequest()
2316 const off_t bytes_in = r->write_queue.bytes_in; in gw_recv_response()
2331 if (r->write_queue.bytes_in > bytes_in) in gw_recv_response()
H A Dmod_wstunnel.c724 chunkqueue_append_mem(&r->write_queue, (char *)buf, sizeof(buf)); in create_MD5_sum()
/lighttpd1.4/src/t/
H A Dtest_mod_ssi.c43 chunkqueue * const cq = &r->write_queue; in test_mod_ssi_read_fd()
163 chunkqueue_reset(&r.write_queue); in test_mod_ssi()
H A Dtest_mod_staticfile.c423 chunkqueue_reset(&r.write_queue); in test_mod_staticfile()
/lighttpd1.4/
H A DNEWS2853 * [core] reset response headers, write_queue for error docs