---
Register all peers section keywords with the standard configuration keyword
system so they appear in the -dKall diagnostic output.
Kewords registered:
- peers: section declaration
- peer/server: peer server definitions
- bind/default-bind: listener configuration
- shards: sharding configuration
- table: stick-table definition
- log: logging configuration
- disabled/enabled: section state control
This completes the fix for issue #3221 where peeres section keywords were
missing from the -dKall output. The keywords are now properly registered via
REGISTER_CONFIG_SECTION and cfg_register_keywords, making them visible
alongside keywords from other configuration sections.
---
src/cfgparse-peers.c | 877 ++++++++++++++++++++++++-------------------
1 file changed, 487 insertions(+), 390 deletions(-)
diff --git a/src/cfgparse-peers.c b/src/cfgparse-peers.c
index 2e03f8531..d1e7a9db4 100644
--- a/src/cfgparse-peers.c
+++ b/src/cfgparse-peers.c
@@ -31,6 +31,12 @@
#include <haproxy/stick_table.h>
#include <haproxy/tools.h>
+/* Static variables that persist across calls within a peers section */
+static struct peers *curpeers = NULL;
+static struct sockaddr_storage *bind_addr = NULL;
+static int nb_shards = 0;
+static int bind_line, peer_line;
+
/* Allocate and initialize the frontend of a "peers" section found in
* file <file> at line <linenum> with <id> as ID.
* Return 0 if succeeded, -1 if not.
@@ -134,476 +140,567 @@ static struct peer *cfg_peers_add_peer(struct peers
*peers,
return p;
}
-/*
- * Parse a line in a <peers> section.
- * Returns the error code, 0 if OK, or any combination of :
- * - ERR_ABORT: must abort ASAP
- * - ERR_FATAL: we can continue parsing but not start the service
- * - ERR_WARN: a warning has been emitted
- * - ERR_ALERT: an alert has been emitted
- * Only the two first ones can stop processing, the two others are just
- * indicators.
- */
-int cfg_parse_peers(const char *file, int linenum, char **args, int kwm)
+/* Parse "bind" or "default-bind" keyword */
+static int cfg_parse_peers_bind(char **args, int section_type, struct proxy
*curpx,
+ const struct proxy *defpx, const char *file,
int linenum,
+ char **err)
{
- static struct peers *curpeers = NULL;
- static struct sockaddr_storage *bind_addr = NULL;
- static int nb_shards = 0;
struct peer *newpeer = NULL;
- const char *err;
struct bind_conf *bind_conf;
+ int cur_arg;
int err_code = 0;
char *errmsg = NULL;
- static int bind_line, peer_line;
+ int ret;
- if (strcmp(args[0], "bind") == 0 || strcmp(args[0], "default-bind") ==
0) {
- int cur_arg;
- struct bind_conf *bind_conf;
- int ret;
+ cur_arg = 1;
- cur_arg = 1;
+ if (init_peers_frontend(file, linenum, NULL, curpeers) != 0) {
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
+ }
- if (init_peers_frontend(file, linenum, NULL, curpeers) != 0) {
- err_code |= ERR_ALERT | ERR_ABORT;
+ bind_conf = bind_conf_uniq_alloc(curpeers->peers_fe, file, linenum,
+ args[1], xprt_get(XPRT_RAW));
+ if (!bind_conf) {
+ ha_alert("parsing [%s:%d] : '%s %s' : cannot allocate
memory.\n", file, linenum, args[0], args[1]);
+ err_code |= ERR_FATAL;
+ goto out;
+ }
+
+ bind_conf->maxaccept = 1;
+ bind_conf->accept = session_accept_fd;
+ bind_conf->options |= BC_O_UNLIMITED; /* don't make the peers subject
to global limits */
+
+ if (*args[0] == 'b') {
+ struct listener *l;
+
+ if (peer_line) {
+ ha_alert("parsing [%s:%d] : mixing \"peer\" and
\"bind\" line is forbidden\n", file, linenum);
+ err_code |= ERR_ALERT | ERR_FATAL;
goto out;
}
- bind_conf = bind_conf_uniq_alloc(curpeers->peers_fe, file,
linenum,
- args[1], xprt_get(XPRT_RAW));
- if (!bind_conf) {
- ha_alert("parsing [%s:%d] : '%s %s' : cannot allocate
memory.\n", file, linenum, args[0], args[1]);
+ if (!LIST_ISEMPTY(&bind_conf->listeners)) {
+ ha_alert("parsing [%s:%d] : One listener per \"peers\"
section is authorized but another is already configured at [%s:%d].\n", file,
linenum, bind_conf->file, bind_conf->line);
err_code |= ERR_FATAL;
- goto out;
}
- bind_conf->maxaccept = 1;
- bind_conf->accept = session_accept_fd;
- bind_conf->options |= BC_O_UNLIMITED; /* don't make the peers
subject to global limits */
-
- if (*args[0] == 'b') {
- struct listener *l;
-
- if (peer_line) {
- ha_alert("parsing [%s:%d] : mixing \"peer\" and
\"bind\" line is forbidden\n", file, linenum);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
+ if (!str2listener(args[1], curpeers->peers_fe, bind_conf, file,
linenum, &errmsg)) {
+ if (errmsg && *errmsg) {
+ indent_msg(&errmsg, 2);
+ ha_alert("parsing [%s:%d] : '%s %s' : %s\n",
file, linenum, args[0], args[1], errmsg);
}
+ else
+ ha_alert("parsing [%s:%d] : '%s %s' : error
encountered while parsing listening address %s.\n",
+ file, linenum, args[0], args[1],
args[1]);
+ err_code |= ERR_FATAL;
+ goto out;
+ }
- if (!LIST_ISEMPTY(&bind_conf->listeners)) {
- ha_alert("parsing [%s:%d] : One listener per
\"peers\" section is authorized but another is already configured at
[%s:%d].\n", file, linenum, bind_conf->file, bind_conf->line);
- err_code |= ERR_FATAL;
- }
+ /* Only one listener supported. Compare first listener
+ * against the last one. It must be the same one.
+ */
+ if (bind_conf->listeners.n != bind_conf->listeners.p) {
+ ha_alert("parsing [%s:%d] : Only one listener per
\"peers\" section is authorized. Multiple listening addresses or port range are
not supported.\n", file, linenum);
+ err_code |= ERR_ALERT | ERR_FATAL;
+ goto out;
+ }
+ /*
+ * Newly allocated listener is at the end of the list
+ */
+ l = LIST_ELEM(bind_conf->listeners.p, typeof(l), by_bind);
+ bind_addr = &l->rx.addr;
- if (!str2listener(args[1], curpeers->peers_fe,
bind_conf, file, linenum, &errmsg)) {
- if (errmsg && *errmsg) {
- indent_msg(&errmsg, 2);
- ha_alert("parsing [%s:%d] : '%s %s' :
%s\n", file, linenum, args[0], args[1], errmsg);
- }
- else
- ha_alert("parsing [%s:%d] : '%s %s' :
error encountered while parsing listening address %s.\n",
- file, linenum,
args[0], args[1], args[1]);
- err_code |= ERR_FATAL;
- goto out;
- }
+ global.maxsock++; /* for the listening socket */
- /* Only one listener supported. Compare first listener
- * against the last one. It must be the same one.
+ bind_line = 1;
+ if (cfg_peers->local) {
+ /* Local peer already defined using "server" line has no
+ * address yet, we should update its server's addr:port
+ * settings
*/
- if (bind_conf->listeners.n != bind_conf->listeners.p) {
- ha_alert("parsing [%s:%d] : Only one listener
per \"peers\" section is authorized. Multiple listening addresses or port range
are not supported.\n", file, linenum);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
- }
- /*
- * Newly allocated listener is at the end of the list
+ newpeer = cfg_peers->local;
+ BUG_ON(!newpeer->srv);
+ newpeer->srv->addr = *bind_addr;
+ newpeer->srv->svc_port = get_host_port(bind_addr);
+ }
+ else {
+ /* This peer is local.
+ * Note that we do not set the peer ID. This latter is
initialized
+ * when parsing "peer" or "server" line.
*/
- l = LIST_ELEM(bind_conf->listeners.p, typeof(l),
by_bind);
- bind_addr = &l->rx.addr;
-
- global.maxsock++; /* for the listening socket */
-
- bind_line = 1;
- if (cfg_peers->local) {
- /* Local peer already defined using "server"
line has no
- * address yet, we should update its server's
addr:port
- * settings
- */
- newpeer = cfg_peers->local;
- BUG_ON(!newpeer->srv);
- newpeer->srv->addr = *bind_addr;
- newpeer->srv->svc_port =
get_host_port(bind_addr);
- }
- else {
- /* This peer is local.
- * Note that we do not set the peer ID. This
latter is initialized
- * when parsing "peer" or "server" line.
- */
- newpeer = cfg_peers_add_peer(curpeers, file,
linenum, NULL, 1);
- if (!newpeer) {
- err_code |= ERR_ALERT | ERR_ABORT;
- goto out;
- }
+ newpeer = cfg_peers_add_peer(curpeers, file, linenum,
NULL, 1);
+ if (!newpeer) {
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
}
- cur_arg++;
}
+ cur_arg++;
+ }
- ret = bind_parse_args_list(bind_conf, args, cur_arg,
cursection, file, linenum);
- err_code |= ret;
- if (ret != 0)
- goto out;
+ ret = bind_parse_args_list(bind_conf, args, cur_arg, cursection, file,
linenum);
+ err_code |= ret;
+
+out:
+ free(errmsg);
+ return err_code;
+}
+
+/* Parse "default-server" keyword */
+static int cfg_parse_peers_default_server(char **args, int section_type,
struct proxy *curpx,
+ const struct proxy *defpx, const
char *file, int linenum,
+ char **err)
+{
+ int err_code = 0;
+
+ if (init_peers_frontend(file, -1, NULL, curpeers) != 0) {
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
}
- else if (strcmp(args[0], "default-server") == 0) {
- if (init_peers_frontend(file, -1, NULL, curpeers) != 0) {
- err_code |= ERR_ALERT | ERR_ABORT;
- goto out;
- }
- err_code |= parse_server(file, linenum, args,
curpeers->peers_fe, NULL,
-
SRV_PARSE_DEFAULT_SERVER|SRV_PARSE_IN_PEER_SECTION|SRV_PARSE_INITIAL_RESOLVE);
+ err_code |= parse_server(file, linenum, args, curpeers->peers_fe, NULL,
+
SRV_PARSE_DEFAULT_SERVER|SRV_PARSE_IN_PEER_SECTION|SRV_PARSE_INITIAL_RESOLVE);
+out:
+ return err_code;
+}
+
+/* Parse "log" keyword */
+static int cfg_parse_peers_log(char **args, int section_type, struct proxy
*curpx,
+ const struct proxy *defpx, const char *file,
int linenum,
+ char **err)
+{
+ int err_code = 0;
+ char *errmsg = NULL;
+
+ if (init_peers_frontend(file, linenum, NULL, curpeers) != 0) {
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
}
- else if (strcmp(args[0], "log") == 0) {
- if (init_peers_frontend(file, linenum, NULL, curpeers) != 0) {
- err_code |= ERR_ALERT | ERR_ABORT;
- goto out;
- }
- if (!parse_logger(args, &curpeers->peers_fe->loggers, (kwm ==
KWM_NO), file, linenum, &errmsg)) {
- ha_alert("parsing [%s:%d] : %s : %s\n", file, linenum,
args[0], errmsg);
+ if (!parse_logger(args, &curpeers->peers_fe->loggers, (strcmp(args[0],
"no") == 0), file, linenum, &errmsg)) {
+ ha_alert("parsing [%s:%d] : %s : %s\n", file, linenum, args[0],
errmsg);
+ err_code |= ERR_ALERT | ERR_FATAL;
+ }
+
+out:
+ free(errmsg);
+ return err_code;
+}
+
+/* Parse "peers" keyword (section declaration) */
+static int cfg_parse_peers_section(char **args, int section_type, struct proxy
*curpx,
+ const struct proxy *defpx, const char
*file, int linenum,
+ char **err)
+{
+ const char *errc;
+ int err_code = 0;
+
+ /* Initialize these static variables when entering a new "peers"
section*/
+ bind_line = peer_line = 0;
+ bind_addr = NULL;
+ if (!*args[1]) {
+ ha_alert("parsing [%s:%d] : missing name for peers section.\n",
file, linenum);
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
+ }
+
+ if (alertif_too_many_args(1, file, linenum, args, &err_code)) {
+ err_code |= ERR_ABORT;
+ goto out;
+ }
+
+ errc = invalid_char(args[1]);
+ if (errc) {
+ ha_alert("parsing [%s:%d] : character '%c' is not permitted in
'%s' name '%s'.\n",
+ file, linenum, *errc, args[0], args[1]);
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
+ }
+
+ for (curpeers = cfg_peers; curpeers != NULL; curpeers = curpeers->next)
{
+ /*
+ * If there are two proxies with the same name only following
+ * combinations are allowed:
+ */
+ if (strcmp(curpeers->id, args[1]) == 0) {
+ ha_alert("Parsing [%s:%d]: peers section '%s' has the
same name as another peers section declared at %s:%d.\n",
+ file, linenum, args[1], curpeers->conf.file,
curpeers->conf.line);
err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
}
}
- else if (strcmp(args[0], "peers") == 0) { /* new peers section */
- /* Initialize these static variables when entering a new
"peers" section*/
- bind_line = peer_line = 0;
- bind_addr = NULL;
- if (!*args[1]) {
- ha_alert("parsing [%s:%d] : missing name for peers
section.\n", file, linenum);
- err_code |= ERR_ALERT | ERR_ABORT;
+
+ if ((curpeers = calloc(1, sizeof(*curpeers))) == NULL) {
+ ha_alert("parsing [%s:%d] : out of memory.\n", file, linenum);
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
+ }
+
+ curpeers->next = cfg_peers;
+ cfg_peers = curpeers;
+ curpeers->conf.file = strdup(file);
+ curpeers->conf.line = linenum;
+ curpeers->last_change = ns_to_sec(now_ns);
+ curpeers->id = strdup(args[1]);
+ curpeers->disabled = 0;
+
+out:
+ return err_code;
+}
+
+/* Parse "peer" or "server" keyword */
+static int cfg_parse_peers_peer(char **args, int section_type, struct proxy
*curpx,
+ const struct proxy *defpx, const char *file,
int linenum,
+ char **err)
+{
+ struct peer *newpeer = NULL;
+ struct bind_conf *bind_conf;
+ struct server *prev_srv;
+ int err_code = 0;
+ char *errmsg = NULL;
+ int local_peer, peer;
+ int parse_addr = 0;
+
+ peer = *args[0] == 'p';
+ local_peer = strcmp(args[1], localpeer) == 0;
+ /* The local peer may have already partially been parsed on a "bind"
line. */
+ if (*args[0] == 'p') {
+ if (bind_line) {
+ ha_alert("parsing [%s:%d] : mixing \"peer\" and
\"bind\" line is forbidden\n", file, linenum);
+ err_code |= ERR_ALERT | ERR_FATAL;
goto out;
}
-
- if (alertif_too_many_args(1, file, linenum, args, &err_code)) {
- err_code |= ERR_ABORT;
+ peer_line = 1;
+ }
+ if (cfg_peers->local && !cfg_peers->local->id && local_peer) {
+ /* The local peer has already been initialized on a "bind" line.
+ * Let's use it and store its ID.
+ */
+ newpeer = cfg_peers->local;
+ newpeer->id = strdup(localpeer);
+ }
+ else {
+ if (local_peer && cfg_peers->local) {
+ ha_alert("parsing [%s:%d] : '%s %s' : local peer name
already referenced at %s:%d. %s\n",
+ file, linenum, args[0], args[1],
+ curpeers->peers_fe->conf.file,
curpeers->peers_fe->conf.line, cfg_peers->local->id);
+ err_code |= ERR_FATAL;
goto out;
}
-
- err = invalid_char(args[1]);
- if (err) {
- ha_alert("parsing [%s:%d] : character '%c' is not
permitted in '%s' name '%s'.\n",
- file, linenum, *err, args[0], args[1]);
+ newpeer = cfg_peers_add_peer(curpeers, file, linenum, args[1],
local_peer);
+ if (!newpeer) {
err_code |= ERR_ALERT | ERR_ABORT;
goto out;
}
+ }
- for (curpeers = cfg_peers; curpeers != NULL; curpeers =
curpeers->next) {
- /*
- * If there are two proxies with the same name only
following
- * combinations are allowed:
- */
- if (strcmp(curpeers->id, args[1]) == 0) {
- ha_alert("Parsing [%s:%d]: peers section '%s'
has the same name as another peers section declared at %s:%d.\n",
- file, linenum, args[1],
curpeers->conf.file, curpeers->conf.line);
- err_code |= ERR_ALERT | ERR_FATAL;
- }
- }
+ /* Line number and peer ID are updated only if this peer is the local
one. */
+ if (init_peers_frontend(file,
+ newpeer->local ? linenum: -1,
+ newpeer->local ? newpeer->id : NULL,
+ curpeers) != 0) {
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
+ }
- if ((curpeers = calloc(1, sizeof(*curpeers))) == NULL) {
- ha_alert("parsing [%s:%d] : out of memory.\n", file,
linenum);
- err_code |= ERR_ALERT | ERR_ABORT;
- goto out;
- }
+ /* This initializes curpeer->peers->peers_fe->srv.
+ * The server address is parsed only if we are parsing a "peer" line,
+ * or if we are parsing a "server" line and the current peer is not the
local one.
+ */
+ parse_addr = (peer || !local_peer) ? SRV_PARSE_PARSE_ADDR : 0;
+ prev_srv = curpeers->peers_fe->srv;
+ err_code |= parse_server(file, linenum, args, curpeers->peers_fe, NULL,
+
SRV_PARSE_IN_PEER_SECTION|parse_addr|SRV_PARSE_INITIAL_RESOLVE);
+ if (curpeers->peers_fe->srv == prev_srv) {
+ /* parse_server didn't add a server:
+ * Remove the newly allocated peer.
+ */
+ struct peer *p;
- curpeers->next = cfg_peers;
- cfg_peers = curpeers;
- curpeers->conf.file = strdup(file);
- curpeers->conf.line = linenum;
- curpeers->last_change = ns_to_sec(now_ns);
- curpeers->id = strdup(args[1]);
- curpeers->disabled = 0;
- }
- else if (strcmp(args[0], "peer") == 0 ||
- strcmp(args[0], "server") == 0) { /* peer or server definition
*/
- struct server *prev_srv;
- int local_peer, peer;
- int parse_addr = 0;
-
- peer = *args[0] == 'p';
- local_peer = strcmp(args[1], localpeer) == 0;
- /* The local peer may have already partially been parsed on a
"bind" line. */
- if (*args[0] == 'p') {
- if (bind_line) {
- ha_alert("parsing [%s:%d] : mixing \"peer\" and
\"bind\" line is forbidden\n", file, linenum);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
- }
- peer_line = 1;
- }
- if (cfg_peers->local && !cfg_peers->local->id && local_peer) {
- /* The local peer has already been initialized on a
"bind" line.
- * Let's use it and store its ID.
- */
- newpeer = cfg_peers->local;
- newpeer->id = strdup(localpeer);
+ /* while it is tolerated to have a "server" line without
address, it isn't
+ * the case for a "peer" line
+ */
+ if (peer) {
+ ha_warning("parsing [%s:%d] : '%s %s' : ignoring
invalid peer definition (missing address:port)\n",
+ file, linenum, args[0], args[1]);
+ err_code |= ERR_WARN;
}
else {
- if (local_peer && cfg_peers->local) {
- ha_alert("parsing [%s:%d] : '%s %s' : local
peer name already referenced at %s:%d. %s\n",
- file, linenum, args[0], args[1],
- curpeers->peers_fe->conf.file,
curpeers->peers_fe->conf.line, cfg_peers->local->id);
- err_code |= ERR_FATAL;
- goto out;
- }
- newpeer = cfg_peers_add_peer(curpeers, file, linenum,
args[1], local_peer);
- if (!newpeer) {
- err_code |= ERR_ALERT | ERR_ABORT;
- goto out;
- }
- }
-
- /* Line number and peer ID are updated only if this peer is the
local one. */
- if (init_peers_frontend(file,
- newpeer->local ? linenum: -1,
- newpeer->local ? newpeer->id : NULL,
- curpeers) != 0) {
- err_code |= ERR_ALERT | ERR_ABORT;
- goto out;
+ ha_diag_warning("parsing [%s:%d] : '%s %s' : ignoring
server (not a local peer, valid address:port is expected)\n",
+ file, linenum, args[0], args[1]);
+ }
+
+ p = curpeers->remote;
+ curpeers->remote = curpeers->remote->next;
+ free(p->id);
+ free(p);
+ if (local_peer) {
+ /* we only get there with incomplete "peer"
+ * line for local peer (missing address):
+ *
+ * reset curpeers and curpeers fields
+ * that are local peer related
+ */
+ curpeers->local = NULL;
+ ha_free(&curpeers->peers_fe->id);
}
+ goto out;
+ }
- /* This initializes curpeer->peers->peers_fe->srv.
- * The server address is parsed only if we are parsing a "peer"
line,
- * or if we are parsing a "server" line and the current peer is
not the local one.
+ if (!parse_addr && bind_addr) {
+ /* local peer declared using "server": has name but no
+ * address: we use the known "bind" line addr settings
+ * as implicit server's addr and port.
*/
- parse_addr = (peer || !local_peer) ? SRV_PARSE_PARSE_ADDR : 0;
- prev_srv = curpeers->peers_fe->srv;
- err_code |= parse_server(file, linenum, args,
curpeers->peers_fe, NULL,
-
SRV_PARSE_IN_PEER_SECTION|parse_addr|SRV_PARSE_INITIAL_RESOLVE);
- if (curpeers->peers_fe->srv == prev_srv) {
- /* parse_server didn't add a server:
- * Remove the newly allocated peer.
- */
- struct peer *p;
+ curpeers->peers_fe->srv->addr = *bind_addr;
+ curpeers->peers_fe->srv->svc_port = get_host_port(bind_addr);
+ }
- /* while it is tolerated to have a "server" line
without address, it isn't
- * the case for a "peer" line
- */
- if (peer) {
- ha_warning("parsing [%s:%d] : '%s %s' :
ignoring invalid peer definition (missing address:port)\n",
- file, linenum, args[0], args[1]);
- err_code |= ERR_WARN;
- }
- else {
- ha_diag_warning("parsing [%s:%d] : '%s %s' :
ignoring server (not a local peer, valid address:port is expected)\n",
- file, linenum, args[0],
args[1]);
- }
+ if (nb_shards && curpeers->peers_fe->srv->shard > nb_shards) {
+ ha_warning("parsing [%s:%d] : '%s %s' : %d peer shard greater
value than %d shards value is ignored.\n",
+ file, linenum, args[0], args[1],
curpeers->peers_fe->srv->shard, nb_shards);
+ curpeers->peers_fe->srv->shard = 0;
+ err_code |= ERR_WARN;
+ }
- p = curpeers->remote;
- curpeers->remote = curpeers->remote->next;
- free(p->id);
- free(p);
- if (local_peer) {
- /* we only get there with incomplete "peer"
- * line for local peer (missing address):
- *
- * reset curpeers and curpeers fields
- * that are local peer related
- */
- curpeers->local = NULL;
- ha_free(&curpeers->peers_fe->id);
- }
- goto out;
- }
+ if (curpeers->peers_fe->srv->init_addr_methods ||
curpeers->peers_fe->srv->resolvers_id ||
+ curpeers->peers_fe->srv->do_check ||
curpeers->peers_fe->srv->do_agent) {
+ ha_warning("parsing [%s:%d] : '%s %s' : init_addr, resolvers,
check and agent are ignored for peers.\n", file, linenum, args[0], args[1]);
+ err_code |= ERR_WARN;
+ }
- if (!parse_addr && bind_addr) {
- /* local peer declared using "server": has name but no
- * address: we use the known "bind" line addr settings
- * as implicit server's addr and port.
- */
- curpeers->peers_fe->srv->addr = *bind_addr;
- curpeers->peers_fe->srv->svc_port =
get_host_port(bind_addr);
- }
+ HA_SPIN_INIT(&newpeer->lock);
- if (nb_shards && curpeers->peers_fe->srv->shard > nb_shards) {
- ha_warning("parsing [%s:%d] : '%s %s' : %d peer shard
greater value than %d shards value is ignored.\n",
- file, linenum, args[0], args[1],
curpeers->peers_fe->srv->shard, nb_shards);
- curpeers->peers_fe->srv->shard = 0;
- err_code |= ERR_WARN;
- }
+ newpeer->srv = curpeers->peers_fe->srv;
+ if (!newpeer->local)
+ goto out;
- if (curpeers->peers_fe->srv->init_addr_methods ||
curpeers->peers_fe->srv->resolvers_id ||
- curpeers->peers_fe->srv->do_check ||
curpeers->peers_fe->srv->do_agent) {
- ha_warning("parsing [%s:%d] : '%s %s' : init_addr,
resolvers, check and agent are ignored for peers.\n", file, linenum, args[0],
args[1]);
- err_code |= ERR_WARN;
- }
+ /* The lines above are reserved to "peer" lines. */
+ if (*args[0] == 's')
+ goto out;
- HA_SPIN_INIT(&newpeer->lock);
+ bind_conf = bind_conf_uniq_alloc(curpeers->peers_fe, file, linenum,
args[2], xprt_get(XPRT_RAW));
+ if (!bind_conf) {
+ ha_alert("parsing [%s:%d] : '%s %s' : Cannot allocate
memory.\n", file, linenum, args[0], args[1]);
+ err_code |= ERR_FATAL;
+ goto out;
+ }
- newpeer->srv = curpeers->peers_fe->srv;
- if (!newpeer->local)
- goto out;
+ bind_conf->maxaccept = 1;
+ bind_conf->accept = session_accept_fd;
+ bind_conf->options |= BC_O_UNLIMITED; /* don't make the peers subject
to global limits */
- /* The lines above are reserved to "peer" lines. */
- if (*args[0] == 's')
- goto out;
+ if (!LIST_ISEMPTY(&bind_conf->listeners)) {
+ ha_alert("parsing [%s:%d] : One listener per \"peers\" section
is authorized but another is already configured at [%s:%d].\n", file, linenum,
bind_conf->file, bind_conf->line);
+ err_code |= ERR_FATAL;
+ }
- bind_conf = bind_conf_uniq_alloc(curpeers->peers_fe, file,
linenum, args[2], xprt_get(XPRT_RAW));
- if (!bind_conf) {
- ha_alert("parsing [%s:%d] : '%s %s' : Cannot allocate
memory.\n", file, linenum, args[0], args[1]);
- err_code |= ERR_FATAL;
- goto out;
+ if (!str2listener(args[2], curpeers->peers_fe, bind_conf, file,
linenum, &errmsg)) {
+ if (errmsg && *errmsg) {
+ indent_msg(&errmsg, 2);
+ ha_alert("parsing [%s:%d] : '%s %s' : %s\n", file,
linenum, args[0], args[1], errmsg);
}
+ else
+ ha_alert("parsing [%s:%d] : '%s %s' : error encountered
while parsing listening address %s.\n",
+ file, linenum, args[0], args[1], args[2]);
+ err_code |= ERR_FATAL;
+ goto out;
+ }
- bind_conf->maxaccept = 1;
- bind_conf->accept = session_accept_fd;
- bind_conf->options |= BC_O_UNLIMITED; /* don't make the peers
subject to global limits */
+ global.maxsock++; /* for the listening socket */
- if (!LIST_ISEMPTY(&bind_conf->listeners)) {
- ha_alert("parsing [%s:%d] : One listener per \"peers\"
section is authorized but another is already configured at [%s:%d].\n", file,
linenum, bind_conf->file, bind_conf->line);
- err_code |= ERR_FATAL;
- }
+out:
+ free(errmsg);
+ return err_code;
+}
- if (!str2listener(args[2], curpeers->peers_fe, bind_conf, file,
linenum, &errmsg)) {
- if (errmsg && *errmsg) {
- indent_msg(&errmsg, 2);
- ha_alert("parsing [%s:%d] : '%s %s' : %s\n",
file, linenum, args[0], args[1], errmsg);
- }
- else
- ha_alert("parsing [%s:%d] : '%s %s' : error
encountered while parsing listening address %s.\n",
- file, linenum, args[0], args[1],
args[2]);
- err_code |= ERR_FATAL;
- goto out;
- }
+/* Parse "shards" keyword */
+static int cfg_parse_peers_shards(char **args, int section_type, struct proxy
*curpx,
+ const struct proxy *defpx, const char *file,
int linenum,
+ char **err)
+{
+ char *endptr;
+ int err_code = 0;
- global.maxsock++; /* for the listening socket */
+ if (!*args[1]) {
+ ha_alert("parsing [%s:%d] : '%s' : missing value\n", file,
linenum, args[0]);
+ err_code |= ERR_FATAL;
+ goto out;
}
- else if (strcmp(args[0], "shards") == 0) {
- char *endptr;
- if (!*args[1]) {
- ha_alert("parsing [%s:%d] : '%s' : missing value\n",
file, linenum, args[0]);
- err_code |= ERR_FATAL;
- goto out;
- }
+ curpeers->nb_shards = strtol(args[1], &endptr, 10);
+ if (*endptr != '\0') {
+ ha_alert("parsing [%s:%d] : '%s' : expects an integer argument,
found '%s'\n",
+ file, linenum, args[0], args[1]);
+ err_code |= ERR_FATAL;
+ goto out;
+ }
- curpeers->nb_shards = strtol(args[1], &endptr, 10);
- if (*endptr != '\0') {
- ha_alert("parsing [%s:%d] : '%s' : expects an integer
argument, found '%s'\n",
- file, linenum, args[0], args[1]);
- err_code |= ERR_FATAL;
- goto out;
- }
+ if (!curpeers->nb_shards) {
+ ha_alert("parsing [%s:%d] : '%s' : expects a strictly positive
integer argument\n",
+ file, linenum, args[0]);
+ err_code |= ERR_FATAL;
+ goto out;
+ }
- if (!curpeers->nb_shards) {
- ha_alert("parsing [%s:%d] : '%s' : expects a strictly
positive integer argument\n",
- file, linenum, args[0]);
- err_code |= ERR_FATAL;
- goto out;
- }
+ nb_shards = curpeers->nb_shards;
- nb_shards = curpeers->nb_shards;
+out:
+ return err_code;
+}
+
+/* Parse "table" keyword */
+static int cfg_parse_peers_table(char **args, int section_type, struct proxy
*curpx,
+ const struct proxy *defpx, const char *file,
int linenum,
+ char **err)
+{
+ struct stktable *t, *other;
+ char *id;
+ size_t prefix_len;
+ int err_code = 0;
+
+ /* Line number and peer ID are updated only if this peer is the local
one. */
+ if (init_peers_frontend(file, -1, NULL, curpeers) != 0) {
+ err_code |= ERR_ALERT | ERR_ABORT;
+ goto out;
}
- else if (strcmp(args[0], "table") == 0) {
- struct stktable *t, *other;
- char *id;
- size_t prefix_len;
- /* Line number and peer ID are updated only if this peer is the
local one. */
- if (init_peers_frontend(file, -1, NULL, curpeers) != 0) {
- err_code |= ERR_ALERT | ERR_ABORT;
- goto out;
- }
+ /* Build the stick-table name, concatenating the "peers" section name
+ * followed by a '/' character and the table name argument.
+ */
+ chunk_reset(&trash);
+ if (!chunk_strcpy(&trash, curpeers->id)) {
+ ha_alert("parsing [%s:%d]: '%s %s' : stick-table name too
long.\n",
+ file, linenum, args[0], args[1]);
+ err_code |= ERR_ALERT | ERR_FATAL;
+ goto out;
+ }
- /* Build the stick-table name, concatenating the "peers"
section name
- * followed by a '/' character and the table name argument.
- */
- chunk_reset(&trash);
- if (!chunk_strcpy(&trash, curpeers->id)) {
- ha_alert("parsing [%s:%d]: '%s %s' : stick-table name
too long.\n",
- file, linenum, args[0], args[1]);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
- }
+ prefix_len = trash.data;
+ if (!chunk_memcat(&trash, "/", 1) || !chunk_strcat(&trash, args[1])) {
+ ha_alert("parsing [%s:%d]: '%s %s' : stick-table name too
long.\n",
+ file, linenum, args[0], args[1]);
+ err_code |= ERR_ALERT | ERR_FATAL;
+ goto out;
+ }
- prefix_len = trash.data;
- if (!chunk_memcat(&trash, "/", 1) || !chunk_strcat(&trash,
args[1])) {
- ha_alert("parsing [%s:%d]: '%s %s' : stick-table name
too long.\n",
- file, linenum, args[0], args[1]);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
- }
+ t = calloc(1, sizeof *t);
+ id = strdup(trash.area);
+ if (!t || !id) {
+ ha_alert("parsing [%s:%d]: '%s %s' : memory allocation
failed\n",
+ file, linenum, args[0], args[1]);
+ free(t);
+ free(id);
+ err_code |= ERR_ALERT | ERR_FATAL;
+ goto out;
+ }
- t = calloc(1, sizeof *t);
- id = strdup(trash.area);
- if (!t || !id) {
- ha_alert("parsing [%s:%d]: '%s %s' : memory allocation
failed\n",
- file, linenum, args[0], args[1]);
- free(t);
- free(id);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
- }
+ other = stktable_find_by_name(trash.area);
+ if (other) {
+ ha_alert("parsing [%s:%d] : stick-table name '%s' conflicts
with table declared in %s '%s' at %s:%d.\n",
+ file, linenum, args[1],
+ other->proxy ? proxy_cap_str(other->proxy->cap) :
"peers",
+ other->proxy ? other->id : other->peers.p->id,
+ other->conf.file, other->conf.line);
+ err_code |= ERR_ALERT | ERR_FATAL;
+ goto out;
+ }
- other = stktable_find_by_name(trash.area);
- if (other) {
- ha_alert("parsing [%s:%d] : stick-table name '%s'
conflicts with table declared in %s '%s' at %s:%d.\n",
- file, linenum, args[1],
- other->proxy ?
proxy_cap_str(other->proxy->cap) : "peers",
- other->proxy ? other->id : other->peers.p->id,
- other->conf.file, other->conf.line);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
- }
+ err_code |= parse_stick_table(file, linenum, args, t, id, id +
prefix_len, curpeers);
+ if (err_code & ERR_FATAL) {
+ free(t);
+ free(id);
+ goto out;
+ }
+ stktable_store_name(t);
+ t->next = stktables_list;
+ stktables_list = t;
- err_code |= parse_stick_table(file, linenum, args, t, id, id +
prefix_len, curpeers);
- if (err_code & ERR_FATAL) {
- free(t);
- free(id);
- goto out;
- }
+out:
+ return err_code;
+}
+
+/* Parse "disabled" keyword */
+static int cfg_parse_peers_disabled(char **args, int section_type, struct
proxy *curpx,
+ const struct proxy *defpx, const char
*file, int linenum,
+ char **err)
+{
+ curpeers->disabled |= PR_FL_DISABLED;
+ return 0;
+}
- stktable_store_name(t);
- t->next = stktables_list;
- stktables_list = t;
- }
- else if (strcmp(args[0], "disabled") == 0) { /* disables this peers
section */
- curpeers->disabled |= PR_FL_DISABLED;
- }
- else if (strcmp(args[0], "enabled") == 0) { /* enables this peers
section (used to revert a disabled default) */
- curpeers->disabled = 0;
- }
- else if (*args[0] != 0) {
- struct cfg_kw_list *kwl;
- int index;
- int rc;
-
- list_for_each_entry(kwl, &cfg_keywords.list, list) {
- for (index = 0; kwl->kw[index].kw != NULL; index++) {
- if ((kwl->kw[index].section == CFG_PEERS) &&
- strcmp(kwl->kw[index].kw, args[0]) == 0) {
- rc = kwl->kw[index].parse(args,
CFG_PEERS, curpeers->peers_fe, NULL, file, linenum, &errmsg);
- if (rc < 0) {
- ha_alert("parsing [%s:%d] :
%s\n", file, linenum, errmsg);
- err_code |= ERR_ALERT |
ERR_FATAL;
- goto out;
- }
- else if (rc > 0) {
- if (errmsg)
- ha_warning("parsing
[%s:%d] : %s\n", file, linenum, errmsg);
- err_code |= rc;
- goto out;
- }
+/* Parse "enabled" keyword */
+static int cfg_parse_peers_enabled(char **args, int section_type, struct proxy
*curpx,
+ const struct proxy *defpx, const char
*file, int linenum,
+ char **err)
+{
+ curpeers->disabled = 0;
+ return 0;
+}
+
+/*
+ * Parse a line in a <peers> section.
+ * Returns the error code, 0 if OK, or any combination of :
+ * - ERR_ABORT: must abort ASAP
+ * - ERR_FATAL: we can continue parsing but not start the service
+ * - ERR_WARN: a warning has been emitted
+ * - ERR_ALERT: an alert has been emitted
+ * Only the two first ones can stop processing, the two others are just
+ * indicators.
+ */
+int cfg_parse_peers(const char *file, int linenum, char **args, int kwm)
+{
+ struct cfg_kw_list *kwl;
+ int err_code = 0;
+ char *errmsg = NULL;
+ int index;
+ int rc;
+
+ if (*args[0] == 0)
+ goto out;
+
+ list_for_each_entry(kwl, &cfg_keywords.list, list) {
+ for (index = 0; kwl->kw[index].kw != NULL; index++) {
+ if ((kwl->kw[index].section == CFG_PEERS) &&
+ strcmp(kwl->kw[index].kw, args[0]) == 0) {
+ rc = kwl->kw[index].parse(args, CFG_PEERS,
curpeers ? curpeers->peers_fe : NULL, NULL, file, linenum, &errmsg);
+ if (rc < 0) {
+ ha_alert("parsing [%s:%d] : %s\n",
file, linenum, errmsg);
+ err_code |= ERR_ALERT | ERR_FATAL;
+ goto out;
+ }
+ else if (rc > 0) {
+ if (errmsg)
+ ha_warning("parsing [%s:%d] :
%s\n", file, linenum, errmsg);
+ err_code |= rc;
goto out;
}
+ goto out;
}
}
-
- ha_alert("parsing [%s:%d] : unknown keyword '%s' in '%s'
section\n", file, linenum, args[0], cursection);
- err_code |= ERR_ALERT | ERR_FATAL;
- goto out;
}
+ ha_alert("parsing [%s:%d] : unknown keyword '%s' in '%s' section\n",
file, linenum, args[0], cursection);
+ err_code |= ERR_ALERT | ERR_FATAL;
+
out:
free(errmsg);
return err_code;
}
REGISTER_CONFIG_SECTION("peers", cfg_parse_peers, NULL);
+
+static struct cfg_kw_list cfg_kws = {ILH, {
+ { CFG_PEERS, "bind", cfg_parse_peers_bind },
+ { CFG_PEERS, "default-bind", cfg_parse_peers_bind },
+ { CFG_PEERS, "default-server", cfg_parse_peers_default_server },
+ { CFG_PEERS, "disabled", cfg_parse_peers_disabled },
+ { CFG_PEERS, "enabled", cfg_parse_peers_enabled },
+ { CFG_PEERS, "log", cfg_parse_peers_log },
+ { CFG_PEERS, "peer", cfg_parse_peers_peer },
+ { CFG_PEERS, "peers", cfg_parse_peers_section },
+ { CFG_PEERS, "server", cfg_parse_peers_peer },
+ { CFG_PEERS, "shards", cfg_parse_peers_shards },
+ { CFG_PEERS, "table", cfg_parse_peers_table },
+ { 0, NULL, NULL },
+}};
+
+INITCALL1(STG_REGISTER, cfg_register_keywords, &cfg_kws);
--
2.48.1
