diff options
Diffstat (limited to 'synapse')
| -rw-r--r-- | synapse/replication/tcp/redis.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/synapse/replication/tcp/redis.py b/synapse/replication/tcp/redis.py index 989c5be032..b63c151cfb 100644 --- a/synapse/replication/tcp/redis.py +++ b/synapse/replication/tcp/redis.py @@ -256,6 +256,13 @@ class SynapseRedisFactory(txredisapi.RedisFactory): convertNumbers=convertNumbers, ) + # Set the homeserver reactor as the clock, if this is not done than + # twisted.internet.protocol.ReconnectingClientFactory.retry will default + # to the reactor. + self.clock = hs.get_reactor() + + # Send pings every 30 seconds (not that get_clock() returns a Clock, not + # a reactor). hs.get_clock().looping_call(self._send_ping, 30 * 1000) @wrap_as_background_process("redis_ping") |