diff options
author | David Baker <dave@matrix.org> | 2016-04-11 12:48:30 +0100 |
---|---|---|
committer | David Baker <dave@matrix.org> | 2016-04-11 12:48:30 +0100 |
commit | 9bb041791ce09209a21c61cadb79c52cba9ac3d9 (patch) | |
tree | 77ab0844a9605c8b3074ba779a236aaa574033fd | |
parent | Actually check if we;re processing (diff) | |
download | synapse-9bb041791ce09209a21c61cadb79c52cba9ac3d9.tar.xz |
Run unsafe proces in a loop until we've caught up
and wrap unsafe process in a try block
Diffstat (limited to '')
-rw-r--r-- | synapse/push/httppusher.py | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/synapse/push/httppusher.py b/synapse/push/httppusher.py index b3b11c5f43..57f0a69e03 100644 --- a/synapse/push/httppusher.py +++ b/synapse/push/httppusher.py @@ -116,7 +116,16 @@ class HttpPusher(object): return try: self.processing = True - yield self._unsafe_process() + # if the max ordering changes while we're running _unsafe_process, + # call it again, and so on until we've caught up. + while True: + starting_max_ordering = self.max_stream_ordering + try: + yield self._unsafe_process() + except: + logger.exception("Exception processing notifs") + if self.max_stream_ordering == starting_max_ordering: + break finally: self.processing = False @@ -127,7 +136,7 @@ class HttpPusher(object): Never call this directly: use _process which will only allow this to run once per pusher. """ - starting_max_ordering = self.max_stream_ordering + unprocessed = yield self.store.get_unread_push_actions_for_user_in_range( self.user_id, self.last_stream_ordering, self.max_stream_ordering ) @@ -188,8 +197,6 @@ class HttpPusher(object): self.timed_call = reactor.callLater(self.backoff_delay, self.on_timer) self.backoff_delay = min(self.backoff_delay * 2, self.MAX_BACKOFF_SEC) break - if self.max_stream_ordering != starting_max_ordering: - self._unsafe_process() @defer.inlineCallbacks def _process_one(self, push_action): |