Home
last modified time | relevance | path

Searched defs:port (Results 1 – 25 of 31) sorted by relevance

12

/unit/src/
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_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_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_hash.c20 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 Dnxt_test_build.c66 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 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
1283 nxt_port_t *port; in nxt_main_port_modules_handler() local
1574 nxt_port_t *port; in nxt_main_port_access_log_handler() local
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_process.c169 nxt_port_t *port; in nxt_process_start() local
456 nxt_port_t *port; in nxt_process_do_start() local
560 nxt_port_t *port; in nxt_process_whoami_ok() local
963 nxt_process_port_add(nxt_task_t *task, nxt_process_t *process, nxt_port_t *port) in nxt_process_port_add()
985 nxt_port_t *port; in nxt_process_close_ports() local
H A Dnxt_sockaddr.c233 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 Dnxt_eventport_engine.c135 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 Dnxt_http_route_addr.c22 nxt_str_t addr, port; in nxt_http_route_addr_pattern_parse() local
H A Dnxt_router.c741 nxt_port_t *port; in nxt_router_conf_data_handler() local
933 nxt_port_t *port; in nxt_router_status_handler() local
2932 nxt_port_t *port; in nxt_router_app_prefork_ready() local
3404 nxt_port_t *port; in nxt_router_thread_start() local
3477 nxt_port_t *port; in nxt_router_rt_add_port() local
3798 nxt_port_t *port; in nxt_router_thread_exit_handler() local
4210 nxt_port_t *port; in nxt_router_app_port_ready() local
4394 nxt_port_t *port; in nxt_router_app_get_port_for_quit() local
4673 nxt_port_t *port; in nxt_router_adjust_idle_timer() local
4886 nxt_port_t *port; in nxt_router_app_port_get() local
[all …]
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
1550 nxt_port_t *port; in nxt_runtime_process_add() local
1647 nxt_port_t *port; in nxt_runtime_process_port_create() local
1674 nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_add()
1694 nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port) in nxt_runtime_port_remove()
H A Dnxt_unit.c383 nxt_unit_port_t port; member
1167 nxt_unit_port_t new_port, *port; in nxt_unit_process_new_port() local
1455 nxt_unit_port_t *port; in nxt_unit_request_check_response_port() local
5090 nxt_unit_port_t *port; in nxt_unit_ctx_alloc() local
5258 nxt_unit_port_t new_port, *port; in nxt_unit_create_port() local
5326 nxt_unit_port_t *port, int queue_fd) in nxt_unit_send_port()
5363 nxt_inline void nxt_unit_port_use(nxt_unit_port_t *port) in nxt_unit_port_use()
5631 nxt_unit_port_t *port; in nxt_unit_remove_port() local
5659 nxt_unit_port_t *port; in nxt_unit_remove_port_unsafe() local
5705 nxt_unit_port_impl_t *port; in nxt_unit_remove_process() local
[all …]
H A Dnxt_http_route_addr.h55 } port; member
H A Dnxt_process.h171 #define nxt_process_port_remove(port) \ argument
180 #define nxt_process_port_each(process, port) \ argument
/unit/go/
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() {
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()
/unit/test/
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
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.py17 def add_tls(self, application='empty', cert='default', port=7080): argument
26 def remove_tls(self, application='empty', port=7080): argument
/unit/src/python/
H A Dnxt_python_asgi.c378 nxt_py_asgi_remove_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_remove_reader()
739 nxt_py_asgi_create_address(nxt_unit_sptr_t *sptr, uint8_t len, uint16_t port) in nxt_py_asgi_create_address()
781 nxt_py_asgi_create_ip_address(nxt_unit_sptr_t *sptr, uint8_t len, uint16_t port) in nxt_py_asgi_create_ip_address()
936 nxt_py_asgi_add_port(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_port()
960 nxt_py_asgi_add_reader(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port) in nxt_py_asgi_add_reader()
1025 nxt_unit_port_t *port) in nxt_py_asgi_remove_port()
1097 nxt_unit_port_t *port; in nxt_py_asgi_port_read() local
/unit/test/unit/
H A Dutils.py52 def waitforsocket(port): argument
/unit/src/java/nginx/unit/websocket/server/
H A DWsHandshakeRequest.java151 int port = req.getServerPort(); in buildRequestUri() local
/unit/src/java/nginx/unit/websocket/
H A DWsWebSocketContainer.java225 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()

12