Refactor to get rid of various frontend scripts

Now, unit-trace.py can control all functionality.

3 files changed, 0 insertions, 225 deletions

diff --git a/scripts/gedf_test.py b/scripts/gedf_test.py
deleted file mode 100755
index 2f67bc0..0000000
--- a/scripts/gedf_test.py
+++ /dev/null
@@ -1,73 +0,0 @@
-#!/usr/bin/python
-
-################################################################################
-# Description
-################################################################################
-# This script performs a G-EDF test and outputs the results to std out.
-
-# This script should be invoked with the names of the trace files you want to
-# use. For example, `gedf_test.py ../sample_traces/*.bin`.
-# You probably want to redirect the (normally lengthy) output to a file!
-# Otherwise, speed is greatly decreased b/c terminal printing is slow.
-
-################################################################################
-# Setup
-################################################################################
-
-# Import the modules we need. You should not need to know about
-# their internals.
-import unit_trace
-from unit_trace import trace_reader
-from unit_trace import sanitizer
-from unit_trace import gedf_test
-from unit_trace import stats
-from unit_trace import stdout_printer
-from unit_trace import visualizer
-from unit_trace import progress
-
-# Get trace files from command line arguments
-from optparse import OptionParser
-usage = "usage: %prog <one or more trace files>"
-parser = OptionParser(usage=usage)
-(options, traces) = parser.parse_args()
-traces = list(traces)
-if len(traces) < 1:
-    parser.print_help()
-    exit()
-
-################################################################################
-# Pipeline
-################################################################################
-
-# Read events from traces
-stream = trace_reader.trace_reader(traces)
-
-# Filter out garbage events
-stream = sanitizer.sanitizer(stream)
-
-# Display progress information using stderr
-# e.g. # records completed so far, total time, etc.
-stream = progress.progress(stream)
-
-# Produce G-EDF error records
-stream = gedf_test.gedf_test(stream)
-
-# Produce a statistics record
-stream = stats.stats(stream)
-
-# Filter some records out
-def my_filter(record):
-    if record.record_type == 'error' and record.type_name == 'inversion_end':
-        if record.job.inversion_end - record.job.inversion_start < 4000000:
-            return False
-    return True
-#stream = filter(my_filter, stream)
-
-# It is possible to split the stream in two, 
-# so we can use more than one output mechanism (for example)
-# without re-doing earlier work.
-# import itertools
-# stream1, stream2 = itertools.tee(stream,2)
-
-# Print the records to stdout
-stdout_printer.stdout_printer(stream)
diff --git a/scripts/unit-trace.py b/scripts/unit-trace.py
deleted file mode 100755
index 5d772e8..0000000
--- a/scripts/unit-trace.py
+++ /dev/null
@@ -1,100 +0,0 @@
-#!/usr/bin/python
-
-################################################################################
-# Description
-################################################################################
-# Control script for unit-trace
-
-################################################################################
-# Setup
-################################################################################
-
-# Import the modules we need. You should not need to know about
-# their internals.
-import unit_trace
-from unit_trace import trace_reader
-from unit_trace import sanitizer
-from unit_trace import gedf_test
-from unit_trace import stats
-from unit_trace import stdout_printer
-from unit_trace import visualizer
-from unit_trace import progress
-from unit_trace import skipper
-from unit_trace import maxer
-
-# Get trace files from command line arguments
-from optparse import OptionParser
-usage = "usage: %prog [options] <one or more trace files>"
-parser = OptionParser(usage=usage)
-parser.add_option("-s", "--skip", dest="skipnum", default=0, type=int,
-    help="Skip over a fixed number of records")
-parser.add_option("-m", "--max", dest="maxnum", default=0, type=int,
-    help="Maximum number of records to parse")
-parser.add_option("-p", "--progress", action="store_true", dest="progress",
-    default=False, help="Show parsing progress")
-parser.add_option("-g", "--gedf", action="store_true", dest="gedf",
-    default=False, help="Run G-EDF test")
-parser.add_option("-i", "--info", action="store_true", dest="info",
-    default=False, help="Show statistical info")
-parser.add_option("-o", "--stdout", action="store_true", dest="stdout",
-    default=False, help="Use stdout_printer")
-parser.add_option("-v", "--visual", action="store_true", dest="visualize",
-    default=False, help="Use visualizer")
-parser.add_option("-c", "--clean", action="store_true", dest="clean",
-    default=False, help="Use sanitizer to clean garbage records")
-(options, traces) = parser.parse_args()
-traces = list(traces)
-if len(traces) < 1:
-    parser.print_help()
-    exit()
-
-################################################################################
-# Pipeline
-################################################################################
-
-# Read events from traces
-stream = trace_reader.trace_reader(traces)
-
-# Skip over records
-if options.skipnum > 0:
-    stream = skipper.skipper(stream, options.skipnum)
-
-# Enforce max number of records to parse
-if options.maxnum > 0:
-    stream = maxer.maxer(stream, options.maxnum)
-
-# Filter out garbage events
-if options.clean is True:
-    stream = sanitizer.sanitizer(stream)
-
-# Display progress information using stderr
-# e.g. # records completed so far, total time, etc.
-if options.progress is True:
-    stream = progress.progress(stream)
-
-# Produce G-EDF error records
-if options.gedf is True:
-    stream = gedf_test.gedf_test(stream)
-
-# Produce a statistics record
-if options.info is True:
-    stream = stats.stats(stream)
-
-# Filter some records out
-#def my_filter(record):
-#    if record.record_type == 'error' and record.type_name == 'inversion_end':
-#        if record.job.inversion_end - record.job.inversion_start < 4000000:
-#            return False
-#    return True
-#stream = filter(my_filter, stream)
-
-# Output
-if options.stdout is True and options.visualize is True:
-    import itertools
-    stream1, stream2 = itertools.tee(stream,2)
-    stdout_printer.stdout_printer(stream1)
-    visualizer.visualizer(stream2) 
-elif options.stdout is True:
-    stdout_printer.stdout_printer(stream)
-elif options.visualize is True:
-    visualizer.visualizer(stream)
diff --git a/scripts/visualize.py b/scripts/visualize.py
deleted file mode 100755
index 2899b43..0000000
--- a/scripts/visualize.py
+++ /dev/null
@@ -1,52 +0,0 @@
-#!/usr/bin/python
-
-################################################################################
-# Description
-################################################################################
-# This scriipt demonstrates the visualizer submodule.
-
-# This script should be invoked with the names of the trace files you want to
-# use. For example, `gedf_test.py ../sample_traces/*.bin`.
-# You probably want to redirect the (normally lengthy) output to a file!
-# Otherwise, speed is greatly decreased b/c terminal printing is slow.
-
-################################################################################
-# Setup
-################################################################################
-
-# Import the modules we need. You should not need to know about
-# their internals.
-import unit_trace
-from unit_trace import trace_reader
-from unit_trace import sanitizer
-from unit_trace import gedf_test
-from unit_trace import stats
-from unit_trace import stdout_printer
-from unit_trace import visualizer
-
-# Get trace files from command line arguments
-from optparse import OptionParser
-usage = "usage: %prog <one or more trace files>"
-parser = OptionParser(usage=usage)
-(options, traces) = parser.parse_args()
-traces = list(traces)
-if len(traces) < 1:
-    parser.print_help()
-    exit()
-
-################################################################################
-# Pipeline
-################################################################################
-
-# Read events from traces
-stream = trace_reader.trace_reader(traces)
-
-# Filter out garbage events
-stream = sanitizer.sanitizer(stream)
-
-# Note: You could include other submodules, to further modify
-# the event stream (e.g. produce G-EDF error records that could be
-# drawn by the visuazlier in future versions).
-
-# Print the records to stdout
-visualizer.visualizer(stream)