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

Better name [#CLICKHOUSE-3753]

Browse Source
This commit is contained in:
Alexey Milovidov 2018-05-31 22:28:30 +03:00
parent 6eb43fe9e9
commit 515bd29df7
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/src/Common/ZooKeeper/ZooKeeperImpl.cpp
View File

@ -997,8 +997,7 @@ void ZooKeeper::receiveEvent()
void ZooKeeper::finalize(bool error_send, bool error_receive)
{
{
/// Will wait for pushRequest method.
std::unique_lock lock(expired_mutex);
std::unique_lock lock(push_request_mutex);
if (expired)
return;
@ -1350,7 +1349,7 @@ void ZooKeeper::pushRequest(RequestInfo && info)
/// to avoid forgotten operations in the queue when session is expired.
/// Invariant: when expired, no new operations will be pushed to the queue in 'pushRequest'
/// and the queue will be drained in 'finalize'.
std::lock_guard lock(expired_mutex);
std::lock_guard lock(push_request_mutex);
if (expired)
throw Exception("Session expired", ZSESSIONEXPIRED);

2
dbms/src/Common/ZooKeeper/ZooKeeperImpl.h
View File

@ -573,7 +573,7 @@ private:
std::atomic<XID> xid {1};
std::atomic<bool> expired {false};
std::mutex expired_mutex;
std::mutex push_request_mutex;
using clock = std::chrono::steady_clock;