Commit 5a8cd90f authored by Paul Rich's avatar Paul Rich
Browse files

fixing accidental bypass of ready check

parent 14d9f76d
......@@ -63,7 +63,15 @@ def dict_to_keyval_str(dct):
def get_current_modes(node_list):
'''Fetch the current memory mode of the listed nodes
node_list - A list of nodes to fetch current information for.
May be cray compact notation
A dictonary of the requested nids. The value is dictonary of MCDRAM and NUMA
modes tuple.
# Short of going out to the nodes and reading secret sauce in /proc we are
# assuming that the nodes mode have not been changed for the next reboot
# (i.e. that this script and the scheduler are the only things changing
......@@ -73,7 +81,7 @@ def get_current_modes(node_list):
# The moral of this story: Do not change the memory mode unless the next
# thing you do is reboot the node.
exp_nodelist = expand_num_list(node_list)
#exp_nodelist = expand_num_list(node_list)
node_cfgs = {}
mcdram_raw_info, err = exec_fetch_output(CAPMC_CMD, ['get_mcdram_cfg',
......@@ -106,13 +114,13 @@ def exec_fetch_output(cmd, args, timeout=None):
proc = Popen(cmd_list, stdout=PIPE, stderr=PIPE)
stdout = ""
stderr = ""
while True:
curr_stdout, curr_stderr = proc.communicate()
stdout += curr_stdout
stderr += curr_stderr
if endtime is not None and int(time.time()) >= endtime:
#signal and kill
timeout_trip = True
#check to see if the process has terminated.
......@@ -182,11 +190,11 @@ def reboot_complete(node_list, timeout, label):
node_info = json.loads(stdout)
if 'ready' not in node_info.keys():
elif not set(node_info['ready']) - set(exp_nodelist):
if not set(node_info['ready']) - set(exp_nodelist):
time.sleep(1.0)'%s: Reboot of nodes %s complete', label, node_list)'%s: Reboot of nodes %s complete', label, node_list)
return True
def main():
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment