[Neo-report] r2409 vincent - /trunk/neo/storage/handlers/replication.py

nobody at svn.erp5.org nobody at svn.erp5.org
Wed Nov 3 15:39:00 CET 2010


Author: vincent
Date: Wed Nov  3 15:39:00 2010
New Revision: 2409

Log:
Factorise "ask" access.

Modified:
    trunk/neo/storage/handlers/replication.py

Modified: trunk/neo/storage/handlers/replication.py
==============================================================================
--- trunk/neo/storage/handlers/replication.py [iso-8859-1] (original)
+++ trunk/neo/storage/handlers/replication.py [iso-8859-1] Wed Nov  3 15:39:00 2010
@@ -105,6 +105,7 @@ class ReplicationHandler(EventHandler):
     @checkConnectionIsReplicatorConnection
     def answerTIDsFrom(self, conn, tid_list):
         app = self.app
+        ask = conn.ask
         # If I have pending TIDs, check which TIDs I don't have, and
         # request the data.
         tid_set = frozenset(tid_list)
@@ -116,7 +117,7 @@ class ReplicationHandler(EventHandler):
                 deleteTransaction(tid)
         missing_tid_set = tid_set - my_tid_set
         for tid in missing_tid_set:
-            conn.ask(Packets.AskTransactionInformation(tid), timeout=300)
+            ask(Packets.AskTransactionInformation(tid), timeout=300)
 
     @checkConnectionIsReplicatorConnection
     def answerTransactionInformation(self, conn, tid,
@@ -129,6 +130,7 @@ class ReplicationHandler(EventHandler):
     @checkConnectionIsReplicatorConnection
     def answerObjectHistoryFrom(self, conn, object_dict):
         app = self.app
+        ask = conn.ask
         my_object_dict = app.replicator.getObjectHistoryFromResult()
         deleteObject = app.dm.deleteObject
         for oid, serial_list in object_dict.iteritems():
@@ -143,7 +145,7 @@ class ReplicationHandler(EventHandler):
             else:
                 missing_serial_set = serial_list
             for serial in missing_serial_set:
-                conn.ask(Packets.AskObject(oid, serial, None), timeout=300)
+                ask(Packets.AskObject(oid, serial, None), timeout=300)
 
     @checkConnectionIsReplicatorConnection
     def answerObject(self, conn, oid, serial_start,





More information about the Neo-report mailing list