Bug
This commit is contained in:
parent
b1e77f6a20
commit
7dac0df58a
|
@ -306,7 +306,7 @@ def fenceNode(node_name, zk):
|
||||||
# Wait 5 seconds
|
# Wait 5 seconds
|
||||||
time.sleep(5)
|
time.sleep(5)
|
||||||
# Get the state
|
# Get the state
|
||||||
node_daemon_state = self.zk.get('/nodes/{}/daemonstate'.format(node_name))[0].decode('ascii')
|
node_daemon_state = zk.get('/nodes/{}/daemonstate'.format(node_name))[0].decode('ascii')
|
||||||
# Is it still 'dead'
|
# Is it still 'dead'
|
||||||
if node_daemon_state == 'dead':
|
if node_daemon_state == 'dead':
|
||||||
failcount += 1
|
failcount += 1
|
||||||
|
|
Loading…
Reference in New Issue