/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()
|