From e545948eefb9df90f4aaf03ebf75c861ed73cd4d Mon Sep 17 00:00:00 2001
From: Patrick Cloke <patrickc@matrix.org>
Date: Thu, 10 Mar 2022 14:32:18 -0500
Subject: Use the reactor from the HomeServer.

---
 synapse/replication/tcp/redis.py | 7 +++++++
 1 file changed, 7 insertions(+)

(limited to 'synapse')

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")
-- 
cgit 1.5.1