o Q_e@sdZddlZddlZddlZddlZddlmZddlm Z ddl Zddl Zddl Zddl ZddlmZmZddlmZddlmZddlmZddlZejr[dd lmZmZmZmZGd d d eZdd dZeej drej !eded efddZ"dSdS)z1Bridges between the Twisted package and Tornado. N)Deferredfailure)Futurefuture_set_exc_info)utf8)gen)Resolver) GeneratorAnyListTuplec @s>eZdZdZd ddZej ddeded edd fd d Z dS)TwistedResolveraTwisted-based asynchronous resolver. This is a non-blocking and non-threaded resolver. It is recommended only when threads cannot be used, since it has limitations compared to the standard ``getaddrinfo``-based `~tornado.netutil.Resolver` and `~tornado.netutil.DefaultExecutorResolver`. Specifically, it returns at most one result, and arguments other than ``host`` and ``family`` are ignored. It may fail to resolve when ``family`` is not ``socket.AF_UNSPEC``. Requires Twisted 12.1 or newer. .. versionchanged:: 5.0 The ``io_loop`` argument (deprecated since version 4.1) has been removed. returnNcCs\tjj|_tjjd}tjjj |jd}tjj jd|jd}tjj |||g|_ dS)Nz /etc/hosts)reactorz/etc/resolv.conf)twistedinternetasyncioreactorAsyncioSelectorReactorrnameshostsr cache CacheResolverclientresolve ResolverChainresolver)self host_resolvercache_resolver real_resolverr!:/usr/lib/python3/dist-packages/tornado/platform/twisted.py initialize9s zTwistedResolver.initializerhostportfamilyz*Generator[Any, Any, List[Tuple[int, Any]]]c cs tjj|r|}tj}nZtjj|r|}tj}nM|j t |}t }| |j |V}t|tjrOz|Wn,tjjjyN}zt|d}~wwtjj|rZtj}ntjj|retj}ntj}|tjkry||krytd||ftt|||ffg} | S)Nz%Requested socket family %d but got %d)rrabstract isIPAddresssocketAF_INET isIPv6AddressAF_INET6r getHostByNamerraddBoth set_result isinstancerFailureraiseExceptionrerror DomainErrorIOError AF_UNSPEC Exceptiontypingcastint) rr$r%r&resolvedresolved_familydeferredfuteresultr!r!r"rGs:    zTwistedResolver.resolverN)r) __name__ __module__ __qualname____doc__r#r coroutinestrr:rr!r!r!r"r's rrcCsddlm}|dS)aInstall ``AsyncioSelectorReactor`` as the default Twisted reactor. .. deprecated:: 5.1 This function is provided for backwards compatibility; code that does not require compatibility with older versions of Tornado should use ``twisted.internet.asyncioreactor.install()`` directly. .. versionchanged:: 6.0.3 In Tornado 5.x and before, this function installed a reactor based on the Tornado ``IOLoop``. When that reactor implementation was removed in Tornado 6.0.0, this function was removed as well. It was restored in Tornado 6.0.3 using the ``asyncio`` reactor instead. rinstallN)twisted.internet.asyncioreactorrIrHr!r!r"rIks  rIregisterdcs0tdtjddffdd }|j|S)Nrrcs,z|tdttYdS)Nzerrback called without error)r2r7rsysexc_inforfr!r"errbacks z_..errback)rrr1 addCallbacksr/)rLrQr!rOr"_srSrA)#rEr)rMtwisted.internet.abstractrrJtwisted.internet.deferrtwisted.pythonrtwisted.names.cachetwisted.names.clienttwisted.names.hoststwisted.names.resolvetornado.concurrentrrtornado.escapertornadortornado.netutilr r8 TYPE_CHECKINGr r r r rrIhasattrconvert_yieldedrKrSr!r!r!r"s0       D