diff options
| author | Erik Johnston <erik@matrix.org> | 2015-08-19 10:08:12 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2015-08-19 10:08:12 +0100 |
| commit | a45ec7c651abdbe54bba4a8fe420e02c9059f390 (patch) | |
| tree | 408fda981530fb1e687690f5107726f61d5b51e5 | |
| parent | Remove an access token log line (diff) | |
| download | synapse-a45ec7c651abdbe54bba4a8fe420e02c9059f390.tar.xz | |
Block on storing the current last_tokens
| -rw-r--r-- | synapse/push/__init__.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/synapse/push/__init__.py b/synapse/push/__init__.py index 36f450c31d..483deb624c 100644 --- a/synapse/push/__init__.py +++ b/synapse/push/__init__.py @@ -345,7 +345,7 @@ class Pusher(object): if processed: self.backoff_delay = Pusher.INITIAL_BACKOFF self.last_token = chunk['end'] - self.store.update_pusher_last_token_and_success( + yield self.store.update_pusher_last_token_and_success( self.app_id, self.pushkey, self.user_name, @@ -354,7 +354,7 @@ class Pusher(object): ) if self.failing_since: self.failing_since = None - self.store.update_pusher_failing_since( + yield self.store.update_pusher_failing_since( self.app_id, self.pushkey, self.user_name, @@ -362,7 +362,7 @@ class Pusher(object): else: if not self.failing_since: self.failing_since = self.clock.time_msec() - self.store.update_pusher_failing_since( + yield self.store.update_pusher_failing_since( self.app_id, self.pushkey, self.user_name, @@ -380,7 +380,7 @@ class Pusher(object): self.user_name, self.pushkey) self.backoff_delay = Pusher.INITIAL_BACKOFF self.last_token = chunk['end'] - self.store.update_pusher_last_token( + yield self.store.update_pusher_last_token( self.app_id, self.pushkey, self.user_name, @@ -388,7 +388,7 @@ class Pusher(object): ) self.failing_since = None - self.store.update_pusher_failing_since( + yield self.store.update_pusher_failing_since( self.app_id, self.pushkey, self.user_name, |