hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix removal of last server from monitor

Browse Source 
If the last server was removed, the parameter would be rejected due to it
being empty. To remove the parameter, the
MonitorManager::reconfigure_monitor should be used. Also fixed the
unnecessary serialization after a failure to remove server from a monitor
and the fact that some errors were logged instead of written to the caller
of the command.
This commit is contained in:
Markus Mäkelä
2019-03-27 00:33:55 +02:00
parent 5ee9b74770
commit c3f3200d2c
1 changed files with 16 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
server/core/config_runtime.cc
View File

@ -198,37 +198,25 @@ bool runtime_remove_server(Monitor* mon, Server* server)
if (MonitorManager::server_is_monitored(server) != mon) if (MonitorManager::server_is_monitored(server) != mon)
{ {
MXS_ERROR("Server '%s' is not monitored by '%s'.", server->name(), mon->m_name); config_runtime_error("Server '%s' is not monitored by '%s'.", server->name(), mon->m_name);
} }
else else
{ {
// Construct the new list. The removed value could be anywhere. MonitorStop stop(mon);
string serverlist = mon->parameters.get_string(CN_SERVERS);
auto names = config_break_list_string(serverlist); // Construct the new server list
bool found = false; auto params = mon->parameters;
for (auto iter = names.begin(); iter != names.end(); ++iter) auto names = config_break_list_string(params.get_string(CN_SERVERS));
names.erase(std::remove(names.begin(), names.end(), server->name()));
std::string servers = mxb::join(names, ",");
params.set(CN_SERVERS, servers);
if (MonitorManager::reconfigure_monitor(mon, params))
{ {
if (*iter == server->name()) rval = MonitorManager::monitor_serialize(mon);
{
found = true;
names.erase(iter);
break;
} }
} }
if (found)
{
// Rebuild the string.
string new_list;
string separator;
for (auto name : names)
{
new_list += separator + name;
separator = ", ";
}
rval = runtime_alter_monitor(mon, CN_SERVERS, new_list.c_str());
}
}
return rval; return rval;
} }
@ -314,9 +302,10 @@ bool runtime_unlink_server(Server* server, const char* target)
} }
else if (monitor) else if (monitor)
{ {
runtime_remove_server(monitor, server); if ((rval = runtime_remove_server(monitor, server)))
{
MonitorManager::monitor_serialize(monitor); MonitorManager::monitor_serialize(monitor);
rval = true; }
} }
if (rval) if (rval)