[Checkins] SVN: zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/replay.py Wait for input to mostly catch up.

[Jim Fulton]

Log message for revision 104901:
  Wait for input to mostly catch up.
  

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

-=-
Modified: zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/replay.py
===================================================================
--- zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/replay.py	2009-10-07 22:47:08 UTC (rev 104900)
+++ zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/replay.py	2009-10-07 22:49:55 UTC (rev 104901)
@@ -464,10 +464,15 @@
             last_times = print_times(last_times, handlers.times,
                                      "after %s transactions" % nt)
 
+        sys.stdout.flush()
+        pending = handlers.calls - handlers.replies - handlers.abandoned
+        while pending > 10000:
+            time.sleep(.01)
+            pending = handlers.calls - handlers.replies - handlers.abandoned
+
         nt += 1
 
         tt = ZODB.TimeStamp.TimeStamp(t.id).timeTime()
-        pending = handlers.calls - handlers.replies - handlers.abandoned
         now = time.time()
         if now > start:
             speed = (tt-firsttt) / (now-start)