diff options
Diffstat (limited to 'scripts/visualize.py')
-rwxr-xr-x | scripts/visualize.py | 22 |
1 files changed, 3 insertions, 19 deletions
diff --git a/scripts/visualize.py b/scripts/visualize.py index 2b828be..5685d1a 100755 --- a/scripts/visualize.py +++ b/scripts/visualize.py | |||
@@ -40,25 +40,9 @@ stream = trace_reader.trace_reader(traces) | |||
40 | # Filter out garbage events | 40 | # Filter out garbage events |
41 | stream = sanitizer.sanitizer(stream) | 41 | stream = sanitizer.sanitizer(stream) |
42 | 42 | ||
43 | # Produce G-EDF error records | 43 | # Note: You could include other submodules, to further modify |
44 | stream = gedf_test.gedf_test(stream) | 44 | # the event stream (e.g. produce G-EDF error records that could be |
45 | 45 | # drawn by the visuazlier in future versions). | |
46 | # Produce a statistics record | ||
47 | stream = stats.stats(stream) | ||
48 | |||
49 | # Filter some records out | ||
50 | def my_filter(record): | ||
51 | if record.record_type == 'error' and record.type_name == 'inversion_end': | ||
52 | if record.job.inversion_end - record.job.inversion_start < 4000000: | ||
53 | return False | ||
54 | return True | ||
55 | #stream = filter(my_filter, stream) | ||
56 | |||
57 | # It is possible to split the stream in two, | ||
58 | # so we can use more than one output mechanism (for example) | ||
59 | # without re-doing earlier work. | ||
60 | # import itertools | ||
61 | # stream1, stream2 = itertools.tee(stream,2) | ||
62 | 46 | ||
63 | # Print the records to stdout | 47 | # Print the records to stdout |
64 | visualizer.visualizer(stream) | 48 | visualizer.visualizer(stream) |