| /unit/test/python/input_iter/ |
| H A D | wsgi.py | 3 content_length = 0
7 content_length += len(l)
12 ('Content-Length', str(content_length)),
|
| /unit/test/python/input_readline/ |
| H A D | wsgi.py | 3 content_length = 0
11 content_length += len(l)
16 ('Content-Length', str(content_length)),
|
| /unit/src/test/ |
| H A D | nxt_unit_websocket_echo.c | 61 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 D | nxt_unit_websocket_chat.c | 177 ws->content_length)); in ws_chat_websocket_handler()
|
| /unit/test/python/mirror/ |
| H A D | wsgi.py | 3 content_length = int(environ.get('CONTENT_LENGTH', 0))
4 body = bytes(environ['wsgi.input'].read(content_length))
|
| /unit/test/python/log_body/ |
| H A D | wsgi.py | 2 content_length = int(environ.get('CONTENT_LENGTH', 0))
3 body = bytes(environ['wsgi.input'].read(content_length))
|
| /unit/test/python/chunked/ |
| H A D | wsgi.py | 3 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 D | wsgi.py | 12 content_length = int(self.environ.get('CONTENT_LENGTH', 0))
13 body = bytes(self.environ['wsgi.input'].read(content_length))
|
| /unit/test/python/variables/ |
| H A D | wsgi.py | 3 content_length = int(environ.get('CONTENT_LENGTH', 0))
4 body = bytes(environ['wsgi.input'].read(content_length))
|
| /unit/test/python/delayed/ |
| H A D | wsgi.py | 8 content_length = int(environ.get('CONTENT_LENGTH', 0))
9 body = bytes(environ['wsgi.input'].read(content_length))
|
| /unit/src/java/ |
| H A D | nxt_jni_InputStream.c | 122 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 D | nxt_unit_response.h | 16 uint64_t content_length; member
|
| H A D | nxt_unit_websocket.h | 23 uint64_t content_length; member
|
| H A D | nxt_http_request.c | 221 if (nxt_fast_path(r->content_length == NULL)) { in nxt_http_request_content_length()
222 r->content_length = field; in nxt_http_request_content_length()
634 nxt_http_field_t *server, *date, *content_length; in nxt_http_request_header_send() local
681 && (r->resp.content_length == NULL || r->resp.content_length->skip)) in nxt_http_request_header_send()
683 content_length = nxt_list_zero_add(r->resp.fields); in nxt_http_request_header_send()
684 if (nxt_slow_path(content_length == NULL)) { in nxt_http_request_header_send()
688 nxt_http_field_name_set(content_length, "Content-Length"); in nxt_http_request_header_send()
695 content_length->value = p; in nxt_http_request_header_send()
697 content_length->value_length = end - p; in nxt_http_request_header_send()
699 r->resp.content_length = content_length; in nxt_http_request_header_send()
|
| H A D | nxt_unit_request.h | 37 uint64_t content_length; member
|
| H A D | nxt_http_response.c | 30 offsetof(nxt_http_request_t, resp.content_length) },
|
| H A D | nxt_http_error.c | 55 r->resp.content_length = NULL; in nxt_http_request_error()
|
| H A D | nxt_http_variables.c | 564 if (r->resp.content_length != NULL) { in nxt_http_var_response_content_length()
565 str->length = r->resp.content_length->value_length; in nxt_http_var_response_content_length()
566 str->start = r->resp.content_length->value; in nxt_http_var_response_content_length()
|
| /unit/src/python/ |
| H A D | nxt_python_asgi_http.c | 24 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 D | nxt_python_wsgi.c | 44 uint64_t content_length; member
319 pctx->content_length = -1; in nxt_python_request_handler()
383 while (pctx->bytes_sent < pctx->content_length) { in nxt_python_request_handler()
1010 pctx->content_length = -1; in nxt_py_start_resp()
1066 if (pctx->content_length == 0) { in nxt_py_start_resp()
1087 nxt_off_t content_length; in nxt_python_response_add_field() local
1110 if (nxt_slow_path(content_length < 0)) { in nxt_python_response_add_field()
1115 pctx->content_length = content_length; in nxt_python_response_add_field()
1190 size = pctx->req->content_length; in nxt_py_input_read()
1215 size = pctx->req->content_length; in nxt_py_input_read()
[all …]
|
| H A D | nxt_python_asgi.h | 23 uint64_t content_length; member
|
| H A D | nxt_python_asgi.c | 1310 nxt_off_t content_length; in nxt_py_asgi_add_field() local
1331 content_length = nxt_off_t_parse((u_char *) val_str, val_len); in nxt_py_asgi_add_field()
1332 if (nxt_slow_path(content_length < 0)) { in nxt_py_asgi_add_field()
1341 ctx->content_length = content_length; in nxt_py_asgi_add_field()
|
| /unit/src/ruby/ |
| H A D | nxt_ruby_stream_io.c | 102 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 D | request.go | 62 ContentLength: int64(req.content_length),
|
| /unit/src/nodejs/unit-http/ |
| H A D | unit.cpp | 731 buffer = create_buffer((size_t) ws->content_length, &data); in create_websocket_frame()
732 nxt_unit_websocket_read(ws, data, ws->content_length); in create_websocket_frame()
759 if (req->content_length == 0) { in request_read()
765 if (wm > req->content_length) { in request_read()
766 wm = req->content_length; in request_read()
|