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

dbms: Better [#METR-18510]

Browse Source
This commit is contained in:
Alexey Arno 2016-09-01 17:03:42 +03:00
parent 2b3a87b7c6
commit 882d40889b
1 changed files with 8 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
libs/libzkutil/src/SingleBarrier.cpp
View File

@ -37,40 +37,23 @@ SingleBarrier::SingleBarrier(GetZooKeeper get_zookeeper_, const std::string & pa
auto zookeeper = get_zookeeper();
int32_t code = zookeeper->tryCreate(path, "", CreateMode::Persistent);
if ((code != ZOK) && (code != ZNODEEXISTS))
throw KeeperException{code};
Ops ops;
auto acl = zookeeper->getDefaultACL();
if (code == ZNODEEXISTS)
{
/// This barrier is already being created by another node.
/// Wait until it has been fully created so that it is usable.
if (!zookeeper->exists(path + "/lock", nullptr, event))
{
do
{
abortIfRequested();
}
while (!event->tryWait(wait_duration));
return;
}
}
ops.push_back(new zkutil::Op::Create{path, "", acl, CreateMode::Persistent});
/// List of tokens.
code = zookeeper->tryCreate(path + "/tokens", "", CreateMode::Persistent);
if ((code != ZOK) && (code != ZNODEEXISTS))
throw KeeperException{code};
ops.push_back(new zkutil::Op::Create{path + "/tokens", "", acl, CreateMode::Persistent});
/// Tokens are tagged so that we can differentiate obsolete tokens that may
/// be deleted from those that are currently used to cross this barrier.
code = zookeeper->tryCreate(path + "/tag", "0", CreateMode::Persistent);
if ((code != ZOK) && (code != ZNODEEXISTS))
throw KeeperException{code};
ops.push_back(new zkutil::Op::Create{path + "/tag", "0", acl, CreateMode::Persistent});
/// We protect some areas of the code in order to reliably determine which
/// token has unblocked this barrier.
code = zookeeper->tryCreate(path + "/lock", "", CreateMode::Persistent);
ops.push_back(new zkutil::Op::Create{path + "/lock", "", acl, CreateMode::Persistent});
int32_t code = zookeeper->tryMulti(ops);
if ((code != ZOK) && (code != ZNODEEXISTS))
throw KeeperException{code};
}