Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 22 of 22) sorted by relevance

/unit/src/
H A Dnxt_port_rpc.c16 uint32_t stream; member
74 lhq->key_hash = nxt_murmur_hash2(stream, sizeof(*stream)); in nxt_port_rpc_lhq_stream()
116 return reg->stream; in nxt_port_rpc_register_handler()
125 uint32_t stream; in nxt_port_rpc_register_handler_ex() local
141 reg->stream = stream; in nxt_port_rpc_register_handler_ex()
183 return reg->stream; in nxt_port_rpc_ex_stream()
262 stream = reg->stream; in nxt_port_rpc_remove_from_peers()
317 stream = msg->port_msg.stream; in nxt_port_rpc_handler()
409 stream = reg->stream; in nxt_port_rpc_remove_peer()
413 msg.port_msg.stream = stream; in nxt_port_rpc_remove_peer()
[all …]
H A Dnxt_router_access_log.c202 uint32_t stream; in nxt_router_access_log_open() local
225 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_open()
229 if (nxt_slow_path(stream == 0)) { in nxt_router_access_log_open()
234 stream, router_port->id, b); in nxt_router_access_log_open()
237 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open()
332 uint32_t stream; in nxt_router_access_log_reopen_handler() local
373 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_reopen_handler()
377 if (nxt_slow_path(stream == 0)) { in nxt_router_access_log_reopen_handler()
382 stream, router_port->id, b); in nxt_router_access_log_reopen_handler()
385 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_reopen_handler()
H A Dnxt_router_request.h27 uint32_t stream; member
H A Dnxt_port_socket.c183 msg.port_msg.stream = stream; in nxt_port_socket_write2()
462 msg->port_msg.stream); in nxt_port_write_handler()
1028 uint32_t stream; member
1043 && frag_key->stream == fmsg->port_msg.stream in nxt_port_lvlhsh_frag_test()
1084 nxt_debug(task, "start frag stream #%uD", msg->port_msg.stream); in nxt_port_frag_start()
1094 frag_key.stream = fmsg->port_msg.stream; in nxt_port_frag_start()
1114 fmsg->port_msg.stream); in nxt_port_frag_start()
1121 fmsg->port_msg.stream); in nxt_port_frag_start()
1142 msg->port_msg.stream); in nxt_port_frag_find()
1144 frag_key.stream = msg->port_msg.stream; in nxt_port_frag_find()
[all …]
H A Dnxt_port.h172 uint32_t stream; member
337 nxt_uint_t type, nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream,
342 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write() argument
345 return nxt_port_socket_write2(task, port, type, fd, -1, stream, reply_port, in nxt_port_socket_write()
352 nxt_port_t *new_port, uint32_t stream);
H A Dnxt_unit.c952 msg.stream = stream; in nxt_unit_ready()
1017 recv_msg.stream = port_msg->stream; in nxt_unit_process_msg()
1335 req_impl->stream = recv_msg->stream; in nxt_unit_process_req_headers()
1605 msg.stream = req_impl->stream; in nxt_unit_send_req_headers_ack()
2654 m.msg.stream = req_impl->stream; in nxt_unit_mmap_buf_send()
3303 msg.stream = req_impl->stream; in nxt_unit_request_done()
3626 msg.stream = 0; in nxt_unit_send_oosm()
3910 msg.stream = 0; in nxt_unit_send_mmap()
6505 stream = &req_impl->stream; in nxt_unit_request_hash_add()
6507 lhq.key_hash = nxt_murmur_hash2(stream, sizeof(*stream)); in nxt_unit_request_hash_add()
[all …]
H A Dnxt_process.c761 uint32_t stream; in nxt_process_whoami() local
784 stream = nxt_port_rpc_register_handler(task, my_port, in nxt_process_whoami()
788 if (nxt_slow_path(stream == 0)) { in nxt_process_whoami()
797 fd, stream, my_port->id, buf); in nxt_process_whoami()
801 nxt_port_rpc_cancel(task, my_port, stream); in nxt_process_whoami()
868 uint32_t stream; in nxt_process_send_created() local
882 stream = nxt_port_rpc_register_handler(task, my_port, in nxt_process_send_created()
887 if (nxt_slow_path(stream == 0)) { in nxt_process_send_created()
892 -1, stream, my_port->id, NULL); in nxt_process_send_created()
896 nxt_port_rpc_cancel(task, my_port, stream); in nxt_process_send_created()
[all …]
H A Dnxt_port_rpc.h30 void nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream);
H A Dnxt_http_websocket.c103 req_rpc_data->stream, in nxt_http_websocket_client()
149 -1, req_rpc_data->stream, in nxt_http_websocket_error_handler()
H A Dnxt_port.c204 nxt_port_t *new_port, uint32_t stream) in nxt_port_send_new_port() argument
221 (void) nxt_port_send_port(task, port, new_port, stream); in nxt_port_send_new_port()
230 uint32_t stream) in nxt_port_send_port() argument
255 stream, 0, b); in nxt_port_send_port()
340 nxt_port_send_new_port(task, rt, port, msg->port_msg.stream); in nxt_port_process_ready_handler()
495 process->stream, 0, buf); in nxt_port_remove_notify_others()
H A Dnxt_script.c482 uint32_t stream; in nxt_script_store_get() local
503 stream = nxt_port_rpc_register_handler(task, recv_port, handler, handler, in nxt_script_store_get()
505 if (nxt_slow_path(stream == 0)) { in nxt_script_store_get()
510 stream, recv_port->id, b); in nxt_script_store_get()
513 nxt_port_rpc_cancel(task, recv_port, stream); in nxt_script_store_get()
603 msg->port_msg.stream, 0, NULL); in nxt_script_store_get_handler()
H A Dnxt_application.c166 uint32_t stream; in nxt_discovery_start() local
184 stream = nxt_port_rpc_register_handler(task, discovery_port, in nxt_discovery_start()
189 if (nxt_slow_path(stream == 0)) { in nxt_discovery_start()
194 stream, discovery_port->id, b); in nxt_discovery_start()
197 nxt_port_rpc_cancel(task, discovery_port, stream); in nxt_discovery_start()
644 process->stream = msg->port_msg.stream; in nxt_proto_start_process_handler()
666 -1, msg->port_msg.stream, 0, NULL); in nxt_proto_start_process_handler()
1142 init->ready_stream = my_port->process->stream; in nxt_unit_default_init()
H A Dnxt_router.c396 uint32_t stream; in nxt_router_start_app_process_handler() local
694 if (msg->port_msg.stream == 0) { in nxt_router_new_port_handler()
712 if (msg->port_msg.stream != 0) { in nxt_router_new_port_handler()
811 tmcf->stream = msg->port_msg.stream; in nxt_router_conf_data_handler()
1055 if (msg->port_msg.stream == 0) { in nxt_router_remove_pid_handler()
2796 uint32_t stream; in nxt_router_listen_socket_rpc_create() local
2830 if (nxt_slow_path(stream == 0)) { in nxt_router_listen_socket_rpc_create()
3025 uint32_t stream; in nxt_router_app_rpc_create() local
3080 stream = nxt_port_rpc_ex_stream(rpc); in nxt_router_app_rpc_create()
4244 req_rpc_data->stream, in nxt_router_req_headers_ack_handler()
[all …]
H A Dnxt_cert.c1038 msg->port_msg.stream, 0, b);
1055 msg->port_msg.stream, 0, NULL);
1065 uint32_t stream; in nxt_cert_store_get() local
1086 stream = nxt_port_rpc_register_handler(task, recv_port, handler, handler, in nxt_cert_store_get()
1088 if (nxt_slow_path(stream == 0)) { in nxt_cert_store_get()
1093 stream, recv_port->id, b); in nxt_cert_store_get()
1096 nxt_port_rpc_cancel(task, recv_port, stream); in nxt_cert_store_get()
1187 msg->port_msg.stream, 0, NULL); in nxt_cert_store_get_handler()
H A Dnxt_controller.c594 uint32_t stream; in nxt_controller_conf_send() local
635 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_conf_send()
638 if (nxt_slow_path(stream == 0)) { in nxt_controller_conf_send()
647 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_conf_send()
1570 uint32_t stream; in nxt_controller_process_status() local
1594 if (nxt_slow_path(stream == 0)) { in nxt_controller_process_status()
1602 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_process_status()
2280 uint32_t stream; in nxt_controller_process_control() local
2341 if (nxt_slow_path(stream == 0)) { in nxt_controller_process_control()
2346 -1, stream, 0, b); in nxt_controller_process_control()
[all …]
H A Dnxt_main_process.c570 process->stream = msg->port_msg.stream; in nxt_main_start_process_handler()
598 -1, msg->port_msg.stream, 0, NULL); in nxt_main_start_process_handler()
639 -1, msg->port_msg.stream, 0, NULL); in nxt_main_process_created_handler()
649 -1, msg->port_msg.stream, 0, NULL); in nxt_main_process_created_handler()
751 msg->port_msg.stream, 0, buf); in nxt_main_process_whoami_handler()
1010 process->stream = 0; in nxt_main_process_sigchld_handler()
1158 nxt_port_socket_write(task, port, type, ls.socket, msg->port_msg.stream, in nxt_main_port_socket_handler()
1425 msg->port_msg.stream, 0, NULL); in nxt_main_port_modules_handler()
1713 msg->port_msg.stream, 0, NULL); in nxt_main_port_access_log_handler()
H A Dnxt_external.c128 NXT_VERSION, my_port->process->stream, in nxt_external_start()
H A Dnxt_router.h85 uint32_t stream; member
H A Dnxt_process.h118 uint32_t stream; member
/unit/src/java/nginx/unit/
H A DResponse.java630 ServletOutputStream stream = new OutputStream(req_info_ptr); in getWriter() local
633 new OutputStreamWriter(stream, Charset.forName(characterEncoding)), in getWriter()
/unit/src/java/nginx/unit/websocket/
H A DLocalStrings.properties24 asyncChannelWrapperSecure.eof=Unexpected end of stream
/unit/docs/
H A Dunit-openapi.yaml129 application/octet-stream:
5512 description: "Filename where Unit redirects the app's stderr stream."
5516 description: "Filename where Unit redirects the app's stdout stream."