/unit/src/ |
H A D | nxt_script.c | 21 nxt_mp_t *mp; member 190 nxt_mp_t *mp; in nxt_script_info_save() local 216 info->mp = mp; in nxt_script_info_save() 232 nxt_mp_destroy(info->mp); in nxt_script_info_save() 239 nxt_mp_destroy(mp); in nxt_script_info_save() 336 nxt_mp_destroy(info->mp); in nxt_script_info_delete() 493 nxt_mp_retain(mp); in nxt_script_store_get() 528 nxt_mp_t *mp; in nxt_script_buf_completion() local 532 mp = b->data; in nxt_script_buf_completion() 535 nxt_mp_free(mp, b); in nxt_script_buf_completion() [all …]
|
H A D | nxt_process.h | 133 nxt_process_t *process, nxt_mp_t *mp); 135 nxt_process_t *process, nxt_mp_t *mp);
|
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_http_parse.c | 108 nxt_http_parse_request_init(nxt_http_request_parse_t *rp, nxt_mp_t *mp) in nxt_http_parse_request_init() argument 110 rp->mem_pool = mp; in nxt_http_parse_request_init() 112 rp->fields = nxt_list_create(mp, 8, sizeof(nxt_http_field_t)); in nxt_http_parse_request_init()
|
H A D | nxt_http_parse.h | 117 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_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_string.h | 119 NXT_EXPORT nxt_str_t *nxt_str_alloc(nxt_mp_t *mp, size_t length); 120 NXT_EXPORT nxt_str_t *nxt_str_dup(nxt_mp_t *mp, nxt_str_t *dst, 122 NXT_EXPORT char *nxt_str_cstrz(nxt_mp_t *mp, const nxt_str_t *src);
|
H A D | nxt_string.c | 11 nxt_str_alloc(nxt_mp_t *mp, size_t length) in nxt_str_alloc() argument 16 s = nxt_mp_get(mp, sizeof(nxt_str_t) + length); in nxt_str_alloc() 34 nxt_str_dup(nxt_mp_t *mp, nxt_str_t *dst, const nxt_str_t *src) in nxt_str_dup() argument 40 dst = nxt_mp_get(mp, sizeof(nxt_str_t) + src->length); in nxt_str_dup() 50 dst->start = nxt_mp_nget(mp, src->length); in nxt_str_dup() 71 nxt_str_cstrz(nxt_mp_t *mp, const nxt_str_t *src) in nxt_str_cstrz() argument 75 dst = nxt_mp_alloc(mp, src->length + 1); in nxt_str_cstrz()
|
H A D | nxt_sockaddr.c | 79 sa = nxt_mp_zalloc(mp, size); in nxt_sockaddr_alloc() 147 sa = nxt_sockaddr_alloc(mp, size, address_length); in nxt_sockaddr_create() 166 nxt_sockaddr_copy(nxt_mp_t *mp, nxt_sockaddr_t *src) in nxt_sockaddr_copy() argument 173 dst = nxt_mp_alloc(mp, length); in nxt_sockaddr_copy() 524 nxt_sockaddr_parse(nxt_mp_t *mp, nxt_str_t *addr) in nxt_sockaddr_parse() argument 528 sa = nxt_sockaddr_parse_optport(mp, addr); in nxt_sockaddr_parse() 554 sa = nxt_sockaddr_unix_parse(mp, addr); in nxt_sockaddr_parse_optport() 557 sa = nxt_sockaddr_inet6_parse(mp, addr); in nxt_sockaddr_parse_optport() 560 sa = nxt_sockaddr_inet_parse(mp, addr); in nxt_sockaddr_parse_optport() 572 nxt_sockaddr_unix_parse(nxt_mp_t *mp, nxt_str_t *addr) in nxt_sockaddr_unix_parse() argument [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_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_conn.h | 222 NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
|
H A D | nxt_status.c | 12 nxt_status_get(nxt_status_report_t *report, nxt_mp_t *mp) in nxt_status_get() argument 32 status = nxt_conf_create_object(mp, 3); in nxt_status_get() 37 obj = nxt_conf_create_object(mp, 4); in nxt_status_get() 51 obj = nxt_conf_create_object(mp, 1); in nxt_status_get() 60 apps = nxt_conf_create_object(mp, report->apps_count); in nxt_status_get() 70 app_obj = nxt_conf_create_object(mp, 2); in nxt_status_get() 78 ret = nxt_conf_set_member_dup(apps, mp, &name, app_obj, i); in nxt_status_get() 83 obj = nxt_conf_create_object(mp, 3); in nxt_status_get() 94 obj = nxt_conf_create_object(mp, 1); in nxt_status_get()
|
H A D | nxt_status.h | 30 nxt_conf_value_t *nxt_status_get(nxt_status_report_t *report, nxt_mp_t *mp);
|
H A D | nxt_conn_accept.c | 88 nxt_mp_t *mp; in nxt_conn_accept_alloc() local 96 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_conn_accept_alloc() 98 if (nxt_fast_path(mp != NULL)) { in nxt_conn_accept_alloc() 99 c = nxt_conn_create(mp, lev->socket.task); in nxt_conn_accept_alloc() 101 nxt_mp_destroy(mp); in nxt_conn_accept_alloc()
|
H A D | nxt_isolation.h | 10 nxt_mp_t *mp);
|
H A D | nxt_sockaddr.h | 65 NXT_EXPORT nxt_sockaddr_t *nxt_sockaddr_alloc(nxt_mp_t *mp, socklen_t socklen, 68 NXT_EXPORT nxt_sockaddr_t *nxt_sockaddr_create(nxt_mp_t *mp, 71 NXT_EXPORT nxt_sockaddr_t *nxt_sockaddr_copy(nxt_mp_t *mp, nxt_sockaddr_t *src) 73 NXT_EXPORT nxt_sockaddr_t *nxt_getsockname(nxt_task_t *task, nxt_mp_t *mp, 82 NXT_EXPORT nxt_sockaddr_t *nxt_sockaddr_parse(nxt_mp_t *mp, nxt_str_t *addr); 83 NXT_EXPORT nxt_sockaddr_t *nxt_sockaddr_parse_optport(nxt_mp_t *mp,
|
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_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_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()
|
H A D | nxt_service.h | 22 NXT_EXPORT nxt_array_t *nxt_services_init(nxt_mp_t *mp);
|
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_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);
|
/unit/src/test/ |
H A D | nxt_http_parse_test.c | 656 nxt_mp_t *mp; in nxt_http_parse_test_bench() local 675 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_http_parse_test_bench() 676 if (nxt_slow_path(mp == NULL)) { in nxt_http_parse_test_bench() 680 if (nxt_slow_path(nxt_http_parse_request_init(&rp, mp) != NXT_OK)) { in nxt_http_parse_test_bench() 701 nxt_mp_destroy(mp); in nxt_http_parse_test_bench()
|