diff options
| author | Kegan Dougal <kegan@matrix.org> | 2015-03-06 14:36:52 +0000 |
|---|---|---|
| committer | Kegan Dougal <kegan@matrix.org> | 2015-03-06 14:36:52 +0000 |
| commit | 0fbfe1b08a791e95dc9e9d417f131e80b4ce8059 (patch) | |
| tree | 8fe875d5cdfab5674bb7d4f1d7b10e716f7f51a7 /synapse/appservice/scheduler.py | |
| parent | Start adding some tests (diff) | |
| download | synapse-0fbfe1b08a791e95dc9e9d417f131e80b4ce8059.tar.xz | |
Add more tests; fix bugs.
Diffstat (limited to 'synapse/appservice/scheduler.py')
| -rw-r--r-- | synapse/appservice/scheduler.py | 4 |
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() |