/unit/src/ |
H A D | nxt_main_process.c | 475 process->mem_pool = nxt_mp_create(1024, 128, 256, 32); in nxt_main_start_process_handler() 476 if (process->mem_pool == NULL) { in nxt_main_start_process_handler() 487 b = nxt_buf_chk_make_plain(process->mem_pool, msg->buf, msg->size); in nxt_main_start_process_handler() 510 process->name = nxt_mp_alloc(process->mem_pool, app_conf->name.length in nxt_main_start_process_handler() 528 conf = nxt_conf_json_parse(process->mem_pool, start, b->mem.free, NULL); in nxt_main_start_process_handler() 540 ret = nxt_conf_map_object(process->mem_pool, conf, nxt_common_app_conf, in nxt_main_start_process_handler() 572 ret = nxt_conf_map_object(process->mem_pool, app_conf->limits, in nxt_main_start_process_handler() 757 buf = nxt_buf_mem_alloc(task->thread->engine->mem_pool, in nxt_main_process_whoami_handler() 1162 out = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_main_port_socket_handler() 1506 lang->mounts = nxt_array_create(rt->mem_pool, nmounts, in nxt_main_port_modules_handler() [all …]
|
H A D | nxt_buf_pool.h | 23 nxt_mp_t *mem_pool; member
|
H A D | nxt_http_chunk_parse.c | 209 b = nxt_buf_mem_alloc(hcp->mem_pool, 0, 0); in nxt_http_chunk_buffer() 217 nxt_mp_retain(hcp->mem_pool); in nxt_http_chunk_buffer()
|
H A D | nxt_http_variables.c | 250 str->start = nxt_mp_nget(r->mem_pool, NXT_TIME_T_LEN + 4); in nxt_http_var_request_time() 350 str->start = nxt_mp_nget(r->mem_pool, str->length); in nxt_http_var_time_local() 412 str->start = nxt_mp_nget(r->mem_pool, 32); in nxt_http_var_request_id() 439 str->start = nxt_mp_nget(r->mem_pool, NXT_OFF_T_LEN); in nxt_http_var_body_bytes_sent() 461 str->start = nxt_mp_nget(r->mem_pool, 3); in nxt_http_var_status() 571 str->start = nxt_mp_nget(r->mem_pool, NXT_OFF_T_LEN); in nxt_http_var_response_content_length()
|
H A D | nxt_port.c | 67 port->mem_pool = mp; in nxt_port_new() 142 nxt_mp_release(port->mem_pool); in nxt_port_release() 235 b = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_send_port() 392 b = nxt_buf_mem_alloc(task->thread->engine->mem_pool, in nxt_port_change_log_file() 485 buf = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, in nxt_port_remove_notify_others()
|
H A D | nxt_process.c | 117 process = nxt_mp_zalloc(rt->mem_pool, sizeof(nxt_process_t) in nxt_process_new() 777 buf = nxt_buf_mem_alloc(main_port->mem_pool, sizeof(nxt_pid_t), 0); in nxt_process_whoami() 789 nxt_mp_free(main_port->mem_pool, buf); in nxt_process_whoami() 802 nxt_mp_free(main_port->mem_pool, buf); in nxt_process_whoami() 984 process->user_cred = nxt_mp_zalloc(process->mem_pool, in nxt_process_creds_set() 991 str = nxt_mp_zalloc(process->mem_pool, user->length + 1); in nxt_process_creds_set() 1002 str = nxt_mp_zalloc(process->mem_pool, group->length + 1); in nxt_process_creds_set() 1014 return nxt_credential_get(task, process->mem_pool, process->user_cred, str); in nxt_process_creds_set()
|
H A D | nxt_upstream_round_robin.c | 58 mp = tmcf->router_conf->mem_pool; in nxt_upstream_round_robin_create() 132 mp = tmcf->router_conf->mem_pool; in nxt_upstream_round_robin_joint_create()
|
H A D | nxt_http_error.c | 43 r->resp.fields = nxt_list_create(r->mem_pool, 8, sizeof(nxt_http_field_t)); in nxt_http_request_error()
|
H A D | nxt_port_socket.c | 123 nxt_mp_destroy(port->mem_pool); in nxt_port_destroy() 953 smsg = nxt_mp_alloc(port->mem_pool, in nxt_port_queue_read_handler() 1086 fmsg = nxt_mp_alloc(port->mem_pool, sizeof(nxt_port_recv_msg_t)); in nxt_port_frag_start() 1103 lhq.pool = port->mem_pool; in nxt_port_frag_start() 1115 nxt_mp_free(port->mem_pool, fmsg); in nxt_port_frag_start() 1123 nxt_mp_free(port->mem_pool, fmsg); in nxt_port_frag_start() 1151 lhq.pool = port->mem_pool; in nxt_port_frag_find() 1235 nxt_mp_free(port->mem_pool, fmsg); in nxt_port_read_msg_process() 1317 b = nxt_buf_mem_alloc(port->mem_pool, port->max_size, 0); in nxt_port_buf_alloc()
|
H A D | nxt_http_route.c | 250 mp = tmcf->router_conf->mem_pool; in nxt_http_routes_create() 369 route = nxt_mp_alloc(tmcf->router_conf->mem_pool, size); in nxt_http_route_create() 416 mp = tmcf->router_conf->mem_pool; in nxt_http_route_match_create() 441 ret = nxt_conf_map_object(tmcf->mem_pool, in nxt_http_route_match_create() 670 mp = rtcf->mem_pool; in nxt_http_action_init() 1201 start = nxt_mp_nget(slices->mem_pool, test->length); in nxt_http_route_pattern_slice() 1334 r, r->mem_pool); in nxt_http_pass_var() 1339 action = nxt_mp_zget(r->mem_pool, in nxt_http_pass_var() 1521 mp = rtcf->mem_pool; in nxt_http_action_create() 1552 action = nxt_mp_zalloc(rtcf->mem_pool, sizeof(nxt_http_action_t)); in nxt_http_pass_application() [all …]
|
H A D | nxt_list.h | 29 nxt_mp_t *mem_pool; member
|
H A D | nxt_isolation.c | 35 nxt_mp_t *mem_pool, nxt_conf_value_t *map_array, 241 process->isolation.cgroup.path = nxt_mp_alloc(process->mem_pool, in nxt_isolation_set_cgroup() 296 ret = nxt_isolation_credential_map(task, process->mem_pool, array, in nxt_isolation_set_creds() 306 ret = nxt_isolation_credential_map(task, process->mem_pool, array, in nxt_isolation_set_creds() 516 process->isolation.rootfs = nxt_mp_alloc(process->mem_pool, in nxt_isolation_set_rootfs() 619 mp = process->mem_pool; in nxt_isolation_set_lang_mounts()
|
H A D | nxt_h1proto_websocket.c | 93 h1p->websocket_timer = nxt_mp_zget(c->mem_pool, in nxt_h1p_websocket_first_frame_start() 346 nxt_buf_t *b = nxt_buf_mem_alloc(c->mem_pool, frame_size - size, 0); in nxt_h1p_conn_ws_frame_header_read() 474 b = nxt_buf_mem_alloc(c->mem_pool, size, 0); in nxt_h1p_ws_io_read_handler() 488 nxt_mp_free(c->mem_pool, b); in nxt_h1p_ws_io_read_handler()
|
H A D | nxt_h1proto.c | 453 h1p = nxt_mp_zget(c->mem_pool, sizeof(nxt_h1proto_t)); in nxt_h1p_conn_proto_init() 526 nxt_mp_release(r->mem_pool); in nxt_h1p_conn_request_init() 730 b = nxt_buf_mem_alloc(c->mem_pool, size, 0); in nxt_h1p_header_buffer_test() 897 b = nxt_buf_file_alloc(r->mem_pool, in nxt_h1p_request_body_read() 906 b = nxt_buf_mem_alloc(r->mem_pool, body_buffer_size, 0); in nxt_h1p_request_body_read() 1913 out = nxt_buf_mem_alloc(c->mem_pool, size, 0); in nxt_h1p_idle_response() 1925 last = nxt_mp_zget(c->mem_pool, NXT_BUF_SYNC_SIZE); in nxt_h1p_idle_response() 2174 c->mem_pool = mp; in nxt_h1p_peer_connect() 2324 body = nxt_buf_file_alloc(r->mem_pool, 0, 0); in nxt_h1p_peer_header_send() 2327 body = nxt_buf_mem_alloc(r->mem_pool, 0, 0); in nxt_h1p_peer_header_send() [all …]
|
H A D | nxt_runtime.h | 16 nxt_mp_t *mem_pool; member
|
H A D | nxt_event_engine.c | 583 mem_cache = nxt_array_create(engine->mem_pool, items, in nxt_event_engine_mem_alloc() 626 return nxt_mp_alloc(engine->mem_pool, size); in nxt_event_engine_mem_alloc() 675 nxt_mp_free(engine->mem_pool, p); in nxt_event_engine_mem_free()
|
H A D | nxt_application.c | 611 process->mem_pool = nxt_mp_create(1024, 128, 256, 32); in nxt_proto_start_process_handler() 612 if (nxt_slow_path(process->mem_pool == NULL)) { in nxt_proto_start_process_handler() 622 process->name = nxt_mp_alloc(process->mem_pool, nxt_app_conf->name.length in nxt_proto_start_process_handler() 1216 lhq.pool = rt->mem_pool; in nxt_proto_process_add() 1245 lhq.pool = rt->mem_pool; in nxt_proto_process_remove()
|
H A D | nxt_process.h | 120 nxt_mp_t *mem_pool; member
|
H A D | nxt_port_memory.c | 562 b = nxt_buf_mem_ts_alloc(task, task->thread->engine->mem_pool, 0); in nxt_port_mmap_get_buf() 572 mp = task->thread->engine->mem_pool; in nxt_port_mmap_get_buf() 678 b = nxt_buf_mem_ts_alloc(task, port->mem_pool, 0); in nxt_port_mmap_get_incoming_buf()
|
H A D | nxt_event_conn_job_sendfile.c | 51 jbs = nxt_job_create(c->mem_pool, sizeof(nxt_job_sendfile_t)); in nxt_event_conn_job_sendfile_start()
|
H A D | nxt_cyassl.c | 185 ssltls = nxt_mp_zget(c->mem_pool, sizeof(nxt_cyassl_conn_t)); in nxt_cyassl_conn_init() 193 mpcl = nxt_mem_pool_cleanup(c->mem_pool, 0); in nxt_cyassl_conn_init()
|
H A D | nxt_gnutls.c | 265 ssltls = nxt_mp_zget(c->mem_pool, sizeof(nxt_gnutls_conn_t)); in nxt_gnutls_conn_init() 273 mpcl = nxt_mem_pool_cleanup(c->mem_pool, 0); in nxt_gnutls_conn_init()
|
H A D | nxt_event_engine.h | 480 nxt_mp_t *mem_pool; member
|
H A D | nxt_conn.h | 149 nxt_mp_t *mem_pool; member
|
/unit/src/test/ |
H A D | nxt_clone_test.c | 455 rt.mem_pool = mp; in nxt_clone_creds_test() 569 array = nxt_conf_json_parse_str(rt->mem_pool, map_str); in nxt_clone_test_parse_map() 580 map->map = nxt_mp_alloc(rt->mem_pool, in nxt_clone_test_parse_map()
|