Home
last modified time | relevance | path

Searched refs:wb (Results 1 – 7 of 7) sorted by relevance

/lighttpd1.4/src/
H A Dmod_scgi.c188 size_t rsz = (size_t)(r->read_queue.bytes_out - hctx->wb.bytes_in); in scgi_create_env()
190 buffer * const b = chunkqueue_prepend_buffer_open_sz(&hctx->wb, rsz); in scgi_create_env()
200 chunkqueue_remove_finished_chunks(&hctx->wb); in scgi_create_env()
222 chunkqueue_remove_finished_chunks(&hctx->wb); in scgi_create_env()
233 chunkqueue_prepend_buffer_commit(&hctx->wb); in scgi_create_env()
234 chunkqueue_mark_written(&hctx->wb, offset); in scgi_create_env()
235 hctx->wb.bytes_in -= (off_t)offset; in scgi_create_env()
236 hctx->wb.bytes_out -= (off_t)offset; in scgi_create_env()
239 chunkqueue_append_chunkqueue(&hctx->wb, &r->reqbody_queue); in scgi_create_env()
H A Dmod_fastcgi.c210 …(chunkqueue_is_empty(&hctx->wb) || hctx->wb.first->type == MEM_CHUNK) /* else FILE_CHUNK for temp … in fcgi_stdin_append()
211 ? chunkqueue_append_mem(&hctx->wb, (const char *)&header, sizeof(header)) in fcgi_stdin_append()
212 : chunkqueue_append_mem_min(&hctx->wb, (const char *)&header, sizeof(header)); in fcgi_stdin_append()
213 chunkqueue_steal(&hctx->wb, req_cq, weWant); in fcgi_stdin_append()
217 if (hctx->wb.bytes_in == hctx->wb_reqlen) { in fcgi_stdin_append()
223 chunkqueue_append_mem(&hctx->wb, (const char *)&header, sizeof(header)); in fcgi_stdin_append()
245 size_t rsz = (size_t)(r->read_queue.bytes_out - hctx->wb.bytes_in); in fcgi_create_env()
247 buffer * const b = chunkqueue_prepend_buffer_open_sz(&hctx->wb, rsz); in fcgi_create_env()
274 chunkqueue_remove_finished_chunks(&hctx->wb); in fcgi_create_env()
285 chunkqueue_prepend_buffer_commit(&hctx->wb); in fcgi_create_env()
H A Dmod_ajp13.c233 (chunkqueue_is_empty(&hctx->wb) || hctx->wb.first->type == MEM_CHUNK) in ajp13_stdin_append()
235 ? chunkqueue_append_mem(&hctx->wb, (char *)&hdr, sizeof(hdr)) in ajp13_stdin_append()
236 : chunkqueue_append_mem_min(&hctx->wb, (char *)&hdr, sizeof(hdr)); in ajp13_stdin_append()
237 chunkqueue_steal(&hctx->wb, req_cq, dlen); in ajp13_stdin_append()
249 if (hctx->wb.bytes_in == hctx->wb_reqlen) { in ajp13_stdin_append_n()
253 chunkqueue_append_mem(&hctx->wb, (char *)hdr, sizeof(hdr)); in ajp13_stdin_append_n()
548 chunkqueue_prepend_buffer_open_sz(&hctx->wb, AJP13_MAX_PACKET_SIZE); in ajp13_create_env()
629 chunkqueue_prepend_buffer_commit(&hctx->wb); in ajp13_create_env()
656 chunkqueue_remove_finished_chunks(&hctx->wb); in ajp13_create_env()
H A Dgw_backend.c1099 chunkqueue_init(&hctx->wb); in handler_ctx_init()
1111 chunkqueue_reset(&hctx->wb); in handler_ctx_free()
1129 chunkqueue_reset(&hctx->wb); in handler_ctx_clear()
1861 if (!chunkqueue_is_empty(&hctx->wb))return; in gw_conditional_tcp_fin()
1891 else if (chunkqueue_is_empty(&hctx->wb)) in gw_write_refill_wb()
2006 if (!chunkqueue_is_empty(&hctx->wb)) { in gw_write_request()
2015 off_t bytes_out = hctx->wb.bytes_out; in gw_write_request()
2030 (long long)hctx->wb.bytes_out, in gw_write_request()
2045 if (hctx->wb.bytes_out == hctx->wb_reqlen) { in gw_write_request()
2184 && (0 == hctx->wb.bytes_in in gw_handle_subrequest()
[all …]
H A Dmod_proxy.c815 (chunkqueue_is_empty(&hctx->wb) || hctx->wb.first->type == MEM_CHUNK) in proxy_stdin_append()
817 ? chunkqueue_append_mem(&hctx->wb, BUF_PTR_LEN(tb)) in proxy_stdin_append()
818 : chunkqueue_append_mem_min(&hctx->wb, BUF_PTR_LEN(tb)); in proxy_stdin_append()
819 chunkqueue_steal(&hctx->wb, req_cq, req_cqlen); in proxy_stdin_append()
821 chunkqueue_append_mem_min(&hctx->wb, CONST_STR_LEN("\r\n")); in proxy_stdin_append()
824 if (hctx->wb.bytes_in == hctx->wb_reqlen) {/*hctx->r->reqbody_length >= 0*/ in proxy_stdin_append()
826 chunkqueue_append_mem(&hctx->wb, CONST_STR_LEN("0\r\n\r\n")); in proxy_stdin_append()
839 size_t rsz = (size_t)(r->read_queue.bytes_out - hctx->gw.wb.bytes_in); in proxy_create_env()
841 buffer * const b = chunkqueue_prepend_buffer_open_sz(&hctx->gw.wb, rsz); in proxy_create_env()
1023 chunkqueue_prepend_buffer_commit(&hctx->gw.wb); in proxy_create_env()
[all …]
H A Dmod_wstunnel.c993 chunkqueue_append_buffer(&hctx->gw.wb, payload); in recv_ietf_00()
1002 chunkqueue_get_memory(&hctx->gw.wb, &len); in recv_ietf_00()
1003 b = hctx->gw.wb.last->mem; in recv_ietf_00()
1015 hctx->gw.wb.bytes_in += buffer_clen(b)-len; in recv_ietf_00()
1267 chunkqueue_append_buffer(&hctx->gw.wb, payload); in recv_rfc_6455()
H A Dgw_backend.h311 chunkqueue wb; /* write queue */ member