|
|
|
@@ -57,12 +57,15 @@ def get_resolver_logger_adapter_default(parent_adapter): |
|
|
|
return ResolverLoggerAdapter(parent_adapter, dns_extra) |
|
|
|
return _get_resolver_logger_adapter_default |
|
|
|
|
|
|
|
async def process_addresses_default(addresses): |
|
|
|
return |
|
|
|
|
|
|
|
def DnsProxy( |
|
|
|
get_resolver=get_resolver_default, |
|
|
|
get_logger_adapter=get_logger_adapter_default, |
|
|
|
get_resolver_logger_adapter=get_resolver_logger_adapter_default, |
|
|
|
get_socket=get_socket_default, num_workers=1000, |
|
|
|
process_addresses=process_addresses_default, |
|
|
|
rules=(), |
|
|
|
): |
|
|
|
|
|
|
|
@@ -178,6 +181,7 @@ def DnsProxy( |
|
|
|
return error(query, dns_response_code_error.args[0]) |
|
|
|
|
|
|
|
request_logger.info('Resolved to %s', ip_addresses) |
|
|
|
await process_addresses(ip_addresses) |
|
|
|
now = loop.time() |
|
|
|
|
|
|
|
def ttl(ip_address): |
|
|
|
|