summary refs log tree commit diff
path: root/synapse/push
diff options
context:
space:
mode:
authorDavid Baker <dave@matrix.org>2016-04-08 16:49:39 +0100
committerDavid Baker <dave@matrix.org>2016-04-08 16:49:39 +0100
commitd96a070a3a6da4e2ff868f656a28f1bfd5f3ea82 (patch)
tree2b75c9e86aeb7b00d5f0314da5f0bfa9d1064879 /synapse/push
parentFix invite pushes (diff)
downloadsynapse-d96a070a3a6da4e2ff868f656a28f1bfd5f3ea82.tar.xz
Actually check if we;re processing
Diffstat (limited to 'synapse/push')
-rw-r--r--synapse/push/httppusher.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/push/httppusher.py b/synapse/push/httppusher.py
index 38b758e6af..b3b11c5f43 100644
--- a/synapse/push/httppusher.py
+++ b/synapse/push/httppusher.py
@@ -112,6 +112,8 @@ class HttpPusher(object):
 
     @defer.inlineCallbacks
     def _process(self):
+        if self.processing:
+            return
         try:
             self.processing = True
             yield self._unsafe_process()