Home
last modified time | relevance | path

Searched refs:mp (Results 1 – 25 of 76) sorted by path

1234

/unit/src/java/nginx/unit/websocket/
H A DWsRemoteEndpointImplBase.java320 MessagePart mp = messageParts.remove(0); in startMessage() local
341 messagePartQueue.add(mp); in startMessage()
350 writeMessagePart(mp); in startMessage()
391 void writeMessagePart(MessagePart mp) { in writeMessagePart() argument
410 if (Util.isControl(mp.getOpCode())) { in writeMessagePart()
427 nextFragmented = !mp.isFin(); in writeMessagePart()
431 if (mp.isFin()) { in writeMessagePart()
450 writeHeader(headerBuffer, mp.isFin(), mp.getRsv(), mp.getOpCode(), in writeMessagePart()
457 mp.getEndHandler(), mp.getBlockingWriteTimeoutExpiry(), in writeMessagePart()
463 doWrite(mp.getEndHandler(), mp.getBlockingWriteTimeoutExpiry(), in writeMessagePart()
[all …]
/unit/src/
H A Dnxt_application.c212 nxt_mp_t *mp; in nxt_discovery_modules() local
222 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_discovery_modules()
223 if (mp == NULL) { in nxt_discovery_modules()
237 modules = nxt_array_create(mp, n, sizeof(nxt_module_t)); in nxt_discovery_modules()
283 b = nxt_buf_mem_alloc(mp, size, 0); in nxt_discovery_modules()
410 nxt_str_dup(mp, &module->version, &version); in nxt_discovery_module()
488 nxt_mp_t *mp; in nxt_discovery_completion_handler() local
492 mp = b->data; in nxt_discovery_completion_handler()
494 nxt_mp_destroy(mp); in nxt_discovery_completion_handler()
990 nxt_cstr_dup(nxt_mp_t *mp, u_char *dst, u_char *src) in nxt_cstr_dup() argument
[all …]
H A Dnxt_array.c11 nxt_array_create(nxt_mp_t *mp, nxt_uint_t n, size_t size) in nxt_array_create() argument
15 array = nxt_mp_alloc(mp, sizeof(nxt_array_t) + n * size); in nxt_array_create()
25 array->mem_pool = mp; in nxt_array_create()
115 nxt_array_copy(nxt_mp_t *mp, nxt_array_t *dst, nxt_array_t *src) in nxt_array_copy() argument
123 dst = nxt_array_create(mp, src->nelts, size); in nxt_array_copy()
H A Dnxt_array.h22 nxt_array_init(nxt_array_t *array, nxt_mp_t *mp, size_t size) in nxt_array_init() argument
26 array->mem_pool = mp; in nxt_array_init()
29 NXT_EXPORT nxt_array_t *nxt_array_create(nxt_mp_t *mp, nxt_uint_t n,
35 NXT_EXPORT nxt_array_t *nxt_array_copy(nxt_mp_t *mp, nxt_array_t *dst,
H A Dnxt_buf.c42 b->data = mp; in nxt_buf_mem_alloc()
67 nxt_mp_retain(mp); in nxt_buf_mem_ts_alloc()
71 b->data = mp; in nxt_buf_mem_ts_alloc()
107 b->data = mp; in nxt_buf_file_alloc()
130 b->data = mp; in nxt_buf_mmap_alloc()
150 b->data = mp; in nxt_buf_sync_alloc()
200 nxt_mp_t *mp; in nxt_buf_completion() local
212 mp = b->data; in nxt_buf_completion()
214 nxt_mp_free(mp, b); in nxt_buf_completion()
273 nxt_mp_t *mp; in nxt_buf_ts_completion() local
[all …]
H A Dnxt_buf.h215 NXT_EXPORT nxt_buf_t *nxt_buf_mem_alloc(nxt_mp_t *mp, size_t size,
217 NXT_EXPORT nxt_buf_t *nxt_buf_mem_ts_alloc(nxt_task_t *task, nxt_mp_t *mp,
219 NXT_EXPORT nxt_buf_t *nxt_buf_file_alloc(nxt_mp_t *mp, size_t size,
221 NXT_EXPORT nxt_buf_t *nxt_buf_mmap_alloc(nxt_mp_t *mp, size_t size);
222 NXT_EXPORT nxt_buf_t *nxt_buf_sync_alloc(nxt_mp_t *mp, nxt_uint_t flags);
227 NXT_EXPORT nxt_buf_t *nxt_buf_make_plain(nxt_mp_t *mp, nxt_buf_t *src,
231 nxt_buf_chk_make_plain(nxt_mp_t *mp, nxt_buf_t *src, size_t size) in nxt_buf_chk_make_plain() argument
234 return nxt_buf_make_plain(mp, src, size); in nxt_buf_chk_make_plain()
240 #define nxt_buf_free(mp, b) \ argument
241 nxt_mp_free((mp), (b))
H A Dnxt_cert.c32 nxt_mp_t *mp; member
368 nxt_mp_t *mp; in nxt_cert_info_save() local
394 info->mp = mp; in nxt_cert_info_save()
410 nxt_mp_destroy(info->mp); in nxt_cert_info_save()
417 nxt_mp_destroy(mp); in nxt_cert_info_save()
805 nxt_mp_destroy(info->mp); in nxt_cert_info_delete()
1076 nxt_mp_retain(mp); in nxt_cert_store_get()
1111 nxt_mp_t *mp; in nxt_cert_buf_completion() local
1115 mp = b->data; in nxt_cert_buf_completion()
1118 nxt_mp_free(mp, b); in nxt_cert_buf_completion()
[all …]
H A Dnxt_cert.h19 nxt_conf_value_t *nxt_cert_info_get_all(nxt_mp_t *mp);
25 void nxt_cert_store_get(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp,
27 void nxt_cert_store_delete(nxt_task_t *task, nxt_str_t *name, nxt_mp_t *mp);
H A Dnxt_conf.c203 ptr = nxt_str_dup(mp, &tmp, str); in nxt_conf_set_string_dup()
253 value = nxt_mp_get(mp, size); in nxt_conf_create_object()
368 value = nxt_mp_get(mp, size); in nxt_conf_create_array()
958 rc = nxt_conf_copy_value(mp, op, copy, value); in nxt_conf_clone()
1034 dst->u.array = nxt_mp_get(mp, size); in nxt_conf_copy_array()
1136 dst->u.object = nxt_mp_get(mp, size); in nxt_conf_copy_object()
1160 rc = nxt_conf_copy_value(mp, NULL, in nxt_conf_copy_object()
1168 rc = nxt_conf_copy_value(mp, pass_op, in nxt_conf_copy_object()
1195 rc = nxt_conf_copy_value(mp, NULL, in nxt_conf_copy_object()
1209 rc = nxt_conf_copy_value(mp, NULL, in nxt_conf_copy_object()
[all …]
H A Dnxt_conf.h94 NXT_EXPORT nxt_int_t nxt_conf_map_object(nxt_mp_t *mp, nxt_conf_value_t *value,
97 nxt_conf_op_ret_t nxt_conf_op_compile(nxt_mp_t *mp, nxt_conf_op_t **ops,
100 nxt_conf_value_t *nxt_conf_clone(nxt_mp_t *mp, nxt_conf_op_t *op,
103 nxt_conf_value_t *nxt_conf_json_parse(nxt_mp_t *mp, u_char *start, u_char *end,
106 #define nxt_conf_json_parse_str(mp, str) \ argument
107 nxt_conf_json_parse(mp, (str)->start, (str)->start + (str)->length, NULL)
121 nxt_mp_t *mp, const nxt_str_t *str);
127 nxt_conf_value_t *nxt_conf_create_object(nxt_mp_t *mp, nxt_uint_t count);
130 nxt_int_t nxt_conf_set_member_dup(nxt_conf_value_t *object, nxt_mp_t *mp,
134 nxt_int_t nxt_conf_set_member_string_dup(nxt_conf_value_t *object, nxt_mp_t *mp,
[all …]
H A Dnxt_conn.c43 nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task) in nxt_conn_create() argument
48 c = nxt_mp_zget(mp, sizeof(nxt_conn_t)); in nxt_conn_create()
53 c->mem_pool = mp; in nxt_conn_create()
95 nxt_mp_t *mp; in nxt_conn_free() local
99 mp = c->mem_pool; in nxt_conn_free()
100 nxt_mp_release(mp); in nxt_conn_free()
H A Dnxt_conn.h222 NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
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_controller.c47 nxt_str_t *str, nxt_mp_t *mp);
241 nxt_mp_t *mp) in nxt_controller_file_read() argument
315 nxt_mp_t *mp; in nxt_controller_start() local
364 nxt_mp_destroy(mp); in nxt_controller_start()
372 nxt_mp_destroy(mp); in nxt_controller_start()
377 vldt.conf_pool = mp; in nxt_controller_start()
510 nxt_mp_t *mp; in nxt_controller_conf_default() local
1391 vldt.conf_pool = mp; in nxt_controller_process_config()
1419 req->conf.pool = mp; in nxt_controller_process_config()
1474 vldt.conf_pool = mp; in nxt_controller_process_config()
[all …]
H A Dnxt_credential.c9 static nxt_int_t nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp,
14 nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc, in nxt_credential_get() argument
63 if (nxt_credential_groups_get(task, mp, uc) != NXT_OK) { in nxt_credential_get()
98 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, in nxt_credential_groups_get() argument
122 uc->gids = nxt_mp_alloc(mp, ngroups * sizeof(gid_t)); in nxt_credential_groups_get()
141 uc->gids = nxt_mp_alloc(mp, ngroups * sizeof(gid_t)); in nxt_credential_groups_get()
183 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc) in nxt_credential_groups_get() argument
207 saved = nxt_mp_alloc(mp, nsaved * sizeof(nxt_gid_t)); in nxt_credential_groups_get()
250 uc->gids = nxt_mp_alloc(mp, ngroups * sizeof(nxt_gid_t)); in nxt_credential_groups_get()
276 nxt_mp_free(mp, saved); in nxt_credential_groups_get()
H A Dnxt_credential.h22 NXT_EXPORT nxt_int_t nxt_credential_get(nxt_task_t *task, nxt_mp_t *mp,
H A Dnxt_file_name.c20 nxt_file_name_create(nxt_mp_t *mp, nxt_file_name_str_t *file_name, in nxt_file_name_create() argument
114 fn = nxt_file_name_alloc(mp, length); in nxt_file_name_create()
H A Dnxt_file_name.h11 NXT_EXPORT nxt_int_t nxt_file_name_create(nxt_mp_t *mp,
H A Dnxt_h1proto.c2140 nxt_mp_t *mp; in nxt_h1p_peer_connect() local
2153 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_h1p_peer_connect()
2155 if (nxt_slow_path(mp == NULL)) { in nxt_h1p_peer_connect()
2159 h1p = nxt_mp_zalloc(mp, sizeof(nxt_h1proto_t)); in nxt_h1p_peer_connect()
2169 c = nxt_conn_create(mp, task); in nxt_h1p_peer_connect()
2174 c->mem_pool = mp; in nxt_h1p_peer_connect()
H A Dnxt_http.h351 int64_t nxt_http_field_hash(nxt_mp_t *mp, nxt_str_t *name,
353 int64_t nxt_http_argument_hash(nxt_mp_t *mp, nxt_str_t *name);
354 int64_t nxt_http_header_hash(nxt_mp_t *mp, nxt_str_t *name);
355 int64_t nxt_http_cookie_hash(nxt_mp_t *mp, nxt_str_t *name);
363 nxt_int_t nxt_http_pass_segments(nxt_mp_t *mp, nxt_str_t *pass,
368 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
372 nxt_mp_t *mp, nxt_conf_value_t *types);
399 nxt_int_t nxt_http_static_mtypes_init(nxt_mp_t *mp, nxt_lvlhsh_t *hash);
400 nxt_int_t nxt_http_static_mtypes_hash_add(nxt_mp_t *mp, nxt_lvlhsh_t *hash,
412 nxt_int_t nxt_http_proxy_init(nxt_mp_t *mp, nxt_http_action_t *action,
H A Dnxt_http_chunk_parse.c251 nxt_mp_t *mp; in nxt_http_chunk_buf_completion() local
263 mp = b->data; in nxt_http_chunk_buf_completion()
265 nxt_mp_free(mp, b); in nxt_http_chunk_buf_completion()
266 nxt_mp_release(mp); in nxt_http_chunk_buf_completion()
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_http_proxy.c53 nxt_http_proxy_init(nxt_mp_t *mp, nxt_http_action_t *action, in nxt_http_proxy_init() argument
68 sa = nxt_sockaddr_parse(mp, &name); in nxt_http_proxy_init()
77 up = nxt_mp_alloc(mp, sizeof(nxt_upstream_t)); in nxt_http_proxy_init()
86 proxy = nxt_mp_alloc(mp, sizeof(nxt_upstream_proxy_t)); in nxt_http_proxy_init()
H A Dnxt_http_request.c107 nxt_http_validate_host(nxt_str_t *host, nxt_mp_t *mp) in nxt_http_validate_host() argument
187 host->start = nxt_mp_nget(mp, host_length); in nxt_http_validate_host()
246 nxt_mp_t *mp; in nxt_http_request_create() local
250 mp = nxt_mp_create(4096, 128, 512, 32); in nxt_http_request_create()
251 if (nxt_slow_path(mp == NULL)) { in nxt_http_request_create()
265 last = nxt_mp_zget(mp, NXT_BUF_SYNC_SIZE); in nxt_http_request_create()
276 r->mem_pool = mp; in nxt_http_request_create()
285 r->tstr_cache.var.pool = mp; in nxt_http_request_create()
291 nxt_mp_release(mp); in nxt_http_request_create()
1143 str.start = nxt_mp_nget(mp, str.length); in nxt_http_field_hash()
[all …]

1234