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 11:12:12 +10:00
parent 04b5175fcf
commit 7d35b7603f
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -66,6 +66,7 @@ class PerDestinationQueue(object):
self._server_name = hs.hostname
self._clock = hs.get_clock()
self._store = hs.get_datastore()
self._reactor = hs.get_reactor()
self._transaction_manager = transaction_manager
self._destination = destination
@ -303,7 +304,7 @@ class PerDestinationQueue(object):
break
# Release the lock after all the work is done
reactor.callLater(acquired_lock.release, 0.0)
self._reactor.callLater(acquired_lock.release, 0.0)
acquired_lock = None
except NotRetryingDestination as e:
logger.debug(
@ -342,7 +343,7 @@ class PerDestinationQueue(object):
# We want to be *very* sure we clear this after we stop processing
self.transmission_loop_running = False
if acquired_lock:
reactor.callLater(acquired_lock.release, 0.0)
self._reactor.callLater(acquired_lock.release, 0.0)
def _get_rr_edus(self, force_flush):
if not self._pending_rrs: