kaslo/synapse
1
0
Fork 0
Code Wiki Activity

temp

Browse Source
This commit is contained in:
Patrick Cloke
2022-03-11 07:27:24 -05:00
parent 829139c3d5
commit b32bb82bee
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
tests/replication/slave/storage/test_events.py
View File

@@ -250,10 +250,13 @@ class SlavedEventStoreTestCase(BaseSlavedStoreTestCase):
self.replicate()
self.check("get_rooms_for_user_with_stream_ordering", (USER_ID_2,), set())
# limit the replication rate
repl_transport = self._server_transport
assert isinstance(repl_transport, FakeTransport)
repl_transport.autoflush = False
# limit the replication rate from server -> client.
print(len(self._redis_transports))
print(self._redis_transports)
assert len(self._redis_transports) == 1
for _, repl_transport in self._redis_transports:
assert isinstance(repl_transport, FakeTransport)
repl_transport.autoflush = False
# build the join and message events and persist them in the same batch.
logger.info("----- build test events ------")