[Checkins] SVN: zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/readonlyreplay.py Option to control how often to output reports.

[Jim Fulton]

Log message for revision 122595:
  Option to control how often to output reports.
  

Changed:
  U   zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/readonlyreplay.py

-=-
Modified: zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/readonlyreplay.py
===================================================================
--- zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/readonlyreplay.py	2011-08-15 11:09:43 UTC (rev 122594)
+++ zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/readonlyreplay.py	2011-08-15 18:24:10 UTC (rev 122595)
@@ -531,6 +531,7 @@
 parser.add_option("--status-port", "-p", dest='status_port',
                   type="int",
                   help="Port to get status data from.")
+parser.add_option("--report-frequency", type="int", default=10000)
 
 
 parser.add_option("--zmq-boss");
@@ -634,6 +635,9 @@
     firsttt = lasttt = log.start()
     speed = speed1 = None
     last_times = {}
+    report_frequency = options.report_frequency
+    summary_frequencey = report_frequency*10
+
     for session, timetime, msgid, async, op, args in log:
 
         if session not in sessions:     # Skip unknown sessions
@@ -656,8 +660,8 @@
             time.sleep(.01)
             nwaaa += 1
 
-        if nrecords and (nrecords%10000 == 0):
-            if (nrecords%100000 == 0):
+        if nrecords and (nrecords%report_frequency == 0):
+            if (nrecords%summary_frequencey == 0):
                 os.system("nc %s %s" % (addr[0], options.status_port))
                 os.system("uptime")
                 last_times = print_times(last_times, handlers.times,