self.results = {}
- def check(self, batch_size=1024):
+ def check(self, *domains, batch_size=1024):
"""
Checks all domains that need checking.
"""
threshold = 64
with self.executor:
- while True:
- # Submit some more tasks whenever we run low
- if len(self.results) < threshold:
- for domain in self.get_domains(batch_size):
- self.submit(domain)
+ # Submit any passed domains
+ for domain in domains:
+ self.submit(domain)
- # Manually commit after a batch has been processed
- self.backend.db.commit()
+ # Main Loop
+ while True:
+ # Submit some more domains for checking unless we have been given
+ # some by the caller.
+ if not domains:
+ if len(self.results) < threshold:
+ for domain in self.get_domains(batch_size):
+ self.submit(domain)
+
+ # Manually commit after a batch has been processed
+ self.backend.db.commit()
# Terminate if we have no domains left to check
if not self.results:
# check-domains
check_domains = subparsers.add_parser("check-domains",
help=_("Checks if domains are alive"))
+ check_domains.add_argument("domain", nargs="*",
+ help=_("Pass any domains to check"))
check_domains.set_defaults(func=self.__check_domains)
# Authentication: create-api-key
Runs the checker over all domains
"""
checker = dnsbl.checker.Checker(backend)
- checker.check()
+ checker.check(*args.domain)
# Authentication