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