Home
last modified time | relevance | path

Searched refs:mp (Results 26 – 50 of 77) sorted by last modified time

1234

/unit/src/
H A Dnxt_script.c21 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 Dnxt_process.h133 nxt_process_t *process, nxt_mp_t *mp);
135 nxt_process_t *process, nxt_mp_t *mp);
H A Dnxt_js.h26 nxt_js_conf_t *nxt_js_conf_new(nxt_mp_t *mp, nxt_bool_t test);
H A Dnxt_http_parse.c108 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 Dnxt_http_parse.h117 nxt_mp_t *mp);
H A Dnxt_job.c16 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 Dnxt_http_return.c25 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 Dnxt_string.h119 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 Dnxt_string.c11 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 Dnxt_sockaddr.c79 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 Dnxt_http_route_addr.c17 nxt_http_route_addr_pattern_parse(nxt_mp_t *mp, in nxt_http_route_addr_pattern_parse() argument
H A Dnxt_port.c25 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 Dnxt_conn.h222 NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
H A Dnxt_status.c12 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 Dnxt_status.h30 nxt_conf_value_t *nxt_status_get(nxt_status_report_t *report, nxt_mp_t *mp);
H A Dnxt_conn_accept.c88 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 Dnxt_isolation.h10 nxt_mp_t *mp);
H A Dnxt_sockaddr.h65 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 Dnxt_http_route_addr.h71 NXT_EXPORT nxt_int_t nxt_http_route_addr_pattern_parse(nxt_mp_t *mp,
H A Dnxt_mp.c282 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 Dnxt_port_memory.c121 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 Dnxt_service.h22 NXT_EXPORT nxt_array_t *nxt_services_init(nxt_mp_t *mp);
H A Dnxt_list.h95 NXT_EXPORT nxt_list_t *nxt_list_create(nxt_mp_t *mp, nxt_uint_t n, size_t size);
H A Dnxt_job.h59 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 Dnxt_http_parse_test.c656 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()

1234