diff options
author | Erik Johnston <erik@matrix.org> | 2021-01-07 17:20:44 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-01-07 17:20:44 +0000 |
commit | 63593134a15a6b47ced61eeb0670071f89400bad (patch) | |
tree | ea7fbbd5f2f29df4570c1a9606bb0b1738c23063 /synapse/replication | |
parent | Fix typo in docs/systemd-with-workers/README.md (#9035) (diff) | |
download | synapse-63593134a15a6b47ced61eeb0670071f89400bad.tar.xz |
Some cleanups to device inbox store. (#9041)
Diffstat (limited to 'synapse/replication')
-rw-r--r-- | synapse/replication/slave/storage/deviceinbox.py | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/synapse/replication/slave/storage/deviceinbox.py b/synapse/replication/slave/storage/deviceinbox.py index 5b045bed02..62b68dd6e9 100644 --- a/synapse/replication/slave/storage/deviceinbox.py +++ b/synapse/replication/slave/storage/deviceinbox.py @@ -18,7 +18,6 @@ from synapse.replication.slave.storage._slaved_id_tracker import SlavedIdTracker from synapse.replication.tcp.streams import ToDeviceStream from synapse.storage.database import DatabasePool from synapse.storage.databases.main.deviceinbox import DeviceInboxWorkerStore -from synapse.util.caches.expiringcache import ExpiringCache from synapse.util.caches.stream_change_cache import StreamChangeCache @@ -37,13 +36,6 @@ class SlavedDeviceInboxStore(DeviceInboxWorkerStore, BaseSlavedStore): self._device_inbox_id_gen.get_current_token(), ) - self._last_device_delete_cache = ExpiringCache( - cache_name="last_device_delete_cache", - clock=self._clock, - max_len=10000, - expiry_ms=30 * 60 * 1000, - ) - def process_replication_rows(self, stream_name, instance_name, token, rows): if stream_name == ToDeviceStream.NAME: self._device_inbox_id_gen.advance(instance_name, token) |