Home
last modified time | relevance | path

Searched refs:nxt_min (Results 1 – 20 of 20) sorted by relevance

/unit/src/
H A Dnxt_http_websocket.c64 copy_size = nxt_min(used_size, frame_size); in nxt_http_websocket_client()
68 buf_free_size = nxt_min(frame_size, PORT_MMAP_DATA_SIZE); in nxt_http_websocket_client()
77 chunk_copy_size = nxt_min(buf_free_size, copy_size); in nxt_http_websocket_client()
H A Dnxt_errno.c145 n = nxt_min((nxt_uint_t) err, nxt_sys_nerr); in nxt_runtime_strerror()
149 size = nxt_min(size, msg->length); in nxt_runtime_strerror()
H A Dnxt_sprintf.c564 length = nxt_min((size_t) (end - buf), length); in nxt_vsprintf()
666 end = nxt_min(end, spf->end); in nxt_integer()
677 end = nxt_min(end, spf->end); in nxt_integer()
706 end = nxt_min(end, spf->end); in nxt_number()
718 end = nxt_min(end, spf->end); in nxt_number()
H A Dnxt_sendbuf.c258 n = c->io->send(c, bm->pos, nxt_min(size, limit)); in nxt_sendbuf_copy_coalesce()
284 return c->io->send(c, b->mem.pos, nxt_min(size, limit)); in nxt_sendbuf_copy_coalesce()
308 size = nxt_min(size, bsize); in nxt_sendbuf_copy()
H A Dnxt_job_file.c100 size = nxt_min(file->size, (nxt_off_t) size); in nxt_job_file_open_and_read()
104 size = nxt_min(file->size, 1024 * 1024); in nxt_job_file_open_and_read()
H A Dnxt_clang.h227 #define nxt_min(val1, val2) \ macro
H A Dnxt_conn_write.c414 limit = nxt_min((size_t) limit, rate->max_limit); in nxt_event_conn_write_limit()
417 return nxt_min((size_t) limit, c->max_chunk); in nxt_event_conn_write_limit()
H A Dnxt_credential.c91 #define NXT_NGROUPS nxt_min(256, NGROUPS_MAX)
H A Dnxt_thread_time.c129 nxt_nanosleep(nxt_min(interval, rest)); in nxt_time_thread()
H A Dnxt_unit.c2898 part_size = nxt_min(size, part_size); in nxt_unit_response_write_nb()
2914 min_size -= nxt_min(min_size, part_size); in nxt_unit_response_write_nb()
2918 part_size = nxt_min(size, PORT_MMAP_DATA_SIZE); in nxt_unit_response_write_nb()
2919 min_part_size = nxt_min(min_size, part_size); in nxt_unit_response_write_nb()
2932 part_size = nxt_min(buf_size, part_size); in nxt_unit_response_write_nb()
2946 min_size -= nxt_min(min_size, part_size); in nxt_unit_response_write_nb()
3138 return nxt_min(max_size, l_size); in nxt_unit_request_readline_size()
3214 copy = nxt_min(rest, copy); in nxt_unit_buf_read()
3335 alloc_size = nxt_min(buf_size, PORT_MMAP_DATA_SIZE); in nxt_unit_websocket_sendv()
3363 copy = nxt_min(l, copy); in nxt_unit_websocket_sendv()
[all …]
H A Dnxt_http_static.c798 alloc = nxt_min(rest, NXT_HTTP_STATIC_BUF_SIZE); in nxt_http_static_body_handler()
863 size = nxt_min(rest, (nxt_off_t) size); in nxt_http_static_buf_completion()
H A Dnxt_h1proto.c879 body_buffer_size = nxt_min(r->conf->socket_conf->body_buffer_size, in nxt_h1p_request_body_read()
944 size = nxt_min(size, body_length); in nxt_h1p_request_body_read()
956 size = nxt_min(body_buffer_size, size); in nxt_h1p_request_body_read()
1040 size = nxt_min(size, body_rest); in nxt_h1p_conn_request_body_read()
H A Dnxt_port_socket.c103 port->max_size = nxt_min(max_size, (size_t) sndbuf); in nxt_port_socket_init()
422 sb.nmax = nxt_min(NXT_IOBUF_MAX * 10 - 1, in nxt_port_write_handler()
H A Dnxt_fastcgi_source.c228 max_record_size = nxt_min(65528, size); in nxt_fastcgi_request_create()
H A Dnxt_http_parse.c360 if (nxt_memcmp(p, "HTTP/", nxt_min(end - p, 5)) == 0) { in nxt_http_parse_request_line()
H A Dnxt_kqueue_engine.c922 lev->ready = nxt_min(lev->batch, (uint32_t) lev->socket.kq_available); in nxt_kqueue_listen_handler()
H A Dnxt_router.c5560 nxt_min(req_size + content_length, PORT_MMAP_DATA_SIZE)); in nxt_router_prepare_msg()
5743 free_size = nxt_min(size, PORT_MMAP_DATA_SIZE); in nxt_router_prepare_msg()
5770 copy_size = nxt_min(free_size, size); in nxt_router_prepare_msg()
/unit/src/test/
H A Dnxt_malloc_test.c48 alignment = nxt_min(alignment, a); in nxt_malloc_run_test()
H A Dnxt_unit_websocket_chat.c176 nxt_min(sizeof(buf), in ws_chat_websocket_handler()
/unit/src/ruby/
H A Dnxt_ruby.c1075 size = nxt_min(size, (size_t) file->rest); in nxt_ruby_rack_file_read()