Correct several bugs from refactor
This commit is contained in:
parent
461183a371
commit
fc0465d112
|
@ -174,6 +174,32 @@ def verifyNode(zk_conn, node):
|
||||||
click.echo('ERROR: No node named "{}" is present in the cluster.'.format(node))
|
click.echo('ERROR: No node named "{}" is present in the cluster.'.format(node))
|
||||||
exit(1)
|
exit(1)
|
||||||
|
|
||||||
|
#
|
||||||
|
# Get the list of valid target hypervisors
|
||||||
|
#
|
||||||
|
def getHypervisors(zk_conn, dom_uuid):
|
||||||
|
valid_hypervisor_list = []
|
||||||
|
full_hypervisor_list = zk_conn.get_children('/nodes')
|
||||||
|
|
||||||
|
try:
|
||||||
|
current_hypervisor = zk_conn.get('/domains/{}/hypervisor'.format(dom_uuid))[0].decode('ascii')
|
||||||
|
except:
|
||||||
|
current_hypervisor = None
|
||||||
|
|
||||||
|
for hypervisor in full_hypervisor_list:
|
||||||
|
daemon_state = zk_conn.get('/nodes/{}/daemonstate'.format(hypervisor))[0].decode('ascii')
|
||||||
|
domain_state = zk_conn.get('/nodes/{}/domainstate'.format(hypervisor))[0].decode('ascii')
|
||||||
|
|
||||||
|
if hypervisor == current_hypervisor:
|
||||||
|
continue
|
||||||
|
|
||||||
|
if daemon_state != 'run' or domain_state != 'ready':
|
||||||
|
continue
|
||||||
|
|
||||||
|
valid_hypervisor_list.append(hypervisor)
|
||||||
|
|
||||||
|
return valid_hypervisor_list
|
||||||
|
|
||||||
#
|
#
|
||||||
# Find a migration target
|
# Find a migration target
|
||||||
#
|
#
|
||||||
|
|
|
@ -101,30 +101,6 @@ def getInformationFromNode(zk_conn, node_name, long_output):
|
||||||
information = '\n'.join(ainformation)
|
information = '\n'.join(ainformation)
|
||||||
return information
|
return information
|
||||||
|
|
||||||
# Get the list of valid target hypervisors
|
|
||||||
def getHypervisors(zk_conn, dom_uuid):
|
|
||||||
valid_hypervisor_list = []
|
|
||||||
full_hypervisor_list = zk_conn.get_children('/nodes')
|
|
||||||
|
|
||||||
try:
|
|
||||||
current_hypervisor = zk_conn.get('/domains/{}/hypervisor'.format(dom_uuid))[0].decode('ascii')
|
|
||||||
except:
|
|
||||||
current_hypervisor = None
|
|
||||||
|
|
||||||
for hypervisor in full_hypervisor_list:
|
|
||||||
daemon_state = zk_conn.get('/nodes/{}/daemonstate'.format(hypervisor))[0].decode('ascii')
|
|
||||||
domain_state = zk_conn.get('/nodes/{}/domainstate'.format(hypervisor))[0].decode('ascii')
|
|
||||||
|
|
||||||
if hypervisor == current_hypervisor:
|
|
||||||
continue
|
|
||||||
|
|
||||||
if daemon_state != 'run' or domain_state != 'ready':
|
|
||||||
continue
|
|
||||||
|
|
||||||
valid_hypervisor_list.append(hypervisor)
|
|
||||||
|
|
||||||
return valid_hypervisor_list
|
|
||||||
|
|
||||||
#
|
#
|
||||||
# Direct Functions
|
# Direct Functions
|
||||||
#
|
#
|
||||||
|
|
|
@ -202,7 +202,7 @@ def define_vm(zk_conn, config_data, target_hypervisor, selector):
|
||||||
transaction.create('/domains/{}/hypervisor'.format(dom_uuid), target_hypervisor.encode('ascii'))
|
transaction.create('/domains/{}/hypervisor'.format(dom_uuid), target_hypervisor.encode('ascii'))
|
||||||
transaction.create('/domains/{}/lasthypervisor'.format(dom_uuid), ''.encode('ascii'))
|
transaction.create('/domains/{}/lasthypervisor'.format(dom_uuid), ''.encode('ascii'))
|
||||||
transaction.create('/domains/{}/failedreason'.format(dom_uuid), ''.encode('ascii'))
|
transaction.create('/domains/{}/failedreason'.format(dom_uuid), ''.encode('ascii'))
|
||||||
transaction.create('/domains/{}/xml'.format(dom_uuid), data.encode('ascii'))
|
transaction.create('/domains/{}/xml'.format(dom_uuid), config_data.encode('ascii'))
|
||||||
results = transaction.commit()
|
results = transaction.commit()
|
||||||
|
|
||||||
return True, ''
|
return True, ''
|
||||||
|
|
Loading…
Reference in New Issue