summary refs log tree commit diff
path: root/synapse/replication
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2017-03-27 14:03:38 +0100
committerErik Johnston <erik@matrix.org>2017-03-30 11:48:35 +0100
commit24d35ab47bdec651706a221974424409d9ab036b (patch)
tree17231cca811506a14ab23094c0ffc2c7c621df95 /synapse/replication
parentUse txn.fetchall() so we can reuse txn (diff)
downloadsynapse-24d35ab47bdec651706a221974424409d9ab036b.tar.xz
Add new storage functions for new replication
The new replication protocol will keep all the streams separate, rather
than muxing multiple streams into one.
Diffstat (limited to 'synapse/replication')
-rw-r--r--synapse/replication/resource.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/resource.py b/synapse/replication/resource.py
index 03930fe958..2d3ec2eca2 100644
--- a/synapse/replication/resource.py
+++ b/synapse/replication/resource.py
@@ -504,7 +504,7 @@ class ReplicationResource(Resource):
 
         if device_lists is not None and device_lists != current_position:
             changes = yield self.store.get_all_device_list_changes_for_remotes(
-                device_lists,
+                device_lists, current_position,
             )
             writer.write_header_and_rows("device_lists", changes, (
                 "position", "user_id", "destination",