/unit/src/java/ |
H A D | nxt_jni_InputStream.c | 166 size_t rest, b_size; in nxt_java_InputStream_skip() local 172 rest = n; in nxt_java_InputStream_skip() 178 b_size = rest < b_size ? rest : b_size; in nxt_java_InputStream_skip() 181 rest -= b_size; in nxt_java_InputStream_skip() 183 if (rest == 0) { in nxt_java_InputStream_skip()
|
/unit/src/ |
H A D | nxt_http_source.c | 30 nxt_http_source_t *hs, nxt_buf_t *rest); 429 nxt_buf_t *rest) in nxt_http_source_header_ready() argument 464 if (nxt_buf_mem_used_size(&rest->mem) != 0) { in nxt_http_source_header_ready() 465 hs->rest = nxt_http_chunk_parse(task, &hsc->parse, rest); in nxt_http_source_header_ready() 467 if (nxt_slow_path(hs->rest == NULL)) { in nxt_http_source_header_ready() 479 if (nxt_buf_mem_used_size(&rest->mem) != 0) { in nxt_http_source_header_ready() 480 hs->rest = rest; in nxt_http_source_header_ready() 573 nxt_buf_chain_add(&hs->rest, in); in nxt_http_source_body_filter()
|
H A D | nxt_http_source.h | 31 nxt_buf_t *rest; member
|
H A D | nxt_http_static.c | 767 nxt_off_t rest; in nxt_http_static_body_handler() local 775 rest = fb->file_end - fb->file_pos; in nxt_http_static_body_handler() 781 alloc = nxt_min(rest, NXT_HTTP_STATIC_BUF_SIZE); in nxt_http_static_body_handler() 796 rest -= alloc; in nxt_http_static_body_handler() 798 } while (rest > 0 && ++n < NXT_HTTP_STATIC_BUF_COUNT); in nxt_http_static_body_handler() 829 nxt_off_t rest; in nxt_http_static_buf_completion() local 843 rest = fb->file_end - fb->file_pos; in nxt_http_static_buf_completion() 846 size = nxt_min(rest, (nxt_off_t) size); in nxt_http_static_buf_completion() 862 if (n == rest) { in nxt_http_static_buf_completion()
|
H A D | nxt_sendbuf.c | 409 nxt_buf_t *b, *next, **last, *rest, **last_rest; in nxt_sendbuf_coalesce_completion() local 412 rest = NULL; in nxt_sendbuf_coalesce_completion() 413 last_rest = &rest; in nxt_sendbuf_coalesce_completion() 444 return rest; in nxt_sendbuf_coalesce_completion()
|
H A D | nxt_fastcgi_source.h | 72 nxt_buf_t *rest; member
|
H A D | nxt_thread_time.c | 102 nxt_nsec_t interval, rest; in nxt_time_thread() local 127 rest = 1000000000 - now.realtime.nsec; in nxt_time_thread() 129 nxt_nanosleep(nxt_min(interval, rest)); in nxt_time_thread()
|
H A D | nxt_http_parse.c | 165 nxt_bool_t rest; in nxt_http_parse_request_line() local 257 rest = 0; in nxt_http_parse_request_line() 316 rest = 1; in nxt_http_parse_request_line() 385 if (rest) { in nxt_http_parse_request_line() 404 if (rest) { in nxt_http_parse_request_line()
|
H A D | nxt_http_route.c | 1471 nxt_str_t rest; in nxt_http_pass_segments() local 1473 if (nxt_slow_path(nxt_str_dup(mp, &rest, pass) == NULL)) { in nxt_http_pass_segments() 1480 p = nxt_memchr(rest.start, '/', rest.length); in nxt_http_pass_segments() 1489 segments->length = p - rest.start; in nxt_http_pass_segments() 1490 segments->start = rest.start; in nxt_http_pass_segments() 1492 rest.length -= segments->length + 1; in nxt_http_pass_segments() 1493 rest.start = p + 1; in nxt_http_pass_segments() 1497 *segments = rest; in nxt_http_pass_segments()
|
H A D | nxt_fastcgi_source.c | 664 fs->rest = b; in nxt_fastcgi_source_header_ready() 706 nxt_buf_chain_add(&fs->rest, in); in nxt_fastcgi_source_body_filter()
|
H A D | nxt_unit.c | 3203 size_t rest, copy, read; in nxt_unit_buf_read() local 3207 rest = size; in nxt_unit_buf_read() 3216 copy = nxt_min(rest, copy); in nxt_unit_buf_read() 3221 rest -= copy; in nxt_unit_buf_read() 3223 if (rest == 0) { in nxt_unit_buf_read() 3236 read = size - rest; in nxt_unit_buf_read()
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 1063 off_t rest; member 1075 size = nxt_min(size, (size_t) file->rest); in nxt_ruby_rack_file_read() 1081 file->rest -= res; in nxt_ruby_rack_file_read() 1084 file->rest = 0; in nxt_ruby_rack_file_read() 1088 read_info->eof = file->rest == 0; in nxt_ruby_rack_file_read() 1131 ruby_file.rest = finfo.st_size; in nxt_ruby_rack_result_body_file_write() 1134 ri.read_info.eof = ruby_file.rest == 0; in nxt_ruby_rack_result_body_file_write() 1135 ri.read_info.buf_size = ruby_file.rest; in nxt_ruby_rack_result_body_file_write()
|
/unit/src/python/ |
H A D | nxt_python_asgi_websocket.c | 493 uint64_t rest; in nxt_py_asgi_websocket_handler() local 522 rest = nxt_py_asgi_ws_max_frame_size - ws->pending_frame_len; in nxt_py_asgi_websocket_handler() 524 if (nxt_slow_path(frame->payload_len > rest)) { in nxt_py_asgi_websocket_handler() 530 rest = nxt_py_asgi_ws_max_buffer_size - ws->pending_payload_len; in nxt_py_asgi_websocket_handler() 532 if (nxt_slow_path(frame->payload_len > rest)) { in nxt_py_asgi_websocket_handler()
|
/unit/ |
H A D | CONTRIBUTING.md | 77 - Limit the subject line to 67 characters, and the rest of the commit message
|