| /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
|