summary refs log tree commit diff
path: root/synapse/app/federation_sender.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2017-04-04 16:41:03 +0100
committerErik Johnston <erik@matrix.org>2017-04-04 16:41:03 +0100
commitd1d5362267adb316e65f046787207aa7d862ec3b (patch)
tree966510860048a787aaff0cd8fdb7d4f86b02490d /synapse/app/federation_sender.py
parentAdd the appropriate amount of preserve_fn (diff)
downloadsynapse-d1d5362267adb316e65f046787207aa7d862ec3b.tar.xz
Add comment
Diffstat (limited to 'synapse/app/federation_sender.py')
-rw-r--r--synapse/app/federation_sender.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/app/federation_sender.py b/synapse/app/federation_sender.py
index fa7b19e53a..cbddc80ca9 100644
--- a/synapse/app/federation_sender.py
+++ b/synapse/app/federation_sender.py
@@ -62,6 +62,11 @@ class FederationSenderSlaveStore(
 ):
     def __init__(self, db_conn, hs):
         super(FederationSenderSlaveStore, self).__init__(db_conn, hs)
+
+        # We pull out the current federation stream position now so that we
+        # always have a known value for the federation position in memory so
+        # that we don't have to bounce via a deferred once when we start the
+        # replication streams.
         self.federation_out_pos_startup = self._get_federation_out_pos(db_conn)
 
     def _get_federation_out_pos(self, db_conn):