diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2022-03-10 08:01:56 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-03-10 13:01:56 +0000 |
| commit | 3e4af36bc8515504721b3c1b1d64d4f45359bf88 (patch) | |
| tree | e39ad5a0a4196056cce920ac906b39ed7417e501 /tests/replication/tcp/streams | |
| parent | Remove dead code in `tests/storage/test_database.py` (#12197) (diff) | |
| download | synapse-3e4af36bc8515504721b3c1b1d64d4f45359bf88.tar.xz | |
Rename get_tcp_replication to get_replication_command_handler. (#12192)
Since the object it returns is a ReplicationCommandHandler. This is clean-up from adding support to Redis where the command handler was added as an additional layer of abstraction from the TCP protocol.
Diffstat (limited to 'tests/replication/tcp/streams')
| -rw-r--r-- | tests/replication/tcp/streams/test_events.py | 2 | ||||
| -rw-r--r-- | tests/replication/tcp/streams/test_typing.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/tests/replication/tcp/streams/test_events.py b/tests/replication/tcp/streams/test_events.py index f9d5da723c..641a94133b 100644 --- a/tests/replication/tcp/streams/test_events.py +++ b/tests/replication/tcp/streams/test_events.py @@ -420,7 +420,7 @@ class EventsStreamTestCase(BaseStreamTestCase): # Manually send an old RDATA command, which should get dropped. This # re-uses the row from above, but with an earlier stream token. - self.hs.get_tcp_replication().send_command( + self.hs.get_replication_command_handler().send_command( RdataCommand("events", "master", 1, row) ) diff --git a/tests/replication/tcp/streams/test_typing.py b/tests/replication/tcp/streams/test_typing.py index 3ff5afc6e5..9a229dd23f 100644 --- a/tests/replication/tcp/streams/test_typing.py +++ b/tests/replication/tcp/streams/test_typing.py @@ -118,7 +118,7 @@ class TypingStreamTestCase(BaseStreamTestCase): # Reset the typing handler self.hs.get_replication_streams()["typing"].last_token = 0 - self.hs.get_tcp_replication()._streams["typing"].last_token = 0 + self.hs.get_replication_command_handler()._streams["typing"].last_token = 0 typing._latest_room_serial = 0 typing._typing_stream_change_cache = StreamChangeCache( "TypingStreamChangeCache", typing._latest_room_serial |