Home
last modified time | relevance | path

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

123

/unit/src/
H A Dnxt_stream_module.c28 up = nxt_mp_zget(c->mem_pool, sizeof(nxt_upstream_peer_t)); in nxt_stream_connection_init()
45 up->mem_pool = c->mem_pool; in nxt_stream_connection_init()
95 rate = nxt_mp_get(c->mem_pool, sizeof(nxt_event_write_rate_t)); in nxt_stream_connection_peer()
130 nxt_mp_destroy(p->client->mem_pool); in nxt_stream_connection_close()
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()
607 nxt_mp_destroy(rt->mem_pool); in nxt_runtime_exit()
1127 mp = rt->mem_pool; in nxt_runtime_listen_socket_add()
1417 if (process->mem_pool != NULL) { in nxt_runtime_process_release()
1418 nxt_mp_destroy(process->mem_pool); in nxt_runtime_process_release()
1421 nxt_mp_free(rt->mem_pool, process); in nxt_runtime_process_release()
1517 lhq.pool = rt->mem_pool; in nxt_runtime_process_get()
1559 lhq.pool = rt->mem_pool; in nxt_runtime_process_add()
[all …]
H A Dnxt_job.c37 job->mem_pool = mp; in nxt_job_create()
70 if (job->mem_pool != NULL) { in nxt_job_destroy()
71 nxt_mp_destroy(job->mem_pool); in nxt_job_destroy()
75 nxt_mp_free(job->mem_pool, job); in nxt_job_destroy()
H A Dnxt_job_resolve.c34 host = nxt_mp_alloc(jbr->job.mem_pool, length); in nxt_job_resolve()
71 mp = jbr->job.mem_pool; in nxt_job_resolve()
128 nxt_mp_free(jbr->job.mem_pool, host); in nxt_job_resolve()
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_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_request.c73 ret = nxt_http_validate_host(&host, r->mem_pool); in nxt_http_request_host()
253 r->mem_pool = mp; in nxt_http_request_create()
319 fields_arr = nxt_array_create(r->mem_pool, 2, sizeof(nxt_http_field_t *)); in nxt_http_request_client_ip()
405 sa = nxt_sockaddr_parse_optport(r->mem_pool, &addr); in nxt_http_request_client_ip_sockaddr()
550 p = nxt_mp_nget(r->mem_pool, nxt_http_date_cache.size); in nxt_http_request_header_send()
573 p = nxt_mp_nget(r->mem_pool, NXT_OFF_T_LEN); in nxt_http_request_header_send()
621 b = nxt_buf_mem_alloc(r->mem_pool, size, 0); in nxt_http_buf_mem()
625 nxt_mp_retain(r->mem_pool); in nxt_http_buf_mem()
647 nxt_mp_free(r->mem_pool, b); in nxt_http_request_mem_buf_completion()
648 nxt_mp_release(r->mem_pool); in nxt_http_request_mem_buf_completion()
[all …]
H A Dnxt_http_static.c83 mp = tmcf->router_conf->mem_pool; in nxt_http_static_init()
317 fname = nxt_mp_nget(r->mem_pool, length + 1); in nxt_http_static_send_ready()
478 f = nxt_mp_get(r->mem_pool, sizeof(nxt_file_t)); in nxt_http_static_send_ready()
521 p = nxt_mp_nget(r->mem_pool, length); in nxt_http_static_send_ready()
601 p = nxt_mp_nget(r->mem_pool, length); in nxt_http_static_send_ready()
783 b = nxt_buf_mem_alloc(r->mem_pool, alloc, 0); in nxt_http_static_body_handler()
791 nxt_mp_retain(r->mem_pool); in nxt_http_static_body_handler()
811 nxt_mp_free(r->mem_pool, b); in nxt_http_static_body_handler()
812 nxt_mp_release(r->mem_pool); in nxt_http_static_body_handler()
890 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_router.h45 nxt_mp_t *mem_pool; member
86 nxt_mp_t *mem_pool; member
138 nxt_mp_t *mem_pool; member
H A Dnxt_fastcgi_source.c127 fs = nxt_mp_zget(us->buffers.mem_pool, sizeof(nxt_fastcgi_source_t)); in nxt_fastcgi_source_handler()
134 fs->header_in.list = nxt_list_create(us->buffers.mem_pool, 8, in nxt_fastcgi_source_handler()
147 stream = nxt_mp_zget(us->buffers.mem_pool, sizeof(nxt_stream_source_t)); in nxt_fastcgi_source_handler()
171 fs->record.parse.mem_pool = us->buffers.mem_pool; in nxt_fastcgi_source_handler()
182 fs->u.header.mem_pool = fs->upstream->buffers.mem_pool; in nxt_fastcgi_source_handler()
310 b = nxt_buf_mem_alloc(fs->upstream->buffers.mem_pool, 16, 0); in nxt_fastcgi_request_create()
718 b = nxt_buf_sync_alloc(fp->mem_pool, NXT_BUF_SYNC_LAST); in nxt_fastcgi_source_last_buf()
H A Dnxt_http_source.c53 hs = nxt_mp_zget(us->buffers.mem_pool, sizeof(nxt_http_source_t)); in nxt_http_source_handler()
60 hs->header_in.list = nxt_list_create(us->buffers.mem_pool, 8, in nxt_http_source_handler()
73 stream = nxt_mp_zget(us->buffers.mem_pool, sizeof(nxt_stream_source_t)); in nxt_http_source_handler()
229 hs->u.header.mem_pool = hs->upstream->buffers.mem_pool; in nxt_http_source_status_filter()
446 hsc = nxt_mp_zalloc(hs->upstream->buffers.mem_pool, in nxt_http_source_header_ready()
462 hsc->parse.mem_pool = hs->upstream->buffers.mem_pool; in nxt_http_source_header_ready()
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_controller.c700 b = nxt_buf_mem_alloc(c->mem_pool, 1024, 0); in nxt_controller_conn_init()
1109 certs = nxt_cert_info_get_all(c->mem_pool); in nxt_controller_process_request()
1247 rc = nxt_conf_op_compile(c->mem_pool, &ops, in nxt_controller_process_config()
1277 vldt.pool = c->mem_pool; in nxt_controller_process_config()
1330 rc = nxt_conf_op_compile(c->mem_pool, &ops, in nxt_controller_process_config()
1360 vldt.pool = c->mem_pool; in nxt_controller_process_config()
1503 value = nxt_cert_info_get_all(c->mem_pool); in nxt_controller_process_cert()
1539 nxt_cert_store_get(task, &name, c->mem_pool, in nxt_controller_process_cert()
2014 value = nxt_conf_create_object(c->mem_pool, n); in nxt_controller_response()
2063 body = nxt_buf_mem_alloc(c->mem_pool, size, 0); in nxt_controller_response()
[all …]
H A Dnxt_http_return.c105 ctx = nxt_mp_zget(r->mem_pool, sizeof(nxt_http_return_ctx_t)); in nxt_http_return()
122 ret = nxt_var_query_init(&r->var_query, r, r->mem_pool); in nxt_http_return()
182 ret = nxt_http_return_encode(r->mem_pool, &ctx->encoded, in nxt_http_return_send_ready()
H A Dnxt_stream_source.c53 c = nxt_event_conn_create(us->buffers.mem_pool, thr->log); in nxt_stream_source_connect()
196 b = nxt_buf_sync_alloc(buffers->mem_pool, NXT_BUF_SYNC_NOBUF); in nxt_stream_source_read_ready()
296 b = nxt_buf_mem_alloc(stream->upstream->buffers.mem_pool, 0, 0); in nxt_stream_source_process_buffers()
391 nxt_buf_free(stream->upstream->buffers.mem_pool, b); in nxt_stream_source_buf_completion()
430 b = nxt_buf_sync_alloc(stream->upstream->buffers.mem_pool, in nxt_stream_source_closed()
H A Dnxt_http_parse.h51 nxt_mp_t *mem_pool; member
99 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_router.c1004 rtcf->mem_pool = mp; in nxt_router_temp_conf()
1016 tmcf->mem_pool = tmp; in nxt_router_temp_conf()
1224 nxt_mp_release(tmcf->mem_pool); in nxt_router_conf_ready()
1279 nxt_mp_destroy(rtcf->mem_pool); in nxt_router_conf_error()
2064 mp = rtcf->mem_pool; in nxt_router_conf_process_static()
2327 lhq.pool = rtcf->mem_pool; in nxt_router_apps_hash_add()
4007 reopen->mem_pool = mp; in nxt_router_access_log_reopen_handler()
5221 nxt_mp_retain(r->mem_pool); in nxt_router_app_port_get()
5262 nxt_mp_retain(r->mem_pool); in nxt_router_process_http_request()
5308 nxt_mp_release(r->mem_pool); in nxt_router_http_request_error()
[all …]
H A Dnxt_cert.h22 nxt_array_t *nxt_cert_store_load(nxt_task_t *task, nxt_mp_t *mem_pool);

123