From ce3fe52498547144191fadf8ff0a8cb6d244334e Mon Sep 17 00:00:00 2001 From: David Baker Date: Fri, 8 Apr 2016 14:02:38 +0100 Subject: Comment why unsafe process is unsafe --- synapse/push/httppusher.py | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'synapse/push/httppusher.py') diff --git a/synapse/push/httppusher.py b/synapse/push/httppusher.py index 9f51106d0f..685c5e48df 100644 --- a/synapse/push/httppusher.py +++ b/synapse/push/httppusher.py @@ -120,6 +120,11 @@ class HttpPusher(object): @defer.inlineCallbacks def _unsafe_process(self): + """ + Looks for unset notifications and dispatch them, in order + Never call this directly: use _process which will only allow this to + run once per pusher. + """ unprocessed = yield self.store.get_unread_push_actions_for_user_in_range( self.user_id, self.last_stream_ordering, self.max_stream_ordering ) -- cgit 1.4.1