diff options
| author | David Baker <dave@matrix.org> | 2016-04-08 16:49:39 +0100 |
|---|---|---|
| committer | David Baker <dave@matrix.org> | 2016-04-08 16:49:39 +0100 |
| commit | d96a070a3a6da4e2ff868f656a28f1bfd5f3ea82 (patch) | |
| tree | 2b75c9e86aeb7b00d5f0314da5f0bfa9d1064879 | |
| parent | Fix invite pushes (diff) | |
| download | synapse-d96a070a3a6da4e2ff868f656a28f1bfd5f3ea82.tar.xz | |
Actually check if we;re processing
| -rw-r--r-- | synapse/push/httppusher.py | 2 |
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() |