| /lighttpd1.4/src/ |
| H A D | chunk.h | 46 typedef struct chunkqueue { struct
55 } chunkqueue; argument
73 chunkqueue *chunkqueue_init(chunkqueue *cq);
95 void chunkqueue_append_chunkqueue(chunkqueue * restrict cq, chunkqueue * restrict src);
111 void chunkqueue_append_buffer_commit(chunkqueue *cq);
146 void chunkqueue_remove_empty_chunks(chunkqueue *cq);
148 void chunkqueue_steal(chunkqueue * restrict dest, chunkqueue * restrict src, off_t len);
150 void chunkqueue_append_cq_range (chunkqueue *dst, const chunkqueue *src, off_t offset, off_t len);
154 void chunkqueue_compact_mem_offset(chunkqueue *cq);
175 void chunkqueue_free(chunkqueue *cq);
[all …]
|
| H A D | chunk.c | 93 chunkqueue *chunkqueue_init(chunkqueue *cq) { in chunkqueue_init()
438 static void chunkqueue_release_chunks(chunkqueue *cq) { in chunkqueue_release_chunks()
446 void chunkqueue_free(chunkqueue *cq) { in chunkqueue_free()
490 void chunkqueue_reset(chunkqueue *cq) { in chunkqueue_reset()
563 void chunkqueue_append_chunkqueue(chunkqueue * const restrict cq, chunkqueue * const restrict src) { in chunkqueue_append_chunkqueue()
607 void chunkqueue_append_buffer_commit(chunkqueue *cq) { in chunkqueue_append_buffer_commit()
703 void chunkqueue_steal(chunkqueue * const restrict dest, chunkqueue * const restrict src, off_t len)… in chunkqueue_steal()
855 chunkqueue src = *dest; /*(copy struct)*/ in chunkqueue_to_tempfiles()
1216 void chunkqueue_append_cq_range (chunkqueue * const dst, const chunkqueue * const src, off_t offset… in chunkqueue_append_cq_range()
1552 chunkqueue_peek_data (chunkqueue * const cq, in chunkqueue_peek_data()
[all …]
|
| H A D | http_chunk.c | 27 static void http_chunk_len_append(chunkqueue * const cq, uintmax_t len) { in http_chunk_len_append()
69 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()
197 static int http_chunk_uses_tempfile(const chunkqueue * const cq, const size_t len) { in http_chunk_uses_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()
255 int http_chunk_transfer_cqlen(request_st * const r, chunkqueue * const src, const size_t len) { in http_chunk_transfer_cqlen()
[all …]
|
| H A D | base.h | 36 …chunkqueue *write_queue; /* a large queue for low-level write ( HTTP response ) [ file, mem ]…
37 chunkqueue *read_queue; /* a small queue for low-level read ( HTTP request ) [ mem ] */
41 int (* network_write)(struct connection *con, chunkqueue *cq, off_t max_bytes);
42 int (* network_read)(struct connection *con, chunkqueue *cq, off_t max_bytes);
148 int (* network_backend_write)(int fd, chunkqueue *cq, off_t max_bytes, log_error_st *errh);
|
| H A D | network_write.c | 116 static int network_remove_finished_chunks(chunkqueue * const cq, const off_t len) { in network_remove_finished_chunks()
131 static int network_write_accounting(const int fd, chunkqueue * const cq, off_t * const p_max_bytes,… in network_write_accounting()
149 static int network_write_mem_chunk(const int fd, chunkqueue * const cq, off_t * const p_max_bytes, … in network_write_mem_chunk()
164 static int network_write_file_chunk_no_mmap(const int fd, chunkqueue * const cq, off_t * const p_ma… in network_write_file_chunk_no_mmap()
199 static int network_write_file_chunk_mmap(const int fd, chunkqueue * const cq, off_t * const p_max_b… in network_write_file_chunk_mmap()
254 static int network_writev_mem_chunks(const int fd, chunkqueue * const cq, off_t * const p_max_bytes… in network_writev_mem_chunks()
295 static int network_write_file_chunk_sendfile(const int fd, chunkqueue * const cq, off_t * const p_m… in network_write_file_chunk_sendfile()
406 static int network_write_chunkqueue_writev(const int fd, chunkqueue * const cq, off_t max_bytes, lo… in network_write_chunkqueue_writev()
434 static int network_write_chunkqueue_sendfile(const int fd, chunkqueue * const cq, off_t max_bytes, … in network_write_chunkqueue_sendfile()
|
| H A D | request.h | 13 struct chunkqueue; /* declaration */
196 struct chunkqueue write_queue; /* HTTP response queue [ file, mem ] */
197 struct chunkqueue read_queue; /* HTTP request queue [ mem ] */
198 struct chunkqueue reqbody_queue; /*(might use tempfiles)*/
|
| H A D | mod_echo.c | 34 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 D | connections.c | 330 chunkqueue * const cq = con->write_queue; in connection_write_1xx_info()
388 chunkqueue * const cq = con->write_queue; /*(bypass r->write_queue)*/ in connection_send_1xx()
420 chunkqueue * const cq = con->write_queue; /*(bypass r->write_queue)*/ in connection_write_100_continue()
641 chunkqueue * const cq = con->read_queue; in connection_handle_read_state()
1193 chunkqueue * const cq = con->read_queue; in connection_state_machine_h2()
1589 connection_handle_read_post_cq_compact (chunkqueue * const cq) in connection_handle_read_post_cq_compact()
1608 connection_handle_read_post_chunked_crlf (chunkqueue * const cq) in connection_handle_read_post_chunked_crlf()
1641 connection_handle_read_post_chunked (request_st * const r, chunkqueue * const cq, chunkqueue * cons… in connection_handle_read_post_chunked()
1805 connection_handle_read_body_unknown (request_st * const r, chunkqueue * const cq, chunkqueue * cons… in connection_handle_read_body_unknown()
1858 chunkqueue * const cq = &r->read_queue; in connection_handle_read_post_state()
[all …]
|
| H A D | h2.h | 12 struct chunkqueue; /* declaration */
107 uint32_t h2_send_cqdata (request_st *r, connection *con, struct chunkqueue *cq, uint32_t dlen);
|
| H A D | response.h | 12 struct chunkqueue; /* declaration */
59 int http_response_transfer_cqlen(request_st *r, struct chunkqueue *cq, size_t len);
|
| H A D | gw_backend.h | 309 chunkqueue *rb; /* read queue */
311 chunkqueue wb; /* write queue */
|
| H A D | http_range.c | 155 chunkqueue * const restrict cq = &r->write_queue; in http_range_single()
184 chunkqueue tq; in http_range_single()
228 chunkqueue * const restrict cq = &r->write_queue; in http_range_multi()
|
| H A D | h2.c | 964 chunkqueue * const reqbody_queue = &r->reqbody_queue; in h2_recv_end_data()
1029 chunkqueue * const cq = con->read_queue; in h2_recv_data()
1085 chunkqueue * const dst = &r->reqbody_queue; in h2_recv_data()
1100 chunkqueue * const rq = &r->read_queue; in h2_recv_data()
1192 h2_frame_cq_compact (chunkqueue * const cq, uint32_t len) in h2_frame_cq_compact()
1487 chunkqueue * const rq = &r->read_queue; in h2_parse_headers_frame()
1711 chunkqueue * const cq = con->read_queue; in h2_parse_frames()
1855 chunkqueue * const cq = con->read_queue; in h2_want_read()
1896 chunkqueue * const cq = con->read_queue; in h2_recv_client_connection_preface()
2327 chunkqueue * const wq = &r->write_queue; in h2_send_headers()
[all …]
|
| H A D | http_chunk.h | 15 int http_chunk_transfer_cqlen(request_st *r, chunkqueue *src, size_t len);
|
| H A D | mod_cgi.c | 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()
1112 chunkqueue * const cq = &r->reqbody_queue; in SUBREQUEST_FUNC()
|
| H A D | mod_dirlisting.c | 602 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()
1526 static int mod_dirlisting_write_cq (const int fd, chunkqueue * const cq, log_error_st * const errh) in mod_dirlisting_write_cq()
1528 chunkqueue in; in mod_dirlisting_write_cq()
|
| H A D | mod_wstunnel.c | 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 D | mod_webdav.c | 769 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()
1159 chunkqueue * const cq = &r->write_queue; in webdav_xml_doc_423_locked()
3845 chunkqueue * const cq = &r->reqbody_queue; in webdav_parse_chunkqueue()
4506 mod_webdav_write_cq (request_st * const r, chunkqueue * const cq, const int fd) in mod_webdav_write_cq()
4526 mod_webdav_write_single_file_chunk (request_st * const r, chunkqueue * const cq) in mod_webdav_write_single_file_chunk()
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()
[all …]
|
| H A D | mod_magnet.c | 2305 chunkqueue * const cq = &r->write_queue; in magnet_respbody()
2344 chunkqueue * const cq = &r->reqbody_queue; in magnet_reqbody_add()
2394 chunkqueue * const cq = &r->reqbody_queue; 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()
|
| H A D | response.c | 76 chunkqueue * const cq = con->write_queue; in http_response_write_header_partial_1xx()
124 chunkqueue * const cq = &r->write_queue; in http_response_write_header()
|
| H A D | mod_extforward.c | 120 int(*saved_network_read)(connection *, chunkqueue *, off_t);
1161 static int mod_extforward_network_read (connection *con, chunkqueue *cq, off_t max_bytes);
1665 chunkqueue *cq, off_t max_bytes) in mod_extforward_network_read()
|
| H A D | mod_deflate.c | 239 chunkqueue in_queue;
1518 chunkqueue * const cq = &hctx->r->write_queue; in mod_deflate_using_libdeflate()
1584 chunkqueue * const cq = &hctx->r->write_queue; in mod_deflate_using_libdeflate()
1695 chunkqueue * const cq = &r->write_queue; in deflate_compress_response()
|
| H A D | mod_ssi.c | 68 chunkqueue wq;
679 chunkqueue * const cq = &p->wq; in process_ssi_stmt()
1464 chunkqueue * const cq = &p->wq; in mod_ssi_read_fd()
|
| H A D | mod_fastcgi.c | 191 chunkqueue * const req_cq = &hctx->r->reqbody_queue; in fcgi_stdin_append()
|
| /lighttpd1.4/src/t/ |
| H A D | test_mod_ssi.c | 43 chunkqueue * const cq = &r->write_queue; in test_mod_ssi_read_fd()
|