diff options
| author | Jonathan Herman <hermanjl@cs.unc.edu> | 2012-11-26 17:06:27 -0500 |
|---|---|---|
| committer | Jonathan Herman <hermanjl@cs.unc.edu> | 2012-11-26 17:06:27 -0500 |
| commit | b43b83beead92ff7cf28a5fe5a2710537268aae1 (patch) | |
| tree | d9c29b14cd18a9df520f36d7e85eb460c30fa7a9 /experiment/executable/executable.py | |
| parent | cb8db5d30ee769304c2c2b00f2a7d9bcb3c4098f (diff) | |
Read locations of binary files from path instead of config.py.
Diffstat (limited to 'experiment/executable/executable.py')
| -rw-r--r-- | experiment/executable/executable.py | 77 |
1 files changed, 0 insertions, 77 deletions
diff --git a/experiment/executable/executable.py b/experiment/executable/executable.py deleted file mode 100644 index 628f711..0000000 --- a/experiment/executable/executable.py +++ /dev/null | |||
| @@ -1,77 +0,0 @@ | |||
| 1 | import sys | ||
| 2 | import subprocess | ||
| 3 | import signal | ||
| 4 | from ..litmus_util import is_executable | ||
| 5 | |||
| 6 | class Executable(object): | ||
| 7 | '''Parent object that represents an executable for use in task-sets.''' | ||
| 8 | |||
| 9 | def __init__(self, exec_file, extra_args=None, stdout_file = None, stderr_file = None): | ||
| 10 | self.exec_file = exec_file | ||
| 11 | self.cwd = None | ||
| 12 | self.stdout_file = stdout_file | ||
| 13 | self.stderr_file = stderr_file | ||
| 14 | self.sp = None | ||
| 15 | |||
| 16 | if extra_args is None: | ||
| 17 | self.extra_args = None | ||
| 18 | else: | ||
| 19 | self.extra_args = list(extra_args) # make a duplicate | ||
| 20 | |||
| 21 | if not is_executable(self.exec_file): | ||
| 22 | raise Exception("Not executable ? : %s" % self.exec_file) | ||
| 23 | |||
| 24 | def __del__(self): | ||
| 25 | # Try and clean up | ||
| 26 | if self.stdout_file is not None: | ||
| 27 | self.stdout_file.close() | ||
| 28 | if self.stderr_file is not None: | ||
| 29 | self.stderr_file.close() | ||
| 30 | |||
| 31 | if self.sp is not None: | ||
| 32 | try: | ||
| 33 | self.sp.terminate() | ||
| 34 | except OSError as e: | ||
| 35 | if e.errno == 3: | ||
| 36 | pass # no such process (already killed), okay | ||
| 37 | else: | ||
| 38 | raise e | ||
| 39 | |||
| 40 | def __get_full_command(self): | ||
| 41 | full_command = [self.exec_file] | ||
| 42 | if self.extra_args is not None: | ||
| 43 | full_command += self.extra_args | ||
| 44 | return full_command | ||
| 45 | |||
| 46 | def __str__(self): | ||
| 47 | return " ".join(self.__get_full_command()) | ||
| 48 | |||
| 49 | def execute(self): | ||
| 50 | '''Execute the binary.''' | ||
| 51 | full_command = self.__get_full_command() | ||
| 52 | self.sp = subprocess.Popen(full_command, stdout=self.stdout_file, | ||
| 53 | stderr=self.stderr_file, cwd=self.cwd) | ||
| 54 | |||
| 55 | def kill(self): | ||
| 56 | self.sp.kill() | ||
| 57 | |||
| 58 | def interrupt(self): | ||
| 59 | self.sp.send_signal(signal.SIGINT) | ||
| 60 | |||
| 61 | def terminate(self): | ||
| 62 | '''Send the terminate signal to the binary.''' | ||
| 63 | self.sp.terminate() | ||
| 64 | |||
| 65 | def wait(self): | ||
| 66 | '''Wait until the executable is finished, checking return code. | ||
| 67 | |||
| 68 | If the exit status is non-zero, raise an exception. | ||
| 69 | |||
| 70 | ''' | ||
| 71 | |||
| 72 | self.sp.wait() | ||
| 73 | if self.sp.returncode != 0: | ||
| 74 | print >>sys.stderr, "Non-zero return: %s %s" % (self.exec_file, " ".join(self.extra_args)) | ||
| 75 | return 0 | ||
| 76 | else: | ||
| 77 | return 1 | ||
