/unit/src/ |
H A D | nxt_unit.c | 101 size_t size); 1010 recv_msg.size = rbuf->size - sizeof(nxt_port_msg_t); in nxt_unit_process_msg() 2417 size, size, mmap_buf, in nxt_unit_response_buf_alloc() 2860 size_t size) in nxt_unit_response_write() argument 2864 res = nxt_unit_response_write_nb(req, start, size, size); in nxt_unit_response_write() 4266 size = mmap_msg->size; in nxt_unit_mmap_read() 4270 recv_msg->size = size; in nxt_unit_mmap_read() 6132 dst->size = src->size; in nxt_unit_rbuf_cpy() 6133 dst->oob.size = src->oob.size; in nxt_unit_rbuf_cpy() 6709 err = posix_memalign(&p, size, size); in nxt_unit_lvlhsh_alloc() [all …]
|
H A D | nxt_sockaddr.c | 26 size_t size; in nxt_sockaddr_cache_alloc() local 33 sa = nxt_event_engine_mem_alloc(engine, &hint, size); in nxt_sockaddr_cache_alloc() 70 size_t size; in nxt_sockaddr_alloc() local 83 sa = nxt_mp_zalloc(mp, size); in nxt_sockaddr_alloc() 98 size_t size, copy; in nxt_sockaddr_create() local 101 size = length; in nxt_sockaddr_create() 112 if (size <= offsetof(struct sockaddr_un, sun_path)) { in nxt_sockaddr_create() 132 size = offsetof(struct sockaddr_un, sun_path) + 1; in nxt_sockaddr_create() 143 size = offsetof(struct sockaddr_un, sun_path) + 1; in nxt_sockaddr_create() 144 copy = size; in nxt_sockaddr_create() [all …]
|
H A D | nxt_port_memory_int.h | 83 uint32_t size; /* Payload data size. */ member
|
H A D | nxt_port_socket.c | 90 size = sndbuf * 4; in nxt_port_socket_init() 92 if (rcvbuf < size) { in nxt_port_socket_init() 282 return size; in nxt_port_enqueue_buf() 296 mm->size); in nxt_port_enqueue_buf() 412 sb.size = 0; in nxt_port_write_handler() 621 size_t size; in nxt_port_buf_completion() local 632 if (size != 0) { in nxt_port_buf_completion() 776 msg.size = n; in nxt_port_read_handler() 995 msg.size = n; in nxt_port_queue_read_handler() 1056 return nxt_mp_align(ctx, size, size); in nxt_port_lvlhsh_frag_alloc() [all …]
|
H A D | nxt_http_static.c | 66 static void *nxt_http_static_mtypes_hash_alloc(void *data, size_t size); 844 ssize_t n, size; in nxt_http_static_buf_completion() local 861 size = nxt_buf_mem_size(&b->mem); in nxt_http_static_buf_completion() 863 size = nxt_min(rest, (nxt_off_t) size); in nxt_http_static_buf_completion() 865 n = nxt_file_read(fb->file, b->mem.start, size, fb->file_pos); in nxt_http_static_buf_completion() 867 if (n != size) { in nxt_http_static_buf_completion() 1084 nxt_http_static_mtypes_hash_alloc(void *data, size_t size) in nxt_http_static_mtypes_hash_alloc() argument 1086 return nxt_mp_align(data, size, size); in nxt_http_static_mtypes_hash_alloc()
|
H A D | nxt_http_request.c | 29 struct tm *tm, size_t size, const char *format); 642 p = nxt_mp_nget(r->mem_pool, nxt_http_date_cache.size); in nxt_http_request_header_send() 650 date->value_length = nxt_http_date_cache.size; in nxt_http_request_header_send() 709 nxt_http_buf_mem(nxt_task_t *task, nxt_http_request_t *r, size_t size) in nxt_http_buf_mem() argument 713 b = nxt_buf_mem_alloc(r->mem_pool, size, 0); in nxt_http_buf_mem() 839 size_t size, const char *format) in nxt_http_date_cache_handler() argument
|
H A D | nxt_mp.c | 46 uint8_t size; member 145 memset((p), 0x5A, size) 423 memset(p, 0, size); in nxt_mp_zalloc() 490 if (size > 1) { in nxt_mp_chunk_pages_index() 630 page->size = 0xFF; in nxt_mp_get_small() 638 page->u.taken += size; in nxt_mp_get_small() 754 block->size = size; in nxt_mp_alloc_large() 882 size = page->size << mp->chunk_size_shift; in nxt_mp_chunk_free() 931 page->size = 0; in nxt_mp_chunk_free() 1006 size = nxt_max(size, NXT_MAX_ALIGNMENT); in nxt_mp_get() [all …]
|
H A D | nxt_http.h | 325 size_t size); 399 size_t size);
|
H A D | nxt_conf.c | 246 size_t size; in nxt_conf_create_object() local 347 size_t size; in nxt_conf_create_array() local 575 ssize_t size; in nxt_conf_map_object() member 1684 return nxt_mp_align(data, size, size); in nxt_conf_object_hash_alloc() 2069 size_t size; in nxt_conf_json_parse_number() local 2153 size = p - start; in nxt_conf_json_parse_number() 2519 len = size; in nxt_conf_json_escape_length() 2521 while (size) { in nxt_conf_json_escape_length() 2543 size--; in nxt_conf_json_escape_length() 2555 while (size) { in nxt_conf_json_escape() [all …]
|
H A D | nxt_router.c | 396 size_t size; in nxt_router_start_app_process_handler() local 761 size_t size; in nxt_router_conf_data_handler() local 780 size = 0; in nxt_router_conf_data_handler() 809 nxt_debug(task, "conf_data_handler(%uz): %*s", size, size, p); in nxt_router_conf_data_handler() 840 nxt_mem_munmap(p, size); in nxt_router_conf_data_handler() 2466 size_t size; in nxt_router_socket_conf() local 2581 size_t size; in nxt_router_listen_socket_rpc_create() local 2810 size_t size; in nxt_router_app_rpc_create() local 3761 size_t size; in nxt_router_access_log_writer() local 3776 + date_cache.size in nxt_router_access_log_writer() [all …]
|
H A D | nxt_http_route.c | 237 size_t size; in nxt_http_routes_create() local 252 routes = nxt_mp_alloc(mp, size); in nxt_http_routes_create() 360 size_t size; in nxt_http_route_create() local 396 size_t size; in nxt_http_route_match_create() local 418 match = nxt_mp_alloc(mp, size); in nxt_http_route_match_create() 688 size_t size; in nxt_http_route_table_create() local 698 table = nxt_mp_alloc(mp, size); in nxt_http_route_table_create() 727 size_t size; in nxt_http_route_ruleset_create() local 738 ruleset = nxt_mp_alloc(mp, size); in nxt_http_route_ruleset_create() 804 size_t size; in nxt_http_route_rule_create() local [all …]
|
H A D | nxt_h1proto.c | 707 size_t size, used; in nxt_h1p_header_buffer_test() local 943 if (size != 0) { 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() 961 body_rest -= size; in nxt_h1p_request_body_read() 1040 size = nxt_min(size, body_rest); in nxt_h1p_conn_request_body_read() 1264 size = status->length; in nxt_h1p_request_header_send() 1500 size = 0; in nxt_h1p_chunk_create() 1527 if (size == 0) { in nxt_h1p_chunk_create() 1895 size_t size; in nxt_h1p_idle_response() local [all …]
|
H A D | nxt_conf_validation.c | 1306 size_t size; in nxt_conf_vldt_error() local 1314 size = end - error; in nxt_conf_vldt_error() 1316 p = nxt_mp_nget(vldt->pool, size); in nxt_conf_vldt_error() 1321 nxt_memcpy(p, error, size); in nxt_conf_vldt_error() 1323 vldt->error.length = size; in nxt_conf_vldt_error() 1843 int64_t size, min_size; in nxt_conf_vldt_thread_stack_size() local 1848 if (size < min_size) { in nxt_conf_vldt_thread_stack_size() 1854 if ((size % nxt_pagesize) != 0) { in nxt_conf_vldt_thread_stack_size() 2800 nxt_int_t size; member 2835 procmap.size = -1; in nxt_conf_vldt_clone_procmap() [all …]
|
H A D | nxt_var.c | 221 size_t size; in nxt_var_compile() local 245 size = sizeof(nxt_var_t) + n * sizeof(nxt_var_sub_t) + str->length; in nxt_var_compile() 247 var = nxt_mp_get(mp, size + strz); in nxt_var_compile()
|
H A D | nxt_port_memory.h | 24 nxt_port_mmap_get_buf(nxt_task_t *task, nxt_port_mmaps_t *mmaps, size_t size); 27 size_t size, size_t min_size); 51 nxt_int_t nxt_shm_open(nxt_task_t *task, size_t size);
|
H A D | nxt_port_rpc.c | 515 msg.size = 0; in nxt_port_rpc_close()
|
H A D | nxt_port_memory.c | 81 if (i + 1 > port_mmaps->size) { in nxt_port_mmap_at() 82 port_mmaps->size = i + 1; in nxt_port_mmap_at() 101 for (i = 0; i < port_mmaps->size; i++) { in nxt_port_mmaps_destroy() 105 port_mmaps->size = 0; in nxt_port_mmaps_destroy() 114 memset((p), 0xA5, size) 337 hdr->id = mmaps->size - 1; in nxt_port_new_port_mmap() 361 mmaps->size--; in nxt_port_new_port_mmap() 625 size -= free_size; in nxt_port_mmap_increase_buf() 758 sb->size = bsize; in nxt_port_mmap_write() 771 msg->size = 0; in nxt_port_mmap_read() [all …]
|
H A D | nxt_port.h | 199 size_t size; member
|
H A D | nxt_openssl.c | 38 uint8_t size; member 96 void *buf, size_t size); 692 ticket->size = 16; 697 ticket->size = 32; 1335 size_t size; local 1341 size = b->mem.end - b->mem.free; 1343 ret = SSL_read(tls->session, b->mem.free, size); 1384 size_t size) argument 1394 ret = SSL_write(tls->session, buf, size); 1399 sb->socket, buf, size, ret, err); [all …]
|
H A D | nxt_thread_id.h | 110 int err, size; in nxt_thread_get_tid() local 114 size = 0; in nxt_thread_get_tid() 118 sizeof(struct __pthrdsinfo), NULL, size); in nxt_thread_get_tid()
|
/unit/ |
H A D | CHANGES | 719 *) Feature: configuration of the request body size limit.
|
/unit/pkg/deb/debian.module/ |
H A D | rules-noarch.in | 74 find $(CURDIR) -maxdepth 1 -size 0 -delete
|
H A D | rules.in | 74 find $(CURDIR) -maxdepth 1 -size 0 -delete
|
/unit/pkg/deb/debian/ |
H A D | rules.in | 95 find $(CURDIR) -maxdepth 1 -size 0 -delete
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 857 uint32_t size; member 883 headers_info.size = 0; in nxt_ruby_rack_result_headers() 893 headers_info.fields, headers_info.size); in nxt_ruby_rack_result_headers() 940 headers_info->size += RSTRING_LEN(r_key) + (pos - value); in nxt_ruby_hash_info() 948 headers_info->size += RSTRING_LEN(r_key) + (value_end - value); in nxt_ruby_hash_info() 1068 nxt_ruby_rack_file_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_ruby_rack_file_read() argument 1075 size = nxt_min(size, (size_t) file->rest); in nxt_ruby_rack_file_read() 1077 res = pread(file->fd, dst, size, file->pos); in nxt_ruby_rack_file_read() 1083 if (size > (size_t) res) { in nxt_ruby_rack_file_read()
|