maxmustermann/synapse
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

try and fix DNS and socket errors from being retried

Browse source
This commit is contained in:
Amber H. Brown 2019-06-24 10:52:45 +10:00
parent 32eb3fca89
commit 4da90de3b2
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
synapse/federation/sender/per_destination_queue.py
View file

@ -194,9 +194,6 @@ class PerDestinationQueue(object):
# We have to keep 2 free slots for presence and rr_edus
limit = MAX_EDUS_PER_TRANSACTION - 2
# Lock before we start doing work
acquired_lock = yield make_deferred_yieldable(self._transaction_manager.limiter.acquire())
device_update_edus, dev_list_id = (
yield self._get_device_update_edus(limit)
)
@ -207,6 +204,9 @@ class PerDestinationQueue(object):
yield self._get_to_device_message_edus(limit)
)
# Lock before we start doing work
acquired_lock = yield make_deferred_yieldable(self._transaction_manager.limiter.acquire())
pending_edus = device_update_edus + to_device_edus
# BEGIN CRITICAL SECTION