Home
last modified time | relevance | path

Searched refs:mem_pool (Results 26 – 50 of 55) sorted by relevance

123

/unit/src/
H A Dnxt_main_process.c475 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 Dnxt_buf_pool.h23 nxt_mp_t *mem_pool; member
H A Dnxt_http_chunk_parse.c209 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 Dnxt_http_variables.c250 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 Dnxt_port.c67 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 Dnxt_process.c117 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 Dnxt_upstream_round_robin.c58 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 Dnxt_http_error.c43 r->resp.fields = nxt_list_create(r->mem_pool, 8, sizeof(nxt_http_field_t)); in nxt_http_request_error()
H A Dnxt_port_socket.c123 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 Dnxt_http_route.c250 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 Dnxt_list.h29 nxt_mp_t *mem_pool; member
H A Dnxt_isolation.c35 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 Dnxt_h1proto_websocket.c93 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 Dnxt_h1proto.c453 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 Dnxt_runtime.h16 nxt_mp_t *mem_pool; member
H A Dnxt_event_engine.c583 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 Dnxt_application.c611 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 Dnxt_process.h120 nxt_mp_t *mem_pool; member
H A Dnxt_port_memory.c562 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 Dnxt_event_conn_job_sendfile.c51 jbs = nxt_job_create(c->mem_pool, sizeof(nxt_job_sendfile_t)); in nxt_event_conn_job_sendfile_start()
H A Dnxt_cyassl.c185 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 Dnxt_gnutls.c265 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 Dnxt_event_engine.h480 nxt_mp_t *mem_pool; member
H A Dnxt_conn.h149 nxt_mp_t *mem_pool; member
/unit/src/test/
H A Dnxt_clone_test.c455 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()

123