Rename message when contending
This commit is contained in:
parent
4249d5d982
commit
b551b54642
|
@ -724,7 +724,7 @@ def update_primary(new_primary, stat, event=''):
|
||||||
# We're a coordinator and there is no primary
|
# We're a coordinator and there is no primary
|
||||||
if new_primary == 'none':
|
if new_primary == 'none':
|
||||||
if this_node.daemon_state == 'run' and this_node.router_state != 'primary':
|
if this_node.daemon_state == 'run' and this_node.router_state != 'primary':
|
||||||
logger.out('Contending for primary routing state', state='i')
|
logger.out('Contending for primary coordinator state', state='i')
|
||||||
zkhandler.writedata(zk_conn, {'/primary_node': myhostname})
|
zkhandler.writedata(zk_conn, {'/primary_node': myhostname})
|
||||||
elif new_primary == myhostname:
|
elif new_primary == myhostname:
|
||||||
zkhandler.writedata(zk_conn, {'/nodes/{}/routerstate'.format(myhostname): 'primary'})
|
zkhandler.writedata(zk_conn, {'/nodes/{}/routerstate'.format(myhostname): 'primary'})
|
||||||
|
|
Loading…
Reference in New Issue