| /unit/src/ |
| H A D | nxt_stream_source.c | 58 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 D | nxt_port_rpc.c | 16 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 D | nxt_http_source.c | 41 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 D | nxt_fastcgi_source.c | 73 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 D | nxt_port_memory.h | 27 nxt_port_mmap_tracking_t *tracking, uint32_t stream);
31 nxt_port_mmap_tracking_t *tracking, uint32_t stream);
|
| H A D | nxt_stream_source.h | 29 void nxt_stream_source_connect(nxt_task_t *task, nxt_stream_source_t *stream);
|
| H A D | nxt_process.c | 481 uint32_t stream; in nxt_process_whoami() local
504 stream = nxt_port_rpc_register_handler(task, my_port, in nxt_process_whoami()
508 if (nxt_slow_path(stream == 0)) { in nxt_process_whoami()
517 fd, stream, my_port->id, buf); in nxt_process_whoami()
521 nxt_port_rpc_cancel(task, my_port, stream); in nxt_process_whoami()
588 uint32_t stream; in nxt_process_send_created() local
602 stream = nxt_port_rpc_register_handler(task, my_port, in nxt_process_send_created()
607 if (nxt_slow_path(stream == 0)) { in nxt_process_send_created()
612 -1, stream, my_port->id, NULL); in nxt_process_send_created()
616 nxt_port_rpc_cancel(task, my_port, stream); in nxt_process_send_created()
[all …]
|
| H A D | nxt_router_request.h | 27 uint32_t stream; member
|
| H A D | nxt_port_socket.c | 183 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 D | nxt_fastcgi_record_parse.c | 24 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 D | nxt_port.h | 158 uint32_t stream; member
327 nxt_uint_t type, nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream,
332 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write() argument
335 return nxt_port_socket_write2(task, port, type, fd, -1, stream, reply_port, in nxt_port_socket_write()
342 nxt_port_t *new_port, uint32_t stream);
|
| H A D | nxt_unit.c | 937 msg.stream = stream; in nxt_unit_ready()
1003 recv_msg.stream = port_msg->stream; in nxt_unit_process_msg()
1321 req_impl->stream = recv_msg->stream; in nxt_unit_process_req_headers()
1591 msg.stream = req_impl->stream; in nxt_unit_send_req_headers_ack()
2639 m.msg.stream = req_impl->stream; in nxt_unit_mmap_buf_send()
3290 msg.stream = req_impl->stream; in nxt_unit_request_done()
3614 msg.stream = 0; in nxt_unit_send_oosm()
3900 msg.stream = 0; in nxt_unit_send_mmap()
6498 stream = &req_impl->stream; in nxt_unit_request_hash_add()
6500 lhq.key_hash = nxt_murmur_hash2(stream, sizeof(*stream)); in nxt_unit_request_hash_add()
[all …]
|
| H A D | nxt_port_rpc.h | 30 void nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream);
|
| H A D | nxt_http_websocket.c | 103 req_rpc_data->stream, in nxt_http_websocket_client()
149 -1, req_rpc_data->stream, in nxt_http_websocket_error_handler()
|
| H A D | nxt_upstream_source.h | 65 nxt_stream_source_t *stream; member
|
| H A D | nxt_port.c | 204 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 D | nxt_router.c | 396 uint32_t stream; in nxt_router_start_app_process_handler() local
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()
977 if (msg->port_msg.stream == 0) { in nxt_router_remove_pid_handler()
2546 uint32_t stream; in nxt_router_listen_socket_rpc_create() local
2580 if (nxt_slow_path(stream == 0)) { in nxt_router_listen_socket_rpc_create()
2775 uint32_t stream; in nxt_router_app_rpc_create() local
3853 uint32_t stream; in nxt_router_access_log_open() local
3880 if (nxt_slow_path(stream == 0)) { in nxt_router_access_log_open()
4335 req_rpc_data->stream, in nxt_router_req_headers_ack_handler()
[all …]
|
| H A D | nxt_port_memory.c | 544 nxt_port_mmap_tracking_t *tracking, uint32_t stream) in nxt_port_mmap_get_tracking() argument
550 nxt_debug(task, "request tracking for stream #%uD", stream); in nxt_port_mmap_get_tracking()
564 *tracking->tracking = stream; in nxt_port_mmap_get_tracking()
575 nxt_port_mmap_tracking_t *tracking, uint32_t stream) in nxt_port_mmap_tracking_cancel() argument
590 res = nxt_atomic_cmp_set(tracking->tracking, stream, 0); in nxt_port_mmap_tracking_cancel()
593 (res ? "cancelled" : "failed to cancel"), stream); in nxt_port_mmap_tracking_cancel()
660 res = nxt_atomic_cmp_set(hdr->tracking + c, msg->port_msg.stream, 0); in nxt_port_mmap_tracking_read()
662 nxt_debug(task, "tracking for stream #%uD %s", msg->port_msg.stream, in nxt_port_mmap_tracking_read()
|
| H A D | nxt_application.c | 159 uint32_t stream; in nxt_discovery_start() local
177 stream = nxt_port_rpc_register_handler(task, discovery_port, in nxt_discovery_start()
182 if (nxt_slow_path(stream == 0)) { in nxt_discovery_start()
187 stream, discovery_port->id, b); in nxt_discovery_start()
190 nxt_port_rpc_cancel(task, discovery_port, stream); in nxt_discovery_start()
637 process->stream = msg->port_msg.stream; in nxt_proto_start_process_handler()
657 -1, msg->port_msg.stream, 0, NULL); in nxt_proto_start_process_handler()
1043 init->ready_stream = my_port->process->stream; in nxt_unit_default_init()
|
| H A D | nxt_cert.c | 1038 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 D | nxt_main_process.c | 510 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()
1307 msg->port_msg.stream, 0, NULL); in nxt_main_port_modules_handler()
1595 msg->port_msg.stream, 0, NULL); in nxt_main_port_access_log_handler()
|
| H A D | nxt_controller.c | 561 uint32_t stream; in nxt_controller_conf_send() local
602 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_conf_send()
605 if (nxt_slow_path(stream == 0)) { in nxt_controller_conf_send()
611 fd, stream, controller_port->id, b); in nxt_controller_conf_send()
614 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_conf_send()
1757 uint32_t stream; in nxt_controller_process_control() local
1814 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_process_control()
1818 if (nxt_slow_path(stream == 0)) { in nxt_controller_process_control()
1823 -1, stream, 0, b); in nxt_controller_process_control()
1825 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_process_control()
|
| H A D | nxt_router.h | 79 uint32_t stream; member
|
| H A D | nxt_process.h | 114 uint32_t stream; member
|
| H A D | nxt_external.c | 128 NXT_VERSION, my_port->process->stream, in nxt_external_start()
|