[Neo-report] r2624 vincent - /trunk/neo/client/app.py
nobody at svn.erp5.org
nobody at svn.erp5.org
Thu Jan 20 14:14:48 CET 2011
Author: vincent
Date: Thu Jan 20 14:14:47 2011
New Revision: 2624
Log:
Word-wrap at 79 chars.
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] Thu Jan 20 14:14:47 2011
@@ -242,8 +242,8 @@ class RevisionIndex(MQIndex):
pass
else:
if result < tid_list[-1]:
- # An invalidation happened from a transaction later than our
- # most recent view of this object, so we cannot answer.
+ # An invalidation happened from a transaction later than
+ # our most recent view of this object, so we cannot answer.
result = None
return result
@@ -256,7 +256,8 @@ class RevisionIndex(MQIndex):
class Application(object):
"""The client node application."""
- def __init__(self, master_nodes, name, connector=None, compress=True, **kw):
+ def __init__(self, master_nodes, name, connector=None, compress=True,
+ **kw):
# Start polling thread
self.em = EventManager()
self.poll_thread = ThreadedPoll(self.em, name=name)
@@ -776,7 +777,8 @@ class Application(object):
resolved_serial_set = resolved_conflict_serial_dict.setdefault(
oid, set())
conflict_serial = max(conflict_serial_set)
- if resolved_serial_set and conflict_serial <= max(resolved_serial_set):
+ if resolved_serial_set and conflict_serial <= max(
+ resolved_serial_set):
# A later serial has already been resolved, skip.
resolved_serial_set.update(conflict_serial_set)
continue
More information about the Neo-report
mailing list