thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 23:52:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix atomic usage

Browse Source
This commit is contained in:
proller 2017-11-01 20:15:05 +03:00
parent c5dcde0c78
commit 3b58e9cd67
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -140,9 +140,9 @@ void ReplicatedMergeTreeRestartingThread::run()
ProfileEvents::increment(ProfileEvents::ReplicaYieldLeadership);
if (storage.is_leader_node)
bool old_val = true;
if (storage.is_leader_node.compare_exchange_strong(old_val, false))
{
storage.is_leader_node = false;
CurrentMetrics::sub(CurrentMetrics::LeaderReplica);
if (storage.merge_selecting_thread.joinable())
storage.merge_selecting_thread.join();
@ -376,9 +376,9 @@ void ReplicatedMergeTreeRestartingThread::partialShutdown()
{
std::lock_guard<std::mutex> lock(storage.leader_node_mutex);
if (storage.is_leader_node)
bool old_val = true;
if (storage.is_leader_node.compare_exchange_strong(old_val, false))
{
storage.is_leader_node = false;
CurrentMetrics::sub(CurrentMetrics::LeaderReplica);
if (storage.merge_selecting_thread.joinable())
storage.merge_selecting_thread.join();