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

Increment ZooKeeperWatch metric only if the callback is registered

Browse Source
This commit is contained in:
Nicolae Vartolomei 2021-07-06 17:10:29 +01:00
parent 9b01ded17a
commit 9b3ceda57c
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Common/ZooKeeper/ZooKeeperImpl.cpp
View File

@ -566,7 +566,6 @@ void ZooKeeper::sendThread()
if (info.watch)
{
info.request->has_watch = true;
CurrentMetrics::add(CurrentMetrics::ZooKeeperWatch);
}
if (expired)
@ -773,6 +772,8 @@ void ZooKeeper::receiveEvent()
if (add_watch)
{
CurrentMetrics::add(CurrentMetrics::ZooKeeperWatch);
/// The key of wathces should exclude the root_path
String req_path = request_info.request->getPath();
removeRootPath(req_path, root_path);