thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-02 12:32:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add a check for the 'host_name' parameter

Browse Source
This commit is contained in:
Nikolay Degterinsky 2023-12-26 22:57:31 +00:00
parent 10bfd054d8
commit 547e3ed6c0
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/Interpreters/DDLTask.cpp
View File

@ -220,7 +220,20 @@ bool DDLTask::findCurrentHostID(ContextPtr global_context, Poco::Logger * log, c
bool host_in_hostlist = false; bool host_in_hostlist = false;
std::exception_ptr first_exception = nullptr; std::exception_ptr first_exception = nullptr;
auto maybe_secure_port = global_context->getTCPPortSecure(); const auto maybe_secure_port = global_context->getTCPPortSecure();
const auto port = global_context->getTCPPort()
if (config_host_name)
{
bool is_local_port = (maybe_secure_port && HostID(*config_host_name, *maybe_secure_port).isLocalAddress(*maybe_secure_port)) ||
HostID(*config_host_name, port).isLocalAddress(port);
if (!is_local_port)
throw Exception(
ErrorCodes::DNS_ERROR,
"{} is not a local adress. Check parameter 'host_name' in the configuration",
*config_host_name)
}
for (const HostID & host : entry.hosts) for (const HostID & host : entry.hosts)
{ {
@ -229,7 +242,7 @@ bool DDLTask::findCurrentHostID(ContextPtr global_context, Poco::Logger * log, c
if (config_host_name != host.host_name) if (config_host_name != host.host_name)
continue; continue;
if (maybe_secure_port != host.port && global_context->getTCPPort() != host.port) if (maybe_secure_port != host.port && port != host.port)
continue; continue;
host_in_hostlist = true; host_in_hostlist = true;
@ -242,7 +255,7 @@ bool DDLTask::findCurrentHostID(ContextPtr global_context, Poco::Logger * log, c
{ {
/// The port is considered local if it matches TCP or TCP secure port that the server is listening. /// The port is considered local if it matches TCP or TCP secure port that the server is listening.
bool is_local_port bool is_local_port
= (maybe_secure_port && host.isLocalAddress(*maybe_secure_port)) || host.isLocalAddress(global_context->getTCPPort()); = (maybe_secure_port && host.isLocalAddress(*maybe_secure_port)) || host.isLocalAddress(port);
if (!is_local_port) if (!is_local_port)
continue; continue;