Home
last modified time | relevance | path

Searched defs:stream (Results 1 – 20 of 20) sorted by path

/unit/src/java/nginx/unit/
H A DResponse.java630 ServletOutputStream stream = new OutputStream(req_info_ptr); in getWriter() local
/unit/src/
H A Dnxt_application.c166 uint32_t stream; in nxt_discovery_start() local
H A Dnxt_cert.c1065 uint32_t stream; in nxt_cert_store_get() local
H A Dnxt_controller.c569 uint32_t stream; in nxt_controller_conf_send() local
1504 uint32_t stream; in nxt_controller_process_status() local
1926 uint32_t stream; in nxt_controller_process_control() local
H A Dnxt_fastcgi_record_parse.c24 nxt_int_t ret, stream; in nxt_fastcgi_record_parse() local
H A Dnxt_fastcgi_source.c124 nxt_stream_source_t *stream; in nxt_fastcgi_source_handler() local
730 nxt_fastcgi_source_error(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_fastcgi_source_error()
H A Dnxt_http_source.c51 nxt_stream_source_t *stream; in nxt_http_source_handler() local
598 nxt_http_source_error(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_http_source_error()
H A Dnxt_port.c204 nxt_port_t *new_port, uint32_t stream) in nxt_port_send_new_port()
230 uint32_t stream) in nxt_port_send_port()
H A Dnxt_port.h163 uint32_t stream; member
333 nxt_uint_t type, nxt_fd_t fd, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write()
H A Dnxt_port_rpc.c16 uint32_t stream; member
72 nxt_port_rpc_lhq_stream(nxt_lvlhsh_query_t *lhq, uint32_t *stream) in nxt_port_rpc_lhq_stream()
125 uint32_t stream; in nxt_port_rpc_register_handler_ex() local
257 uint32_t stream; in nxt_port_rpc_remove_from_peers() local
310 uint32_t stream; in nxt_port_rpc_handler() local
370 uint32_t stream; in nxt_port_rpc_remove_peer() local
460 nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream) in nxt_port_rpc_cancel()
H A Dnxt_port_socket.c161 nxt_fd_t fd, nxt_fd_t fd2, uint32_t stream, nxt_port_id_t reply_port, in nxt_port_socket_write2()
1028 uint32_t stream; member
H A Dnxt_process.c505 uint32_t stream; in nxt_process_whoami() local
612 uint32_t stream; in nxt_process_send_created() local
H A Dnxt_process.h114 uint32_t stream; member
H A Dnxt_router.c375 uint32_t stream; in nxt_router_start_app_process_handler() local
2629 uint32_t stream; in nxt_router_listen_socket_rpc_create() local
2858 uint32_t stream; in nxt_router_app_rpc_create() local
H A Dnxt_router.h81 uint32_t stream; member
H A Dnxt_router_access_log.c202 uint32_t stream; in nxt_router_access_log_open() local
332 uint32_t stream; in nxt_router_access_log_reopen_handler() local
H A Dnxt_router_request.h27 uint32_t stream; member
H A Dnxt_stream_source.c36 nxt_stream_source_connect(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_stream_source_connect()
95 nxt_stream_source_t *stream; in nxt_stream_source_connected() local
172 nxt_stream_source_t *stream; in nxt_stream_source_read_ready() local
246 nxt_stream_source_t *stream; in nxt_stream_source_read_done() local
286 nxt_stream_source_process_buffers(nxt_stream_source_t *stream, in nxt_stream_source_process_buffers()
346 nxt_stream_source_t *stream; in nxt_stream_source_buf_completion() local
398 nxt_stream_source_t *stream; in nxt_stream_source_refused() local
421 nxt_stream_source_t *stream; in nxt_stream_source_closed() local
445 nxt_stream_source_t *stream; in nxt_stream_source_error() local
464 nxt_stream_source_close(nxt_task_t *task, nxt_stream_source_t *stream) in nxt_stream_source_close()
H A Dnxt_unit.c221 uint32_t stream; member
249 uint32_t stream; member
846 int *log_fd, uint32_t *stream, in nxt_unit_read_env()
942 nxt_unit_ready(nxt_unit_ctx_t *ctx, int ready_fd, uint32_t stream, int queue_fd) in nxt_unit_ready()
6493 uint32_t *stream; in nxt_unit_request_hash_add() local
6535 nxt_unit_request_hash_find(nxt_unit_ctx_t *ctx, uint32_t stream, int remove) in nxt_unit_request_hash_find()
H A Dnxt_upstream_source.h65 nxt_stream_source_t *stream; member