3
Z_ð]êw  ã               @   sŽ  d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlmZ ddlm	Z	 ddlm
Z
 ddlZdd	„ Zed
ƒZx"ejD ]Zeeeede ƒƒ q€W ejjjdddgƒ x&ejjD ]Zeejeede ƒƒ qºW x*ejjjD ]Zeejjeede ƒƒ qäW x,ejjjD ]Zeejjeede ƒƒ �qW [eZdZdZejejdƒZejejdƒZeZejjddƒj ƒ dFk�r’e!edƒ�r’ejej"dƒZdd„ Z#dd„ Z$d d!„ Z%G d"d#„ d#ej&j'ƒZ(G d$d%„ d%e)ƒZ*G d&d'„ d'e)ƒZ+e+e*ƒ d(�Z&ej,d)dd)fd*d+„Z-d,d-„ Z.d.d/„ Z/d0d1„ Z0dGd2d3„Z1d4d5„ Z2d6d7„ Z3d8d9„ Z4d:d;„ Z5d<d=„ Z6ed>dddd?fd@dA„Z7ed>dddfdBdC„Z8dDdE„ Z9e8ej:_8e7ej:_7dS )Hz1greendns - non-blocking DNS support for Eventlet
é    N)Úpatcher)Ú_socket_nodns)Úos)Útime)Úselectc             C   s   t tttdœ}tj| f|ŽS )N)r   r   r   Úsocket)r   r   r   r   r   Úimport_patched)Úmodule_nameÚmodules© r   ú=/tmp/pip-build-yz_zf6az/eventlet/eventlet/support/greendns.pyr   0   s
    r   Údnszdns.Z
dnskeybaseZdsbaseZtxtbasezdns.rdtypes.zdns.rdtypes.IN.zdns.rdtypes.ANY.g      $@zLookup timed outzName or service not knownZEVENTLET_DEPRECATED_EAI_NODATAÚ Ú1ÚyÚyesÚ
EAI_NODATAz#No address associated with hostnamec             C   sB   t | tjƒsdS ytjj| ƒ W n tjjk
r8   dS X dS dS )z+Return True if host is a valid IPv4 addressFTN)Ú
isinstanceÚsixÚstring_typesr   Zipv4Ú	inet_atonÚ	exceptionÚSyntaxError)Úhostr   r   r   Úis_ipv4_addr[   s    r   c             C   sR   t | tjƒsdS | jddƒd } ytjj| ƒ W n tjjk
rH   dS X dS dS )z+Return True if host is a valid IPv6 addressFú%é   r   TN)	r   r   r   Úsplitr   Úipv6r   r   r   )r   r   r   r   Úis_ipv6_addrg   s    r   c             C   s   t | ƒpt| ƒS )z3Return True if host is a valid IPv4 or IPv6 address)r   r   )r   r   r   r   Ú
is_ip_addrt   s    r    c               @   s   e Zd ZdZddd„ZdS )ÚHostsAnswerz%Answer class for HostsResolver objectTc             C   sZ   d| _ || _|| _|| _|| _| r2|r2tjjƒ ‚|| _t	|dƒrPt
j
ƒ |j nd| _dS )a^  Create a new answer

        :qname: A dns.name.Name instance of the query name
        :rdtype: The rdatatype of the query
        :rdclass: The rdataclass of the query
        :rrset: The dns.rrset.RRset with the response, must have ttl attribute
        :raise_on_no_answer: Whether to raise dns.resolver.NoAnswer if no
           answer.
        NÚttlr   )ÚresponseÚqnameÚrdtypeÚrdclassÚcanonical_namer   ÚresolverÚNoAnswerÚrrsetÚhasattrr   r"   Ú
expiration)Úselfr$   r%   r&   r*   Úraise_on_no_answerr   r   r   Ú__init__|   s    


zHostsAnswer.__init__N)T)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r/   r   r   r   r   r!   y   s   r!   c               @   s`   e Zd ZdZejdejƒZdefdd„Z	dd„ Z
dd	„ Zejjejjd
ddfdd„Zdd„ ZdS )ÚHostsResolverzºClass to parse the hosts file

    Attributes
    ----------

    :fname: The filename of the hosts file in use.
    :interval: The time between checking for hosts file modification
    zæ
        \s*  # Leading space
        ([^\r\n#]*?)  # The actual match, non-greedy so as not to include trailing space
        \s*  # Trailing space
        (?:[#][^\r\n]+)?  # Comments
        (?:$|[\r\n]+)  # EOF or newline
    Nc             C   sh   i | _ i | _i | _|| _|| _|d krPtjdkr8d| _ntjdkrPtjjdƒ| _d| _	| jrd| j
ƒ  d S )NÚposixz
/etc/hostsÚntz'%SystemRoot%\system32\drivers\etc\hostsr   )Ú_v4Ú_v6Ú_aliasesÚintervalÚfnamer   ÚnameÚpathÚ
expandvarsÚ
_last_loadÚ_load)r-   r;   r:   r   r   r   r/   ¤   s    

zHostsResolver.__init__c             C   s`   y$t | jdƒ�}|jƒ }W dQ R X W n ttfk
r<   g S X |jdd�}tjjd| j	j
|ƒƒS )z½Read the contents of the hosts file

        Return list of lines, comment lines and empty lines are
        excluded.

        Note that this performs disk I/O so can be blocking.
        ÚrbNÚignore)Úerrors)Úopenr;   ÚreadÚIOErrorÚOSErrorÚdecoder   ÚmovesÚfilterÚLINES_REÚfindall)r-   ÚfpÚfdataZudatar   r   r   Ú
_readlines´   s    zHostsResolver._readlinesc             C   sÎ   | j ƒ }| jjƒ  | jjƒ  | jjƒ  x˜|D ]�}|jƒ }t|ƒdk rFq,|jdƒ}t|ƒr`| j}nt	|ƒr,|j
dƒrtq,| j}nq,|jdƒjƒ }|||< x&|D ]}|jƒ }|||< || j|< qšW q,W tjƒ | _dS )zjLoad hosts file

        This will unconditionally (re)load the data from the hosts
        file.
        é   r   Zfe80N)rO   r7   Úclearr8   r9   r   ÚlenÚpopr   r   Ú
startswithÚlowerr   r?   )r-   ÚlinesÚlineÚpartsÚipZipmapÚcnameÚaliasr   r   r   r@   Æ   s.    






zHostsResolver._loadFTc             C   sÒ  t j ƒ }| j| j |k r | jƒ  tjj}t|tj	ƒrF|}tj
j|ƒ}nt|ƒ}|jƒ }tjj|||ƒ}	| j| j | |	_|tjjkrÞ|tjjkrÞ| jj|ƒ}
|
 r¾|jƒ r¾| jj|dd… ƒ}
|
rÜ|	jtjjjj|||
ƒƒ nä|tjjkoô|tjjk�rL| jj|ƒ}
|
 �r*|jƒ �r*| jj|dd… ƒ}
|
�rÂ|	jtjjjj|||
ƒƒ nv|tjjk�rÂ|tjjk�rÂ| jj|ƒ}| �rš|jƒ �rš| jj|dd… ƒ}|�rÂ|	jtjjjj||tj
j|ƒƒƒ t||||	|ƒS )aY  Query the hosts file

        The known rdtypes are dns.rdatatype.A, dns.rdatatype.AAAA and
        dns.rdatatype.CNAME.

        The ``rdclass`` parameter must be dns.rdataclass.IN while the
        ``tcp`` and ``source`` parameters are ignored.

        Return a HostAnswer instance or raise a dns.resolver.NoAnswer
        exception.
        Nr   éÿÿÿÿr\   r\   )r   r?   r:   r@   r   Ú
rdataclassÚINr   r   r   r<   Ú	from_textÚstrrU   r*   ZRRsetr"   Ú	rdatatypeÚAr7   ÚgetZis_absoluteÚaddÚrdtypesÚAAAAr8   ÚCNAMEr9   ÚANYr!   )r-   r$   r%   r&   ÚtcpÚsourcer.   Únowr<   r*   ÚaddrrZ   r   r   r   Úqueryæ   s>    zHostsResolver.queryc             C   sb   g }|| j kr| j | }n|}|j|ƒ x*tj| j ƒD ]\}}||kr6|j|ƒ q6W |j|ƒ |S )z1Return a list of all the aliases of a given cname)r9   Úappendr   Ú	iteritemsÚremove)r-   ÚhostnameÚaliasesZcannonr[   rZ   r   r   r   Ú
getaliases  s    


zHostsResolver.getaliases)r0   r1   r2   r3   ÚreÚcompileÚVERBOSErK   Ú	HOSTS_TTLr/   rO   r@   r   ra   rb   r]   r^   rm   rs   r   r   r   r   r4   ’   s   
 -r4   c               @   sV   e Zd ZdZddd„Zdd„ Zejjej	j
ddd	ejjejjfd	fd
d„Zdd„ ZdS )ÚResolverProxyz�Resolver class which can also use /etc/hosts

    Initialise with a HostsResolver instance in order for it to also
    use the hosts file.
    Nú/etc/resolv.confc             C   s   || _ || _| jƒ  dS )ah  Initialise the resolver proxy

        :param hosts_resolver: An instance of HostsResolver to use.

        :param filename: The filename containing the resolver
           configuration.  The default value is correct for both UNIX
           and Windows, on Windows it will result in the configuration
           being read from the Windows registry.
        N)Ú_hostsÚ	_filenamerQ   )r-   Úhosts_resolverÚfilenamer   r   r   r/   -  s    
zResolverProxy.__init__c             C   s$   t jj| jd�| _t jjƒ | j_d S )N)r}   )r   r(   ZResolverr{   Ú	_resolverZLRUCacheÚcache)r-   r   r   r   rQ   ;  s    zResolverProxy.clearFTc	          	      sî   dddg‰ˆ dkrd‰ t ˆ tjƒr0tjjˆ dƒ‰ ‡fdd„}	‡ ‡‡fdd„}
| jrž|tjjkrž||krž|	| jj	ˆ |dd	�ržˆd dk	s˜ˆd
 dk	s˜| rž|
ƒ S |	| j
j	ˆ ||||dd	� tˆ ƒd
krè|	| j
j	ˆ jtjjƒ||||dd	� |
ƒ S )aP  Query the resolver, using /etc/hosts if enabled.

        Behavior:
        1. if hosts is enabled and contains answer, return it now
        2. query nameservers for qname if use_network is True
        3. if qname did not contain dots, pretend it was top-level domain,
           query "foobar." and append to previous result
        Nr   z0.0.0.0c                sŽ   y| ||Ž}W n( t k
r6 } z|ˆ d< dS d }~X nX |jd k	rŠt|jƒrŠˆ d d krb|ˆ d< nˆ d jj|jƒ ˆ d  t|jƒ7  < dS )Nr   Fr   rP   T)Ú	Exceptionr*   rR   Zunion_update)ZfunÚargsÚkwargsÚaÚe)Úresultr   r   ÚstepR  s    
z!ResolverProxy.query.<locals>.stepc                  sl   ˆd d k	r,ˆr$ˆd dkr$t jj‚ˆd S ˆd d k	rXˆsPtˆd t jjƒ rXˆd ‚t jjˆ fd�‚d S )Nr   rP   r   )Úqnames)r   r(   r)   r   ÚNXDOMAINr   )r$   r.   r…   r   r   Úend`  s    z ResolverProxy.query.<locals>.endF)r.   r   )r   r   r   r   r<   r_   rz   r]   r^   rm   r~   rR   ZconcatenateÚroot)r-   r$   r%   r&   ri   rj   r.   Z_hosts_rdtypesÚuse_networkr†   r‰   r   )r$   r.   r…   r   rm   ?  s     

zResolverProxy.queryc             C   s|   | j r| j j|ƒ}ng }x^y| jj|tjjƒ}W n" tjjtjj	fk
rR   P Y qX |j
dd„ |jD ƒƒ |d j}qW |S )z4Return a list of all the aliases of a given hostnamec             s   s   | ]}t |jƒV  qd S )N)r`   Útarget)Ú.0Úrrr   r   r   ú	<genexpr>Š  s    z+ResolverProxy.getaliases.<locals>.<genexpr>r   )rz   rs   r~   rm   r   ra   rg   r(   r)   rˆ   Úextendr*   rŒ   )r-   rq   rr   Úansr   r   r   rs   ~  s    zResolverProxy.getaliases)Nry   )r0   r1   r2   r3   r/   rQ   r   ra   rb   r]   r^   rf   rm   rs   r   r   r   r   rx   &  s   
<rx   )r|   Tc             C   sÐ   |t jkrtjj}n"|t jkr(tjj}nt jt jdƒ‚|dkrBt	}yRy|j
| |||d�S  tj	jk
r�   |sŠttjj| ƒ|tjjddƒS ‚ Y nX W n6 tjjk
r°   t‚Y n tjjk
rÊ   t‚Y nX dS )a8  Resolve a name for a given family using the global resolver proxy.

    This method is called by the global getaddrinfo() function. If use_network
    is False, only resolution via hosts file will be performed.

    Return a dns.resolver.Answer instance.  If there is no answer it's
    rrset will be emtpy.
    zAddress family not supportedN)r.   r‹   F)r   ÚAF_INETr   ra   rb   ÚAF_INET6rf   ÚgaierrorÚ
EAI_FAMILYr(   rm   rˆ   r!   r<   ÚNamer]   r^   r   ÚTimeoutÚEAI_EAGAIN_ERRORÚDNSExceptionÚEAI_NODATA_ERROR)r<   ÚfamilyZraisesÚ_proxyr‹   r%   r   r   r   Úresolve’  s*    





r�   c             C   st   yt j| tjjƒ}W nL tj jk
r,   | S  tjjk
rF   t‚Y n* tjj	k
r`   t
‚Y nX t|d jƒS dS )z'Return the canonical name of a hostnamer   N)r(   rm   r   ra   rg   r)   r   r—   r˜   r™   rš   r`   rŒ   )r   r‘   r   r   r   Úresolve_cnameµ  s    
rž   c             C   sF   y
t j| ƒS  tjjk
r&   t‚Y n tjjk
r@   t‚Y nX dS )z×Return a list of for aliases for the given hostname

    This method does translate the dnspython exceptions into
    socket.gaierror exceptions.  If no aliases are available an empty
    list will be returned.
    N)r(   rs   r   r   r—   r˜   r™   rš   )r   r   r   r   rs   Ã  s    
rs   c       	      C   sz  |t j@ rt‚g }|t jkrÐd}xšdD ]’}x†t jt jgD ]v}yt| |d|d�}W n@ t jk
r� } z"|jt j	tjt
jfkr|‚ |}W Y dd}~X q8X |jr8|jdd„ |jD ƒƒ q8W |r&P q&W |dk	rÎ| rÎ|‚nœ|t jkoâ|t j@ �rHt| t jdƒ}|j�rdd„ |jD ƒ}| �s |t j@ �rlt| t jdƒ}|j�rld	d„ |jD ƒ}n$t| |dƒ}|j�rld
d„ |jD ƒ}t|jƒ|fS )zTResolve a hostname to a list of addresses

    Helper function for getaddrinfo.
    NFT)r‹   c             s   s   | ]}|j V  qd S )N)Úaddress)r�   rŽ   r   r   r   r�   æ  s    z&_getaddrinfo_lookup.<locals>.<genexpr>c             S   s   g | ]
}|j ‘qS r   )rŸ   )r�   rŽ   r   r   r   ú
<listcomp>î  s    z'_getaddrinfo_lookup.<locals>.<listcomp>c             S   s   g | ]}d |j  ‘qS )z::ffff:)rŸ   )r�   rŽ   r   r   r   r    ò  s    c             S   s   g | ]
}|j ‘qS r   )rŸ   )r�   rŽ   r   r   r   r    ö  s    )FT)r   ÚAI_NUMERICHOSTÚEAI_NONAME_ERRORÚ	AF_UNSPECr“   r’   r�   r”   ÚerrnoÚ	EAI_AGAINrš   r*   r�   ÚAI_V4MAPPEDÚAI_ALLr`   r$   )	r   r›   ÚflagsÚaddrsÚerrr‹   ZqfamilyZanswerr„   r   r   r   Ú_getaddrinfo_lookupÒ  s>    


r«   c             C   s@  t | tjƒr| jdƒjdƒ} | dk	r@t| ƒ r@t| ||ƒ\}}n
| }| g}|tjB dtj	A @ }g }	d}
xf|D ]^}ytj
||||||ƒ}W n6 tjk
r¾ } z|tj@ r¬|}
wl‚ W Y dd}~X nX |	j|ƒ qlW |	sè|
rÚ|
‚tjtjdƒ‚|tj	@ �r<t|ƒ�st|ƒjdƒjdƒ}|	d }|d |d |d ||d	 f|	d< |	S )
aC  Replacement for Python's socket.getaddrinfo

    This does the A and AAAA lookups asynchronously after which it
    calls the OS' getaddrinfo(3) using the AI_NUMERICHOST flag.  This
    flag ensures getaddrinfo(3) does not use the network itself and
    allows us to respect all the other arguments like the native OS.
    ÚidnaÚasciiNiÿÿ  zNo address foundr   r   rP   é   )r   r   r   ÚencoderH   r    r«   r   r¡   ÚAI_CANONNAMEÚgetaddrinfoÚerrorÚAI_ADDRCONFIGr�   r”   Ú
EAI_NONAMErž   )r   Úportr›   ÚsocktypeÚprotor¨   r$   r©   ZaiflagsÚresrª   rl   Zair„   r   r   r   r±   ú  s:    



"r±   c             C   s   t | ƒr| S t| ƒ}|d jS )z-Replacement for Python's socket.gethostbynamer   )r   r�   rŸ   )rq   r*   r   r   r   Úgethostbyname"  s    r¹   c             C   s`   t | ƒr| g | gfS t| ƒ}t| ƒ}dd„ |jD ƒ}t|jƒ}|d dkrV|dd… }|||fS )z0Replacement for Python's socket.gethostbyname_exc             S   s   g | ]
}|j ‘qS r   )rŸ   )r�   rŽ   r   r   r   r    0  s    z$gethostbyname_ex.<locals>.<listcomp>r   Ú.Nr\   r\   )r   r�   rs   r*   r`   r$   )rq   r‘   rr   r©   r$   r   r   r   Úgethostbyname_ex*  s    
r»   c             C   s¬  y| \}}W n2 t tfk
r>   t| tƒs6~ tdƒ‚nt‚Y nX |tj@ rX|tj@ rXt‚t|ƒròyDt	j
tjj|ƒtjjƒ}t|ƒdkr�tjdƒ‚|d jjdd�}W nJ tjjk
rÊ   |tj@ rÆt‚Y n& tjjk
rî   |tj@ rêt‚Y nX n²y<t	j
|ƒ}t|ƒdk�rtjdƒ‚|tj@ �r,|d j}W nF tjjk
�rL   t‚Y n* tjjk
�rt   tjtjdfƒ‚Y nX |tj@ �s¤|tj@ �r”d�p–d	}tj||ƒ}||fS )
zTReplacement for Python's socket.getnameinfo.

    Currently only supports IPv4.
    z(getnameinfo() argument 1 must be a tupler   z'sockaddr resolved to multiple addressesr   T)Zomit_final_dotz#No address associated with hostnameÚudpri   )Ú
ValueErrorÚ	TypeErrorr   Útupler¢   r   ÚNI_NAMEREQDÚNI_NUMERICHOSTr   r(   rm   r   ZreversenameÚfrom_addressra   ZPTRrR   r²   rŒ   Zto_textr   r—   r˜   r™   rŸ   r”   r   ÚNI_NUMERICSERVÚNI_DGRAMÚgetservbyport)Zsockaddrr¨   r   rµ   r*   r·   r   r   r   Úgetnameinfo7  sJ    







rÆ   c             C   s‚   t ƒ }xv|dkr|y| j|ƒ}W n: tjk
rX   |tjƒ  dkrHtjj‚tj	dƒ wY nX |dkrft
‚|t|ƒ }||7 }qW |S )a  coro friendly replacement for dns.query._net_read
    Read the specified number of bytes from sock.  Keep trying until we
    either get the desired amount, or we hit EOF.
    A Timeout exception will be raised if the operation is not completed
    by the expiration time.
    r   g        g{®Gáz„?ó    )Ú	bytearrayÚrecvr   Útimeoutr   r   r   r—   ÚeventletÚsleepÚEOFErrorrR   )ÚsockÚcountr,   ÚsÚnr   r   r   Ú	_net_readl  s    

rÒ   c             C   sh   d}t |ƒ}xV||k rby|| j||d… ƒ7 }W q tjk
r^   |tjƒ  dkrZtjj‚Y qX qW dS )zÈcoro friendly replacement for dns.query._net_write
    Write the specified data to the socket.
    A Timeout exception will be raised if the operation is not completed
    by the expiration time.
    r   Ng        )rR   Úsendr   rÊ   r   r   r   r—   )rÎ   Údatar,   ÚcurrentÚlr   r   r   Ú
_net_write„  s    
r×   é5   Fc             C   sP  | j ƒ }|dkr6ytjj|ƒ}W n   tjj}Y nX |tjjkr\||f}	|dk	rœ||f}n@|tjjkrœtjjtjj|ƒƒ}
|
|ddf}	|dk	rœ||ddf}t	j	|t	j
ƒ}|j|ƒ �z^tjj|ƒ}|dk	rÖ|j|ƒ xVy|j||	ƒ P W qØ t	jk
�r(   |tjƒ  dk�rtjj‚tjdƒ wØY qØX qØW d}xÞ|�rT|tjƒ  dk�rTtjj‚|�rdtjdƒ d}y|jdƒ\}}W n t	jk
�r–   �w4Y nX tjj|d ƒtjjk�ræ|d }tjjtjj|ƒƒ}||d |d	 |d
 f}||	k�ròP |�s4tjjd||	f ƒ‚�q4W W d|jƒ  X tjj|| j| jd�}| j|ƒ�sLtjjƒ ‚|S )ae  coro friendly replacement for dns.query.udp
    Return the response obtained after sending a query via UDP.

    @param q: the query
    @type q: dns.message.Message
    @param where: where to send the message
    @type where: string containing an IPv4 or IPv6 address
    @param timeout: The number of seconds to wait before the query times out.
    If None, the default, wait forever.
    @type timeout: float
    @param port: The port to which to send the message.  The default is 53.
    @type port: int
    @param af: the address family to use.  The default is None, which
    causes the address family to use to be inferred from the form of of where.
    If the inference attempt fails, AF_INET is used.
    @type af: int
    @rtype: dns.message.Message object
    @param source: source address.  The default is the IPv4 wildcard address.
    @type source: string
    @param source_port: The port from which to send the message.
    The default is 0.
    @type source_port: int
    @param ignore_unexpected: If True, ignore responses from unexpected
    sources.  The default is False.
    @type ignore_unexpected: boolNr   g        g{®Gáz„?FTiÿÿ  r   rP   é   z$got a response from %s instead of %s)ÚkeyringÚrequest_mac)Úto_wirer   ÚinetÚaf_for_addressr’   r“   r   Ú	inet_ntoar   r   Ú
SOCK_DGRAMÚ
settimeoutrm   Ú_compute_expirationÚbindÚsendtorÊ   r   r   r—   rË   rÌ   ÚrecvfromZUnexpectedSourceÚcloseÚmessageÚ	from_wirerÚ   ÚmacÚis_responseÚBadResponse)ÚqÚwhererÊ   rµ   Úafrj   Úsource_portZignore_unexpectedÚwireÚdestinationZwhere_truncrÐ   r,   ZtriedrÂ   rl   Úrr   r   r   r¼   •  sp    








r¼   c             C   s   | j ƒ }|dkr6ytjj|ƒ}W n   tjj}Y nX |tjjkr\||f}|dk	rˆ||f}n,|tjjkrˆ||ddf}|dk	rˆ||ddf}tj|tjƒ}	|	j|ƒ zÄtj	j
|ƒ}
|dk	rÀ|	j|ƒ xRy|	j|ƒ P W qÂ tjk
�r   |
tjƒ  dkrþtjj‚tjdƒ wÂY qÂX qÂW t|ƒ}tjd|ƒ| }t|	||
ƒ t|	d|
ƒ}tjd|ƒ\}tt|	||
ƒƒ}W d|	jƒ  X tjj|| j| jd�}| j|ƒ�sœtj	j ƒ ‚|S )aÞ  coro friendly replacement for dns.query.tcp
    Return the response obtained after sending a query via TCP.

    @param q: the query
    @type q: dns.message.Message object
    @param where: where to send the message
    @type where: string containing an IPv4 or IPv6 address
    @param timeout: The number of seconds to wait before the query times out.
    If None, the default, wait forever.
    @type timeout: float
    @param port: The port to which to send the message.  The default is 53.
    @type port: int
    @param af: the address family to use.  The default is None, which
    causes the address family to use to be inferred from the form of of where.
    If the inference attempt fails, AF_INET is used.
    @type af: int
    @rtype: dns.message.Message object
    @param source: source address.  The default is the IPv4 wildcard address.
    @type source: string
    @param source_port: The port from which to send the message.
    The default is 0.
    @type source_port: intNr   g        g{®Gáz„?z!HrP   )rÚ   rÛ   )!rÜ   r   rÝ   rÞ   r’   r“   r   ÚSOCK_STREAMrá   rm   râ   rã   ÚconnectrÊ   r   r   r—   rË   rÌ   rR   ÚstructÚpackr×   rÒ   ÚunpackÚbytesræ   rç   rè   rÚ   ré   rê   rë   )rì   rí   rÊ   rµ   rî   rj   rï   rð   rñ   rÐ   r,   rÖ   ZtcpmsgZldatarò   r   r   r   ri   û  sP    






ri   c               C   s   t jƒ  d S )N)r(   rQ   r   r   r   r   ÚresetD  s    rù   )r   r   r   )r   r   r   r   );r3   rt   rõ   ÚsysrË   r   Zeventlet.greenr   r   r   r   r   r   r   Ú__all__ÚpkgÚsetattrre   r�   r^   rh   r   ZDNS_QUERY_TIMEOUTrw   r”   r¥   r˜   r´   r¢   rš   Úenvironrc   rU   r+   r   r   r   r    r(   ZAnswerr!   Úobjectr4   rx   r’   r�   rž   rs   r«   r±   r¹   r»   rÆ   rÒ   r×   r¼   ri   rù   rm   r   r   r   r   Ú<module>   sr   ! i"(
(5eH