78 lines
3.1 KiB
Python
78 lines
3.1 KiB
Python
#!/bin/env python
|
|
import sys
|
|
sys.path.append("../../src/")
|
|
|
|
import time
|
|
|
|
sys.setrecursionlimit(10000)
|
|
|
|
loads = range(5000, 30000, 1000)
|
|
termination_time = 200
|
|
iters = int(sys.argv[1])
|
|
|
|
import subprocess
|
|
output = open('/tmp/output', 'w')
|
|
for nodes, models in [(5, 150), (50, 900)]:
|
|
for relocator in [True, False]:
|
|
f = open("dist_activity_synthetic/result_%i_%s" % (nodes, relocator), 'w')
|
|
for load in loads:
|
|
f.write(str(load))
|
|
for _ in range(iters):
|
|
command = "mpirun -np %i -machinefile ~/machines python dist_activity_synthetic/movingcircle.py %i %i %i %s"
|
|
command = (command % (nodes, models, load, termination_time, relocator))
|
|
start = time.time()
|
|
subprocess.check_output(command, shell=True, stderr=output)
|
|
f.write(" %s" % (time.time() - start))
|
|
print("%i %s" % (load, time.time() - start))
|
|
f.write("\n")
|
|
f.close()
|
|
f = open("dist_activity_synthetic/result_%i_local" % nodes, 'w')
|
|
for load in loads:
|
|
f.write(str(load))
|
|
for _ in range(iters):
|
|
command = "python dist_activity_synthetic/movingcircle.py %i %i %i False"
|
|
command = (command % (models, load, termination_time))
|
|
start = time.time()
|
|
subprocess.check_output(command, shell=True, stderr=output)
|
|
f.write(" %s" % (time.time() - start))
|
|
print("%i %s" % (load, time.time() - start))
|
|
f.write("\n")
|
|
f.close()
|
|
|
|
for relocator in [True, False]:
|
|
load = 10000
|
|
models = 1500
|
|
termination_time = 200
|
|
f = open("dist_activity_synthetic/result_nodes_%s" % relocator, 'w')
|
|
for nodes in range(3, 50):
|
|
for _ in range(iters):
|
|
command = "mpirun -np %i -machinefile ~/machines python dist_activity_synthetic/movingcircle.py %i %i %i %s"
|
|
command = (command % (nodes, models, load, termination_time, relocator))
|
|
start = time.time()
|
|
subprocess.check_output(command, shell=True, stderr=output)
|
|
f.write(" %s" % (time.time() - start))
|
|
print("%i %s" % (nodes, time.time() - start))
|
|
f.write("\n")
|
|
f.close()
|
|
f = open("dist_activity_synthetic/result_nodes_local", 'w')
|
|
f.write("1")
|
|
for _ in range(iters):
|
|
command = "python dist_activity_synthetic/movingcircle.py %i %i %i False"
|
|
command = (command % (models, load, termination_time))
|
|
start = time.time()
|
|
subprocess.check_output(command, shell=True, stderr=output)
|
|
f.write(" %s" % (time.time() - start))
|
|
print("1 %s" % (time.time() - start))
|
|
f.write("\n")
|
|
f.close()
|
|
|
|
for relocator in [True, False]:
|
|
try:
|
|
import os
|
|
os.remove("activity-log")
|
|
except OSError:
|
|
pass
|
|
# Put the load rather high, to create a nice 'bad' distribution
|
|
subprocess.check_output("mpirun -np 3 -machinefile ~/machines python dist_activity_synthetic/movingcircle.py 100 30000 400 " + str(relocator), shell=True, stderr=output)
|
|
import shutil
|
|
shutil.move("activity-log", "dist_activity_synthetic/activity-log_" + str("AT" if relocator else "NO"))
|