MirrorHub/synapse
0
0
Fork 1
mirror of https://mau.dev/maunium/synapse.git synced 2024-11-18 16:02:15 +01:00
Code Issues Projects Releases Wiki Activity

Unsafe process should call itself if the max has changed

Browse source
This commit is contained in:
David Baker 2016-04-08 14:06:54 +01:00
parent ce3fe52498
commit 52d1008661
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
synapse/push/httppusher.py
View file

@ -125,6 +125,7 @@ class HttpPusher(object):
Never call this directly: use _process which will only allow this to Never call this directly: use _process which will only allow this to
run once per pusher. run once per pusher.
""" """
starting_max_ordering = self.max_stream_ordering
unprocessed = yield self.store.get_unread_push_actions_for_user_in_range( unprocessed = yield self.store.get_unread_push_actions_for_user_in_range(
self.user_id, self.last_stream_ordering, self.max_stream_ordering self.user_id, self.last_stream_ordering, self.max_stream_ordering
) )
@ -185,6 +186,8 @@ class HttpPusher(object):
self.timed_call = reactor.callLater(self.backoff_delay, self.on_timer) self.timed_call = reactor.callLater(self.backoff_delay, self.on_timer)
self.backoff_delay = min(self.backoff_delay * 2, self.MAX_BACKOFF_SEC) self.backoff_delay = min(self.backoff_delay * 2, self.MAX_BACKOFF_SEC)
break break
if self.max_stream_ordering != starting_max_ordering:
self._unsafe_process()
@defer.inlineCallbacks @defer.inlineCallbacks
def _process_one(self, push_action): def _process_one(self, push_action):