Home
last modified time | relevance | path

Searched refs:mp (Results 1 – 25 of 84) 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()
937 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.c46 nxt_str_t *str, nxt_mp_t *mp);
224 nxt_mp_t *mp) in nxt_controller_file_read() argument
298 nxt_mp_t *mp; in nxt_controller_start() local
340 nxt_mp_destroy(mp); in nxt_controller_start()
348 nxt_mp_destroy(mp); in nxt_controller_start()
353 vldt.conf_pool = mp; in nxt_controller_start()
486 nxt_mp_t *mp; in nxt_controller_conf_default() local
1325 vldt.conf_pool = mp; in nxt_controller_process_config()
1353 req->conf.pool = mp; in nxt_controller_process_config()
1408 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()
95 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, in nxt_credential_groups_get() argument
119 uc->gids = nxt_mp_alloc(mp, ngroups * sizeof(gid_t)); in nxt_credential_groups_get()
138 uc->gids = nxt_mp_alloc(mp, ngroups * sizeof(gid_t)); in nxt_credential_groups_get()
180 nxt_credential_groups_get(nxt_task_t *task, nxt_mp_t *mp, nxt_credential_t *uc) in nxt_credential_groups_get() argument
204 saved = nxt_mp_alloc(mp, nsaved * sizeof(nxt_gid_t)); in nxt_credential_groups_get()
247 uc->gids = nxt_mp_alloc(mp, ngroups * sizeof(nxt_gid_t)); in nxt_credential_groups_get()
273 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_fastcgi_source.c606 nxt_fastcgi_source_hash_create(nxt_mp_t *mp, nxt_lvlhsh_t *lh) in nxt_fastcgi_source_hash_create() argument
608 return nxt_upstream_header_hash_add(mp, lh, nxt_fastcgi_source_headers, in nxt_fastcgi_source_hash_create()
H A Dnxt_fastcgi_source.h87 NXT_EXPORT nxt_int_t nxt_fastcgi_source_hash_create(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.c2130 nxt_mp_t *mp; in nxt_h1p_peer_connect() local
2143 mp = nxt_mp_create(1024, 128, 256, 32); in nxt_h1p_peer_connect()
2145 if (nxt_slow_path(mp == NULL)) { in nxt_h1p_peer_connect()
2149 h1p = nxt_mp_zalloc(mp, sizeof(nxt_h1proto_t)); in nxt_h1p_peer_connect()
2159 c = nxt_conn_create(mp, task); in nxt_h1p_peer_connect()
2164 c->mem_pool = mp; in nxt_h1p_peer_connect()
H A Dnxt_http.h343 int64_t nxt_http_field_hash(nxt_mp_t *mp, nxt_str_t *name,
345 int64_t nxt_http_argument_hash(nxt_mp_t *mp, nxt_str_t *name);
346 int64_t nxt_http_header_hash(nxt_mp_t *mp, nxt_str_t *name);
347 int64_t nxt_http_cookie_hash(nxt_mp_t *mp, nxt_str_t *name);
355 nxt_int_t nxt_http_pass_segments(nxt_mp_t *mp, nxt_str_t *pass,
360 nxt_task_t *task, nxt_mp_t *mp, nxt_conf_value_t *cv);
364 nxt_mp_t *mp, nxt_conf_value_t *types);
383 nxt_int_t nxt_http_static_mtypes_init(nxt_mp_t *mp, nxt_lvlhsh_t *hash);
384 nxt_int_t nxt_http_static_mtypes_hash_add(nxt_mp_t *mp, nxt_lvlhsh_t *hash,
396 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.c110 nxt_http_parse_request_init(nxt_http_request_parse_t *rp, nxt_mp_t *mp) in nxt_http_parse_request_init() argument
112 rp->mem_pool = mp; in nxt_http_parse_request_init()
114 rp->fields = nxt_list_create(mp, 8, sizeof(nxt_http_field_t)); in nxt_http_parse_request_init()
H A Dnxt_http_parse.h116 nxt_mp_t *mp);

1234