[Checkins] SVN: zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/replay.py *** empty log message ***

[Jim Fulton]

Log message for revision 104754:
  *** empty log message ***

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-02 17:18:18 UTC (rev 104753)
+++ zc.zeoinputlog/branches/replay/src/zc/zeoinputlog/replay.py	2009-10-02 17:25:23 UTC (rev 104754)
@@ -120,7 +120,7 @@
         else:
             index = 1
         session, timetime, message = records[index]
-        marshal.dump(('%s%s' % (index, session), timetime, message), fo)
+        marshal.dump(('%d%s' % (index, session), timetime, message), fo)
         try:
             records[index] = marshal.load(files[index])
         except EOFError:
@@ -128,7 +128,8 @@
 
     index = not index
     while 1:
-        marshal.dump(records[index], fo)
+        session, timetime, message = records[index]
+        marshal.dump(('%d%s' % (index, session), timetime, message), fo)
         try:
             records[index] = marshal.load(files[index])
         except EOFError:
@@ -166,6 +167,12 @@
 
             yield session, timetime, msgid, async, op, args
 
+    def __len__(self):
+        n = 0
+        for x in self:
+            n += 1
+        return n
+
     def sessions(self):
         sessions = {}
         f = open(self.fname)