Document script that runs distributed orbit

README.md

@@ -106,6 +106,35 @@ Python 2.x is needed in order to run the scripts.
   
   ```
 
+- Distributed Orbit
+  ```bash
+  python dist.py
+  ```
+  
+  Variables that can be tweaked with their default values.
+  ```python
+  # Path to the file that will hold the results.
+  fname = 'dist.log'
+  # Number of repetitions per configuration.
+  reps = 1
+  # List of versions.
+  versions = ["short", "intermediate", "long"]
+  # Perform parallel image computations.
+  iwps = [False, True]
+  # No of cores used by each worker node.
+  cores = [1]
+  # Ratio of No of workers to No of cores in each worker node.
+  workersPerCore = 1
+  # Master node information
+  master = {"host": "127.0.0.1", "port": 5050}
+  # Maximum number of workers nodes
+  maxSlaves = 60
+  # No of workers nodes to add after each iteration
+  step = 2
+  # Port of the 1st worker node (Assume that the host will be localhost).
+  workerPort = 5051
+  ```
+
 Memory Profiling
 ----------------
 

dist.py

@@ -4,6 +4,7 @@
 from __future__ import print_function
 import sys, subprocess, time, os.path
 
+# Path to the file that will hold the results.
 fname = 'dist.log'
 fexists = os.path.isfile(fname)
 if fexists:
@@ -19,15 +20,30 @@ def print_all(s):
   f.flush()
   print (s, file=sys.stdout)
 
+# Number of repetitions per configuration.
 reps = 1
+# List of versions.
 versions = ["short", "intermediate", "long"]
+# Perform parallel image computations.
 iwps = [False, True]
+# No of cores used by each worker node.
 cores = [1]
+# Ratio of No of workers to No of cores in each worker node.
 workersPerCore = 1
+# Master node information
 master = {"host": "127.0.0.1", "port": 5050}
+# Maximum number of workers nodes
+maxSlaves = 60
+# No of workers nodes to add after each iteration
+step = 2
+# Port of the 1st worker node (Assume that the host will be localhost).
+workerPort = 5051
+allAvailableSlaves = []
+for port in range(workerPort, workerPort+maxSlaves):
+  allAvailableSlaves.append({"host": "127.0.0.1", "port": port})
 slaves = []
-for port in range(5051, 5051+64):
-  slaves.append({"host": "127.0.0.1", "port": port})
+for n in range(2, maxSlaves+1, step):
+  slaves.append(allAvailableSlaves[0:n])
 
 if len(ls) == 0: 
   print_all("Parallel Orbit")
@@ -38,17 +54,17 @@ if len(ls) == 0:
   print_all("Using Cores: %s" % cores)
   print_all("Workers Per Core: %s" % workersPerCore)
   print_all("Master @ %s" % master)
-  print_all("Slaves @ %s" % slaves)
+  print_all("Slaves @ %s" % [len(xs) for xs in slaves])
   print_all("======================================================================")
 
 
 for iwp in iwps:
   for vsn in versions:
-    for n in range(2, 60+1, 2):
+    for slvs in slaves:
       for core in cores:
         for rep in range(reps):
           workers = workersPerCore * core
-          slvs = slaves[0:n]
+          n = len(slvs)
           l = "Slaves: %s, Version: %s, IWP: %s, Cores: %s, Workers: %s, Execution: %s" % (n, vsn, iwp, core, workers, rep)
           if l in ls:
             continue