From 37ddaeca128d0035f04f13b186eec460d979efcb Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Thu, 23 Aug 2018 11:17:29 -0400 Subject: [PATCH] fix ping queue bug --- lbrynet/dht/protocol.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/lbrynet/dht/protocol.py b/lbrynet/dht/protocol.py index f9a7efa3b..197761026 100644 --- a/lbrynet/dht/protocol.py +++ b/lbrynet/dht/protocol.py @@ -73,8 +73,10 @@ class PingQueue(object): yield defer.DeferredList([_ping(contact) for contact in pinged]) for contact in checked: - if contact in self._enqueued_contacts: + if contact in self._enqueued_contacts and contact in pinged: del self._enqueued_contacts[contact] + elif contact not in self._queue: + self._queue.appendleft(contact) defer.returnValue(None)