mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-25 09:02:00 +00:00
zkutil: additions [#METR-2944].
This commit is contained in:
parent
c68cfd5c88
commit
58fb17ae88
@ -610,6 +610,9 @@ ZooKeeper::GetFuture ZooKeeper::asyncGet(const std::string & path)
|
||||
},
|
||||
future.task.get());
|
||||
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperGet);
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperTransactions);
|
||||
|
||||
if (code != ZOK)
|
||||
throw KeeperException(code, path);
|
||||
|
||||
@ -636,6 +639,9 @@ ZooKeeper::TryGetFuture ZooKeeper::asyncTryGet(const std::string & path)
|
||||
},
|
||||
future.task.get());
|
||||
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperGet);
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperTransactions);
|
||||
|
||||
if (code != ZOK)
|
||||
throw KeeperException(code, path);
|
||||
|
||||
@ -662,6 +668,9 @@ ZooKeeper::ExistsFuture ZooKeeper::asyncExists(const std::string & path)
|
||||
},
|
||||
future.task.get());
|
||||
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperExists);
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperTransactions);
|
||||
|
||||
if (code != ZOK)
|
||||
throw KeeperException(code, path);
|
||||
|
||||
@ -693,6 +702,9 @@ ZooKeeper::GetChildrenFuture ZooKeeper::asyncGetChildren(const std::string & pat
|
||||
},
|
||||
future.task.get());
|
||||
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperGetChildren);
|
||||
ProfileEvents::increment(ProfileEvents::ZooKeeperTransactions);
|
||||
|
||||
if (code != ZOK)
|
||||
throw KeeperException(code, path);
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user