forked from LBRYCommunity/lbry-sdk
fix ping queue bug
This commit is contained in:
parent
2c546b2cde
commit
37ddaeca12
1 changed files with 3 additions and 1 deletions
|
@ -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)
|
||||
|
||||
|
|
Loading…
Reference in a new issue