Commit 2162e752 authored by Julien Muchembled's avatar Julien Muchembled

Fix replication of partitions with many object changes

parent 19b24acd
......@@ -204,7 +204,7 @@ class StorageOperationHandler(EventHandler):
msg_id = conn.getPeerId()
conn = weakref.proxy(conn)
dm = app.dm
object_list = dm.getReplicationObjectList(min_tid, max_tid, length,
object_list = dm.getReplicationObjectList(min_tid, max_tid, length + 1,
partition, min_oid)
if length < len(object_list):
next_tid, next_oid = object_list.pop()
......
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