Merge pull request #4734 from matrix-org/rav/repl_debug

Add some debug to help with #4733

2 files changed, 4 insertions, 0 deletions

diff --git a/changelog.d/4734.misc b/changelog.d/4734.misc
new file mode 100644

index 0000000000..f4e3aeb44f
--- /dev/null
+++ b/changelog.d/4734.misc
@@ -0,0 +1 @@
+Add some debug to help with #4733.
diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py

index 0b3fe6cbf5..4f4d9915a8 100644
--- a/synapse/replication/tcp/protocol.py
+++ b/synapse/replication/tcp/protocol.py
@@ -52,6 +52,7 @@ indicate which side is sending, these are *not* included on the wire::
 import fcntl
 import logging
 import struct
+import traceback
 from collections import defaultdict
 
 from six import iteritems, iterkeys
@@ -323,6 +324,8 @@ class BaseReplicationStreamProtocol(LineOnlyReceiver):
         we or the remote has closed the connection)
         """
         logger.info("[%s] Stop producing", self.id())
+        # debug for #4733
+        logger.info("Traceback: %s", "".join(traceback.format_stack()))
         self.on_connection_closed()
 
     def connectionLost(self, reason):