| /unit/src/ |
| 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_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_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_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_test_build.c | 66 port_associate(int port, int source, uintptr_t object, int events, void *user) in port_associate()
73 port_dissociate(int port, int source, uintptr_t object) in port_dissociate()
80 port_send(int port, int events, void *user) in port_send()
86 int port_getn(int port, port_event_t list[], uint_t max, uint_t *nget, in port_getn()
|
| H A D | nxt_main_process.c | 403 nxt_port_t *port; in nxt_main_new_port_handler() local
432 nxt_port_t *port; in nxt_main_start_process_handler() local
614 nxt_port_t *port; in nxt_main_process_created_handler() local
684 nxt_port_t *port; in nxt_main_process_whoami_handler() local
765 nxt_port_t *port; in nxt_main_process_port_create() local
854 nxt_port_t *port; in nxt_main_process_sigusr1_handler() local
953 nxt_port_t *port; in nxt_main_process_sigchld_handler() local
1100 nxt_port_t *port; in nxt_main_port_socket_handler() local
1399 nxt_port_t *port; in nxt_main_port_modules_handler() local
1690 nxt_port_t *port; in nxt_main_port_access_log_handler() local
|
| 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_sockaddr.c | 233 uint32_t port; in nxt_sockaddr_text() local
328 uint32_t port; in nxt_sockaddr_port_number() local
649 nxt_int_t ret, port; in nxt_sockaddr_inet6_parse() local
722 nxt_int_t port; in nxt_sockaddr_inet_parse() 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_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_router.c | 762 nxt_port_t *port; in nxt_router_conf_data_handler() local
954 nxt_port_t *port; in nxt_router_status_handler() local
3108 nxt_port_t *port; in nxt_router_app_prefork_ready() local
3580 nxt_port_t *port; in nxt_router_thread_start() local
3653 nxt_port_t *port; in nxt_router_rt_add_port() local
4011 nxt_port_t *port; in nxt_router_thread_exit_handler() local
4423 nxt_port_t *port; in nxt_router_app_port_ready() local
4607 nxt_port_t *port; in nxt_router_app_get_port_for_quit() local
4886 nxt_port_t *port; in nxt_router_adjust_idle_timer() local
5099 nxt_port_t *port; in nxt_router_app_port_get() local
[all …]
|
| H A D | nxt_process.c | 185 nxt_port_t *port; in nxt_process_start() local
712 nxt_port_t *port; in nxt_process_do_start() local
816 nxt_port_t *port; in nxt_process_whoami_ok() local
1219 nxt_process_port_add(nxt_task_t *task, nxt_process_t *process, nxt_port_t *port) in nxt_process_port_add()
1241 nxt_port_t *port; in nxt_process_close_ports() local
|
| 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
1616 nxt_port_t *port; in nxt_runtime_process_add() local
1713 nxt_port_t *port; in nxt_runtime_process_port_create() local
1740 nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_add()
1760 nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_remove()
|
| H A D | nxt_unit.c | 383 nxt_unit_port_t port; member
1185 nxt_unit_port_t new_port, *port; in nxt_unit_process_new_port() local
1473 nxt_unit_port_t *port; in nxt_unit_request_check_response_port() local
5108 nxt_unit_port_t *port; in nxt_unit_ctx_alloc() local
5276 nxt_unit_port_t new_port, *port; in nxt_unit_create_port() local
5344 nxt_unit_port_t *port, int queue_fd) in nxt_unit_send_port()
5381 nxt_inline void nxt_unit_port_use(nxt_unit_port_t *port) in nxt_unit_port_use()
5649 nxt_unit_port_t *port; in nxt_unit_remove_port() local
5677 nxt_unit_port_t *port; in nxt_unit_remove_port_unsafe() local
5723 nxt_unit_port_impl_t *port; in nxt_unit_remove_process() local
[all …]
|
| H A D | nxt_http_route_addr.h | 55 } port; member
|
| H A D | nxt_application.c | 599 nxt_port_t *port; in nxt_proto_start_process_handler() local
689 nxt_port_t *port; in nxt_proto_quit_children() local
769 nxt_port_t *port; in nxt_proto_sigchld_handler() local
|
| /unit/go/ |
| 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() {
|
| 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()
|
| /unit/test/ |
| H A D | test_tls_tickets.py | 49 def connect(ctx=None, session=None, port=7080): argument
75 def set_tickets(tickets=True, port=7080): argument
|
| H A D | test_upstreams_rr.py | 50 def get_resps(req=100, port=7080): argument
67 def get_resps_sc(req=100, port=7080): argument
|
| H A D | test_tls.py | 15 def add_tls(application='empty', cert='default', port=7080): argument
88 def remove_tls(application='empty', port=7080): argument
|
| /unit/src/python/ |
| H A D | nxt_python_asgi.c | 415 nxt_py_asgi_remove_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_remove_reader()
815 nxt_py_asgi_create_address(nxt_unit_sptr_t *sptr, uint8_t len, uint16_t port) in nxt_py_asgi_create_address()
855 nxt_py_asgi_create_ip_address(nxt_unit_sptr_t *sptr, uint8_t len, uint16_t port) in nxt_py_asgi_create_ip_address()
1002 nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_port()
1026 nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_reader()
1091 nxt_unit_port_t *port) in nxt_py_asgi_remove_port()
1163 nxt_unit_port_t *port; in nxt_py_asgi_port_read() local
|
| /unit/test/unit/ |
| H A D | utils.py | 58 def waitforsocket(port): argument
|
| /unit/src/java/nginx/unit/websocket/server/ |
| H A D | WsHandshakeRequest.java | 151 int port = req.getServerPort(); in buildRequestUri() local
|
| /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()
|