MAJOR: server: postpone address resolution
Server addresses are not resolved anymore upon the first pass so that we
don't fail if an address cannot be resolved by the libc. Instead they are
processed all at once after the configuration is fully loaded, by the new
function srv_init_addr(). This function only acts on the server's address
if this address uses an FQDN, which appears in server->hostname.
For now the function does two things, to followup with HAProxy's historical
default behavior:
1. apply server IP address found in server-state file if runtime DNS
resolution is enabled for this server
2. use the DNS resolver provided by the libc
If none of the 2 options above can find an IP address, then an error is
returned.
All of this will be needed to support the new server parameter "init-addr".
For now, the biggest user-visible change is that all server resolution errors
are dumped at once instead of causing a startup failure one by one.
diff --git a/src/haproxy.c b/src/haproxy.c
index 896d116..4806c56 100644
--- a/src/haproxy.c
+++ b/src/haproxy.c
@@ -958,6 +958,13 @@
for (px = proxy; px; px = px->next)
srv_compute_all_admin_states(px);
+ /* Apply servers' configured address */
+ err_code |= srv_init_addr();
+ if (err_code & (ERR_ABORT|ERR_FATAL)) {
+ Alert("Failed to initialize server(s) addr.\n");
+ exit(1);
+ }
+
if (global.mode & MODE_CHECK) {
struct peers *pr;
struct proxy *px;
diff --git a/src/server.c b/src/server.c
index f38ee8d..11add3c 100644
--- a/src/server.c
+++ b/src/server.c
@@ -34,6 +34,7 @@
#include <proto/dns.h>
static void srv_update_state(struct server *srv, int version, char **params);
+static int srv_apply_lastaddr(struct server *srv, int *err_code);
/* List head of all known server keywords */
static struct srv_kw_list srv_keywords = {
@@ -973,7 +974,7 @@
* - IP:+N => port=+N, relative
* - IP:-N => port=-N, relative
*/
- sk = str2sa_range(args[2], &port1, &port2, &errmsg, NULL, &fqdn, 1);
+ sk = str2sa_range(args[2], &port1, &port2, &errmsg, NULL, &fqdn, 0);
if (!sk) {
Alert("parsing [%s:%d] : '%s %s' : %s\n", file, linenum, args[0], args[1], errmsg);
err_code |= ERR_ALERT | ERR_FATAL;
@@ -2257,23 +2258,9 @@
}
server_recalc_eweight(srv);
- /* update server IP only if DNS resolution is used on the server */
+ /* load server IP only if DNS resolution is used on the server */
if (srv->resolution) {
- struct sockaddr_storage addr;
-
- memset(&addr, 0, sizeof(struct sockaddr_storage));
-
- if (str2ip2(params[0], &addr, AF_UNSPEC)) {
- int port;
-
- /* save the port, applies the new IP then reconfigure the port */
- port = get_host_port(&srv->addr);
- srv->addr.ss_family = addr.ss_family;
- str2ip2(params[0], &srv->addr, srv->addr.ss_family);
- set_host_port(&srv->addr, port);
- }
- else
- chunk_appendf(msg, ", can't parse IP: %s", params[0]);
+ srv->lastaddr = strdup(params[0]);
}
break;
default:
@@ -3089,6 +3076,84 @@
return 1;
}
+/* Sets the server's address (srv->addr) from srv->hostname using the libc's
+ * resolver. This is suited for initial address configuration. Returns 0 on
+ * success otherwise a non-zero error code. In case of error, *err_code, if
+ * not NULL, is filled up.
+ */
+int srv_set_addr_via_libc(struct server *srv, int *err_code)
+{
+ if (str2ip2(srv->hostname, &srv->addr, 1) == NULL) {
+ Alert("parsing [%s:%d] : 'server %s' : invalid address: '%s'\n",
+ srv->conf.file, srv->conf.line, srv->id, srv->hostname);
+ if (err_code)
+ *err_code |= ERR_ALERT | ERR_FATAL;
+ return 1;
+ }
+ return 0;
+}
+
+/* Sets the server's address (srv->addr) from srv->lastaddr which was filled
+ * from the state file. This is suited for initial address configuration.
+ * Returns 0 on success otherwise a non-zero error code. In case of error,
+ * *err_code, if not NULL, is filled up.
+ */
+static int srv_apply_lastaddr(struct server *srv, int *err_code)
+{
+ if (!str2ip2(srv->lastaddr, &srv->addr, 0)) {
+ if (err_code)
+ *err_code |= ERR_WARN;
+ return 1;
+ }
+ return 0;
+}
+
+/*
+ * This function parses all backends and all servers within each backend
+ * and performs servers' addr resolution based on information provided by:
+ * - configuration file
+ * - server-state file (states provided by an 'old' haproxy process)
+ *
+ * Returns 0 if no error, otherwise, a combination of ERR_ flags.
+ */
+int srv_init_addr(void)
+{
+ struct proxy *curproxy;
+ int return_code = 0;
+
+ curproxy = proxy;
+ while (curproxy) {
+ struct server *srv;
+ int err_code = 0;
+
+ /* servers are in backend only */
+ if (!(curproxy->cap & PR_CAP_BE))
+ goto srv_init_addr_next;
+
+ for (srv = curproxy->srv; srv; srv = srv->next) {
+ err_code = 0;
+
+ if (srv->lastaddr) {
+ if (srv_apply_lastaddr(srv, &err_code) == 0)
+ continue;
+ return_code |= err_code;
+ }
+
+ if (srv->hostname) {
+ if (srv_set_addr_via_libc(srv, &err_code) == 0)
+ continue;
+ return_code = err_code;
+ }
+ }
+
+ srv_init_addr_next:
+ curproxy = curproxy->next;
+ }
+
+ return return_code;
+}
+
+
/*
* Local variables:
* c-indent-level: 8