← Back
Editing: _resolver.cpython-38.pyc
U J0�[R! � @ s~ d Z ddlmZmZ eZddlmZmZm Z m Z m Z m Z m Z ddlmZ ddlmZmZmZmZ ddlmZ ddlmZ ddlmZ dd lm Z m Z dd l m Z dd l m!Z! dd l"m#Z# ee�G d d� de$��Z%e&e e g�Z'e&e g�ee&e g�e e'e iZ(ee e e iZ)e e d�Z*e de diZ+ee�G dd� de$��Z,ee�G dd� de$��Z-ee�G dd� de$��Z.ee�G dd� de$��Z/dS )z= IPv6-aware hostname resolution. @see: L{IHostnameResolver} � )�division�absolute_import)� getaddrinfo�AF_INET�AF_INET6� AF_UNSPEC� SOCK_STREAM� SOCK_DGRAM�gaierror)� implementer)�IHostnameResolver�IHostResolution�IResolverSimple�IResolutionReceiver)�DNSLookupError)�Deferred)�deferToThreadPool)� IPv4Address� IPv6Address)� nativeString)� _idnaBytes)�Loggerc @ s e Zd ZdZdd� ZdS )�HostResolutionz9 The in-progress resolution of a given hostname. c C s || _ dS )zA Create a L{HostResolution} with the given name. N)�name)�selfr � r �</usr/lib/python3/dist-packages/twisted/internet/_resolver.py�__init__% s zHostResolution.__init__N)�__name__� __module__� __qualname__�__doc__r r r r r r s r )�TCP�UDPr" r# c @ s( e Zd ZdZdefdd�Zd dd�ZdS ) � GAIResolverzp L{IHostnameResolver} implementation that resolves hostnames by calling L{getaddrinfo} in a thread. Nc C s$ || _ |dkr|jn|| _|| _dS )a� Create a L{GAIResolver}. @param reactor: the reactor to schedule result-delivery on @type reactor: L{IReactorThreads} @param getThreadPool: a function to retrieve the thread pool to use for scheduling name resolutions. If not supplied, the use the given C{reactor}'s thread pool. @type getThreadPool: 0-argument callable returning a L{twisted.python.threadpool.ThreadPool} @param getaddrinfo: a reference to the L{getaddrinfo} to use - mainly parameterized for testing. @type getaddrinfo: callable with the same signature as L{getaddrinfo} N)�_reactor� getThreadPool�_getThreadPool� _getaddrinfo)r Zreactorr& r r r r r M s �zGAIResolver.__init__r r" c sr �� � }t|dkrtnt|� � t| �� ����fdd�}t�j||�}t��} ��| � |j �fdd��} | S )�< See L{IHostnameResolver.resolveHostName} @param resolutionReceiver: see interface @param hostName: see interface @param portNumber: see interface @param addressTypes: see interface @param transportSemantics: see interface @return: see interface Nc s0 z�� ��� ��W S tk r* g Y S X d S �N)r( r r )� addressFamily�hostName� portNumberr � socketTyper r �gety s �z(GAIResolver.resolveHostName.<locals>.getc sD | D ]2\}}}}}t | }� �|t�|d�f|�� � q� �� d S �Nr" )� _afToType�addressResolved�_socktypeToTyper/ �resolutionComplete)�resultZfamilyZsocktype�protoZ cannonameZsockaddrZaddrType��resolutionReceiverr r �deliverResults� s �z3GAIResolver.resolveHostName.<locals>.deliverResults) r' � _typesToAF�_any� frozenset�_transportToSocketr r% r �resolutionBegan� addCallback) r r8 r, r- � addressTypes�transportSemanticsZpoolr/ �d� resolutionr9 r )r+ r, r- r8 r r. r �resolveHostNamed s � zGAIResolver.resolveHostName)r Nr" )r r r r! r r rD r r r r r$ F s �r$ c @ s( e Zd ZdZe� Zdd� Zd dd�ZdS ) �SimpleResolverComplexifierzF A converter from L{IResolverSimple} to L{IHostnameResolver}. c C s || _ dS )zW Construct a L{SimpleResolverComplexifier} with an L{IResolverSimple}. N)�_simpleResolver)r ZsimpleResolverr r r r � s z#SimpleResolverComplexifier.__init__r Nr" c s� z� � d�� W n tk r* t� �� Y nX t� �� t� �}��|� �j�� �}��fdd�}� �fdd�} |�|| � �fdd�} |� | � |S )r) �asciic s �� td| � �� d S r0 )r2 r )�address)r- r8 r r �addressReceived� s �zCSimpleResolverComplexifier.resolveHostName.<locals>.addressReceivedc s$ | � t�s �jjd| � �jd� d S )Nz'while looking up {name} with {resolver})r Zresolver)Zcheckr �_logZfailurerF )�error)r, r r r � errorReceived� s �zASimpleResolverComplexifier.resolveHostName.<locals>.errorReceivedc s � � � d S r* )r4 )r5 r7 r r �finish� s z:SimpleResolverComplexifier.resolveHostName.<locals>.finish) �encode�UnicodeEncodeErrorr r r r> rF � getHostByNameZ addCallbacksr? ) r r8 r, r- r@ rA rC Z onAddressrI rL rM r )r, r- r8 r r rD � s z*SimpleResolverComplexifier.resolveHostName)r Nr" )r r r r! r rJ r rD r r r r rE � s �rE c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) � FirstOneWinszT An L{IResolutionReceiver} which fires a L{Deferred} with its first result. c C s || _ d| _dS )zp @param deferred: The L{Deferred} to fire when the first resolution result arrives. FN)� _deferred� _resolved)r Zdeferredr r r r � s zFirstOneWins.__init__c C s || _ dS )z� See L{IResolutionReceiver.resolutionBegan} @param resolution: See L{IResolutionReceiver.resolutionBegan} N)� _resolution)r rC r r r r> � s z FirstOneWins.resolutionBeganc C s" | j r dS d| _ | j�|j� dS )z� See L{IResolutionReceiver.addressResolved} @param address: See L{IResolutionReceiver.addressResolved} NT)rS rR �callbackZhost)r rH r r r r2 � s z FirstOneWins.addressResolvedc C s" | j r dS | j�t| jj�� dS )z? See L{IResolutionReceiver.resolutionComplete} N)rS rR Zerrbackr rT r )r r r r r4 � s z FirstOneWins.resolutionCompleteN)r r r r! r r> r2 r4 r r r r rQ � s rQ c @ s" e Zd ZdZdd� Zddd�ZdS ) �ComplexResolverSimplifierzE A converter from L{IHostnameResolver} to L{IResolverSimple} c C s || _ dS )z� Create a L{ComplexResolverSimplifier} with an L{IHostnameResolver}. @param nameResolver: The L{IHostnameResolver} to use. N)� _nameResolver)r Z nameResolverr r r r s z"ComplexResolverSimplifier.__init__r c C s" t � }| j�t|�|dtg� |S )z� See L{IResolverSimple.getHostByName} @param name: see L{IResolverSimple.getHostByName} @param timeouts: see L{IResolverSimple.getHostByName} @return: see L{IResolverSimple.getHostByName} r )r rW rD rQ r )r r Ztimeoutsr5 r r r rP s �z'ComplexResolverSimplifier.getHostByNameN)r )r r r r! r rP r r r r rV � s rV N)0r! Z __future__r r �typeZ __metaclass__Zsocketr r r r r r r Zzope.interfacer Ztwisted.internet.interfacesr r r r Ztwisted.internet.errorr Ztwisted.internet.deferr Ztwisted.internet.threadsr Ztwisted.internet.addressr r Ztwisted.python.compatr Ztwisted.internet._idnar Ztwisted.loggerr �objectr r< r; r: r1 r= r3 r$ rE rQ rV r r r r �<module> sV $ � �� �G?-
Save File
Cancel