IntenseWebs/nginx
3
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2025-02-25 18:55:26 -06:00
Code Issues Packages Projects Releases Wiki Activity

Added FreeBSD support for "listen ... reuseport".

Browse Source
This commit is contained in:
Ruslan Ermilov 2018-07-02 13:54:33 +03:00
parent 4bf4650f2f
commit 468e37734c
1 changed files with 54 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
src/core/ngx_connection.c
View File

@ -281,6 +281,22 @@ ngx_set_inherited_sockets(ngx_cycle_t *cycle)
reuseport = 0; reuseport = 0;
olen = sizeof(int); olen = sizeof(int);
#ifdef SO_REUSEPORT_LB
if (getsockopt(ls[i].fd, SOL_SOCKET, SO_REUSEPORT_LB,
(void *) &reuseport, &olen)
== -1)
{
ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno,
"getsockopt(SO_REUSEPORT_LB) %V failed, ignored",
&ls[i].addr_text);
} else {
ls[i].reuseport = reuseport ? 1 : 0;
}
#else
if (getsockopt(ls[i].fd, SOL_SOCKET, SO_REUSEPORT, if (getsockopt(ls[i].fd, SOL_SOCKET, SO_REUSEPORT,
(void *) &reuseport, &olen) (void *) &reuseport, &olen)
== -1) == -1)
@ -292,6 +308,7 @@ ngx_set_inherited_sockets(ngx_cycle_t *cycle)
} else { } else {
ls[i].reuseport = reuseport ? 1 : 0; ls[i].reuseport = reuseport ? 1 : 0;
} }
#endif
#endif #endif
@ -430,6 +447,20 @@ ngx_open_listening_sockets(ngx_cycle_t *cycle)
int reuseport = 1; int reuseport = 1;
#ifdef SO_REUSEPORT_LB
if (setsockopt(ls[i].fd, SOL_SOCKET, SO_REUSEPORT_LB,
(const void *) &reuseport, sizeof(int))
== -1)
{
ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_socket_errno,
"setsockopt(SO_REUSEPORT_LB) %V failed, "
"ignored",
&ls[i].addr_text);
}
#else
if (setsockopt(ls[i].fd, SOL_SOCKET, SO_REUSEPORT, if (setsockopt(ls[i].fd, SOL_SOCKET, SO_REUSEPORT,
(const void *) &reuseport, sizeof(int)) (const void *) &reuseport, sizeof(int))
== -1) == -1)
@ -438,6 +469,7 @@ ngx_open_listening_sockets(ngx_cycle_t *cycle)
"setsockopt(SO_REUSEPORT) %V failed, ignored", "setsockopt(SO_REUSEPORT) %V failed, ignored",
&ls[i].addr_text); &ls[i].addr_text);
} }
#endif
ls[i].add_reuseport = 0; ls[i].add_reuseport = 0;
} }
@ -488,6 +520,27 @@ ngx_open_listening_sockets(ngx_cycle_t *cycle)
reuseport = 1; reuseport = 1;
#ifdef SO_REUSEPORT_LB
if (setsockopt(s, SOL_SOCKET, SO_REUSEPORT_LB,
(const void *) &reuseport, sizeof(int))
== -1)
{
ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
"setsockopt(SO_REUSEPORT_LB) %V failed",
&ls[i].addr_text);
if (ngx_close_socket(s) == -1) {
ngx_log_error(NGX_LOG_EMERG, log, ngx_socket_errno,
ngx_close_socket_n " %V failed",
&ls[i].addr_text);
}
return NGX_ERROR;
}
#else
if (setsockopt(s, SOL_SOCKET, SO_REUSEPORT, if (setsockopt(s, SOL_SOCKET, SO_REUSEPORT,
(const void *) &reuseport, sizeof(int)) (const void *) &reuseport, sizeof(int))
== -1) == -1)
@ -504,6 +557,7 @@ ngx_open_listening_sockets(ngx_cycle_t *cycle)
return NGX_ERROR; return NGX_ERROR;
} }
#endif
} }
#endif #endif