parallelvirtualcluster
/
pvc
1
0
Fork 0
Code Issues 11 Pull Requests Projects Releases 111 Wiki Activity

Parse the node_list as t_node array of objects for easy resouce passing

This commit is contained in:
Joshua Boniface 2018-06-04 01:52:26 -04:00
parent 285b4434b7
commit 55ebbea6cf
2 changed files with 18 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
NodeInstance.py
View File

@ -3,7 +3,7 @@
import os, sys, socket, time, threading, libvirt, kazoo.client, pvcf import os, sys, socket, time, threading, libvirt, kazoo.client, pvcf
class NodeInstance(threading.Thread): class NodeInstance(threading.Thread):
def __init__(self, name, node_list, s_domain, zk): def __init__(self, name, t_node, s_domain, zk):
super(NodeInstance, self).__init__() super(NodeInstance, self).__init__()
# Passed-in variables on creation # Passed-in variables on creation
self.zkey = '/nodes/%s' % name self.zkey = '/nodes/%s' % name
@ -11,7 +11,7 @@ class NodeInstance(threading.Thread):
self.name = name self.name = name
self.state = 'stop' self.state = 'stop'
self.stop_thread = threading.Event() self.stop_thread = threading.Event()
self.node_list = node_list self.t_node = t_node
self.s_domain = s_domain self.s_domain = s_domain
self.domain_list = [] self.domain_list = []
@ -45,8 +45,8 @@ class NodeInstance(threading.Thread):
return self.domain_list return self.domain_list
# Update value functions # Update value functions
def updatenodelist(self, node_list): def updatenodelist(self, t_node):
self.node_list = node_list self.t_node = t_node
def updatedomainlist(self, s_domain): def updatedomainlist(self, s_domain):
self.s_domain = s_domain self.s_domain = s_domain
@ -58,11 +58,12 @@ class NodeInstance(threading.Thread):
# Flush all VMs on the host # Flush all VMs on the host
def flush(self): def flush(self):
for domain in self.domain_list: for domain in self.domain_list:
print(domain)
# Determine the best target hypervisor # Determine the best target hypervisor
least_mem = (2^64)/8 least_mem = (2^64)/8
least_load = 999.0 least_load = 999.0
least_host = "" least_host = ""
for node in node_list: for node in self.t_node:
node_freemem = node.getfreemem() node_freemem = node.getfreemem()
if node_freemem < least_mem: if node_freemem < least_mem:
least_mem = node_freemem least_mem = node_freemem
@ -135,16 +136,17 @@ class NodeInstance(threading.Thread):
flushed_node_list = [] flushed_node_list = []
inactive_node_list = [] inactive_node_list = []
for node in self.node_list: for node in self.t_node:
#node_state = t_node[node].getstate() node_name = node.getname()
state, stat = self.zk.get('/nodes/%s/state' % node) state, stat = self.zk.get('/nodes/%s/state' % node_name)
node_state = state.decode('ascii') node_state = state.decode('ascii')
if node_state == 'start': if node_state == 'start':
active_node_list.append(node) active_node_list.append(node_name)
elif node_state == 'flush': elif node_state == 'flush':
flushed_node_list.append(node) flushed_node_list.append(node_name)
self.flush()
else: else:
inactive_node_list.append(node) inactive_node_list.append(node_name)
print('Active nodes: %s' % active_node_list) print('Active nodes: %s' % active_node_list)
print('Flushed nodes: %s' % flushed_node_list) print('Flushed nodes: %s' % flushed_node_list)

7
pvcd.py
View File

@ -75,12 +75,15 @@ def updatenodes(new_node_list):
print('Node list: %s' % node_list) print('Node list: %s' % node_list)
for node in node_list: for node in node_list:
if node in t_node: if node in t_node:
t_node[node].updatenodelist(node_list) t_node[node].updatenodelist(t_node)
else: else:
t_node[node] = NodeInstance.NodeInstance(node, node_list, s_domain, zk); t_node[node] = NodeInstance.NodeInstance(node, t_node, s_domain, zk);
if node == myhostname: if node == myhostname:
t_node[node].start() t_node[node].start()
time.sleep(0.2) time.sleep(0.2)
for node in node_list:
if node in t_node:
t_node[node].updatenodelist(t_node)
@zk.ChildrenWatch('/domains') @zk.ChildrenWatch('/domains')
def updatedomains(new_domain_list): def updatedomains(new_domain_list):