Merge branch 'wip-ecrts14-pgm' of ssh://rtsrv.cs.unc.edu/home/litmus/experiment-scripts into wip-ecrts14-pgm

1 files changed, 3 insertions, 3 deletions

diff --git a/parse/sched.py b/parse/sched.py
index d773c8a..83004f2 100644
--- a/parse/sched.py
+++ b/parse/sched.py
@@ -13,7 +13,7 @@ from heapq import *
 
 class TimeTracker:
     '''Store stats for durations of time demarcated by sched_trace records.'''
-    def __init__(self, is_valid_duration = lambda x: True, delay_buffer_size = 1, max_pending = 100):
+    def __init__(self, is_valid_duration = lambda x: True, delay_buffer_size = 1, max_pending = -1):
         self.validator = is_valid_duration
         self.avg = self.max = self.num = 0
 
@@ -51,13 +51,13 @@ class TimeTracker:
         # Give up on some jobs if they've been hanging around too long.
         # While not strictly needed, it helps improve performance and
         # it is unlikey to cause too much trouble.
-        if(len(self.start_records) > self.max_pending):
+        if(self.max_pending >= 0 and len(self.start_records) > self.max_pending):
             to_discard = len(self.start_records) - self.max_pending
             for i in range(to_discard):
                 # pop off the oldest jobs
                 del self.start_records[self.start_records.iterkeys().next()]
             self.discarded += to_discard
-        if(len(self.end_records) > self.max_pending):
+        if(self.max_pending >= 0 and len(self.end_records) > self.max_pending):
             to_discard = len(self.end_records) - self.max_pending
             for i in range(to_discard):
                 # pop off the oldest jobs