| Server IP : 138.197.176.125 / Your IP : 216.73.217.55 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
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?-