/unit/go/ |
H A D | nxt_cgo_lib.c | 51 nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_cgo_port_send() 60 nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_cgo_port_recv()
|
H A D | port.go | 26 type port struct { struct 27 key port_key 28 rcv *net.UnixConn 29 snd *net.UnixConn 47 func add_port(p *port) { 63 func (p *port) Close() {
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsWebSocketContainer.java | 225 int port = path.getPort(); in connectToServerRecursive() local 563 private static ByteBuffer createProxyRequest(String host, int port) { in createProxyRequest() 631 private static Map<String, List<String>> createRequestHeaders(String host, int port, in createRequestHeaders() 889 private SSLEngine createSSLEngine(Map<String,Object> userProperties, String host, int port) in createSSLEngine()
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | WsHandshakeRequest.java | 151 int port = req.getServerPort(); in buildRequestUri() local
|
/unit/src/nodejs/unit-http/ |
H A D | unit.cpp | 33 nxt_unit_port_t *port; member 471 Unit::add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in add_port() 522 Unit::remove_port(nxt_unit_t *unit, nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in remove_port()
|
/unit/src/ |
H A D | nxt_application.c | 592 nxt_port_t *port; in nxt_proto_start_process_handler() local 680 nxt_port_t *port; in nxt_proto_quit_children() local
|
H A D | nxt_cert.c | 1130 nxt_port_t *port; in nxt_cert_store_get_handler() local
|
H A D | nxt_event_engine.h | 479 nxt_port_t *port; member
|
H A D | nxt_eventport_engine.c | 135 int port; in nxt_eventport_free() local 299 int ret, port; in nxt_eventport_commit_changes() local 438 int port; in nxt_eventport_signal() local
|
H A D | nxt_http_route_addr.c | 22 nxt_str_t addr, port; in nxt_http_route_addr_pattern_parse() local
|
H A D | nxt_http_route_addr.h | 54 } port; member
|
H A D | nxt_job_resolve.h | 16 in_port_t port; member
|
H A D | nxt_main_process.c | 343 nxt_port_t *port; in nxt_main_new_port_handler() local 372 nxt_port_t *port; in nxt_main_start_process_handler() local 554 nxt_port_t *port; in nxt_main_process_created_handler() local 619 nxt_port_t *port; in nxt_main_process_whoami_handler() local 700 nxt_port_t *port; in nxt_main_process_port_create() local 789 nxt_port_t *port; in nxt_main_process_sigusr1_handler() local 888 nxt_port_t *port; in nxt_main_process_sigchld_handler() local 1031 nxt_port_t *port; in nxt_main_port_socket_handler() local 1281 nxt_port_t *port; in nxt_main_port_modules_handler() local 1572 nxt_port_t *port; in nxt_main_port_access_log_handler() local
|
H A D | nxt_port.c | 26 nxt_port_t *port; in nxt_port_mp_cleanup() local 53 nxt_port_t *port; in nxt_port_new() local 88 nxt_port_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_close() 161 nxt_port_enable(nxt_task_t *task, nxt_port_t *port, in nxt_port_enable() 206 nxt_port_t *port; in nxt_port_send_new_port() local 262 nxt_port_t *port; in nxt_port_new_port_handler() local 312 nxt_port_t *port; in nxt_port_process_ready_handler() local 379 nxt_port_t *port; in nxt_port_change_log_file() local 459 nxt_port_t *port; in nxt_port_remove_notify_others() local 549 nxt_port_t *port; member [all …]
|
H A D | nxt_port.h | 197 nxt_port_t *port; member 327 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write() 357 nxt_inline void nxt_port_inc_use(nxt_port_t *port) in nxt_port_inc_use()
|
H A D | nxt_port_hash.c | 20 nxt_port_t *port; in nxt_port_hash_test() local 63 nxt_port_hash_add(nxt_lvlhsh_t *port_hash, nxt_port_t *port) in nxt_port_hash_add() 94 nxt_port_hash_remove(nxt_lvlhsh_t *port_hash, nxt_port_t *port) in nxt_port_hash_remove()
|
H A D | nxt_port_memory.c | 664 nxt_port_mmap_get_incoming_buf(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_get_incoming_buf() 711 nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_mmap_write() 804 nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b) in nxt_port_mmap_get_method() 856 nxt_port_t *port; in nxt_process_broadcast_shm_ack() local 872 nxt_port_broadcast_shm_ack(nxt_task_t *task, nxt_port_t *port, void *data) in nxt_port_broadcast_shm_ack()
|
H A D | nxt_port_rpc.c | 92 nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_register_handler() 121 nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_register_handler_ex() 188 nxt_port_rpc_ex_set_peer(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_ex_set_peer() 254 nxt_port_rpc_remove_from_peers(nxt_task_t *task, nxt_port_t *port, in nxt_port_rpc_remove_from_peers() 312 nxt_port_t *port; in nxt_port_rpc_handler() local 367 nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, nxt_pid_t peer) in nxt_port_rpc_remove_peer() 460 nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream) in nxt_port_rpc_cancel() 493 nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port) in nxt_port_rpc_close()
|
H A D | nxt_port_socket.c | 120 nxt_port_destroy(nxt_port_t *port) in nxt_port_destroy() 128 nxt_port_write_enable(nxt_task_t *task, nxt_port_t *port) in nxt_port_write_enable() 143 nxt_port_write_close(nxt_port_t *port) in nxt_port_write_close() 374 nxt_port_t *port; in nxt_port_write_handler() local 569 nxt_port_msg_first(nxt_port_t *port) in nxt_port_msg_first() 721 nxt_port_read_close(nxt_port_t *port) in nxt_port_read_close() 736 nxt_port_t *port; in nxt_port_read_handler() local 817 nxt_port_t *port; in nxt_port_queue_read_handler() local 1305 nxt_port_buf_alloc(nxt_port_t *port) in nxt_port_buf_alloc() 1328 nxt_port_buf_free(nxt_port_t *port, nxt_buf_t *b) in nxt_port_buf_free() [all …]
|
H A D | nxt_process.c | 169 nxt_port_t *port; in nxt_process_start() local 432 nxt_port_t *port; in nxt_process_do_start() local 536 nxt_port_t *port; in nxt_process_whoami_ok() local 987 nxt_process_port_add(nxt_task_t *task, nxt_process_t *process, nxt_port_t *port) in nxt_process_port_add() 1009 nxt_port_t *port; in nxt_process_close_ports() local
|
H A D | nxt_process.h | 169 #define nxt_process_port_remove(port) \ argument 178 #define nxt_process_port_each(process, port) \ argument
|
H A D | nxt_router.c | 763 nxt_port_t *port; in nxt_router_conf_data_handler() local 1485 nxt_port_t *port; in nxt_router_conf_create() local 2894 nxt_port_t *port; in nxt_router_app_prefork_ready() local 3366 nxt_port_t *port; in nxt_router_thread_start() local 3439 nxt_port_t *port; in nxt_router_rt_add_port() local 4138 nxt_port_t *port; in nxt_router_thread_exit_handler() local 4550 nxt_port_t *port; in nxt_router_app_port_ready() local 4734 nxt_port_t *port; in nxt_router_app_get_port_for_quit() local 5013 nxt_port_t *port; in nxt_router_adjust_idle_timer() local 5226 nxt_port_t *port; in nxt_router_app_port_get() local [all …]
|
H A D | nxt_router.h | 83 nxt_port_t *port; member
|
H A D | nxt_runtime.c | 497 nxt_port_t *port; in nxt_runtime_stop_app_processes() local 524 nxt_port_t *port; in nxt_runtime_stop_all_processes() local 1547 nxt_port_t *port; in nxt_runtime_process_add() local 1642 nxt_port_t *port; in nxt_runtime_process_port_create() local 1669 nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_add() 1689 nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_remove()
|
H A D | nxt_sockaddr.c | 237 uint32_t port; in nxt_sockaddr_text() local 332 uint32_t port; in nxt_sockaddr_port_number() local 437 nxt_sockaddr_ntop(nxt_sockaddr_t *sa, u_char *buf, u_char *end, nxt_bool_t port) in nxt_sockaddr_ntop() 728 nxt_int_t ret, port; in nxt_sockaddr_inet6_parse() local 801 nxt_int_t port; in nxt_sockaddr_inet_parse() local 982 nxt_int_t port; in nxt_job_sockaddr_inet6_parse() local 1075 nxt_int_t port; in nxt_job_sockaddr_inet_parse() local
|