diff options
| author | Erik Johnston <erik@matrix.org> | 2017-03-13 09:59:54 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2017-03-13 09:59:54 +0000 |
| commit | 672dcf59d3f9da12da43a77e316e2eec76d3ee4c (patch) | |
| tree | 9186644b06ef01e609ca018e02100ceecf0f3ea4 /synapse/replication/slave/storage/deviceinbox.py | |
| parent | Merge tag 'v0.19.3-rc1' into release-v0.19.3 (diff) | |
| parent | Revert "Support registration & login with phone number" (diff) | |
| download | synapse-672dcf59d3f9da12da43a77e316e2eec76d3ee4c.tar.xz | |
Merge branch 'develop' of github.com:matrix-org/synapse into release-v0.19.3
Diffstat (limited to 'synapse/replication/slave/storage/deviceinbox.py')
| -rw-r--r-- | synapse/replication/slave/storage/deviceinbox.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/synapse/replication/slave/storage/deviceinbox.py b/synapse/replication/slave/storage/deviceinbox.py index cc860f9f9b..f9102e0d89 100644 --- a/synapse/replication/slave/storage/deviceinbox.py +++ b/synapse/replication/slave/storage/deviceinbox.py @@ -17,6 +17,7 @@ from ._base import BaseSlavedStore from ._slaved_id_tracker import SlavedIdTracker from synapse.storage import DataStore from synapse.util.caches.stream_change_cache import StreamChangeCache +from synapse.util.caches.expiringcache import ExpiringCache class SlavedDeviceInboxStore(BaseSlavedStore): @@ -34,6 +35,13 @@ class SlavedDeviceInboxStore(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, + ) + get_to_device_stream_token = DataStore.get_to_device_stream_token.__func__ get_new_messages_for_device = DataStore.get_new_messages_for_device.__func__ get_new_device_msgs_for_remote = DataStore.get_new_device_msgs_for_remote.__func__ |