summary refs log tree commit diff
path: root/synapse/federation/transaction_queue.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2015-02-18 11:30:37 +0000
committerErik Johnston <erik@matrix.org>2015-02-18 11:30:37 +0000
commit47d3ff4cf8ebceacc680c9e5b414150c6edbf85b (patch)
tree00fd47f6c011254ad0e639ef2d6e51bb47b9dc49 /synapse/federation/transaction_queue.py
parentRemove spurious comma. Remove temp run_on_reactor (diff)
downloadsynapse-47d3ff4cf8ebceacc680c9e5b414150c6edbf85b.tar.xz
Don't send failure to self
Diffstat (limited to '')
-rw-r--r--synapse/federation/transaction_queue.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py
index ae04774c76..f0041d4d12 100644
--- 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(