diff options
| author | Erik Johnston <erik@matrix.org> | 2020-07-10 18:26:36 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-07-10 18:26:36 +0100 |
| commit | f299441cc67f31dcd47b8fdfda4a218bee9df9ba (patch) | |
| tree | bba78ca419a547249491c81f3c9968cf526c13b1 /synapse/replication/tcp/handler.py | |
| parent | Fix resync remote devices on receive PDU in worker mode. (#7815) (diff) | |
| download | synapse-f299441cc67f31dcd47b8fdfda4a218bee9df9ba.tar.xz | |
Add ability to shard the federation sender (#7798)
Diffstat (limited to 'synapse/replication/tcp/handler.py')
| -rw-r--r-- | synapse/replication/tcp/handler.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py index 55b3b79008..80f5df60f9 100644 --- a/synapse/replication/tcp/handler.py +++ b/synapse/replication/tcp/handler.py @@ -238,7 +238,7 @@ class ReplicationCommandHandler: federation_ack_counter.inc() if self._federation_sender: - self._federation_sender.federation_ack(cmd.token) + self._federation_sender.federation_ack(cmd.instance_name, cmd.token) async def on_REMOVE_PUSHER( self, conn: AbstractConnection, cmd: RemovePusherCommand @@ -527,7 +527,7 @@ class ReplicationCommandHandler: """Ack data for the federation stream. This allows the master to drop data stored purely in memory. """ - self.send_command(FederationAckCommand(token)) + self.send_command(FederationAckCommand(self._instance_name, token)) def send_user_sync( self, instance_id: str, user_id: str, is_syncing: bool, last_sync_ms: int |