Home
last modified time | relevance | path

Searched refs:mem_pool (Results 1 – 25 of 55) sorted by relevance

123

/unit/src/
H A Dnxt_http_rewrite.c51 &r->tstr_cache, r, r->mem_pool); in nxt_http_rewrite()
65 rp.mem_pool = r->mem_pool; in nxt_http_rewrite()
86 target.start = nxt_mp_alloc(r->mem_pool, target.length); in nxt_http_rewrite()
99 r->path = nxt_mp_alloc(r->mem_pool, sizeof(nxt_str_t)); in nxt_http_rewrite()
H A Dnxt_array.c25 array->mem_pool = mp; in nxt_array_create()
35 nxt_mp_free(array->mem_pool, array->elts); in nxt_array_destroy()
38 nxt_mp_free(array->mem_pool, array); in nxt_array_destroy()
61 p = nxt_mp_alloc(array->mem_pool, array->size * new_alloc); in nxt_array_add()
70 nxt_mp_free(array->mem_pool, array->elts); in nxt_array_add()
H A Dnxt_port_rpc.c150 lhq.pool = port->mem_pool; in nxt_port_rpc_register_handler_ex()
161 nxt_mp_free(port->mem_pool, reg); in nxt_port_rpc_register_handler_ex()
219 lhq.pool = port->mem_pool; in nxt_port_rpc_ex_set_peer()
266 lhq.pool = port->mem_pool; in nxt_port_rpc_remove_from_peers()
323 lhq.pool = port->mem_pool; in nxt_port_rpc_handler()
360 nxt_mp_free(port->mem_pool, reg); in nxt_port_rpc_handler()
379 lhq.pool = port->mem_pool; in nxt_port_rpc_remove_peer()
441 lhq.pool = port->mem_pool; in nxt_port_rpc_remove_peer()
452 nxt_mp_free(port->mem_pool, reg); in nxt_port_rpc_remove_peer()
467 lhq.pool = port->mem_pool; in nxt_port_rpc_cancel()
[all …]
H A Dnxt_buf_pool.c38 b = nxt_buf_mem_alloc(bp->mem_pool, size, bp->flags); in nxt_buf_pool_mem_alloc()
78 b = nxt_buf_file_alloc(bp->mem_pool, size, bp->flags); in nxt_buf_pool_file_alloc()
118 b = nxt_buf_mmap_alloc(bp->mem_pool, size); in nxt_buf_pool_mmap_alloc()
150 nxt_buf_free(bp->mem_pool, b); in nxt_buf_pool_free()
181 nxt_buf_free(bp->mem_pool, b); in nxt_buf_pool_destroy()
H A Dnxt_runtime.c66 rt->mem_pool = mp; in nxt_runtime_create()
168 inherited_sockets = nxt_array_create(rt->mem_pool, in nxt_runtime_inherited_listen_sockets()
321 thread_pools = nxt_array_create(rt->mem_pool, 1, in nxt_runtime_thread_pools()
624 nxt_mp_destroy(rt->mem_pool); in nxt_runtime_exit()
1193 mp = rt->mem_pool; in nxt_runtime_listen_socket_add()
1486 if (process->mem_pool != NULL) { in nxt_runtime_process_release()
1487 nxt_mp_destroy(process->mem_pool); in nxt_runtime_process_release()
1490 nxt_mp_free(rt->mem_pool, process); in nxt_runtime_process_release()
1586 lhq.pool = rt->mem_pool; in nxt_runtime_process_get()
1628 lhq.pool = rt->mem_pool; in nxt_runtime_process_add()
[all …]
H A Dnxt_job.c40 job->mem_pool = mp; in nxt_job_create()
72 if (job->mem_pool != NULL) { in nxt_job_destroy()
73 nxt_mp_destroy(job->mem_pool); in nxt_job_destroy()
77 nxt_mp_free(job->mem_pool, job); in nxt_job_destroy()
H A Dnxt_http_set_headers.c27 headers = nxt_array_create(rtcf->mem_pool, 4, in nxt_http_set_headers_init()
50 hv->name.start = nxt_mp_nget(rtcf->mem_pool, name.length); in nxt_http_set_headers_init()
120 value = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_str_t) * n); in nxt_http_set_headers()
137 &r->tstr_cache, r, r->mem_pool); in nxt_http_set_headers()
H A Dnxt_http_proxy.c124 us = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_upstream_server_t)); in nxt_upstream_proxy_handler()
130 peer = nxt_mp_zalloc(r->mem_pool, sizeof(nxt_http_peer_t)); in nxt_upstream_proxy_handler()
139 nxt_mp_retain(r->mem_pool); in nxt_upstream_proxy_handler()
188 nxt_mp_release(r->mem_pool); in nxt_http_proxy_upstream_error()
314 nxt_mp_release(r->mem_pool); in nxt_http_proxy_send_body()
329 nxt_mp_retain(r->mem_pool); in nxt_http_proxy_buf_mem_alloc()
371 nxt_mp_release(r->mem_pool); in nxt_http_proxy_buf_mem_free()
386 nxt_mp_release(r->mem_pool); in nxt_http_proxy_error()
H A Dnxt_router_access_log.c81 ret = nxt_conf_map_object(rtcf->mem_pool, value, in nxt_router_access_log_create()
148 ctx = nxt_mp_get(r->mem_pool, sizeof(nxt_router_access_log_ctx_t)); in nxt_router_access_log_writer()
164 &r->tstr_cache, r, r->mem_pool); in nxt_router_access_log_writer()
211 b = nxt_buf_mem_alloc(tmcf->mem_pool, access_log->path.length + 1, 0); in nxt_router_access_log_open()
323 nxt_mp_t *mem_pool; member
356 reopen->mem_pool = mp; in nxt_router_access_log_reopen_handler()
432 nxt_mp_release(reopen->mem_pool); in nxt_router_access_log_reopen_ready()
444 nxt_mp_release(reopen->mem_pool); in nxt_router_access_log_reopen_error()
H A Dnxt_array.h17 nxt_mp_t *mem_pool; member
26 array->mem_pool = mp; in nxt_array_init()
H A Dnxt_conn_proxy.c398 wb = nxt_buf_mem_alloc(source->mem_pool, 0, 0); in nxt_conn_proxy_read_process()
423 nxt_buf_free(source->mem_pool, rb); in nxt_conn_proxy_read_process()
486 nxt_buf_free(c->mem_pool, b); in nxt_conn_proxy_write_add()
582 nxt_buf_free(sink->mem_pool, wb); in nxt_conn_proxy_write_process()
591 rb = nxt_buf_mem_alloc(sink->mem_pool, 0, 0); in nxt_conn_proxy_write_process()
615 nxt_buf_free(sink->mem_pool, wb); in nxt_conn_proxy_write_process()
693 nxt_buf_free(c->mem_pool, second); in nxt_conn_proxy_read_add()
697 nxt_buf_free(c->mem_pool, b); in nxt_conn_proxy_read_add()
720 b = nxt_buf_sync_alloc(source->mem_pool, 0); in nxt_conn_proxy_close()
886 nxt_mp_free(source->mem_pool, b); in nxt_conn_proxy_shutdown()
[all …]
H A Dnxt_http_return.c42 mp = rtcf->mem_pool; in nxt_http_return_init()
109 ctx = nxt_mp_zget(r->mem_pool, sizeof(nxt_http_return_ctx_t)); in nxt_http_return()
129 &r->tstr_cache, r, r->mem_pool); in nxt_http_return()
189 ret = nxt_http_return_encode(r->mem_pool, &ctx->encoded, in nxt_http_return_send_ready()
H A Dnxt_http_static.c86 mp = rtcf->mem_pool; in nxt_http_static_init()
341 fname = nxt_mp_nget(r->mem_pool, length + 1); in nxt_http_static_send_ready()
502 f = nxt_mp_get(r->mem_pool, sizeof(nxt_file_t)); in nxt_http_static_send_ready()
545 p = nxt_mp_nget(r->mem_pool, length); in nxt_http_static_send_ready()
627 p = nxt_mp_nget(r->mem_pool, length); in nxt_http_static_send_ready()
815 b = nxt_buf_mem_alloc(r->mem_pool, alloc, 0); in nxt_http_static_body_handler()
823 nxt_mp_retain(r->mem_pool); in nxt_http_static_body_handler()
843 nxt_mp_free(r->mem_pool, b); in nxt_http_static_body_handler()
844 nxt_mp_release(r->mem_pool); in nxt_http_static_body_handler()
922 nxt_mp_free(r->mem_pool, b); in nxt_http_static_buf_completion()
[all …]
H A Dnxt_list.c21 list->mem_pool = mp; in nxt_list_create()
42 last = nxt_mp_get(list->mem_pool, in nxt_list_add()
H A Dnxt_conn.c53 c->mem_pool = mp; in nxt_conn_create()
99 mp = c->mem_pool; in nxt_conn_free()
161 sa = nxt_mp_get(c->mem_pool, size); in nxt_conn_local_addr()
H A Dnxt_http_request.c96 ret = nxt_http_validate_host(&host, r->mem_pool); in nxt_http_request_host()
276 r->mem_pool = mp; in nxt_http_request_create()
359 client_ip_fields = nxt_array_create(r->mem_pool, 1, in nxt_http_request_forward()
481 sa = nxt_sockaddr_parse_optport(r->mem_pool, &addr); in nxt_http_request_client_ip_sockaddr()
690 p = nxt_mp_nget(r->mem_pool, NXT_OFF_T_LEN); in nxt_http_request_header_send()
738 b = nxt_buf_mem_alloc(r->mem_pool, size, 0); in nxt_http_buf_mem()
742 nxt_mp_retain(r->mem_pool); in nxt_http_buf_mem()
764 nxt_mp_free(r->mem_pool, b); in nxt_http_request_mem_buf_completion()
765 nxt_mp_release(r->mem_pool); in nxt_http_request_mem_buf_completion()
864 nxt_mp_release(r->mem_pool); in nxt_http_request_close_handler()
[all …]
H A Dnxt_file.h30 #define nxt_file_name_str_set(file_name, mem_pool, name) \ argument
34 #define nxt_file_name_alloc(mem_pool, len) \ argument
35 nxt_mp_nget(mem_pool, len)
H A Dnxt_router.h45 nxt_mp_t *mem_pool; member
92 nxt_mp_t *mem_pool; member
144 nxt_mp_t *mem_pool; member
H A Dnxt_controller.c741 b = nxt_buf_mem_alloc(c->mem_pool, 1024, 0); in nxt_controller_conn_init()
1212 certs = nxt_cert_info_get_all(c->mem_pool); in nxt_controller_process_request()
1221 scripts = nxt_script_info_get_all(c->mem_pool); in nxt_controller_process_request()
1360 rc = nxt_conf_op_compile(c->mem_pool, &ops, in nxt_controller_process_config()
1390 vldt.pool = c->mem_pool; in nxt_controller_process_config()
1473 vldt.pool = c->mem_pool; in nxt_controller_process_config()
1637 req->conn->mem_pool); in nxt_controller_status_handler()
1774 nxt_cert_store_get(task, &name, c->mem_pool, in nxt_controller_process_cert()
2038 nxt_script_store_get(task, &name, c->mem_pool, in nxt_controller_process_script()
2586 body = nxt_buf_mem_alloc(c->mem_pool, size, 0); in nxt_controller_response()
[all …]
H A Dnxt_http_parse.h52 nxt_mp_t *mem_pool; member
100 nxt_mp_t *mem_pool; member
H A Dnxt_upstream.c42 mp = tmcf->router_conf->mem_pool; in nxt_upstreams_create()
120 up = nxt_mp_zalloc(router_conf->mem_pool, n * sizeof(nxt_upstream_t *)); in nxt_upstreams_joint_create()
H A Dnxt_cert.h22 nxt_array_t *nxt_cert_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);
H A Dnxt_router.c1082 rtcf->mem_pool = mp; in nxt_router_temp_conf()
1103 tmcf->mem_pool = tmp; in nxt_router_temp_conf()
1341 nxt_mp_release(tmcf->mem_pool); in nxt_router_conf_ready()
1390 nxt_mp_destroy(rtcf->mem_pool); in nxt_router_conf_error()
1661 mp = rtcf->mem_pool; in nxt_router_conf_create()
2285 mp = rtcf->mem_pool; in nxt_router_conf_process_static()
2577 lhq.pool = rtcf->mem_pool; in nxt_router_apps_hash_add()
5130 nxt_mp_retain(r->mem_pool); in nxt_router_app_port_get()
5171 nxt_mp_retain(r->mem_pool); in nxt_router_process_http_request()
5217 nxt_mp_release(r->mem_pool); in nxt_router_http_request_error()
[all …]
H A Dnxt_job.h43 nxt_mp_t *mem_pool; member
H A Dnxt_script.h23 nxt_array_t *nxt_script_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);

123