X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=coresched_vs.py;h=06aeb547b0ce4b51a994eabf2d0ec35c010f12fc;hb=ac6786141feadccdc48b819ab21a825a54881ded;hp=774eb30448a09cdf091f7cac729bc32192117152;hpb=1b4f53e648b13f7629970787b6ec03387e2d966a;p=nodemanager.git diff --git a/coresched_vs.py b/coresched_vs.py index 774eb30..06aeb54 100644 --- a/coresched_vs.py +++ b/coresched_vs.py @@ -173,7 +173,7 @@ class CoreSched: lastCpu = cpu logger.log("CoreSched: allocating unit " + str(cpu) + " to slice " + name) - reservations[name] = reservations.get(name,[]) + [cpu] + reservations[name] = reservations.get(name, []) + [cpu] # now find a memory node to go with the cpu if memSchedule: @@ -181,7 +181,7 @@ class CoreSched: if mem != None: mems.remove(mem) logger.log("CoreSched: allocating memory node " + str(mem) + " to slice " + name) - mem_reservations[name] = mem_reservations.get(name,[]) + [mem] + mem_reservations[name] = mem_reservations.get(name, []) + [mem] else: logger.log("CoreSched: failed to find memory node for cpu" + str(cpu)) @@ -206,9 +206,9 @@ class CoreSched: # note that if a reservation is [], then we don't need to add # bestEffort cores to it, since it is bestEffort by default. - if reservations.get(name,[]) != []: + if reservations.get(name, []) != []: reservations[name] = reservations[name] + reservations["_default"] - mem_reservations[name] = mem_reservations.get(name,[]) + mem_reservations["_default"] + mem_reservations[name] = mem_reservations.get(name, []) + mem_reservations["_default"] logger.log("CoreSched: adding besteffort units to " + name + ". new units = " + str(reservations[name])) self.reserveUnits(self.cgroup_var_name, reservations) @@ -295,7 +295,7 @@ class CoreSched: if mems_map[self.mems[0]] == []: work = [] for item in reversed(self.mems): - if mems_map[item]!=[]: + if mems_map[item] != []: work = mems_map[item] else: # mems_map[item]==[] mems_map[item] = work @@ -332,7 +332,8 @@ class CoreSched: return [] siblings = [] - x = int(open(fn,"rt").readline().strip(),16) + with open(fn, "rt") as f: + x = int(f.readline().strip(), 16) cpuid = 0 while (x>0): if (x&1)!=0: @@ -354,12 +355,12 @@ if __name__=="__main__": print "cpus:", x.listToRange(x.get_cpus()) print "sibling map:" for item in x.get_cpus(): - print " ", item, ",".join([str(y) for y in x.cpu_siblings.get(item,[])]) + print " ", item, ",".join([str(y) for y in x.cpu_siblings.get(item, [])]) print "mems:", x.listToRange(x.get_mems()) print "cpu to memory map:" for item in x.get_mems(): - print " ", item, ",".join([str(y) for y in x.mems_map.get(item,[])]) + print " ", item, ",".join([str(y) for y in x.mems_map.get(item, [])]) rspec_sl_test1 = {"cpu_cores": "1"} rec_sl_test1 = {"_rspec": rspec_sl_test1}