From 367329cf8cfe16205357821c460a6558d866b3f4 Mon Sep 17 00:00:00 2001 From: Connor Olding Date: Thu, 12 Aug 2021 22:36:59 -0700 Subject: [PATCH] fix missing handling of deferred IPs --- respodns/dns.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/respodns/dns.py b/respodns/dns.py index 60566d6..03f5eff 100644 --- a/respodns/dns.py +++ b/respodns/dns.py @@ -297,7 +297,6 @@ async def read_all_ips(filepaths, blocking=False, callback=None): async def main(db, filepaths, checks, ipinfo, opts: Options): # ipinfo can be None. - from .util import make_pooler from asyncio import Queue, QueueFull, create_task from queue import SimpleQueue @@ -347,8 +346,10 @@ async def main(db, filepaths, checks, ipinfo, opts: Options): await trying #lament("AWAITED trying") + while not deferred.empty(): + await locate_me.put(deferred.get()) + #lament("STOPPING locating") - #done_locating.set() await locate_me.put(None) #lament("AWAIT locating")