diff options
| author | Erik Johnston <erik@matrix.org> | 2020-05-27 19:31:44 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-05-27 19:34:07 +0100 |
| commit | 35c308731d3a014f20a91467830c808358681259 (patch) | |
| tree | d6db0def2a763cefe67ac50227c70143b3c664ab /synapse/replication | |
| parent | Improve changelog wording (diff) | |
| download | synapse-35c308731d3a014f20a91467830c808358681259.tar.xz | |
Speed up processing of federation stream RDATA rows.
Instead of storing and sending an ACK for every single row we send synchronously, we instead do it asynchronously while batching up updates.
Diffstat (limited to 'synapse/replication')
| -rw-r--r-- | synapse/replication/tcp/handler.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py index cbcf46f3ae..932e63bd27 100644 --- a/synapse/replication/tcp/handler.py +++ b/synapse/replication/tcp/handler.py @@ -116,6 +116,8 @@ class ReplicationCommandHandler: # batching works. self._pending_batches = {} # type: Dict[str, List[Any]] + self._queued_events = {} # type: Dict[str, List[Any]] + # The factory used to create connections. self._factory = None # type: Optional[ReconnectingClientFactory] |