Home
last modified time | relevance | path

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

12

/unit/src/
H A Dnxt_stream_source.c58 stream->conn = c; in nxt_stream_source_connect()
71 stream->error_handler(task, stream); in nxt_stream_source_connect()
98 stream = data; in nxt_stream_source_connected()
175 stream = data; in nxt_stream_source_read_ready()
249 stream = data; in nxt_stream_source_read_done()
279 stream->next->filter(task, stream->next->context, b); in nxt_stream_source_read_done()
400 stream = data; in nxt_stream_source_refused()
424 stream = data; in nxt_stream_source_closed()
434 stream->error_handler(task, stream); in nxt_stream_source_closed()
447 stream = data; in nxt_stream_source_error()
[all …]
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_http_source.c41 nxt_stream_source_t *stream);
51 nxt_stream_source_t *stream; in nxt_http_source_handler() local
70 stream = us->stream; in nxt_http_source_handler()
72 if (stream == NULL) { in nxt_http_source_handler()
74 if (nxt_slow_path(stream == NULL)) { in nxt_http_source_handler()
78 us->stream = stream; in nxt_http_source_handler()
79 stream->upstream = us; in nxt_http_source_handler()
89 stream->next = &hs->query; in nxt_http_source_handler()
99 if (nxt_fast_path(stream->out != NULL)) { in nxt_http_source_handler()
102 nxt_stream_source_connect(task, stream); in nxt_http_source_handler()
[all …]
H A Dnxt_fastcgi_source.c73 nxt_stream_source_t *stream);
124 nxt_stream_source_t *stream; in nxt_fastcgi_source_handler() local
144 stream = us->stream; in nxt_fastcgi_source_handler()
146 if (stream == NULL) { in nxt_fastcgi_source_handler()
148 if (nxt_slow_path(stream == NULL)) { in nxt_fastcgi_source_handler()
152 us->stream = stream; in nxt_fastcgi_source_handler()
153 stream->upstream = us; in nxt_fastcgi_source_handler()
163 stream->next = &fs->query; in nxt_fastcgi_source_handler()
180 if (nxt_fast_path(stream->out != NULL)) { in nxt_fastcgi_source_handler()
184 nxt_stream_source_connect(task, stream); in nxt_fastcgi_source_handler()
[all …]
H A Dnxt_router_access_log.c199 uint32_t stream; in nxt_router_access_log_open() local
222 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_open()
226 if (nxt_slow_path(stream == 0)) { in nxt_router_access_log_open()
231 stream, router_port->id, b); in nxt_router_access_log_open()
234 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_open()
329 uint32_t stream; in nxt_router_access_log_reopen_handler() local
370 stream = nxt_port_rpc_register_handler(task, router_port, in nxt_router_access_log_reopen_handler()
374 if (nxt_slow_path(stream == 0)) { in nxt_router_access_log_reopen_handler()
379 stream, router_port->id, b); in nxt_router_access_log_reopen_handler()
382 nxt_port_rpc_cancel(task, router_port, stream); in nxt_router_access_log_reopen_handler()
H A Dnxt_process.c505 uint32_t stream; in nxt_process_whoami() local
528 stream = nxt_port_rpc_register_handler(task, my_port, in nxt_process_whoami()
532 if (nxt_slow_path(stream == 0)) { in nxt_process_whoami()
541 fd, stream, my_port->id, buf); in nxt_process_whoami()
545 nxt_port_rpc_cancel(task, my_port, stream); in nxt_process_whoami()
612 uint32_t stream; in nxt_process_send_created() local
626 stream = nxt_port_rpc_register_handler(task, my_port, in nxt_process_send_created()
631 if (nxt_slow_path(stream == 0)) { in nxt_process_send_created()
636 -1, stream, my_port->id, NULL); in nxt_process_send_created()
640 nxt_port_rpc_cancel(task, my_port, stream); in nxt_process_send_created()
[all …]
H A Dnxt_stream_source.h29 void nxt_stream_source_connect(nxt_task_t *task, nxt_stream_source_t *stream);
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_fastcgi_record_parse.c24 nxt_int_t ret, stream; in nxt_fastcgi_record_parse() local
71 stream = fp->type - NXT_FASTCGI_STDOUT; in nxt_fastcgi_record_parse()
73 ret = nxt_fastcgi_buffer(fp, &tail[stream], b); in nxt_fastcgi_record_parse()
H A Dnxt_port.h163 uint32_t stream; member
328 nxt_uint_t type, nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream,
333 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write() argument
336 return nxt_port_socket_write2(task, port, type, fd, -1, stream, reply_port, in nxt_port_socket_write()
343 nxt_port_t *new_port, uint32_t stream);
H A Dnxt_unit.c934 msg.stream = stream; in nxt_unit_ready()
999 recv_msg.stream = port_msg->stream; in nxt_unit_process_msg()
1317 req_impl->stream = recv_msg->stream; in nxt_unit_process_req_headers()
1587 msg.stream = req_impl->stream; in nxt_unit_send_req_headers_ack()
2635 m.msg.stream = req_impl->stream; in nxt_unit_mmap_buf_send()
3284 msg.stream = req_impl->stream; in nxt_unit_request_done()
3607 msg.stream = 0; in nxt_unit_send_oosm()
3891 msg.stream = 0; in nxt_unit_send_mmap()
6486 stream = &req_impl->stream; in nxt_unit_request_hash_add()
6488 lhq.key_hash = nxt_murmur_hash2(stream, sizeof(*stream)); in nxt_unit_request_hash_add()
[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_upstream_source.h65 nxt_stream_source_t *stream; member
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()
1086 init->ready_stream = my_port->process->stream; in nxt_unit_default_init()
H A Dnxt_controller.c569 uint32_t stream; in nxt_controller_conf_send() local
610 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_conf_send()
613 if (nxt_slow_path(stream == 0)) { in nxt_controller_conf_send()
622 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_conf_send()
1496 uint32_t stream; in nxt_controller_process_status() local
1520 if (nxt_slow_path(stream == 0)) { in nxt_controller_process_status()
1528 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_process_status()
1918 uint32_t stream; in nxt_controller_process_control() local
1979 if (nxt_slow_path(stream == 0)) { in nxt_controller_process_control()
1984 -1, stream, 0, b); in nxt_controller_process_control()
[all …]
H A Dnxt_router.c375 uint32_t stream; in nxt_router_start_app_process_handler() local
673 if (msg->port_msg.stream == 0) { in nxt_router_new_port_handler()
691 if (msg->port_msg.stream != 0) { in nxt_router_new_port_handler()
790 tmcf->stream = msg->port_msg.stream; in nxt_router_conf_data_handler()
1034 if (msg->port_msg.stream == 0) { in nxt_router_remove_pid_handler()
2620 uint32_t stream; in nxt_router_listen_socket_rpc_create() local
2654 if (nxt_slow_path(stream == 0)) { in nxt_router_listen_socket_rpc_create()
2849 uint32_t stream; in nxt_router_app_rpc_create() local
2904 stream = nxt_port_rpc_ex_stream(rpc); in nxt_router_app_rpc_create()
4031 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_main_process.c510 process->stream = msg->port_msg.stream; in nxt_main_start_process_handler()
538 -1, msg->port_msg.stream, 0, NULL); in nxt_main_start_process_handler()
579 -1, msg->port_msg.stream, 0, NULL); in nxt_main_process_created_handler()
589 -1, msg->port_msg.stream, 0, NULL); in nxt_main_process_created_handler()
686 msg->port_msg.stream, 0, buf); in nxt_main_process_whoami_handler()
945 process->stream = 0; in nxt_main_process_sigchld_handler()
1089 nxt_port_socket_write(task, port, type, ls.socket, msg->port_msg.stream, in nxt_main_port_socket_handler()
1309 msg->port_msg.stream, 0, NULL); in nxt_main_port_modules_handler()
1597 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.h81 uint32_t stream; member
H A Dnxt_process.h114 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()

12