Don't send failure to self

2015-02-18 11:30:37 +00:00 · 2015-02-18 11:30:37 +00:00 · 47d3ff4cf8
parent 36e144091b
commit 47d3ff4cf8
1 changed files with 3 additions and 0 deletions
--- a/synapse/federation/transaction_queue.py
+++ b/synapse/federation/transaction_queue.py
@ -128,6 +128,9 @@ class TransactionQueue(object):

    @defer.inlineCallbacks
    def enqueue_failure(self, failure, destination):
+        if destination == self.server_name:
+            return
+
        deferred = defer.Deferred()

        self.pending_failures_by_dest.setdefault(