Home
last modified time | relevance | path

Searched defs:port (Results 1 – 25 of 32) sorted by last modified time

12

/unit/test/
H A Dtest_tls.py18 def add_tls(self, application='empty', cert='default', port=7080): argument
27 def remove_tls(self, application='empty', port=7080): argument
H A Dtest_upstreams_rr.py46 def get_resps(self, req=100, port=7080): argument
62 def get_resps_sc(self, req=100, port=7080): argument
H A Dtest_tls_tickets.py48 def set_tickets(self, tickets=True, port=7080): argument
54 def connect(self, ctx=None, session=None, port=7080): argument
/unit/src/
H A Dnxt_unit.c383 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 Dnxt_sockaddr.c237 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 Dnxt_port_socket.c120 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 Dnxt_router.c763 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 Dnxt_router.h83 nxt_port_t *port; member
H A Dnxt_port_rpc.c92 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 Dnxt_port_memory.c664 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 Dnxt_port.h197 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 Dnxt_event_engine.h479 nxt_port_t *port; member
H A Dnxt_main_process.c343 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 Dnxt_cert.c1130 nxt_port_t *port; in nxt_cert_store_get_handler() local
H A Dnxt_port.c26 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 Dnxt_application.c592 nxt_port_t *port; in nxt_proto_start_process_handler() local
680 nxt_port_t *port; in nxt_proto_quit_children() local
H A Dnxt_process.h169 #define nxt_process_port_remove(port) \ argument
178 #define nxt_process_port_each(process, port) \ argument
H A Dnxt_process.c169 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 Dnxt_runtime.c497 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 Dnxt_http_route_addr.c22 nxt_str_t addr, port; in nxt_http_route_addr_pattern_parse() local
/unit/src/python/
H A Dnxt_python_asgi.c376 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 Dnxt_cgo_lib.c51 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 Dport.go26 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 Dunit.cpp33 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 Dutils.py52 def waitforsocket(port): argument

12