diff options
| author | Sean Quah <8349537+squahtx@users.noreply.github.com> | 2021-10-22 18:15:41 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-10-22 18:15:41 +0100 |
| commit | 2b82ec425fccb0ef626242779f7ccd4d77a0685c (patch) | |
| tree | d541487cf7936d98807c5b1ef5128bb1bb5c783c /synapse/replication/tcp/handler.py | |
| parent | Fix synapse.config module "read" command (#11145) (diff) | |
| download | synapse-2b82ec425fccb0ef626242779f7ccd4d77a0685c.tar.xz | |
Add type hints for most `HomeServer` parameters (#11095)
Diffstat (limited to 'synapse/replication/tcp/handler.py')
| -rw-r--r-- | synapse/replication/tcp/handler.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py index 6aa9318027..06fd06fdf3 100644 --- a/synapse/replication/tcp/handler.py +++ b/synapse/replication/tcp/handler.py @@ -294,7 +294,7 @@ class ReplicationCommandHandler: # This shouldn't be possible raise Exception("Unrecognised command %s in stream queue", cmd.NAME) - def start_replication(self, hs): + def start_replication(self, hs: "HomeServer"): """Helper method to start a replication connection to the remote server using TCP. """ @@ -321,6 +321,8 @@ class ReplicationCommandHandler: hs.config.redis.redis_host, # type: ignore[arg-type] hs.config.redis.redis_port, self._factory, + timeout=30, + bindAddress=None, ) else: client_name = hs.get_instance_name() @@ -331,6 +333,8 @@ class ReplicationCommandHandler: host, # type: ignore[arg-type] port, self._factory, + timeout=30, + bindAddress=None, ) def get_streams(self) -> Dict[str, Stream]: |