/unit/src/ |
H A D | nxt_http_return.c | 25 static nxt_int_t nxt_http_return_encode(nxt_mp_t *mp, nxt_str_t *encoded, 38 nxt_mp_t *mp; in nxt_http_return_init() local 42 mp = rtcf->mem_pool; in nxt_http_return_init() 44 conf = nxt_mp_zget(mp, sizeof(nxt_http_return_conf_t)); in nxt_http_return_init() 67 return nxt_http_return_encode(mp, &conf->encoded, &str); in nxt_http_return_init() 151 nxt_http_return_encode(nxt_mp_t *mp, nxt_str_t *encoded, in nxt_http_return_encode() argument 165 encoded->start = nxt_mp_nget(mp, encoded->length); in nxt_http_return_encode()
|
H A D | nxt_http_route.c | 239 nxt_mp_t *mp; in nxt_http_routes_create() local 250 mp = tmcf->router_conf->mem_pool; in nxt_http_routes_create() 252 routes = nxt_mp_alloc(mp, size); in nxt_http_routes_create() 398 nxt_mp_t *mp; in nxt_http_route_match_create() local 418 match = nxt_mp_alloc(mp, size); in nxt_http_route_match_create() 653 nxt_mp_t *mp; in nxt_http_action_init() local 670 mp = rtcf->mem_pool; in nxt_http_action_init() 724 table = nxt_mp_alloc(mp, size); in nxt_http_route_table_create() 840 rule = nxt_mp_alloc(mp, size); in nxt_http_route_rule_create() 1515 nxt_mp_t *mp; in nxt_http_action_create() local [all …]
|
H A D | nxt_http_route_addr.c | 17 nxt_http_route_addr_pattern_parse(nxt_mp_t *mp, in nxt_http_route_addr_pattern_parse() argument
|
H A D | nxt_http_route_addr.h | 71 NXT_EXPORT nxt_int_t nxt_http_route_addr_pattern_parse(nxt_mp_t *mp,
|
H A D | nxt_http_static.c | 78 nxt_mp_t *mp; in nxt_http_static_init() local 86 mp = rtcf->mem_pool; in nxt_http_static_init() 88 conf = nxt_mp_zget(mp, sizeof(nxt_http_static_conf_t)); in nxt_http_static_init() 97 conf->shares = nxt_mp_zget(mp, sizeof(nxt_http_static_share_t) in nxt_http_static_init() 120 ret = nxt_conf_get_string_dup(acf->index, mp, &conf->index); in nxt_http_static_init() 173 action->fallback = nxt_mp_alloc(mp, sizeof(nxt_http_action_t)); in nxt_http_static_init() 929 nxt_http_static_mtypes_init(nxt_mp_t *mp, nxt_lvlhsh_t *hash) in nxt_http_static_mtypes_init() argument 1007 ret = nxt_http_static_mtypes_hash_add(mp, hash, &exten, type); in nxt_http_static_mtypes_init() 1034 nxt_http_static_mtypes_hash_add(nxt_mp_t *mp, nxt_lvlhsh_t *hash, in nxt_http_static_mtypes_hash_add() argument 1040 mtype = nxt_mp_get(mp, sizeof(nxt_http_static_mtype_t)); in nxt_http_static_mtypes_hash_add() [all …]
|
H A D | nxt_http_variables.c | 138 nxt_http_unknown_var_ref(nxt_mp_t *mp, nxt_var_ref_t *ref, nxt_str_t *name) in nxt_http_unknown_var_ref() argument 154 lower = nxt_str_alloc(mp, str.length); in nxt_http_unknown_var_ref() 177 hash = nxt_http_header_hash(mp, &str); in nxt_http_unknown_var_ref() 193 hash = nxt_http_argument_hash(mp, &str); in nxt_http_unknown_var_ref() 209 hash = nxt_http_cookie_hash(mp, &str); in nxt_http_unknown_var_ref() 218 ref->data = nxt_var_field_new(mp, &str, (uint32_t) hash); in nxt_http_unknown_var_ref()
|
H A D | nxt_isolation.c | 72 nxt_mp_t *mp) in nxt_isolation_main_prefork() argument 319 nxt_isolation_credential_map(nxt_task_t *task, nxt_mp_t *mp, in nxt_isolation_credential_map() argument 352 map->map = nxt_mp_alloc(mp, map->size * sizeof(nxt_clone_map_entry_t)); in nxt_isolation_credential_map() 360 ret = nxt_conf_map_object(mp, obj, nxt_clone_map_entry_conf, in nxt_isolation_credential_map() 614 nxt_mp_t *mp; in nxt_isolation_set_lang_mounts() local 619 mp = process->mem_pool; in nxt_isolation_set_lang_mounts() 622 mounts = nxt_array_copy(mp, NULL, lang_mounts); in nxt_isolation_set_lang_mounts() 637 mnt[i].dst = nxt_mp_alloc(mp, rootfs_len + len + 1); in nxt_isolation_set_lang_mounts() 663 mnt->dst = nxt_mp_nget(mp, rootfs_len + nxt_length("/tmp") + 1); in nxt_isolation_set_lang_mounts() 682 mnt->dst = nxt_mp_nget(mp, rootfs_len + nxt_length("/proc") + 1); in nxt_isolation_set_lang_mounts()
|
H A D | nxt_isolation.h | 10 nxt_mp_t *mp);
|
H A D | nxt_job.c | 16 nxt_job_create(nxt_mp_t *mp, size_t size) in nxt_job_create() argument 21 if (mp == NULL) { in nxt_job_create() 22 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_job_create() 23 if (nxt_slow_path(mp == NULL)) { in nxt_job_create() 27 job = nxt_mp_zget(mp, size); in nxt_job_create() 31 job = nxt_mp_zalloc(mp, size); in nxt_job_create() 40 job->mem_pool = mp; in nxt_job_create() 85 nxt_job_cleanup_add(nxt_mp_t *mp, nxt_job_t *job) 89 mpcl = nxt_mem_pool_cleanup(mp, 0);
|
H A D | nxt_job.h | 59 NXT_EXPORT void *nxt_job_create(nxt_mp_t *mp, size_t size); 62 NXT_EXPORT nxt_int_t nxt_job_cleanup_add(nxt_mp_t *mp, nxt_job_t *job);
|
H A D | nxt_job_cache_file.c | 12 nxt_job_cache_file_create(nxt_mp_t *mp) in nxt_job_cache_file_create() argument 16 jbc = nxt_job_create(mp, sizeof(nxt_job_cache_file_t)); in nxt_job_cache_file_create()
|
H A D | nxt_js.c | 84 nxt_js_conf_new(nxt_mp_t *mp, nxt_bool_t test) in nxt_js_conf_new() argument 88 jcf = nxt_mp_zget(mp, sizeof(nxt_js_conf_t)); in nxt_js_conf_new() 93 jcf->pool = mp; in nxt_js_conf_new() 96 jcf->modules = nxt_array_create(mp, 4, sizeof(nxt_js_module_t)); in nxt_js_conf_new() 101 jcf->funcs = nxt_array_create(mp, 4, sizeof(nxt_str_t)); in nxt_js_conf_new()
|
H A D | nxt_js.h | 26 nxt_js_conf_t *nxt_js_conf_new(nxt_mp_t *mp, nxt_bool_t test);
|
H A D | nxt_list.c | 11 nxt_list_create(nxt_mp_t *mp, nxt_uint_t n, size_t size) in nxt_list_create() argument 15 list = nxt_mp_get(mp, sizeof(nxt_list_t) + n * size); in nxt_list_create() 21 list->mem_pool = mp; in nxt_list_create()
|
H A D | nxt_list.h | 95 NXT_EXPORT nxt_list_t *nxt_list_create(nxt_mp_t *mp, nxt_uint_t n, size_t size);
|
H A D | nxt_listen_socket.c | 30 nxt_listen_socket_create(nxt_task_t *task, nxt_mp_t *mp, in nxt_listen_socket_create() argument 101 sa = nxt_sockaddr_alloc(mp, sa->socklen + 4, sa->length + 4); in nxt_listen_socket_create()
|
H A D | nxt_listen_socket.h | 57 NXT_EXPORT nxt_int_t nxt_listen_socket_create(nxt_task_t *task, nxt_mp_t *mp,
|
H A D | nxt_main_process.c | 866 nxt_mp_t *mp; in nxt_main_process_sigusr1_handler() local 886 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_main_process_sigusr1_handler() 887 if (mp == NULL) { in nxt_main_process_sigusr1_handler() 895 nxt_mp_destroy(mp); in nxt_main_process_sigusr1_handler() 939 nxt_mp_destroy(mp); in nxt_main_process_sigusr1_handler() 957 nxt_mp_destroy(mp); in nxt_main_process_sigusr1_handler() 1411 nxt_mp_t *mp; in nxt_main_port_modules_handler() local 1449 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_main_port_modules_handler() 1450 if (mp == NULL) { in nxt_main_port_modules_handler() 1454 b = nxt_buf_chk_make_plain(mp, b, msg->size); in nxt_main_port_modules_handler() [all …]
|
H A D | nxt_mp.c | 282 return mp; in nxt_mp_create() 289 mp->retain++; in nxt_mp_retain() 291 nxt_thread_log_debug("mp %p retain: %uD", mp, mp->retain); in nxt_mp_retain() 298 mp->retain--; in nxt_mp_release() 300 nxt_thread_log_debug("mp %p release: %uD", mp, mp->retain); in nxt_mp_release() 345 nxt_free(mp); in nxt_mp_destroy() 673 n = mp->cluster_size >> mp->page_size_shift; in nxt_mp_alloc_cluster() 938 n = mp->cluster_size >> mp->page_size_shift; in nxt_mp_chunk_free() 952 n = mp->cluster_size >> mp->page_size_shift; in nxt_mp_chunk_free() 980 p = nxt_mp_get_small(mp, &mp->nget_pages, size); in nxt_mp_nget() [all …]
|
H A D | nxt_mp.h | 42 NXT_EXPORT void nxt_mp_destroy(nxt_mp_t *mp); 47 NXT_EXPORT void nxt_mp_retain(nxt_mp_t *mp); 53 NXT_EXPORT void nxt_mp_release(nxt_mp_t *mp); 60 NXT_EXPORT nxt_bool_t nxt_mp_is_empty(nxt_mp_t *mp); 67 NXT_EXPORT void *nxt_mp_alloc(nxt_mp_t *mp, size_t size) 75 NXT_EXPORT void *nxt_mp_zalloc(nxt_mp_t *mp, size_t size) 87 NXT_EXPORT void nxt_mp_free(nxt_mp_t *mp, void *p); 91 NXT_EXPORT void *nxt_mp_nget(nxt_mp_t *mp, size_t size) 98 NXT_EXPORT void *nxt_mp_get(nxt_mp_t *mp, size_t size) 105 NXT_EXPORT void *nxt_mp_zget(nxt_mp_t *mp, size_t size) [all …]
|
H A D | nxt_openssl.c | 70 nxt_conf_value_t *value, nxt_mp_t *mp); 74 nxt_tls_init_t *tls_init, nxt_mp_t *mp); 81 nxt_tls_conf_t *conf, nxt_mp_t *mp); 451 nxt_mp_t *mp, nxt_bool_t single) argument 548 nxt_mp_t *mp) argument 581 zcmd = nxt_str_cstrz(mp, &cmd); 582 zvalue = nxt_str_cstrz(mp, &value); 630 nxt_mp_t *mp) argument 850 nxt_mp_t *mp) argument 937 mp) [all …]
|
H A D | nxt_pcre.c | 30 nxt_regex_compile(nxt_mp_t *mp, nxt_str_t *source, nxt_regex_err_t *err) in nxt_regex_compile() argument 39 re = nxt_mp_get(mp, sizeof(nxt_regex_t) + source->length + 1); in nxt_regex_compile() 58 nxt_pcre_mp = mp; in nxt_regex_compile() 105 nxt_regex_match_create(nxt_mp_t *mp, size_t size) in nxt_regex_match_create() argument 109 match = nxt_mp_get(mp, sizeof(nxt_regex_match_t) + sizeof(int) * size); in nxt_regex_match_create()
|
H A D | nxt_pcre2.c | 24 nxt_regex_compile(nxt_mp_t *mp, nxt_str_t *source, nxt_regex_err_t *err) in nxt_regex_compile() argument 36 nxt_pcre2_free, mp); in nxt_regex_compile() 46 re = nxt_mp_get(mp, sizeof(nxt_regex_t)); in nxt_regex_compile() 51 if (nxt_slow_path(nxt_str_dup(mp, &re->pattern, source) == NULL)) { in nxt_regex_compile() 98 nxt_pcre2_malloc(PCRE2_SIZE size, void *mp) in nxt_pcre2_malloc() argument 100 return nxt_mp_get(mp, size); in nxt_pcre2_malloc() 105 nxt_pcre2_free(void *p, void *mp) in nxt_pcre2_free() argument 111 nxt_regex_match_create(nxt_mp_t *mp, size_t size) in nxt_regex_match_create() argument 116 ctx = pcre2_general_context_create(nxt_pcre2_malloc, nxt_pcre2_free, mp); in nxt_regex_match_create()
|
H A D | nxt_port.c | 25 nxt_mp_t *mp; in nxt_port_mp_cleanup() local 29 mp = data; in nxt_port_mp_cleanup() 44 nxt_mp_free(mp, port); in nxt_port_mp_cleanup() 52 nxt_mp_t *mp; in nxt_port_new() local 55 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_port_new() 57 if (nxt_slow_path(mp == NULL)) { in nxt_port_new() 61 port = nxt_mp_zalloc(mp, sizeof(nxt_port_t)); in nxt_port_new() 67 port->mem_pool = mp; in nxt_port_new() 70 nxt_mp_cleanup(mp, nxt_port_mp_cleanup, task, port, mp); in nxt_port_new() 78 nxt_mp_destroy(mp); in nxt_port_new()
|
H A D | nxt_port_memory.c | 121 nxt_mp_t *mp; in nxt_port_mmap_buf_completion() local 189 mp = b->data; in nxt_port_mmap_buf_completion() 191 nxt_mp_free(mp, b); in nxt_port_mmap_buf_completion() 192 nxt_mp_release(mp); in nxt_port_mmap_buf_completion() 545 nxt_mp_t *mp; in nxt_port_mmap_get_buf() local 572 mp = task->thread->engine->mem_pool; in nxt_port_mmap_get_buf() 573 nxt_mp_free(mp, b); in nxt_port_mmap_get_buf() 574 nxt_mp_release(mp); in nxt_port_mmap_get_buf()
|