summary refs log tree commit diff
path: root/synapse/appservice/scheduler.py
diff options
context:
space:
mode:
authorKegan Dougal <kegan@matrix.org>2015-03-06 14:36:52 +0000
committerKegan Dougal <kegan@matrix.org>2015-03-06 14:36:52 +0000
commit0fbfe1b08a791e95dc9e9d417f131e80b4ce8059 (patch)
tree8fe875d5cdfab5674bb7d4f1d7b10e716f7f51a7 /synapse/appservice/scheduler.py
parentStart adding some tests (diff)
downloadsynapse-0fbfe1b08a791e95dc9e9d417f131e80b4ce8059.tar.xz
Add more tests; fix bugs.
Diffstat (limited to 'synapse/appservice/scheduler.py')
-rw-r--r--synapse/appservice/scheduler.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/appservice/scheduler.py b/synapse/appservice/scheduler.py
index 754f39381f..f54df9c9a5 100644
--- a/synapse/appservice/scheduler.py
+++ b/synapse/appservice/scheduler.py
@@ -174,7 +174,7 @@ class _Recoverer(object):
         self.backoff_counter = 1
 
     def recover(self):
-        self.clock.call_later(2000 ** self.backoff_counter, self.retry)
+        self.clock.call_later(1000 * (2 ** self.backoff_counter), self.retry)
 
     @defer.inlineCallbacks
     def retry(self):
@@ -184,7 +184,7 @@ class _Recoverer(object):
                 txn.complete(self.store)
                 # reset the backoff counter and retry immediately
                 self.backoff_counter = 1
-                self.retry()
+                yield self.retry()
             else:
                 self.backoff_counter += 1
                 self.recover()