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