diff options
| author | Mark Haines <mark.haines@matrix.org> | 2016-05-16 12:59:41 +0100 |
|---|---|---|
| committer | Mark Haines <mark.haines@matrix.org> | 2016-05-16 12:59:41 +0100 |
| commit | dd95eb4cb5f1519bfd328249f97f8731c4a11b64 (patch) | |
| tree | 96220dc54d2d6d0b36999c5c01db8d5f5b13b851 /synapse/federation/transaction_queue.py | |
| parent | add a url_preview_ip_range_whitelist config param so we can whitelist the mat... (diff) | |
| parent | fix logo (diff) | |
| download | synapse-dd95eb4cb5f1519bfd328249f97f8731c4a11b64.tar.xz | |
Merge branch 'develop' into matthew/preview_url_ip_whitelist
Diffstat (limited to 'synapse/federation/transaction_queue.py')
| -rw-r--r-- | synapse/federation/transaction_queue.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py index 1928da03b3..5787f854d4 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py @@ -20,6 +20,7 @@ from .persistence import TransactionActions from .units import Transaction from synapse.api.errors import HttpResponseException +from synapse.util.async import run_on_reactor from synapse.util.logutils import log_function from synapse.util.logcontext import PreserveLoggingContext from synapse.util.retryutils import ( @@ -199,6 +200,8 @@ class TransactionQueue(object): @defer.inlineCallbacks @log_function def _attempt_new_transaction(self, destination): + yield run_on_reactor() + # list of (pending_pdu, deferred, order) if destination in self.pending_transactions: # XXX: pending_transactions can get stuck on by a never-ending |