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

Removed state_mutex lock from addSubscriber - Updated checking of SYSTEM SYNC REPLICA

Browse Source
This commit is contained in:
Smita Kulkarni 2023-02-07 12:19:58 +01:00
parent 135615cda6
commit fb765696b6
2 changed files with 0 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp
View File

@ -2478,7 +2478,6 @@ String ReplicatedMergeTreeMergePredicate::getCoveringVirtualPart(const String &
ReplicatedMergeTreeQueue::SubscriberHandler
ReplicatedMergeTreeQueue::addSubscriber(ReplicatedMergeTreeQueue::SubscriberCallBack && callback)
{
std::lock_guard lock(state_mutex);
std::lock_guard lock_subscribers(subscribers_mutex);
auto it = subscribers.emplace(subscribers.end(), std::move(callback));

1
src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -7587,7 +7587,6 @@ bool StorageReplicatedMergeTree::waitForProcessingQueue(UInt64 max_wait_millisec
if (partial_shutdown_called)
throw Exception(ErrorCodes::ABORTED, "Shutdown is called for table");
}
return true;
}