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

Rewriting ZooKeeper library [#CLICKHOUSE-2]

Browse Source
This commit is contained in:
Alexey Milovidov 2018-03-19 22:25:21 +03:00
parent c8f8dc429c
commit 644c5e67b6
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1088,7 +1088,11 @@ void ZooKeeper::pushRequest(RequestInfo && info)
info.request->addRootPath(root_path); info.request->addRootPath(root_path);
if (!info.request->xid) if (!info.request->xid)
{
info.request->xid = xid.fetch_add(1); info.request->xid = xid.fetch_add(1);
if (info.request->xid < 0)
throw Exception("XID overflow");
}
{ {
std::lock_guard lock(operations_mutex); std::lock_guard lock(operations_mutex);

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

@ -476,7 +476,7 @@ private:
std::optional<ReadBufferFromPocoSocket> in; std::optional<ReadBufferFromPocoSocket> in;
std::optional<WriteBufferFromPocoSocket> out; std::optional<WriteBufferFromPocoSocket> out;
std::atomic<XID> xid {1}; /// TODO deal with xid overflow std::atomic<XID> xid {1};
struct RequestInfo struct RequestInfo
{ {