Home
last modified time | relevance | path

Searched refs:port (Results 1 – 25 of 56) sorted by relevance

123

/unit/src/
H A Dnxt_port.c26 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 Dnxt_port_socket.c130 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 Dnxt_port_rpc.c150 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 Dnxt_port_hash.c20 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 Dnxt_http_route_addr.c58 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 Dnxt_port_rpc.h16 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 Dnxt_port.h211 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 Dnxt_router.c813 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 Dnxt_unit.c1526 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 Dnxt_main_process.c418 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 Dnxt_test_build.c66 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 Dnxt_eventport_engine.c135 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 Dnxt_sockaddr.c233 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 Dnxt_port_hash.h14 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 Dnxt_process.c185 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 Dtest_tls_tickets.py49 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 Dtest_client_ip.py42 (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 Dtest_routing.py1582 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 Dtest_unix_abstract.py51 (addr, port) = address[sock_type]
56 port=port,
H A Dtest_upstreams_rr.py51 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 Dtest_status.py63 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 Dnxt_cgo_lib.c13 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 Dport.go26 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 Dnxt_python_asgi.c28 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 DWsHandshakeRequest.java151 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()

123