Set Daemon migration selector in zookeeper
This commit is contained in:
parent
33a54cf7f2
commit
a0b9087167
|
@ -1504,6 +1504,17 @@ def node_keepalive():
|
||||||
if debug:
|
if debug:
|
||||||
logger.out("Keepalive starting", state='d', prefix='main-thread')
|
logger.out("Keepalive starting", state='d', prefix='main-thread')
|
||||||
|
|
||||||
|
# Set the migration selector in Zookeeper for clients to read
|
||||||
|
if config['enable_hypervisor']:
|
||||||
|
if this_node.router_state == 'primary':
|
||||||
|
try:
|
||||||
|
if zkhandler.read('/config/migration_target_selector') != config['migration_target_selector']:
|
||||||
|
raise
|
||||||
|
except Exception:
|
||||||
|
zkhandler.write([
|
||||||
|
('/config/migration_target_selector', config['migration_target_selector'])
|
||||||
|
])
|
||||||
|
|
||||||
# Set the upstream IP in Zookeeper for clients to read
|
# Set the upstream IP in Zookeeper for clients to read
|
||||||
if config['enable_networking']:
|
if config['enable_networking']:
|
||||||
if this_node.router_state == 'primary':
|
if this_node.router_state == 'primary':
|
||||||
|
|
Loading…
Reference in New Issue