Home
last modified time | relevance | path

Searched refs:size (Results 1 – 25 of 161) sorted by last modified time

1234567

/unit/src/
H A Dnxt_conn.h57 size_t size, nxt_uint_t flags);
84 size_t size);
250 ssize_t nxt_conn_io_recv(nxt_conn_t *c, void *buf, size_t size,
258 size_t size);
265 ssize_t nxt_event_conn_io_send(nxt_conn_t *c, void *buf, size_t size);
H A Dnxt_http_request.c29 struct tm *tm, size_t size, const char *format);
644 p = nxt_mp_nget(r->mem_pool, nxt_http_date_cache.size); in nxt_http_request_header_send()
652 date->value_length = nxt_http_date_cache.size; in nxt_http_request_header_send()
711 nxt_http_buf_mem(nxt_task_t *task, nxt_http_request_t *r, size_t size) in nxt_http_buf_mem() argument
715 b = nxt_buf_mem_alloc(r->mem_pool, size, 0); in nxt_http_buf_mem()
844 size_t size, const char *format) in nxt_http_date_cache_handler() argument
H A Dnxt_unit.c101 size_t size);
1006 recv_msg.size = rbuf->size - sizeof(nxt_port_msg_t); in nxt_unit_process_msg()
2413 size, size, mmap_buf, in nxt_unit_response_buf_alloc()
2856 size_t size) in nxt_unit_response_write() argument
2860 res = nxt_unit_response_write_nb(req, start, size, size); in nxt_unit_response_write()
4262 size = mmap_msg->size; in nxt_unit_mmap_read()
4266 recv_msg->size = size; in nxt_unit_mmap_read()
6128 dst->size = src->size; in nxt_unit_rbuf_cpy()
6129 dst->oob.size = src->oob.size; in nxt_unit_rbuf_cpy()
6705 err = posix_memalign(&p, size, size); in nxt_unit_lvlhsh_alloc()
[all …]
H A Dnxt_router.c374 size_t size; in nxt_router_start_app_process_handler() local
739 size_t size; in nxt_router_conf_data_handler() local
758 size = 0; in nxt_router_conf_data_handler()
787 nxt_debug(task, "conf_data_handler(%uz): %*s", size, size, p); in nxt_router_conf_data_handler()
818 nxt_mem_munmap(p, size); in nxt_router_conf_data_handler()
2504 size_t size; in nxt_router_socket_conf() local
2527 size = nxt_sockaddr_size(sa); in nxt_router_socket_conf()
2619 size_t size; in nxt_router_listen_socket_rpc_create() local
2848 size_t size; in nxt_router_app_rpc_create() local
5401 while (size > 0) { in nxt_router_prepare_msg()
[all …]
H A Dnxt_port.h204 size_t size; member
H A Dnxt_event_engine.h513 size_t size);
515 void *p, size_t size);
516 void *nxt_event_engine_buf_mem_alloc(nxt_event_engine_t *engine, size_t size);
H A Dnxt_h1proto.c707 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()
1896 size_t size; in nxt_h1p_idle_response() local
[all …]
H A Dnxt_controller.c568 size_t size; in nxt_controller_conf_send() local
585 size = nxt_conf_json_length(conf, NULL); in nxt_controller_conf_send()
592 fd = nxt_shm_open(task, size); in nxt_controller_conf_send()
604 nxt_mem_munmap(mem, size); in nxt_controller_conf_send()
606 size = end - (u_char *) mem; in nxt_controller_conf_send()
2068 size_t size; in nxt_controller_conf_store() local
2080 fd = nxt_shm_open(task, size); in nxt_controller_conf_store()
2092 nxt_mem_munmap(mem, size); in nxt_controller_conf_store()
2094 size = end - (u_char *) mem; in nxt_controller_conf_store()
2119 size_t size; in nxt_controller_response() local
[all …]
H A Dnxt_conf.c246 size_t size; in nxt_conf_create_object() local
361 size_t size; in nxt_conf_create_array() local
589 ssize_t size; in nxt_conf_map_object() member
1698 return nxt_mp_align(data, size, size); in nxt_conf_object_hash_alloc()
2083 size_t size; in nxt_conf_json_parse_number() local
2167 size = p - start; in nxt_conf_json_parse_number()
2533 len = size; in nxt_conf_json_escape_length()
2535 while (size) { in nxt_conf_json_escape_length()
2557 size--; in nxt_conf_json_escape_length()
2569 while (size) { in nxt_conf_json_escape()
[all …]
H A Dnxt_main_process.c30 nxt_uint_t size; member
61 const char *name, u_char *buf, size_t size);
1028 size_t size; in nxt_main_port_socket_handler() local
1074 size = ls.end - ls.start; in nxt_main_port_socket_handler()
1079 size + 1); in nxt_main_port_socket_handler()
1456 size_t n, size; in nxt_main_port_conf_store_handler() local
1477 size = 0; in nxt_main_port_conf_store_handler()
1501 nxt_debug(task, "conf_store_handler(%uz): %*s", size, size, p); in nxt_main_port_conf_store_handler()
1527 nxt_mem_munmap(p, size); in nxt_main_port_conf_store_handler()
1539 u_char *buf, size_t size) in nxt_main_file_store() argument
[all …]
H A Dnxt_sockaddr.c22 size_t size; in nxt_sockaddr_cache_alloc() local
29 sa = nxt_event_engine_mem_alloc(engine, &hint, size); in nxt_sockaddr_cache_alloc()
66 size_t size; in nxt_sockaddr_alloc() local
79 sa = nxt_mp_zalloc(mp, size); in nxt_sockaddr_alloc()
94 size_t size, copy; in nxt_sockaddr_create() local
97 size = length; in nxt_sockaddr_create()
108 if (size <= offsetof(struct sockaddr_un, sun_path)) { in nxt_sockaddr_create()
128 size = offsetof(struct sockaddr_un, sun_path) + 1; in nxt_sockaddr_create()
139 size = offsetof(struct sockaddr_un, sun_path) + 1; in nxt_sockaddr_create()
140 copy = size; in nxt_sockaddr_create()
[all …]
H A Dnxt_conf_validation.c1328 size_t size; in nxt_conf_vldt_error() local
1336 size = end - error; in nxt_conf_vldt_error()
1338 p = nxt_mp_nget(vldt->pool, size); in nxt_conf_vldt_error()
1343 nxt_memcpy(p, error, size); in nxt_conf_vldt_error()
1345 vldt->error.length = size; in nxt_conf_vldt_error()
1870 int64_t size, min_size; in nxt_conf_vldt_thread_stack_size() local
1875 if (size < min_size) { in nxt_conf_vldt_thread_stack_size()
1881 if ((size % nxt_pagesize) != 0) { in nxt_conf_vldt_thread_stack_size()
2832 nxt_int_t size; member
2867 procmap.size = -1; in nxt_conf_vldt_clone_procmap()
[all …]
H A Dnxt_process.h70 uint32_t size; member
H A Dnxt_main.h84 typedef void *(*nxt_mem_proto_alloc_t)(void *pool, size_t size);
H A Dnxt_application.c210 size_t size; in nxt_discovery_modules() local
251 size = nxt_length("[]"); in nxt_discovery_modules()
259 size += nxt_length("{\"type\": ,"); in nxt_discovery_modules()
260 size += nxt_length(" \"version\": \"\","); in nxt_discovery_modules()
261 size += nxt_length(" \"file\": \"\","); in nxt_discovery_modules()
262 size += nxt_length(" \"mounts\": []},"); in nxt_discovery_modules()
264 size += NXT_INT_T_LEN in nxt_discovery_modules()
270 size += mounts->nelts * nxt_length("{\"src\": \"\", \"dst\": \"\", " in nxt_discovery_modules()
277 size += nxt_strlen(mnt[j].src) + nxt_strlen(mnt[j].dst) in nxt_discovery_modules()
283 b = nxt_buf_mem_alloc(mp, size, 0); in nxt_discovery_modules()
H A Dnxt_isolation.c288 offsetof(nxt_clone_map_entry_t, size), in nxt_isolation_credential_map()
292 map->size = nxt_conf_array_elements_count(map_array); in nxt_isolation_credential_map()
294 if (map->size == 0) { in nxt_isolation_credential_map()
298 map->map = nxt_mp_alloc(mp, map->size * sizeof(nxt_clone_map_entry_t)); in nxt_isolation_credential_map()
303 for (i = 0; i < map->size; i++) { in nxt_isolation_credential_map()
329 if (clone->uidmap.size == 0 && clone->gidmap.size == 0) { in nxt_isolation_vldt_creds()
334 if (nxt_slow_path(clone->uidmap.size > 0)) { in nxt_isolation_vldt_creds()
341 if (nxt_slow_path(clone->gidmap.size > 0)) { in nxt_isolation_vldt_creds()
H A Dnxt_var.c337 size_t size; in nxt_var_compile() local
365 size = sizeof(nxt_var_t) + n * sizeof(nxt_var_sub_t) + str->length; in nxt_var_compile()
367 var = nxt_mp_get(mp, size + strz); in nxt_var_compile()
H A Dnxt_http_static.c66 static void *nxt_http_static_mtypes_hash_alloc(void *data, size_t size);
847 ssize_t n, size; in nxt_http_static_buf_completion() local
864 size = nxt_buf_mem_size(&b->mem); in nxt_http_static_buf_completion()
866 size = nxt_min(rest, (nxt_off_t) size); in nxt_http_static_buf_completion()
868 n = nxt_file_read(fb->file, b->mem.start, size, fb->file_pos); in nxt_http_static_buf_completion()
870 if (n != size) { in nxt_http_static_buf_completion()
1087 nxt_http_static_mtypes_hash_alloc(void *data, size_t size) in nxt_http_static_mtypes_hash_alloc() argument
1089 return nxt_mp_align(data, size, size); in nxt_http_static_mtypes_hash_alloc()
H A Dnxt_http_route.c237 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()
690 size_t size; in nxt_http_route_table_create() local
700 table = nxt_mp_alloc(mp, size); in nxt_http_route_table_create()
729 size_t size; in nxt_http_route_ruleset_create() local
740 ruleset = nxt_mp_alloc(mp, size); in nxt_http_route_ruleset_create()
806 size_t size; in nxt_http_route_rule_create() local
[all …]
H A Dnxt_http_variables.c25 struct tm *tm, size_t size, const char *format);
198 str->length = date_cache.size; in nxt_http_var_time_local()
214 size_t size, const char *format) in nxt_http_log_date() argument
232 return nxt_sprintf(buf, buf + size, format, in nxt_http_log_date()
H A Dnxt_unix.h282 #define nxt_iobuf_set(iob, p, size) \ argument
285 (iob)->iov_len = size; \
288 #define nxt_iobuf_add(iob, size) \ argument
289 (iob)->iov_len += size
H A Dnxt_clone.c148 if (map->size > 0) { in nxt_clone_credential_map_set()
149 len = len * map->size + 1; in nxt_clone_credential_map_set()
159 for (i = 0; i < map->size; i++) { in nxt_clone_credential_map_set()
169 if (i+1 < map->size) { in nxt_clone_credential_map_set()
265 if (map->size == 0) { in nxt_clone_vldt_credential_uidmap()
275 map->size); in nxt_clone_vldt_credential_uidmap()
293 for (i = 0; i < map->size; i++) { in nxt_clone_vldt_credential_uidmap()
333 if (map->size == 0) { in nxt_clone_vldt_credential_gidmap()
340 map->size); in nxt_clone_vldt_credential_gidmap()
358 m.size); in nxt_clone_vldt_credential_gidmap()
[all …]
/unit/
H A DCHANGES758 *) Feature: configuration of the request body size limit.
/unit/src/ruby/
H A Dnxt_ruby.c824 uint32_t size; member
850 headers_info.size = 0; in nxt_ruby_rack_result_headers()
860 headers_info.fields, headers_info.size); in nxt_ruby_rack_result_headers()
907 headers_info->size += RSTRING_LEN(r_key) + (pos - value); in nxt_ruby_hash_info()
915 headers_info->size += RSTRING_LEN(r_key) + (value_end - value); in nxt_ruby_hash_info()
1035 nxt_ruby_rack_file_read(nxt_unit_read_info_t *read_info, void *dst, size_t size) in nxt_ruby_rack_file_read() argument
1042 size = nxt_min(size, (size_t) file->rest); in nxt_ruby_rack_file_read()
1044 res = pread(file->fd, dst, size, file->pos); in nxt_ruby_rack_file_read()
1050 if (size > (size_t) res) { in nxt_ruby_rack_file_read()
/unit/test/unit/
H A Dhttp.py258 size = int(chunks.pop(0), 16)
261 pytest.fail('Invalid chunk size %s' % str(size))
263 if size == 0:
269 body += temp_body[:size]
271 temp_body = temp_body[size + len(crlf) :]

1234567