/unit/src/ |
H A D | nxt_sockaddr.c | 48 return sa; in nxt_sockaddr_cache_alloc() 59 nxt_event_engine_mem_free(engine, sa->cache_hint, sa, 0); in nxt_sockaddr_cache_free() 86 return sa; in nxt_sockaddr_alloc() 161 return sa; in nxt_sockaddr_create() 253 sa->port_start += sa->address_length + 1; in nxt_sockaddr_text() 270 sa->port_start += sa->address_length + 3; in nxt_sockaddr_text() 308 sa->port_start += sa->address_length; in nxt_sockaddr_text() 539 return sa; in nxt_sockaddr_parse() 567 return sa; in nxt_sockaddr_parse_optport() 630 return sa; in nxt_sockaddr_unix_parse() [all …]
|
H A D | nxt_sockaddr.h | 76 NXT_EXPORT void nxt_sockaddr_text(nxt_sockaddr_t *sa); 79 NXT_EXPORT uint32_t nxt_sockaddr_port_number(nxt_sockaddr_t *sa); 99 #define nxt_sockaddr_size(sa) \ argument 100 (offsetof(nxt_sockaddr_t, u) + sa->socklen + sa->length) 101 #define nxt_sockaddr_start(sa) nxt_pointer_to(sa, (sa)->start) argument 102 #define nxt_sockaddr_address(sa) nxt_pointer_to(sa, (sa)->address_start) argument 103 #define nxt_sockaddr_port(sa) nxt_pointer_to(sa, (sa)->port_start) argument 104 #define nxt_sockaddr_port_length(sa) \ argument 105 (((sa)->start + (sa)->length) - (sa)->port_start)
|
H A D | nxt_listen_socket.c | 37 nxt_sockaddr_t *sa; in nxt_listen_socket_create() local 48 sa = ls->sockaddr; in nxt_listen_socket_create() 54 log.ctx = sa; in nxt_listen_socket_create() 99 orig_sa = sa; in nxt_listen_socket_create() 101 sa = nxt_sockaddr_alloc(mp, sa->socklen + 4, sa->length + 4); in nxt_listen_socket_create() 102 if (sa == NULL) { in nxt_listen_socket_create() 106 sa->type = SOCK_STREAM; in nxt_listen_socket_create() 113 nxt_sockaddr_text(sa); in nxt_listen_socket_create() 388 nxt_sockaddr_t *sa; in nxt_listen_socket_log_handler() local 390 sa = ctx; in nxt_listen_socket_log_handler() [all …]
|
H A D | nxt_socket.c | 58 if (sa->u.sockaddr.sa_family == AF_UNIX) { in nxt_socket_defer_accept() 175 nxt_socket_bind(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_bind() argument 177 nxt_debug(task, "bind(%d, %*s)", s, (size_t) sa->length, in nxt_socket_bind() 178 nxt_sockaddr_start(sa)); in nxt_socket_bind() 180 if (nxt_fast_path(bind(s, &sa->u.sockaddr, sa->socklen) == 0)) { in nxt_socket_bind() 185 s, (size_t) sa->length, nxt_sockaddr_start(sa), nxt_socket_errno); in nxt_socket_bind() 192 nxt_socket_connect(nxt_task_t *task, nxt_socket_t s, nxt_sockaddr_t *sa) in nxt_socket_connect() argument 199 s, (size_t) sa->length, nxt_sockaddr_start(sa)); in nxt_socket_connect() 201 if (connect(s, &sa->u.sockaddr, sa->socklen) == 0) { in nxt_socket_connect() 211 s, (size_t) sa->length, nxt_sockaddr_start(sa)); in nxt_socket_connect() [all …]
|
H A D | nxt_conn.c | 137 nxt_sockaddr_t *sa; in nxt_conn_local_addr() local 161 sa = nxt_mp_get(c->mem_pool, size); in nxt_conn_local_addr() 162 if (nxt_slow_path(sa == NULL)) { in nxt_conn_local_addr() 166 sa->socklen = socklen; in nxt_conn_local_addr() 167 sa->length = length; in nxt_conn_local_addr() 169 ret = getsockname(c->socket.fd, &sa->u.sockaddr, &socklen); in nxt_conn_local_addr() 175 c->local = sa; in nxt_conn_local_addr() 177 nxt_sockaddr_text(sa); in nxt_conn_local_addr() 184 return sa; in nxt_conn_local_addr()
|
H A D | nxt_signal.c | 74 struct sigaction sa; in nxt_signal_action() local 76 nxt_memzero(&sa, sizeof(struct sigaction)); in nxt_signal_action() 77 sigemptyset(&sa.sa_mask); in nxt_signal_action() 78 sa.sa_handler = handler; in nxt_signal_action() 80 if (sigaction(signo, &sa, NULL) == 0) { in nxt_signal_action()
|
H A D | nxt_main_process.c | 1116 nxt_sockaddr_t *sa; in nxt_main_port_socket_handler() local 1145 (size_t) sa->length, nxt_sockaddr_start(sa)); in nxt_main_port_socket_handler() 1151 (size_t) sa->length, nxt_sockaddr_start(sa), ls.socket); in nxt_main_port_socket_handler() 1187 s = socket(sa->u.sockaddr.sa_family, sa->type, 0); in nxt_main_listening_socket() 1202 (size_t) sa->length, nxt_sockaddr_start(sa), err); in nxt_main_listening_socket() 1210 (size_t) sa->length, nxt_sockaddr_start(sa), in nxt_main_listening_socket() 1222 (size_t) sa->length, nxt_sockaddr_start(sa), in nxt_main_listening_socket() 1230 if (bind(s, &sa->u.sockaddr, sa->socklen) != 0) { in nxt_main_listening_socket() 1268 (size_t) sa->length, nxt_sockaddr_start(sa), err); in nxt_main_listening_socket() 1317 nxt_sockaddr_t *sa; in nxt_main_port_socket_unlink_handler() local [all …]
|
H A D | nxt_http_proxy.c | 57 nxt_sockaddr_t *sa; in nxt_http_proxy_init() local 61 sa = NULL; in nxt_http_proxy_init() 68 sa = nxt_sockaddr_parse(mp, &name); in nxt_http_proxy_init() 69 if (nxt_slow_path(sa == NULL)) { in nxt_http_proxy_init() 73 sa->type = SOCK_STREAM; in nxt_http_proxy_init() 76 if (sa != NULL) { in nxt_http_proxy_init() 82 up->name.length = sa->length; in nxt_http_proxy_init() 83 up->name.start = nxt_sockaddr_start(sa); in nxt_http_proxy_init() 91 proxy->sockaddr = sa; in nxt_http_proxy_init()
|
H A D | nxt_socket.h | 97 nxt_sockaddr_t *sa); 103 nxt_sockaddr_t *sa); 105 nxt_sockaddr_t *sa);
|
H A D | nxt_upstream_round_robin.c | 51 nxt_sockaddr_t *sa; in nxt_upstream_round_robin_create() local 97 sa = nxt_sockaddr_parse(mp, &name); in nxt_upstream_round_robin_create() 98 if (nxt_slow_path(sa == NULL)) { in nxt_upstream_round_robin_create() 102 sa->type = SOCK_STREAM; in nxt_upstream_round_robin_create() 104 urr->server[i].sockaddr = sa; in nxt_upstream_round_robin_create()
|
H A D | nxt_http_request.c | 419 nxt_sockaddr_t *sa, *prev_sa; in nxt_http_request_forward_client_ip() local 446 if (nxt_slow_path(sa == NULL)) { in nxt_http_request_forward_client_ip() 455 r->remote = sa; in nxt_http_request_forward_client_ip() 461 r->remote = sa; in nxt_http_request_forward_client_ip() 465 prev_sa = sa; in nxt_http_request_forward_client_ip() 478 nxt_sockaddr_t *sa; in nxt_http_request_client_ip_sockaddr() local 483 sa = nxt_sockaddr_parse_optport(r->mem_pool, &addr); in nxt_http_request_client_ip_sockaddr() 484 if (nxt_slow_path(sa == NULL)) { in nxt_http_request_client_ip_sockaddr() 488 switch (sa->u.sockaddr.sa_family) { in nxt_http_request_client_ip_sockaddr() 490 if (sa->u.sockaddr_in.sin_addr.s_addr == INADDR_ANY) { in nxt_http_request_client_ip_sockaddr() [all …]
|
H A D | nxt_runtime.c | 567 nxt_sockaddr_t *sa; in nxt_runtime_exit() local 570 sa = rt->controller_listen; in nxt_runtime_exit() 581 sa = ls->sockaddr; in nxt_runtime_exit() 777 nxt_sockaddr_t *sa; in nxt_runtime_conf_init() local 929 sa = nxt_sockaddr_parse(rt->mem_pool, &control); in nxt_runtime_conf_init() 930 if (nxt_slow_path(sa == NULL)) { in nxt_runtime_conf_init() 934 sa->type = SOCK_STREAM; in nxt_runtime_conf_init() 936 rt->controller_listen = sa; in nxt_runtime_conf_init() 1250 ls->sockaddr = nxt_sockaddr_create(mp, &sa->u.sockaddr, sa->socklen, in nxt_runtime_listen_socket_add() 1251 sa->length); in nxt_runtime_listen_socket_add() [all …]
|
H A D | nxt_kqueue_engine.c | 566 struct sigaction sa; in nxt_kqueue_add_signal() local 570 nxt_memzero(&sa, sizeof(struct sigaction)); in nxt_kqueue_add_signal() 571 sigemptyset(&sa.sa_mask); in nxt_kqueue_add_signal() 579 sa.sa_handler = (signo == SIGCHLD) ? SIG_DFL : SIG_IGN; in nxt_kqueue_add_signal() 581 if (sigaction(signo, &sa, NULL) != 0) { in nxt_kqueue_add_signal() 935 struct sockaddr *sa; in nxt_kqueue_conn_io_accept() local 947 sa = &c->remote->u.sockaddr; in nxt_kqueue_conn_io_accept() 953 s = accept(lev->socket.fd, sa, &socklen); in nxt_kqueue_conn_io_accept()
|
H A D | nxt_conn_accept.c | 141 struct sockaddr *sa; in nxt_conn_io_accept() local 150 sa = &c->remote->u.sockaddr; in nxt_conn_io_accept() 161 s = accept(lev->socket.fd, sa, &socklen); in nxt_conn_io_accept()
|
H A D | nxt_runtime.h | 132 nxt_sockaddr_t *sa);
|
H A D | nxt_router.c | 2679 nxt_sockaddr_t *sa; in nxt_router_socket_conf() local 2684 if (nxt_slow_path(sa == NULL)) { in nxt_router_socket_conf() 2689 sa->type = SOCK_STREAM; in nxt_router_socket_conf() 2692 (size_t) sa->length, nxt_sockaddr_start(sa)); in nxt_router_socket_conf() 2699 size = nxt_sockaddr_size(sa); in nxt_router_socket_conf() 2713 nxt_memcpy(ls->sockaddr, sa, size); in nxt_router_socket_conf() 2723 switch (sa->u.sockaddr.sa_family) { in nxt_router_socket_conf() 2900 nxt_sockaddr_t *sa; in nxt_router_listen_socket_error() 2936 (size_t) sa->length, nxt_sockaddr_start(sa), in nxt_router_listen_socket_error() 3853 nxt_sockaddr_t *sa; in nxt_router_listen_socket_release() local [all …]
|
H A D | nxt_conf_validation.c | 1704 nxt_sockaddr_t *sa; in nxt_conf_vldt_listener() local 1710 sa = nxt_sockaddr_parse(vldt->pool, &str); in nxt_conf_vldt_listener() 1711 if (nxt_slow_path(sa == NULL)) { in nxt_conf_vldt_listener() 1957 nxt_sockaddr_t *sa; in nxt_conf_vldt_proxy() local 1968 sa = nxt_sockaddr_parse(vldt->pool, &name); in nxt_conf_vldt_proxy() 1969 if (sa != NULL) { in nxt_conf_vldt_proxy() 3291 nxt_sockaddr_t *sa; in nxt_conf_vldt_server() local 3302 sa = nxt_sockaddr_parse(vldt->pool, &str); in nxt_conf_vldt_server() 3303 if (sa == NULL) { in nxt_conf_vldt_server()
|
H A D | nxt_http_route.c | 1745 nxt_sockaddr_t *sa) in nxt_http_route_addr_pattern_match() argument 1760 switch (sa->u.sockaddr.sa_family) { in nxt_http_route_addr_pattern_match() 1770 sin = &sa->u.sockaddr_in; in nxt_http_route_addr_pattern_match() 1816 sin6 = &sa->u.sockaddr_in6; in nxt_http_route_addr_pattern_match() 1880 nxt_http_route_addr_rule_t *addr_rule, nxt_sockaddr_t *sa) in nxt_http_route_addr_rule() argument 1898 matches = nxt_http_route_addr_pattern_match(p, sa); in nxt_http_route_addr_rule()
|
H A D | nxt_epoll_engine.c | 1013 struct sockaddr *sa; in nxt_epoll_conn_io_accept4() local 1022 sa = &c->remote->u.sockaddr; in nxt_epoll_conn_io_accept4() 1028 s = accept4(lev->socket.fd, sa, &socklen, SOCK_NONBLOCK); in nxt_epoll_conn_io_accept4()
|
/unit/auto/ |
H A D | sockets | 40 struct sockaddr sa; 42 sa.sa_len = 0; 43 printf(\"%d\", sa.sa_len);
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsWebSocketContainer.java | 227 SocketAddress sa = null; in connectToServerRecursive() local 235 sa = proxy.address(); in connectToServerRecursive() 236 if (sa instanceof InetSocketAddress) { in connectToServerRecursive() 237 InetSocketAddress inet = (InetSocketAddress) sa; in connectToServerRecursive() 239 sa = new InetSocketAddress(inet.getHostName(), inet.getPort()); in connectToServerRecursive() 259 if (sa == null) { in connectToServerRecursive() 260 sa = new InetSocketAddress(host, port); in connectToServerRecursive() 303 Future<Void> fConnect = socketChannel.connect(sa); in connectToServerRecursive()
|