aboutsummaryrefslogtreecommitdiff
path: root/src/core
diff options
context:
space:
mode:
authorRuslan Ermilov <ru@nginx.com>2016-05-23 16:37:20 +0300
committerRuslan Ermilov <ru@nginx.com>2016-05-23 16:37:20 +0300
commitfd064d3b88e59ee71aec508687403539b01d643c (patch)
tree8cec8e57171f8484d0e720b51b331e716d843a1d /src/core
parentd650688ba5f966bd13b5449b52192b19a4715ee4 (diff)
downloadnginx-fd064d3b88e59ee71aec508687403539b01d643c.tar.gz
nginx-fd064d3b88e59ee71aec508687403539b01d643c.zip
Introduced the ngx_sockaddr_t type.
It's properly aligned and can hold any supported sockaddr.
Diffstat (limited to 'src/core')
-rw-r--r--src/core/ngx_connection.c10
-rw-r--r--src/core/ngx_inet.c6
-rw-r--r--src/core/ngx_inet.h29
-rw-r--r--src/core/ngx_resolver.c42
4 files changed, 45 insertions, 42 deletions
diff --git a/src/core/ngx_connection.c b/src/core/ngx_connection.c
index 19ec4ab75..16ba63003 100644
--- a/src/core/ngx_connection.c
+++ b/src/core/ngx_connection.c
@@ -151,12 +151,12 @@ ngx_set_inherited_sockets(ngx_cycle_t *cycle)
ls = cycle->listening.elts;
for (i = 0; i < cycle->listening.nelts; i++) {
- ls[i].sockaddr = ngx_palloc(cycle->pool, NGX_SOCKADDRLEN);
+ ls[i].sockaddr = ngx_palloc(cycle->pool, sizeof(ngx_sockaddr_t));
if (ls[i].sockaddr == NULL) {
return NGX_ERROR;
}
- ls[i].socklen = NGX_SOCKADDRLEN;
+ ls[i].socklen = sizeof(ngx_sockaddr_t);
if (getsockname(ls[i].fd, ls[i].sockaddr, &ls[i].socklen) == -1) {
ngx_log_error(NGX_LOG_CRIT, cycle->log, ngx_socket_errno,
"getsockname() of the inherited "
@@ -1278,7 +1278,7 @@ ngx_connection_local_sockaddr(ngx_connection_t *c, ngx_str_t *s,
{
socklen_t len;
ngx_uint_t addr;
- u_char sa[NGX_SOCKADDRLEN];
+ ngx_sockaddr_t sa;
struct sockaddr_in *sin;
#if (NGX_HAVE_INET6)
ngx_uint_t i;
@@ -1316,9 +1316,9 @@ ngx_connection_local_sockaddr(ngx_connection_t *c, ngx_str_t *s,
if (addr == 0) {
- len = NGX_SOCKADDRLEN;
+ len = sizeof(ngx_sockaddr_t);
- if (getsockname(c->fd, (struct sockaddr *) &sa, &len) == -1) {
+ if (getsockname(c->fd, &sa.sockaddr, &len) == -1) {
ngx_connection_error(c, ngx_socket_errno, "getsockname() failed");
return NGX_ERROR;
}
diff --git a/src/core/ngx_inet.c b/src/core/ngx_inet.c
index 2ed4a1497..12bf9f81a 100644
--- a/src/core/ngx_inet.c
+++ b/src/core/ngx_inet.c
@@ -763,7 +763,7 @@ ngx_parse_inet_url(ngx_pool_t *pool, ngx_url_t *u)
return NGX_ERROR;
}
- ngx_memcpy(sin, u->sockaddr, sizeof(struct sockaddr_in));
+ ngx_memcpy(sin, &u->sockaddr, sizeof(struct sockaddr_in));
u->addrs[0].sockaddr = (struct sockaddr *) sin;
u->addrs[0].socklen = sizeof(struct sockaddr_in);
@@ -790,7 +790,7 @@ ngx_parse_inet_url(ngx_pool_t *pool, ngx_url_t *u)
u->family = u->addrs[0].sockaddr->sa_family;
u->socklen = u->addrs[0].socklen;
- ngx_memcpy(u->sockaddr, u->addrs[0].sockaddr, u->addrs[0].socklen);
+ ngx_memcpy(&u->sockaddr, u->addrs[0].sockaddr, u->addrs[0].socklen);
switch (u->family) {
@@ -920,7 +920,7 @@ ngx_parse_inet6_url(ngx_pool_t *pool, ngx_url_t *u)
return NGX_ERROR;
}
- ngx_memcpy(sin6, u->sockaddr, sizeof(struct sockaddr_in6));
+ ngx_memcpy(sin6, &u->sockaddr, sizeof(struct sockaddr_in6));
u->addrs[0].sockaddr = (struct sockaddr *) sin6;
u->addrs[0].socklen = sizeof(struct sockaddr_in6);
diff --git a/src/core/ngx_inet.h b/src/core/ngx_inet.h
index 2f76f79af..422aabec4 100644
--- a/src/core/ngx_inet.h
+++ b/src/core/ngx_inet.h
@@ -13,14 +13,6 @@
#include <ngx_core.h>
-/*
- * TODO: autoconfigure NGX_SOCKADDRLEN and NGX_SOCKADDR_STRLEN as
- * sizeof(struct sockaddr_storage)
- * sizeof(struct sockaddr_un)
- * sizeof(struct sockaddr_in6)
- * sizeof(struct sockaddr_in)
- */
-
#define NGX_INET_ADDRSTRLEN (sizeof("255.255.255.255") - 1)
#define NGX_INET6_ADDRSTRLEN \
(sizeof("ffff:ffff:ffff:ffff:ffff:ffff:255.255.255.255") - 1)
@@ -29,15 +21,26 @@
#if (NGX_HAVE_UNIX_DOMAIN)
#define NGX_SOCKADDR_STRLEN (sizeof("unix:") - 1 + NGX_UNIX_ADDRSTRLEN)
-#else
+#elif (NGX_HAVE_INET6)
#define NGX_SOCKADDR_STRLEN (NGX_INET6_ADDRSTRLEN + sizeof("[]:65535") - 1)
+#else
+#define NGX_SOCKADDR_STRLEN (NGX_INET_ADDRSTRLEN + sizeof(":65535") - 1)
#endif
+/* compatibility */
+#define NGX_SOCKADDRLEN sizeof(ngx_sockaddr_t)
+
+
+typedef union {
+ struct sockaddr sockaddr;
+ struct sockaddr_in sockaddr_in;
+#if (NGX_HAVE_INET6)
+ struct sockaddr_in6 sockaddr_in6;
+#endif
#if (NGX_HAVE_UNIX_DOMAIN)
-#define NGX_SOCKADDRLEN sizeof(struct sockaddr_un)
-#else
-#define NGX_SOCKADDRLEN 512
+ struct sockaddr_un sockaddr_un;
#endif
+} ngx_sockaddr_t;
typedef struct {
@@ -92,7 +95,7 @@ typedef struct {
unsigned wildcard:1;
socklen_t socklen;
- u_char sockaddr[NGX_SOCKADDRLEN];
+ ngx_sockaddr_t sockaddr;
ngx_addr_t *addrs;
ngx_uint_t naddrs;
diff --git a/src/core/ngx_resolver.c b/src/core/ngx_resolver.c
index e00fe229a..e06c2f8cf 100644
--- a/src/core/ngx_resolver.c
+++ b/src/core/ngx_resolver.c
@@ -2992,15 +2992,15 @@ failed:
static void
ngx_resolver_srv_names_handler(ngx_resolver_ctx_t *cctx)
{
- ngx_uint_t i;
- u_char (*sockaddr)[NGX_SOCKADDRLEN];
- ngx_addr_t *addrs;
- ngx_resolver_t *r;
- struct sockaddr_in *sin;
- ngx_resolver_ctx_t *ctx;
- ngx_resolver_srv_name_t *srv;
+ ngx_uint_t i;
+ ngx_addr_t *addrs;
+ ngx_resolver_t *r;
+ ngx_sockaddr_t *sockaddr;
+ struct sockaddr_in *sin;
+ ngx_resolver_ctx_t *ctx;
+ ngx_resolver_srv_name_t *srv;
#if (NGX_HAVE_INET6)
- struct sockaddr_in6 *sin6;
+ struct sockaddr_in6 *sin6;
#endif
r = cctx->resolver;
@@ -3026,7 +3026,7 @@ ngx_resolver_srv_names_handler(ngx_resolver_ctx_t *cctx)
return;
}
- sockaddr = ngx_resolver_alloc(r, cctx->naddrs * NGX_SOCKADDRLEN);
+ sockaddr = ngx_resolver_alloc(r, cctx->naddrs * sizeof(ngx_sockaddr_t));
if (sockaddr == NULL) {
ngx_resolver_free(r, addrs);
ngx_resolve_name_done(cctx);
@@ -3039,10 +3039,10 @@ ngx_resolver_srv_names_handler(ngx_resolver_ctx_t *cctx)
}
for (i = 0; i < cctx->naddrs; i++) {
- addrs[i].sockaddr = (struct sockaddr *) sockaddr[i];
+ addrs[i].sockaddr = &sockaddr[i].sockaddr;
addrs[i].socklen = cctx->addrs[i].socklen;
- ngx_memcpy(sockaddr[i], cctx->addrs[i].sockaddr,
+ ngx_memcpy(&sockaddr[i], cctx->addrs[i].sockaddr,
addrs[i].socklen);
switch (addrs[i].sockaddr->sa_family) {
@@ -4161,14 +4161,14 @@ static ngx_resolver_addr_t *
ngx_resolver_export(ngx_resolver_t *r, ngx_resolver_node_t *rn,
ngx_uint_t rotate)
{
- ngx_uint_t d, i, j, n;
- u_char (*sockaddr)[NGX_SOCKADDRLEN];
- in_addr_t *addr;
- struct sockaddr_in *sin;
- ngx_resolver_addr_t *dst;
+ ngx_uint_t d, i, j, n;
+ in_addr_t *addr;
+ ngx_sockaddr_t *sockaddr;
+ struct sockaddr_in *sin;
+ ngx_resolver_addr_t *dst;
#if (NGX_HAVE_INET6)
- struct in6_addr *addr6;
- struct sockaddr_in6 *sin6;
+ struct in6_addr *addr6;
+ struct sockaddr_in6 *sin6;
#endif
n = rn->naddrs;
@@ -4181,7 +4181,7 @@ ngx_resolver_export(ngx_resolver_t *r, ngx_resolver_node_t *rn,
return NULL;
}
- sockaddr = ngx_resolver_calloc(r, n * NGX_SOCKADDRLEN);
+ sockaddr = ngx_resolver_calloc(r, n * sizeof(ngx_sockaddr_t));
if (sockaddr == NULL) {
ngx_resolver_free(r, dst);
return NULL;
@@ -4196,7 +4196,7 @@ ngx_resolver_export(ngx_resolver_t *r, ngx_resolver_node_t *rn,
addr = (rn->naddrs == 1) ? &rn->u.addr : rn->u.addrs;
do {
- sin = (struct sockaddr_in *) sockaddr[d];
+ sin = &sockaddr[d].sockaddr_in;
sin->sin_family = AF_INET;
sin->sin_addr.s_addr = addr[j++];
dst[d].sockaddr = (struct sockaddr *) sin;
@@ -4219,7 +4219,7 @@ ngx_resolver_export(ngx_resolver_t *r, ngx_resolver_node_t *rn,
addr6 = (rn->naddrs6 == 1) ? &rn->u6.addr6 : rn->u6.addrs6;
do {
- sin6 = (struct sockaddr_in6 *) sockaddr[d];
+ sin6 = &sockaddr[d].sockaddr_in6;
sin6->sin6_family = AF_INET6;
ngx_memcpy(sin6->sin6_addr.s6_addr, addr6[j++].s6_addr, 16);
dst[d].sockaddr = (struct sockaddr *) sin6;