diff options
| author | Erik Johnston <erik@matrix.org> | 2017-04-04 16:41:03 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2017-04-04 16:41:03 +0100 |
| commit | d1d5362267adb316e65f046787207aa7d862ec3b (patch) | |
| tree | 966510860048a787aaff0cd8fdb7d4f86b02490d /synapse/app | |
| parent | Add the appropriate amount of preserve_fn (diff) | |
| download | synapse-d1d5362267adb316e65f046787207aa7d862ec3b.tar.xz | |
Add comment
Diffstat (limited to '')
| -rw-r--r-- | synapse/app/federation_sender.py | 5 |
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): |