Skip to content

Commit 2b80f27

Browse files
committed
CR from @rgs1; need to always set zxids to -1
1 parent d402974 commit 2b80f27

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

zk_shell/shell.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1698,6 +1698,7 @@ def fetch(endpoint, states, znodes, ephemerals, datasize, sessions, zxids, idx):
16981698
ephemerals[idx] = int(eph_count)
16991699
datasize[idx] = int(dsize)
17001700
sessions[idx] = int(session_count)
1701+
zxids[idx] = -1
17011702

17021703
try:
17031704
srvr = self._zk.cmd(hosts_to_endpoints(endpoint), "srvr")
@@ -1706,7 +1707,7 @@ def fetch(endpoint, states, znodes, ephemerals, datasize, sessions, zxids, idx):
17061707
zxids[idx] = int(line.split(None)[1], 0)
17071708
break
17081709
except:
1709-
zxids[idx] = -1
1710+
pass
17101711

17111712
workers = []
17121713
for idx, endpoint in enumerate(endpoints, 1):

0 commit comments

Comments
 (0)