/unit/src/ |
H A D | nxt_port.c | 26 nxt_port_t *port; in nxt_port_mp_cleanup() local 28 port = obj; in nxt_port_mp_cleanup() 53 nxt_port_t *port; in nxt_port_new() local 64 port->id = id; in nxt_port_new() 83 return port; in nxt_port_new() 92 nxt_debug(task, "port %p %d:%d close, type %d", port, port->pid, in nxt_port_close() 93 port->id, port->type); in nxt_port_close() 129 nxt_debug(task, "port %p %d:%d release, type %d", port, port->pid, in nxt_port_release() 130 port->id, port->type); in nxt_port_release() 562 port = pw->port; in nxt_port_post_handler() [all …]
|
H A D | nxt_port_socket.c | 130 port->socket.fd = port->pair[1]; in nxt_port_write_enable() 206 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_socket_write2() 233 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_socket_write2() 705 port->socket.fd = port->pair[0]; in nxt_port_read_enable() 825 msg.port = port; in nxt_port_queue_read_handler() 852 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler() 859 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler() 875 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler() 934 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler() 941 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler() [all …]
|
H A D | nxt_port_rpc.c | 150 lhq.pool = port->mem_pool; in nxt_port_rpc_register_handler_ex() 168 nxt_port_inc_use(port); in nxt_port_rpc_register_handler_ex() 219 lhq.pool = port->mem_pool; in nxt_port_rpc_ex_set_peer() 312 nxt_port_t *port; in nxt_port_rpc_handler() local 318 port = msg->port; in nxt_port_rpc_handler() 323 lhq.pool = port->mem_pool; in nxt_port_rpc_handler() 362 nxt_port_use(task, port, -1); in nxt_port_rpc_handler() 379 lhq.pool = port->mem_pool; in nxt_port_rpc_remove_peer() 395 msg.port = port; in nxt_port_rpc_remove_peer() 467 lhq.pool = port->mem_pool; in nxt_port_rpc_cancel() [all …]
|
H A D | nxt_port_hash.c | 20 nxt_port_t *port; in nxt_port_hash_test() local 23 port = data; in nxt_port_hash_test() 27 && pid_port_id->pid == port->pid in nxt_port_hash_test() 28 && pid_port_id->port_id == port->id) in nxt_port_hash_test() 69 pid_port.pid = port->pid; in nxt_port_hash_add() 70 pid_port.port_id = port->id; in nxt_port_hash_add() 74 lhq.value = port; in nxt_port_hash_add() 85 port->id, port->pid); in nxt_port_hash_add() 100 pid_port.pid = port->pid; in nxt_port_hash_remove() 101 pid_port.port_id = port->id; in nxt_port_hash_remove() [all …]
|
H A D | nxt_http_route_addr.c | 58 nxt_str_null(&port); in nxt_http_route_addr_pattern_parse() 91 port.length = end - port.start; in nxt_http_route_addr_pattern_parse() 207 port.length = addr.start + addr.length - port.start; in nxt_http_route_addr_pattern_parse() 275 if (port.length == 0) { in nxt_http_route_addr_pattern_parse() 280 base->port.start = 0; in nxt_http_route_addr_pattern_parse() 286 delim = memchr(port.start, '-', port.length - 1); in nxt_http_route_addr_pattern_parse() 288 ret = nxt_int_parse(port.start, delim - port.start); in nxt_http_route_addr_pattern_parse() 295 ret = nxt_int_parse(delim + 1, port.start + port.length - (delim + 1)); in nxt_http_route_addr_pattern_parse() 300 base->port.end = ret; in nxt_http_route_addr_pattern_parse() 303 ret = nxt_int_parse(port.start, port.length); in nxt_http_route_addr_pattern_parse() [all …]
|
H A D | nxt_port_rpc.h | 16 uint32_t nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, 19 void *nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, 24 void nxt_port_rpc_ex_set_peer(nxt_task_t *task, nxt_port_t *port, 28 void nxt_port_rpc_remove_peer(nxt_task_t *task, nxt_port_t *port, 30 void nxt_port_rpc_cancel(nxt_task_t *task, nxt_port_t *port, uint32_t stream); 31 void nxt_port_rpc_close(nxt_task_t *task, nxt_port_t *port);
|
H A D | nxt_port.h | 211 nxt_port_t *port; member 330 void nxt_port_destroy(nxt_port_t *port); 331 void nxt_port_close(nxt_task_t *task, nxt_port_t *port); 333 void nxt_port_write_close(nxt_port_t *port); 335 void nxt_port_read_close(nxt_port_t *port); 341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write() argument 349 void nxt_port_enable(nxt_task_t *task, nxt_port_t *port, 367 nxt_int_t nxt_port_post(nxt_task_t *task, nxt_port_t *port, 369 void nxt_port_use(nxt_task_t *task, nxt_port_t *port, int i); 371 nxt_inline void nxt_port_inc_use(nxt_port_t *port) in nxt_port_inc_use() argument [all …]
|
H A D | nxt_router.c | 813 tmcf->port = port; in nxt_router_conf_data_handler() 3133 port->main_app_port = port; in nxt_router_app_prefork_ready() 3145 &app->name, port->pid, port->id); in nxt_router_app_prefork_ready() 3625 engine->port = port; in nxt_router_thread_start() 4021 port = engine->port; in nxt_router_thread_exit_handler() 4514 port->main_app_port = port; in nxt_router_app_port_ready() 4703 port->pid, port->id, in nxt_router_app_port_release() 4820 port->pid, port->id); in nxt_router_app_port_close() 4831 &app->name, port->pid, port->id, in nxt_router_app_port_close() 4931 &app->name, port->pid, port->id); in nxt_router_adjust_idle_timer() [all …]
|
H A D | nxt_unit.c | 1526 port = &port_impl->port; in nxt_unit_request_check_response_port() 1536 port->id.pid, port->id.id); in nxt_unit_request_check_response_port() 5404 port->in_fd, port->out_fd); in nxt_unit_port_release() 5450 port->id.pid, port->id.id, in nxt_unit_add_port() 5529 port->id.pid, port->id.id, in nxt_unit_add_port() 5530 port->in_fd, port->out_fd, queue); in nxt_unit_add_port() 5546 port->id.pid, port->id.id); in nxt_unit_add_port() 5551 new_port->port = *port; in nxt_unit_add_port() 5556 port->id.pid, port->id.id); in nxt_unit_add_port() 5690 port->in_fd, port->out_fd, port->data); in nxt_unit_remove_port_unsafe() [all …]
|
H A D | nxt_main_process.c | 418 nxt_port_t *port; in nxt_main_new_port_handler() local 422 port = msg->u.new_port; in nxt_main_new_port_handler() 424 if (port != NULL in nxt_main_new_port_handler() 431 port->queue = mem; in nxt_main_new_port_handler() 629 nxt_port_t *port; in nxt_main_process_created_handler() local 641 process = port->process; in nxt_main_process_created_handler() 699 nxt_port_t *port; in nxt_main_process_whoami_handler() local 736 port->pair[0] = -1; in nxt_main_process_whoami_handler() 780 nxt_port_t *port; in nxt_main_process_port_create() local 789 process = port->process; in nxt_main_process_port_create() [all …]
|
H A D | nxt_test_build.c | 66 port_associate(int port, int source, uintptr_t object, int events, void *user) in port_associate() argument 73 port_dissociate(int port, int source, uintptr_t object) in port_dissociate() argument 80 port_send(int port, int events, void *user) in port_send() argument 86 int port_getn(int port, port_event_t list[], uint_t max, uint_t *nget, in port_getn() argument
|
H A D | nxt_eventport_engine.c | 135 int port; in nxt_eventport_free() local 137 port = engine->u.eventport.fd; in nxt_eventport_free() 141 if (port != -1 && close(port) != 0) { in nxt_eventport_free() 143 port, nxt_errno); in nxt_eventport_free() 299 int ret, port; in nxt_eventport_commit_changes() local 304 port = engine->u.eventport.fd; in nxt_eventport_commit_changes() 307 port, engine->u.eventport.nchanges); in nxt_eventport_commit_changes() 321 ret = port_associate(port, PORT_SOURCE_FD, in nxt_eventport_commit_changes() 438 int port; in nxt_eventport_signal() local 440 port = engine->u.eventport.fd; in nxt_eventport_signal() [all …]
|
H A D | nxt_sockaddr.c | 233 uint32_t port; in nxt_sockaddr_text() local 255 port = sa->u.sockaddr_in.sin_port; in nxt_sockaddr_text() 328 uint32_t port; in nxt_sockaddr_port_number() local 352 return ntohs((uint16_t) port); in nxt_sockaddr_port_number() 649 nxt_int_t ret, port; in nxt_sockaddr_inet6_parse() local 670 port = 0; in nxt_sockaddr_inet6_parse() 683 if (port < 1 || port > 65535) { in nxt_sockaddr_inet6_parse() 722 nxt_int_t port; in nxt_sockaddr_inet_parse() local 745 port = 0; in nxt_sockaddr_inet_parse() 751 port = nxt_int_parse(p, length); in nxt_sockaddr_inet_parse() [all …]
|
H A D | nxt_port_hash.h | 14 nxt_int_t nxt_port_hash_add(nxt_lvlhsh_t *port_hash, nxt_port_t *port); 16 nxt_int_t nxt_port_hash_remove(nxt_lvlhsh_t *port_hash, nxt_port_t *port);
|
H A D | nxt_process.c | 185 nxt_port_t *port; in nxt_process_start() local 237 nxt_port_read_close(port); in nxt_process_start() 251 nxt_port_close(task, port); in nxt_process_start() 256 nxt_port_use(task, port, -1); in nxt_process_start() 712 nxt_port_t *port; in nxt_process_do_start() local 742 nxt_port_write_close(port); in nxt_process_do_start() 816 nxt_port_t *port; in nxt_process_whoami_ok() local 835 port->pid = pid; in nxt_process_whoami_ok() 1223 port->process = process; in nxt_process_port_add() 1241 nxt_port_t *port; in nxt_process_close_ports() local [all …]
|
/unit/test/ |
H A D | test_tls_tickets.py | 49 def connect(ctx=None, session=None, port=8080): argument 75 def set_tickets(tickets=True, port=8080): argument 125 set_tickets(TICKET2, port=8081) 156 set_tickets(TICKET, port=8081) 157 set_tickets(TICKET2, port=8082) 160 _, _, reused = connect(ctx, sess, port=8081) 162 _, _, reused = connect(ctx, sess, port=8082) 165 sess, ctx, _ = connect(port=8081) 169 sess, ctx, _ = connect(port=8082) 181 _, _, reused = connect(ctx, sess, port=8082) [all …]
|
H A D | test_client_ip.py | 42 (addr, port) = address[sock_type] 47 port=port, 55 assert client.get(port=8081)['body'] == '127.0.0.1', 'ipv4 default' 57 client.get(sock_type='ipv6', port=8082)['body'] == '::1' 65 assert client.get(port=8081)['body'] == '127.0.0.1', 'ipv4 default 2' 67 client.get(sock_type='ipv6', port=8082)['body'] == '::1'
|
H A D | test_routing.py | 1582 port = sock.getsockname()[1] 1583 return (sock, port) 1585 sock, port = sock_port() 1592 sock, port = sock_port() 1599 sock, port = sock_port() 1606 sock, port = sock_port() 1659 return client.get(sock_type='ipv6', port=8081) 1770 return client.get(sock_type='ipv6', port=8081) 1820 assert client.get(port=8081)['status'] == 404, '1 ipv4' 1824 assert client.get(port=8081)['status'] == 404, '0 ipv4' [all …]
|
H A D | test_unix_abstract.py | 51 (addr, port) = address[sock_type] 56 port=port,
|
H A D | test_upstreams_rr.py | 51 def get_resps(req=100, port=8080): argument 55 status = client.get(port=port)['status'] 68 def get_resps_sc(req=100, port=8080): argument 82 resp = client.http(to_send, raw_resp=True, raw=True, port=port) 225 resps = get_resps_sc(req=30, port=8090) 237 resps = get_resps_sc(req=30, port=8090) 252 r_two = sum_resps(r_two, get_resps(req=10, port=8090))
|
H A D | test_status.py | 63 assert client.get(port=8081)['status'] == 200 72 assert client.get(port=8082)['status'] == 503 88 sock = client.get(port=8081, no_recv=True) 139 port=8081,
|
/unit/go/ |
H A D | nxt_cgo_lib.c | 13 static ssize_t nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, 15 static ssize_t nxt_cgo_port_recv(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, 51 nxt_cgo_port_send(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port, in nxt_cgo_port_send() argument 54 return nxt_go_port_send(port->id.pid, port->id.id, 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() argument 63 return nxt_go_port_recv(port->id.pid, port->id.id, in nxt_cgo_port_recv()
|
H A D | port.go | 26 type port struct { struct 34 m map[port_key]*port 39 func find_port(key port_key) *port { 47 func add_port(p *port) { argument 51 port_registry_.m = make(map[port_key]*port) 63 func (p *port) Close() { argument 99 new_port := &port{
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 28 nxt_unit_port_t *port); 35 uint16_t port); 37 uint8_t len, uint16_t port); 44 nxt_unit_port_t *port); 420 if (port == NULL || port->in_fd == -1) { in nxt_py_asgi_remove_reader() 426 nxt_unit_debug(ctx, "asgi_remove_reader %d %p", port->in_fd, port); in nxt_py_asgi_remove_reader() 1006 if (port->in_fd == -1) { in nxt_py_asgi_add_port() 1019 nxt_unit_debug(ctx, "asgi_add_port %d %p %p", port->in_fd, ctx, port); in nxt_py_asgi_add_port() 1032 nxt_unit_debug(ctx, "asgi_add_reader %d %p %p", port->in_fd, ctx, port); in nxt_py_asgi_add_reader() 1091 nxt_unit_port_t *port) in nxt_py_asgi_remove_port() argument [all …]
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | WsHandshakeRequest.java | 151 int port = req.getServerPort(); in buildRequestUri() local 152 if (port < 0) { in buildRequestUri() 154 port = 80; in buildRequestUri() 170 if ((scheme.equals("http") && (port != 80)) in buildRequestUri() 171 || (scheme.equals("https") && (port != 443))) { in buildRequestUri() 173 uri.append(port); in buildRequestUri()
|