/unit/test/ |
H A D | test_tls.py | 18 def add_tls(self, application='empty', cert='default', port=7080): argument 27 def remove_tls(self, application='empty', port=7080): argument
|
H A D | test_upstreams_rr.py | 46 def get_resps(self, req=100, port=7080): argument 62 def get_resps_sc(self, req=100, port=7080): argument
|
H A D | test_tls_tickets.py | 48 def set_tickets(self, tickets=True, port=7080): argument 54 def connect(self, ctx=None, session=None, port=7080): argument
|
/unit/src/ |
H A D | nxt_unit.c | 383 nxt_unit_port_t port; member 1171 nxt_unit_port_t new_port, *port; in nxt_unit_process_new_port() local 1459 nxt_unit_port_t *port; in nxt_unit_request_check_response_port() local 5094 nxt_unit_port_t *port; in nxt_unit_ctx_alloc() local 5262 nxt_unit_port_t new_port, *port; in nxt_unit_create_port() local 5330 nxt_unit_port_t *port, int queue_fd) in nxt_unit_send_port() 5367 nxt_inline void nxt_unit_port_use(nxt_unit_port_t *port) in nxt_unit_port_use() 5635 nxt_unit_port_t *port; in nxt_unit_remove_port() local 5663 nxt_unit_port_t *port; in nxt_unit_remove_port_unsafe() local 5709 nxt_unit_port_impl_t *port; in nxt_unit_remove_process() local [all …]
|
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
|
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_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_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_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.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_event_engine.h | 479 nxt_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_cert.c | 1130 nxt_port_t *port; in nxt_cert_store_get_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_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_process.h | 169 #define nxt_process_port_remove(port) \ argument 178 #define nxt_process_port_each(process, port) \ argument
|
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_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_http_route_addr.c | 22 nxt_str_t addr, port; in nxt_http_route_addr_pattern_parse() local
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 376 nxt_py_asgi_remove_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_remove_reader() 737 nxt_py_asgi_create_address(nxt_unit_sptr_t *sptr, uint8_t len, uint16_t port) in nxt_py_asgi_create_address() 892 nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_port() 916 nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_reader() 981 nxt_unit_port_t *port) in nxt_py_asgi_remove_port() 1053 nxt_unit_port_t *port; in nxt_py_asgi_port_read() local
|
/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/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/test/unit/ |
H A D | utils.py | 52 def waitforsocket(port): argument
|