Skip to content

Commit

Permalink
Do not suppress output & Disregard executions with 1 worker node
Browse files Browse the repository at this point in the history
  • Loading branch information
aggelgian committed Jan 16, 2015
1 parent f3c7728 commit 633e172
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions single_dist.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ def print_all(s):
for port in range(workerPort, workerPort+maxSlaves):
allAvailableSlaves.append({"host": "127.0.0.1", "port": port})
slaves = []
for n in [1] + range(2, maxSlaves+1, step):
for n in range(2, maxSlaves+1, step):
slaves.append(allAvailableSlaves[0:n])

if len(ls) == 0:
Expand Down Expand Up @@ -71,11 +71,11 @@ def print_all(s):
print_all("Slaves: %s, Version: %s, IWP: %s, Cores: %s, Workers: %s, Execution: %s" % (n, vsn, iwp, core, workers, rep))
time.sleep(2)
for slv in slvs:
cmd = "./orbit +RTS -N%s -RTS dist slave %s %s > /dev/null" % (core, slv["host"], slv["port"])
cmd = "./orbit +RTS -N%s -RTS dist slave %s %s" % (core, slv["host"], slv["port"])
prcs = subprocess.Popen(cmd, shell=True)
time.sleep(2)
t1 = time.time()
cmd = "./orbit +RTS -N1 -RTS dist master %s %s %s %s %s > /dev/null" % (iwp, vsn, workers, master["host"], master["port"])
cmd = "./orbit +RTS -N1 -RTS dist master %s %s %s %s %s" % (iwp, vsn, workers, master["host"], master["port"])
p = subprocess.Popen(cmd, shell=True)
p.wait()
t2 = time.time()
Expand Down

0 comments on commit 633e172

Please sign in to comment.