Commit ea10e385 authored by Grégory Wisniewski's avatar Grégory Wisniewski

Ask a packet only if not available on local storage.

git-svn-id: https://svn.erp5.org/repos/neo/trunk@2505 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent 973f8b66
...@@ -157,7 +157,8 @@ class ReplicationHandler(EventHandler): ...@@ -157,7 +157,8 @@ class ReplicationHandler(EventHandler):
deleteObject(oid, serial) deleteObject(oid, serial)
missing_object_set = object_set - my_object_set missing_object_set = object_set - my_object_set
for oid, serial in missing_object_set: for oid, serial in missing_object_set:
ask(Packets.AskObject(oid, serial, None), timeout=300) if not app.dm.objectPresent(oid, serial):
ask(Packets.AskObject(oid, serial, None), timeout=300)
if sum((len(x) for x in object_dict.itervalues())) == MIN_RANGE_LENGTH: if sum((len(x) for x in object_dict.itervalues())) == MIN_RANGE_LENGTH:
ask(self._doAskCheckSerialRange(max_oid, add64(max_serial, 1), ask(self._doAskCheckSerialRange(max_oid, add64(max_serial, 1),
RANGE_LENGTH)) RANGE_LENGTH))
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment