Created run_exps.py script.

Currently poorly documented.

14 files changed, 738 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..7c62cf4
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,4 @@
+*~
+\#*#
+*.pyc
+.ropeproject*
\ No newline at end of file
diff --git a/__init__.py b/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/__init__.py
diff --git a/config/__init__.py b/config/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/config/__init__.py
diff --git a/config/config.example.py b/config/config.example.py
new file mode 100644
index 0000000..5176460
--- /dev/null
+++ b/config/config.example.py
@@ -0,0 +1,46 @@
+from __future__ import print_function
+import os
+import sys
+
+REPOS = {'liblitmus'   : '/home/hermanjl/git/liblitmus',
+         'sched_trace' : '/home/hermanjl/git/sched_trace',
+         'analysis'    : '/home/hermanjl/git/overhead-analysis-cjk',
+         'ft_tools'    : '/home/hermanjl/git/ft_tools/ftcat',
+         'trace-cmd'   : '/home/hermanjl/git/trace-cmd'}
+
+BINS = {'bespin'    : '{}/bespin'.format(REPOS['liblitmus']),
+        'colorspin' : '{}/colorspin'.format(REPOS['liblitmus']),
+        'rtspin'    : '{}/rtspin'.format(REPOS['liblitmus']),
+        'release'   : '{}/release_ts'.format(REPOS['liblitmus']),
+        'ftcat'     : '{}/ftcat'.format(REPOS['ft_tools']),
+        'st_trace'  : '{}/st_trace'.format(REPOS['ft_tools']),
+        'split'     : '{}/split'.format(REPOS['analysis']),
+        'sort'      : '{}/sort-all'.format(REPOS['analysis']),
+        'analyze'   : '{}/analyze'.format(REPOS['analysis']),
+        'trace-cmd' : '{}/trace-cmd'.format(REPOS['trace-cmd'])}
+
+DEFAULTS = {'params_file' : 'params.py',
+            'sched_file'  : 'sched.py',
+            'exps_file'   : 'exps.py',
+            'duration'    : '10',
+            'spin'                : 'rtspin'}
+
+FILES = {'ft_data'    : 'ft.bin',
+         'linux_data' : 'trace.dat',
+         'sched_data' : 'st-{}.bin',
+         'log_data'   : 'trace.slog'}
+
+PARAMS = {'sched' : 'scheduler',
+          'dur'   : 'duration'}
+
+valid = True
+for repo, loc in REPOS.items():
+    if not os.path.isdir(loc):
+        valid = False
+        print("Cannot access repo '%s' at '%s'" % (repo, loc), file=sys.stderr)
+for prog, loc in BINS.items():
+    if not os.path.isfile(loc):
+        valid = False
+        print("Cannot access program '%s' at '%s'" % (prog, loc), file=sys.stderr)
+if not valid:
+    print("Errors in config file", file=sys.stderr)
diff --git a/config/config.py b/config/config.py
new file mode 100644
index 0000000..5176460
--- /dev/null
+++ b/config/config.py
@@ -0,0 +1,46 @@
+from __future__ import print_function
+import os
+import sys
+
+REPOS = {'liblitmus'   : '/home/hermanjl/git/liblitmus',
+         'sched_trace' : '/home/hermanjl/git/sched_trace',
+         'analysis'    : '/home/hermanjl/git/overhead-analysis-cjk',
+         'ft_tools'    : '/home/hermanjl/git/ft_tools/ftcat',
+         'trace-cmd'   : '/home/hermanjl/git/trace-cmd'}
+
+BINS = {'bespin'    : '{}/bespin'.format(REPOS['liblitmus']),
+        'colorspin' : '{}/colorspin'.format(REPOS['liblitmus']),
+        'rtspin'    : '{}/rtspin'.format(REPOS['liblitmus']),
+        'release'   : '{}/release_ts'.format(REPOS['liblitmus']),
+        'ftcat'     : '{}/ftcat'.format(REPOS['ft_tools']),
+        'st_trace'  : '{}/st_trace'.format(REPOS['ft_tools']),
+        'split'     : '{}/split'.format(REPOS['analysis']),
+        'sort'      : '{}/sort-all'.format(REPOS['analysis']),
+        'analyze'   : '{}/analyze'.format(REPOS['analysis']),
+        'trace-cmd' : '{}/trace-cmd'.format(REPOS['trace-cmd'])}
+
+DEFAULTS = {'params_file' : 'params.py',
+            'sched_file'  : 'sched.py',
+            'exps_file'   : 'exps.py',
+            'duration'    : '10',
+            'spin'                : 'rtspin'}
+
+FILES = {'ft_data'    : 'ft.bin',
+         'linux_data' : 'trace.dat',
+         'sched_data' : 'st-{}.bin',
+         'log_data'   : 'trace.slog'}
+
+PARAMS = {'sched' : 'scheduler',
+          'dur'   : 'duration'}
+
+valid = True
+for repo, loc in REPOS.items():
+    if not os.path.isdir(loc):
+        valid = False
+        print("Cannot access repo '%s' at '%s'" % (repo, loc), file=sys.stderr)
+for prog, loc in BINS.items():
+    if not os.path.isfile(loc):
+        valid = False
+        print("Cannot access program '%s' at '%s'" % (prog, loc), file=sys.stderr)
+if not valid:
+    print("Errors in config file", file=sys.stderr)
diff --git a/experiment/__init__.py b/experiment/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/experiment/__init__.py
diff --git a/experiment/executable/__init__.py b/experiment/executable/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/experiment/executable/__init__.py
diff --git a/experiment/executable/executable.py b/experiment/executable/executable.py
new file mode 100644
index 0000000..6697a8d
--- /dev/null
+++ b/experiment/executable/executable.py
@@ -0,0 +1,71 @@
+import sys
+import subprocess
+import signal
+from ..litmus_util import is_executable
+
+class Executable(object):
+    """Parent object that represents an executable for use in task-sets."""
+
+    def __init__(self, exec_file, extra_args=None, stdout_file = None, stderr_file = None):
+        self.exec_file = exec_file
+        self.cwd = None
+        self.stdout_file = stdout_file
+        self.stderr_file = stderr_file
+        self.sp = None
+
+        if extra_args is None:
+            self.extra_args = None
+        else:
+            self.extra_args = list(extra_args) # make a duplicate
+
+        if not is_executable(self.exec_file):
+            raise Exception("Not executable ? : %s" % self.exec_file)
+
+    def __del__(self):
+        # Try and clean up
+        if self.stdout_file is not None:
+            self.stdout_file.close()
+        if self.stderr_file is not None:
+            self.stderr_file.close()
+
+        if self.sp is not None:
+            try:
+                self.sp.terminate()
+            except OSError as e:
+                if e.errno == 3:
+                    pass # no such process (already killed), okay
+                else:
+                    raise e
+
+    def __get_full_command(self):
+        full_command = [self.exec_file]
+        if self.extra_args is not None:
+            full_command += self.extra_args
+        return full_command
+
+    def execute(self):
+        """Execute the binary."""
+        full_command = self.__get_full_command()
+        self.sp = subprocess.Popen(full_command, stdout=self.stdout_file,
+                stderr=self.stderr_file, cwd=self.cwd)
+
+    def kill(self):
+        self.sp.kill()
+
+    def interrupt(self):
+        self.sp.send_signal(signal.SIGINT)
+
+    def terminate(self):
+        """Send the terminate signal to the binary."""
+        self.sp.terminate()
+
+    def wait(self):
+        """Wait until the executable is finished, checking return code.
+
+        If the exit status is non-zero, raise an exception.
+
+        """
+
+        self.sp.wait()
+        if self.sp.returncode != 0:
+            print >>sys.stderr, "Non-zero return: %s %s" % (self.exec_file, self.extra_args)
diff --git a/experiment/executable/ftcat.py b/experiment/executable/ftcat.py
new file mode 100644
index 0000000..9966312
--- /dev/null
+++ b/experiment/executable/ftcat.py
@@ -0,0 +1,33 @@
+import os
+import stat
+
+from executable import Executable
+
+class FTcat(Executable):
+    """Used to wrap the ftcat binary in the Experiment object."""
+
+    def __init__(self, ft_cat_bin, stdout_file, stderr_file, dev, events, cpu=None):
+        """Extends the Executable initializer method with ftcat attributes."""
+