diff options
| author | Erik Johnston <erik@matrix.org> | 2020-09-14 10:16:41 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-14 10:16:41 +0100 |
| commit | 04cc249b43e8716513f788b2a4eeb8ede24d19df (patch) | |
| tree | 1f5e539b9db71f3d47980ce99c47e6f1d747352b /synapse/handlers/room_member.py | |
| parent | Merge tag 'v1.20.0rc3' into develop (diff) | |
| download | synapse-04cc249b43e8716513f788b2a4eeb8ede24d19df.tar.xz | |
Add experimental support for sharding event persister. Again. (#8294)
This is *not* ready for production yet. Caveats: 1. We should write some tests... 2. The stream token that we use for events can get stalled at the minimum position of all writers. This means that new events may not be processed and e.g. sent down sync streams if a writer isn't writing or is slow.
Diffstat (limited to 'synapse/handlers/room_member.py')
| -rw-r--r-- | synapse/handlers/room_member.py | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/synapse/handlers/room_member.py b/synapse/handlers/room_member.py index 100f335b80..01a6e88262 100644 --- a/synapse/handlers/room_member.py +++ b/synapse/handlers/room_member.py @@ -82,13 +82,6 @@ class RoomMemberHandler: self._enable_lookup = hs.config.enable_3pid_lookup self.allow_per_room_profiles = self.config.allow_per_room_profiles - self._event_stream_writer_instance = hs.config.worker.writers.events - self._is_on_event_persistence_instance = ( - self._event_stream_writer_instance == hs.get_instance_name() - ) - if self._is_on_event_persistence_instance: - self.persist_event_storage = hs.get_storage().persistence - self._join_rate_limiter_local = Ratelimiter( clock=self.clock, rate_hz=hs.config.ratelimiting.rc_joins_local.per_second, |