Home
last modified time | relevance | path

Searched refs:cq (Results 1 – 16 of 16) sorted by relevance

/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dchunk.c22 chunkqueue *cq; in chunkqueue_init() local
24 cq = calloc(1, sizeof(*cq)); in chunkqueue_init()
26 cq->first = NULL; in chunkqueue_init()
27 cq->last = NULL; in chunkqueue_init()
31 return cq; in chunkqueue_init()
96 free(cq); in chunkqueue_free()
118 cq->first = c; in chunkqueue_prepend_chunk()
131 cq->last = c; in chunkqueue_append_chunk()
287 if (cq->tempdirs && cq->tempdirs->used) { in chunkqueue_get_append_tempfile()
368 for (c = cq->first; c; c = cq->first) { in chunkqueue_remove_finished_chunks()
[all …]
H A Dhttp_chunk.c55 chunkqueue *cq; in http_chunk_append_file() local
59 cq = con->write_queue; in http_chunk_append_file()
68 chunkqueue_append_mem(cq, "\r\n", 2 + 1); in http_chunk_append_file()
75 chunkqueue *cq; in http_chunk_append_buffer() local
79 cq = con->write_queue; in http_chunk_append_buffer()
85 chunkqueue_append_buffer(cq, mem); in http_chunk_append_buffer()
88 chunkqueue_append_mem(cq, "\r\n", 2 + 1); in http_chunk_append_buffer()
95 chunkqueue *cq; in http_chunk_append_mem() local
99 cq = con->write_queue; in http_chunk_append_mem()
105 chunkqueue_append_mem(cq, "", 1); in http_chunk_append_mem()
[all …]
H A Dnetwork_backends.h62 int network_write_chunkqueue_write(server *srv, connection *con, int fd, chunkqueue *cq, off_t max_…
63 int network_write_chunkqueue_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_t max…
64 int network_write_chunkqueue_linuxsendfile(server *srv, connection *con, int fd, chunkqueue *cq, of…
65 int network_write_chunkqueue_freebsdsendfile(server *srv, connection *con, int fd, chunkqueue *cq, …
66 int network_write_chunkqueue_solarissendfilev(server *srv, connection *con, int fd, chunkqueue *cq,…
67 int network_write_chunkqueue_mtcp_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_…
69 int network_write_chunkqueue_openssl(server *srv, connection *con, SSL *ssl, chunkqueue *cq, off_t …
H A Dnetwork_write.c27 int network_write_chunkqueue_write(server *srv, connection *con, int fd, chunkqueue *cq, off_t max_… in network_write_chunkqueue_write() argument
30 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_write()
75 cq->bytes_out += r; in network_write_chunkqueue_write()
187 cq->bytes_out += r; in network_write_chunkqueue_write()
H A Dnetwork_freebsd_sendfile.c34 int network_write_chunkqueue_freebsdsendfile(server *srv, connection *con, int fd, chunkqueue *cq, … in network_write_chunkqueue_freebsdsendfile() argument
37 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_freebsdsendfile()
104 cq->bytes_out += r; in network_write_chunkqueue_freebsdsendfile()
195 cq->bytes_out += r; in network_write_chunkqueue_freebsdsendfile()
H A Dnetwork_solaris_sendfilev.c41 int network_write_chunkqueue_solarissendfilev(server *srv, connection *con, int fd, chunkqueue *cq,… in network_write_chunkqueue_solarissendfilev() argument
44 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_solarissendfilev()
111 cq->bytes_out += r; in network_write_chunkqueue_solarissendfilev()
187 cq->bytes_out += written; in network_write_chunkqueue_solarissendfilev()
H A Dnetwork_mtcp_writev.c32 network_write_chunkqueue_mtcp_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_t ma…
36 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) {
120 cq->bytes_out += r;
310 cq->bytes_out += r;
346 int network_write_chunkqueue_mtcp_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_… in network_write_chunkqueue_mtcp_writev() argument
349 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_mtcp_writev()
394 cq->bytes_out += r; in network_write_chunkqueue_mtcp_writev()
507 cq->bytes_out += r; in network_write_chunkqueue_mtcp_writev()
H A Dnetwork_openssl.c30 int network_write_chunkqueue_openssl(server *srv, connection *con, SSL *ssl, chunkqueue *cq, off_t … in network_write_chunkqueue_openssl() argument
61 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_openssl()
148 cq->bytes_out += r; in network_write_chunkqueue_openssl()
261 cq->bytes_out += r; in network_write_chunkqueue_openssl()
H A Dnetwork_linux_sendfile.c30 int network_write_chunkqueue_linuxsendfile(server *srv, connection *con, int fd, chunkqueue *cq, of… in network_write_chunkqueue_linuxsendfile() argument
33 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_linuxsendfile()
99 cq->bytes_out += r; in network_write_chunkqueue_linuxsendfile()
213 cq->bytes_out += r; in network_write_chunkqueue_linuxsendfile()
H A Dconnections.c935 for (c = cq->first; c;) {
940 cq->first = c->next;
941 if (cq->first == NULL) cq->last = NULL;
943 c->next = cq->unused;
944 cq->unused = c;
945 cq->unused_chunks++;
947 c = cq->first;
956 fc->next = cq->unused;
957 cq->unused = fc;
958 cq->unused_chunks++;
[all …]
H A Dchunk.h60 chunk * chunkqueue_get_append_tempfile(chunkqueue *cq);
62 int chunkqueue_remove_finished_chunks(chunkqueue *cq);
H A Dnetwork_writev.c33 int network_write_chunkqueue_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_t max… in network_write_chunkqueue_writev() argument
36 for(c = cq->first; (max_bytes > 0) && (NULL != c); c = c->next) { in network_write_chunkqueue_writev()
120 cq->bytes_out += r; in network_write_chunkqueue_writev()
310 cq->bytes_out += r; in network_write_chunkqueue_writev()
H A Dnetwork.c996 network_write_chunkqueue(server *srv, connection *con, chunkqueue *cq, off_t max_bytes) { argument
1032 written = cq->bytes_out;
1038 if (cq->first && cq->first->next) {
1046 ret = srv->network_ssl_backend_write(srv, con, con->ssl, cq, max_bytes);
1049 ret = srv->network_backend_write(srv, con, con->fd, cq, max_bytes);
1053 chunkqueue_remove_finished_chunks(cq);
1054 ret = chunkqueue_is_empty(cq) ? 0 : 1;
1064 written = cq->bytes_out - written;
H A Dmod_webdav.c1003 for (c = cq->first; cq->bytes_out != cq->bytes_in; c = cq->first) { in webdav_parse_chunkqueue()
1004 size_t weWant = cq->bytes_out - cq->bytes_in; in webdav_parse_chunkqueue()
1040 …log_error_write(srv, __FILE__, __LINE__, "sodd", "xmlParseChunk failed at:", cq->bytes_out, weHave… in webdav_parse_chunkqueue()
1044 cq->bytes_out += weHave; in webdav_parse_chunkqueue()
1062 cq->bytes_out += weHave; in webdav_parse_chunkqueue()
1068 chunkqueue_remove_finished_chunks(cq); in webdav_parse_chunkqueue()
1612 chunkqueue *cq = con->request_content_queue; in URIHANDLER_FUNC() local
1628 assert(chunkqueue_length(cq) == (off_t)con->request.content_length); in URIHANDLER_FUNC()
1709 for (c = cq->first; c; c = cq->first) { in URIHANDLER_FUNC()
1772 cq->bytes_out += r; in URIHANDLER_FUNC()
[all …]
H A Dmod_cgi.c1077 chunkqueue *cq = con->request_content_queue; in cgi_create_env() local
1080 assert(chunkqueue_length(cq) == (off_t)con->request.content_length); in cgi_create_env()
1083 for (c = cq->first; c; c = cq->first) { in cgi_create_env()
1150 cq->bytes_out += r; in cgi_create_env()
1156 chunkqueue_remove_finished_chunks(cq); in cgi_create_env()
H A Dbase.h663 …int (* network_backend_write)(struct server *srv, connection *con, int fd, chunkqueue *cq, off_t m…
665 …int (* network_ssl_backend_write)(struct server *srv, connection *con, SSL *ssl, chunkqueue *cq, o…