diff options
| author | Patrick Cloke <patrickc@matrix.org> | 2023-09-06 11:25:28 -0400 |
|---|---|---|
| committer | Patrick Cloke <patrickc@matrix.org> | 2023-09-06 11:25:28 -0400 |
| commit | 55c20da4a3464d6b1bc3b789f837475c6580b057 (patch) | |
| tree | ec2cab1806871561919354a67dec6978496e85ae /synapse/replication | |
| parent | Fix incorrect docstring for Ratelimiter. (#16255) (diff) | |
| parent | Link to MSC in changelog. (diff) | |
| download | synapse-55c20da4a3464d6b1bc3b789f837475c6580b057.tar.xz | |
Merge remote-tracking branch 'origin/release-v1.91' into release-v1.92
Diffstat (limited to 'synapse/replication')
| -rw-r--r-- | synapse/replication/tcp/client.py | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index 51285e6d33..ca8a76f77c 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -28,7 +28,6 @@ from synapse.logging.context import PreserveLoggingContext, make_deferred_yielda from synapse.metrics.background_process_metrics import run_as_background_process from synapse.replication.tcp.streams import ( AccountDataStream, - CachesStream, DeviceListsStream, PushersStream, PushRulesStream, @@ -76,7 +75,6 @@ class ReplicationDataHandler: self._instance_name = hs.get_instance_name() self._typing_handler = hs.get_typing_handler() self._state_storage_controller = hs.get_storage_controllers().state - self.auth = hs.get_auth() self._notify_pushers = hs.config.worker.start_pushers self._pusher_pool = hs.get_pusherpool() @@ -224,16 +222,6 @@ class ReplicationDataHandler: self._state_storage_controller.notify_event_un_partial_stated( row.event_id ) - # invalidate the introspection token cache - elif stream_name == CachesStream.NAME: - for row in rows: - if row.cache_func == "introspection_token_invalidation": - if row.keys[0] is None: - # invalidate the whole cache - # mypy ignore - the token cache is defined on MSC3861DelegatedAuth - self.auth.invalidate_token_cache() # type: ignore[attr-defined] - else: - self.auth.invalidate_cached_tokens(row.keys) # type: ignore[attr-defined] await self._presence_handler.process_replication_rows( stream_name, instance_name, token, rows |