summary refs log tree commit diff
path: root/synapse/replication/slave/storage/deviceinbox.py
diff options
context:
space:
mode:
authorMark Haines <mark.haines@matrix.org>2016-09-09 11:48:23 +0100
committerMark Haines <mark.haines@matrix.org>2016-09-09 11:48:23 +0100
commit6a6cbfcf1e12c0f34a280764f892eaa23e720d57 (patch)
treeeebe6c9c13bbbbc86819c9a7a97e63b145b150f6 /synapse/replication/slave/storage/deviceinbox.py
parentMerge pull request #1087 from matrix-org/markjh/reapply_delta (diff)
downloadsynapse-6a6cbfcf1e12c0f34a280764f892eaa23e720d57.tar.xz
Track the max_stream_device_id in a separate table, since we delete from the inbox table
Diffstat (limited to 'synapse/replication/slave/storage/deviceinbox.py')
-rw-r--r--synapse/replication/slave/storage/deviceinbox.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/slave/storage/deviceinbox.py b/synapse/replication/slave/storage/deviceinbox.py
index 251078ba57..3bfd5e8213 100644
--- a/synapse/replication/slave/storage/deviceinbox.py
+++ b/synapse/replication/slave/storage/deviceinbox.py
@@ -23,7 +23,7 @@ class SlavedDeviceInboxStore(BaseSlavedStore):
     def __init__(self, db_conn, hs):
         super(SlavedDeviceInboxStore, self).__init__(db_conn, hs)
         self._device_inbox_id_gen = SlavedIdTracker(
-            db_conn, "device_inbox", "stream_id",
+            db_conn, "device_max_stream_id", "stream_id",
         )
         self._device_inbox_stream_cache = StreamChangeCache(
             "DeviceInboxStreamChangeCache",