Actually check if we;re processing

9 years ago · d96a070a3a
parent ed3979df5f
commit d96a070a3a
1 changed files with 2 additions and 0 deletions
--- 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()