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

Update src/Storages/PostgreSQL/PostgreSQLReplicationHandler.cpp

Browse Source 
Co-authored-by: tavplubix <tavplubix@gmail.com>
This commit is contained in:
Kseniia Sumarokova 2021-03-20 13:50:16 +03:00 committed by GitHub
parent 6bb81630e5
commit 4e63b8e5dd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/Storages/PostgreSQL/PostgreSQLReplicationHandler.cpp
View File

@ -217,26 +217,19 @@ NameSet PostgreSQLReplicationHandler::loadFromSnapshot(std::string & snapshot_na
void PostgreSQLReplicationHandler::consumerFunc() void PostgreSQLReplicationHandler::consumerFunc()
{ {
auto start_time = std::chrono::steady_clock::now();
std::vector<std::pair<Int32, String>> skipped_tables; std::vector<std::pair<Int32, String>> skipped_tables;
while (!stop_synchronization) bool schedule_now = consumer->consume(skipped_tables);
{
bool reschedule = !consumer->consume(skipped_tables);
if (!skipped_tables.empty()) if (!skipped_tables.empty())
consumer->updateSkipList(reloadFromSnapshot(skipped_tables)); consumer->updateSkipList(reloadFromSnapshot(skipped_tables));
if (reschedule) if (stop_synchronization)
break; return;
auto end_time = std::chrono::steady_clock::now(); if (schedule_now)
auto duration = std::chrono::duration_cast<std::chrono::milliseconds>(end_time - start_time); consumer_task->schedule();
if (duration.count() > max_thread_work_duration_ms) else
break;
}
if (!stop_synchronization)
consumer_task->scheduleAfter(reschedule_ms); consumer_task->scheduleAfter(reschedule_ms);
} }