notwa/respodns
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

fix missing handling of deferred IPs

Browse source
This commit is contained in:
Connor Olding 2021-08-12 22:36:59 -07:00
parent a71d9c33d7
commit 367329cf8c
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
respodns/dns.py
View file

@ -297,7 +297,6 @@ async def read_all_ips(filepaths, blocking=False, callback=None):
async def main(db, filepaths, checks, ipinfo, opts: Options): async def main(db, filepaths, checks, ipinfo, opts: Options):
# ipinfo can be None. # ipinfo can be None.
from .util import make_pooler
from asyncio import Queue, QueueFull, create_task from asyncio import Queue, QueueFull, create_task
from queue import SimpleQueue from queue import SimpleQueue
@ -347,8 +346,10 @@ async def main(db, filepaths, checks, ipinfo, opts: Options):
await trying await trying
#lament("AWAITED trying") #lament("AWAITED trying")
while not deferred.empty():
await locate_me.put(deferred.get())
#lament("STOPPING locating") #lament("STOPPING locating")
#done_locating.set()
await locate_me.put(None) await locate_me.put(None)
#lament("AWAIT locating") #lament("AWAIT locating")