[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