thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-30 19:42:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbms: addition to prev. revision [#METR-17573].

Browse Source
This commit is contained in:
Alexey Milovidov 2015-11-10 00:07:22 +03:00
parent e78ed9f802
commit f8e58463a6
1 changed files with 0 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
dbms/src/Storages/MergeTree/ReplicatedMergeTreeRestartingThread.cpp
View File

@ -367,35 +367,6 @@ void ReplicatedMergeTreeRestartingThread::goReadOnlyPermanently()
}
static time_t extractTimeOfLogEntryIfGetPart(zkutil::ZooKeeperPtr & zookeeper, const String & name, const String & path)
{
String content;
zkutil::Stat stat;
if (!zookeeper->tryGet(path + "/" + name, content, &stat))
return 0; /// Узел уже успел удалиться.
ReplicatedMergeTreeLogEntry::Ptr entry = ReplicatedMergeTreeLogEntry::parse(content, stat);
if (entry->type == ReplicatedMergeTreeLogEntry::GET_PART)
return entry->create_time;
return 0;
}
/// В массиве имён узлов - элементов очереди/лога находит первый, имеющий тип GET_PART и возвращает его время; либо ноль, если не нашёл.
static time_t findFirstGetPartEntry(zkutil::ZooKeeperPtr & zookeeper, const Strings & nodes, const String & path)
{
for (const auto & name : nodes)
{
time_t res = extractTimeOfLogEntryIfGetPart(zookeeper, name, path);
if (res)
return res;
}
return 0;
}
void ReplicatedMergeTreeRestartingThread::checkReplicationDelays(time_t & out_absolute_delay, time_t & out_relative_delay)
{
out_absolute_delay = 0;