[Neo-report] r1934 vincent - /trunk/neo/client/app.py

nobody at svn.erp5.org nobody at svn.erp5.org
Wed Mar 10 16:52:14 CET 2010


Author: vincent
Date: Wed Mar 10 16:52:12 2010
New Revision: 1934

Log:
Separate code to wait for all pending responses from waitStoreResponses.

Modified:
    trunk/neo/client/app.py

Modified: trunk/neo/client/app.py
==============================================================================
--- trunk/neo/client/app.py [iso-8859-1] (original)
+++ trunk/neo/client/app.py [iso-8859-1] Wed Mar 10 16:52:12 2010
@@ -618,22 +618,26 @@
         return result
 
     @profiler_decorator
+    def waitResponses(self):
+        """Wait for all requests to be answered (or their connection to be
+        dected as closed)"""
+        queue = self.local_var.queue
+        pending = self.dispatcher.pending
+        _waitAnyMessage = self._waitAnyMessage
+        while pending(queue):
+            _waitAnyMessage()
+
+    @profiler_decorator
     def waitStoreResponses(self, tryToResolveConflict):
         result = []
         append = result.append
         resolved_oid_set = set()
         update = resolved_oid_set.update
         local_var = self.local_var
-        queue = self.local_var.queue
         tid = local_var.tid
-        _waitAnyMessage = self._waitAnyMessage
         _handleConflicts = self._handleConflicts
-        pending = self.dispatcher.pending
         while True:
-            # Wait for all requests to be answered (or their connection to be
-            # dected as closed)
-            while pending(queue):
-                _waitAnyMessage()
+            self.waitResponses()
             if tryToResolveConflict is None:
                 break
             conflicts = _handleConflicts(tryToResolveConflict)





More information about the Neo-report mailing list