12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879 |
- #!/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"))
|