From ee7e4289f11c834b2baf2b5df9ddfee061d37e70 Mon Sep 17 00:00:00 2001 From: Kevin Froman Date: Thu, 19 Jul 2018 17:32:21 -0500 Subject: [PATCH] Fixed thread exhaustion for address sync --- onionr/communicator2.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/onionr/communicator2.py b/onionr/communicator2.py index 450647ad..b4a32649 100755 --- a/onionr/communicator2.py +++ b/onionr/communicator2.py @@ -79,9 +79,9 @@ class OnionrCommunicatorDaemon: peerPoolTimer = OnionrCommunicatorTimers(self, self.getOnlinePeers, 60) OnionrCommunicatorTimers(self, self.lookupBlocks, 7, requiresPeer=True) OnionrCommunicatorTimers(self, self.getBlocks, 10, requiresPeer=True) - OnionrCommunicatorTimers(self, self.clearOfflinePeer, 120) - OnionrCommunicatorTimers(self, self.lookupKeys, 125, requiresPeer=True) - OnionrCommunicatorTimers(self, self.lookupAdders, 600, requiresPeer=True) + OnionrCommunicatorTimers(self, self.clearOfflinePeer, 58) + OnionrCommunicatorTimers(self, self.lookupKeys, 60, requiresPeer=True) + OnionrCommunicatorTimers(self, self.lookupAdders, 60, requiresPeer=True) # set loop to execute instantly to load up peer pool (replaced old pool init wait) peerPoolTimer.count = (peerPoolTimer.frequency - 1) @@ -124,8 +124,7 @@ class OnionrCommunicatorDaemon: peer = self.pickOnlinePeer() newAdders = self.peerAction(peer, action='pex') self._core._utils.mergeAdders(newAdders) - - self.decrementThreadCount('lookupKeys') + self.decrementThreadCount('lookupAdders') def lookupBlocks(self): '''Lookup new blocks & add them to download queue'''