Home
last modified time | relevance | path

Searched refs:content_length (Results 1 – 25 of 38) sorted by relevance

12

/unit/test/python/input_iter/
H A Dwsgi.py3 content_length = 0
7 content_length += len(l)
12 ('Content-Length', str(content_length)),
/unit/test/python/input_readline/
H A Dwsgi.py3 content_length = 0
11 content_length += len(l)
16 ('Content-Length', str(content_length)),
/unit/src/test/
H A Dnxt_unit_websocket_echo.c61 if (buf_size < ws->content_length) { in ws_echo_websocket_handler()
62 buf = realloc(buf, ws->content_length); in ws_echo_websocket_handler()
63 buf_size = ws->content_length; in ws_echo_websocket_handler()
74 size = nxt_unit_websocket_read(ws, buf, ws->content_length); in ws_echo_websocket_handler()
H A Dnxt_unit_websocket_chat.c177 ws->content_length)); in ws_chat_websocket_handler()
/unit/test/python/mirror/
H A Dwsgi.py3 content_length = int(environ.get('CONTENT_LENGTH', 0))
4 body = bytes(environ['wsgi.input'].read(content_length))
/unit/test/python/log_body/
H A Dwsgi.py2 content_length = int(environ.get('CONTENT_LENGTH', 0))
3 body = bytes(environ['wsgi.input'].read(content_length))
/unit/test/python/variables/
H A Dwsgi.py3 content_length = int(environ.get('CONTENT_LENGTH', 0))
4 body = bytes(environ['wsgi.input'].read(content_length))
/unit/test/python/ctx_iter_atexit/
H A Dwsgi.py12 content_length = int(self.environ.get('CONTENT_LENGTH', 0))
13 body = bytes(self.environ['wsgi.input'].read(content_length))
/unit/test/python/delayed/
H A Dwsgi.py8 content_length = int(environ.get('CONTENT_LENGTH', 0))
9 body = bytes(environ['wsgi.input'].read(content_length))
/unit/src/java/
H A Dnxt_jni_InputStream.c122 return req->content_length == 0; in nxt_java_InputStream_isFinished()
194 n = n < (jlong) req->content_length ? n : (jlong) req->content_length; in nxt_java_InputStream_skip()
196 req->content_length -= n; in nxt_java_InputStream_skip()
209 return req->content_length; in nxt_java_InputStream_available()
/unit/src/
H A Dnxt_unit_response.h16 uint64_t content_length; member
H A Dnxt_unit_websocket.h23 uint64_t content_length; member
H A Dnxt_http_request.c217 if (nxt_fast_path(r->content_length == NULL)) { in nxt_http_request_content_length()
218 r->content_length = field; in nxt_http_request_content_length()
547 nxt_http_field_t *server, *date, *content_length; in nxt_http_request_header_send() local
583 && (r->resp.content_length == NULL || r->resp.content_length->skip)) in nxt_http_request_header_send()
585 content_length = nxt_list_zero_add(r->resp.fields); in nxt_http_request_header_send()
586 if (nxt_slow_path(content_length == NULL)) { in nxt_http_request_header_send()
590 nxt_http_field_name_set(content_length, "Content-Length"); in nxt_http_request_header_send()
597 content_length->value = p; in nxt_http_request_header_send()
599 content_length->value_length = end - p; in nxt_http_request_header_send()
601 r->resp.content_length = content_length; in nxt_http_request_header_send()
H A Dnxt_unit_request.h36 uint64_t content_length; member
H A Dnxt_upstream_source.h29 nxt_off_t content_length; member
H A Dnxt_http_response.c30 offsetof(nxt_http_request_t, resp.content_length) },
H A Dnxt_http_error.c55 r->resp.content_length = NULL; in nxt_http_request_error()
H A Dnxt_http.h111 nxt_http_field_t *content_length; member
156 nxt_http_field_t *content_length; member
/unit/src/python/
H A Dnxt_python_wsgi.c44 uint64_t content_length; member
311 pctx->content_length = -1; in nxt_python_request_handler()
374 while (pctx->bytes_sent < pctx->content_length) { in nxt_python_request_handler()
942 pctx->content_length = -1; in nxt_py_start_resp()
998 if (pctx->content_length == 0) { in nxt_py_start_resp()
1019 nxt_off_t content_length; in nxt_python_response_add_field() local
1042 if (nxt_slow_path(content_length < 0)) { in nxt_python_response_add_field()
1047 pctx->content_length = content_length; in nxt_python_response_add_field()
1122 size = pctx->req->content_length; in nxt_py_input_read()
1147 size = pctx->req->content_length; in nxt_py_input_read()
[all …]
H A Dnxt_python_asgi_http.c24 uint64_t content_length; member
99 http->content_length = -1; in nxt_py_asgi_http_create()
173 size = req->content_length; in nxt_py_asgi_http_read_msg()
229 if (req->content_length > 0) { in nxt_py_asgi_http_read_msg()
336 add_field_ctx.content_length = -1; in nxt_py_asgi_http_response_start()
348 http->content_length = add_field_ctx.content_length; in nxt_py_asgi_http_response_start()
393 > http->content_length)) in nxt_py_asgi_http_response_body()
H A Dnxt_python_asgi.h23 uint64_t content_length; member
H A Dnxt_python_asgi.c1200 nxt_off_t content_length; in nxt_py_asgi_add_field() local
1221 content_length = nxt_off_t_parse((u_char *) val_str, val_len); in nxt_py_asgi_add_field()
1222 if (nxt_slow_path(content_length < 0)) { in nxt_py_asgi_add_field()
1231 ctx->content_length = content_length; in nxt_py_asgi_add_field()
/unit/src/ruby/
H A Dnxt_ruby_stream_io.c102 if (req->content_length == 0) { in nxt_ruby_stream_io_gets()
157 copy_size = rctx->req->content_length; in nxt_ruby_stream_io_read()
/unit/go/
H A Drequest.go62 ContentLength: int64(req.content_length),
/unit/src/nodejs/unit-http/
H A Dunit.cpp730 buffer = create_buffer((size_t) ws->content_length, &data); in create_websocket_frame()
731 nxt_unit_websocket_read(ws, data, ws->content_length); in create_websocket_frame()
758 if (req->content_length == 0) { in request_read()
764 if (wm > req->content_length) { in request_read()
765 wm = req->content_length; in request_read()

12