mirror of
https://github.com/samba-team/samba.git
synced 2024-12-24 21:34:56 +03:00
cf17a48d29
Signed-off-by: Martin Schwenke <martin@meltin.net> Reviewed-by: Amitay Isaacs <amitay@gmail.com>
125 lines
3.0 KiB
C
125 lines
3.0 KiB
C
/*
|
|
CTDB cluster config handling
|
|
|
|
Copyright (C) Martin Schwenke 2018
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "replace.h"
|
|
#include "system/network.h"
|
|
|
|
#include "lib/util/debug.h"
|
|
|
|
#include "common/conf.h"
|
|
|
|
#include "cluster_conf.h"
|
|
|
|
#define CLUSTER_TRANSPORT_DEFAULT "tcp"
|
|
|
|
/*
|
|
* Ideally this wants to be a void function but it also used directly
|
|
* as a validation function
|
|
*/
|
|
static bool check_static_string_change(const char *key,
|
|
const char *old_value,
|
|
const char *new_value,
|
|
enum conf_update_mode mode)
|
|
{
|
|
if (mode == CONF_MODE_RELOAD) {
|
|
if (strcmp(old_value, new_value) != 0) {
|
|
D_WARNING("Ignoring update of [%s] -> %s\n",
|
|
CLUSTER_CONF_SECTION,
|
|
key);
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
static bool validate_transport(const char *key,
|
|
const char *old_transport,
|
|
const char *new_transport,
|
|
enum conf_update_mode mode)
|
|
{
|
|
/* Don't allow "ib" for now. It is broken! */
|
|
if (strcmp(new_transport, CLUSTER_TRANSPORT_DEFAULT) != 0) {
|
|
D_ERR("Invalid value for [cluster] -> transport = %s\n",
|
|
new_transport);
|
|
return false;
|
|
}
|
|
|
|
/* This sometimes warns but always returns true */
|
|
return check_static_string_change(key,
|
|
old_transport,
|
|
new_transport,
|
|
mode);
|
|
}
|
|
|
|
static bool validate_node_address(const char *key,
|
|
const char *old_node_address,
|
|
const char *new_node_address,
|
|
enum conf_update_mode mode)
|
|
{
|
|
struct in_addr addr4;
|
|
struct in6_addr addr6;
|
|
int ret;
|
|
|
|
if (new_node_address == NULL) {
|
|
goto good;
|
|
}
|
|
|
|
ret = inet_pton(AF_INET, new_node_address, &addr4);
|
|
if (ret == 1) {
|
|
goto good;
|
|
}
|
|
|
|
ret = inet_pton(AF_INET6, new_node_address, &addr6);
|
|
if (ret == 1) {
|
|
goto good;
|
|
}
|
|
|
|
D_ERR("Invalid value for [cluster] -> node address = %s\n",
|
|
new_node_address);
|
|
return false;
|
|
|
|
good:
|
|
/* This sometimes warns but always returns true */
|
|
return check_static_string_change(key,
|
|
old_node_address,
|
|
new_node_address,
|
|
mode);
|
|
}
|
|
|
|
void cluster_conf_init(struct conf_context *conf)
|
|
{
|
|
conf_define_section(conf, CLUSTER_CONF_SECTION, NULL);
|
|
|
|
conf_define_string(conf,
|
|
CLUSTER_CONF_SECTION,
|
|
CLUSTER_CONF_TRANSPORT,
|
|
CLUSTER_TRANSPORT_DEFAULT,
|
|
validate_transport);
|
|
conf_define_string(conf,
|
|
CLUSTER_CONF_SECTION,
|
|
CLUSTER_CONF_NODE_ADDRESS,
|
|
NULL,
|
|
validate_node_address);
|
|
conf_define_string(conf,
|
|
CLUSTER_CONF_SECTION,
|
|
CLUSTER_CONF_RECOVERY_LOCK,
|
|
NULL,
|
|
check_static_string_change);
|
|
}
|