ó
ÐH/\c           @` sÙ  d  Z  d d l m Z m Z m 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 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 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 m Z d d l m Z d d l m Z d d l m Z m  Z  d d l! m" Z# d d l! m$ Z$ d d l! m% Z% d g Z& d e% f d „  ƒ  YZ' d e( f d „  ƒ  YZ) d S(   s!   
c-ares based hostname resolver.
i    (   t   absolute_importt   print_functiont   divisionN(   t   getaddrinfo(   t   gaierror(   t   error(   t   string_types(   t	   text_type(   t   reraise(   t   PY3(   t   Waiter(   t   get_hub(   t	   AF_UNSPEC(   t   AF_INET(   t   AF_INET6(   t   SOCK_STREAM(   t
   SOCK_DGRAM(   t   SOCK_RAW(   t   AI_NUMERICHOST(   t   config(   t   AresSettingMixini   (   t   channelt	   InvalidIP(   t   _lookup_port(   t   _resolve_special(   t   AbstractResolvert   Resolverc           B` s­   e  Z d  Z e Z d e d „ Z d „  Z d „  Z	 d „  Z
 e d „ Z e d „ Z d „  Z d d d d d	 „ Z d d d d d
 „ Z d „  Z d „  Z d „  Z d „  Z RS(   sá  
    Implementation of the resolver API using the `c-ares`_ library.

    This implementation uses the c-ares library to handle name
    resolution. c-ares is natively asynchronous at the socket level
    and so integrates well into gevent's event loop.

    In comparison to :class:`gevent.resolver_thread.Resolver` (which
    delegates to the native system resolver), the implementation is
    much more complex. In addition, there have been reports of it not
    properly honoring certain system configurations (for example, the
    order in which IPv4 and IPv6 results are returned may not match
    the threaded resolver). However, because it does not use threads,
    it may scale better for applications that make many lookups.

    There are some known differences from the system resolver:

    - ``gethostbyname_ex`` and ``gethostbyaddr`` may return different
      for the ``aliaslist`` tuple member. (Sometimes the same,
      sometimes in a different order, sometimes a different alias
      altogether.)
    - ``gethostbyname_ex`` may return the ``ipaddrlist`` in a different order.
    - ``getaddrinfo`` does not return ``SOCK_RAW`` results.
    - ``getaddrinfo`` may return results in a different order.
    - Handling of ``.local`` (mDNS) names may be different, even if they are listed in
      the hosts file.
    - c-ares will not resolve ``broadcasthost``, even if listed in the hosts file.
    - This implementation may raise ``gaierror(4)`` where the system implementation would raise
      ``herror(1)``.
    - The results for ``localhost`` may be different. In particular, some system
      resolvers will return more results from ``getaddrinfo`` than c-ares does,
      such as SOCK_DGRAM results, and c-ares may report more ips on a multi-homed
      host.

    .. caution:: This module is considered extremely experimental on PyPy, and
       due to its implementation in cython, it may be slower. It may also lead to
       interpreter crashes.

    .. _c-ares: http://c-ares.haxx.se
    c         K` sã   | d  k r t ƒ  } n  | |  _ | r„ xZ t j j ƒ  D]F } t | t ƒ r7 | j ƒ  } | d  k	 r} | j	 | j
 | ƒ q} q7 q7 Wn  |  j | j |  |  _ t j ƒ  |  _ | |  _ | j j d t ƒ |  _ |  j j |  j ƒ d  S(   Nt   ref(   t   NoneR   t   hubR   t   settingst   valuest
   isinstanceR   t   gett
   setdefaultt
   kwarg_namet
   ares_classt   loopt   arest   ost   getpidt   pidt   paramst   forkt   Falset   fork_watchert   startt   _on_fork(   t   selfR   t   use_environt   kwargst   settingt   value(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   __init__U   s    	 	c         C` s   d t  |  ƒ |  j f S(   Ns/   <gevent.resolver_ares.Resolver at 0x%x ares=%r>(   t   idR&   (   R0   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   __repr__e   s    c         C` sb   t  j ƒ  } | |  j k r^ |  j j j |  j j ƒ |  j |  j j |  j	  |  _ | |  _ n  d  S(   N(
   R'   R(   R)   R   R%   t   run_callbackR&   t   destroyR$   R*   (   R0   R)   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyR/   h   s
    c         C` sE   |  j  d  k	 r4 |  j j j |  j  j ƒ d  |  _  n  |  j j ƒ  d  S(   N(   R&   R   R   R%   R8   R9   R-   t   stop(   R0   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   closep   s    c         C` s'   t  | | ƒ } |  j | | ƒ d d S(   Niÿÿÿÿi    (   R   t   gethostbyname_ex(   R0   t   hostnamet   family(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   gethostbynamev   s    c         C` sX  t  r[ t | t ƒ r' | j d ƒ } q§ t | t t f ƒ s§ t d t | ƒ j ƒ ‚ q§ nL t | t	 ƒ r| | j d ƒ } n+ t | t ƒ s§ t d t | ƒ j ƒ ‚ n  xª t
 rS|  j } yR t |  j ƒ } | j | | | ƒ | j ƒ  } | d st d d ƒ ‚ n  | SWqª t k
 rO| |  j k rP| d k rFd g  d g f S‚  qPqª Xqª Wd  S(	   Nt   idnas   Expected es(idna), not %st   asciis   Expected string, not %siÿÿÿÿiûÿÿÿs#   No address associated with hostnames   255.255.255.255(   R	   R    t   strt   encodet   bytest	   bytearrayt	   TypeErrort   typet   __name__R   t   TrueR&   R
   R   R?   R!   R   (   R0   R=   R>   R&   t   waitert   result(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyR<   z   s.    		
c         C` s   t  | | ƒ S(   N(   t   lookup_port(   R0   t   portt   socktype(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyR   ™   s    i    c      	   C` sH  t  | t ƒ r! | j d ƒ } n3 t  | t ƒ s; | t @rT t | | | | | | ƒ S|  j | | ƒ \ } } t d f t d f t	 d f g } | rÇ g  | D]$ \ }	 }
 |	 | k rš |	 |
 f ^ qš } n  | rg  | D]$ \ }	 }
 | |
 k rÔ |	 |
 f ^ qÔ } n  |  j
 } | t k rQt |  j d ƒ } | j | | t ƒ | j | | t ƒ n~ | t k r…t |  j d ƒ } | j | | t ƒ nJ | t k r¹t |  j d ƒ } | j | | t ƒ n t d d | f ƒ ‚ | j ƒ  } t | ƒ d k r| d | d k r| j ƒ  n  g  } g  } g  } xû | D]ó } | j t k r“xÛ | d	 D]E } | | f } x0 | D]( \ } } | j t | | d
 | f ƒ q`WqGWq'| j t k r'xu | d	 D]f } | d k rÈ| } n | } | | d d f } x0 | D]( \ } } | j t | | d
 | f ƒ qçWq­Wq'q'W| | | 7} | sDt d d ƒ ‚ n  | S(   NR@   i   i   i    i   i   i   s   ai_family not supported: %riÿÿÿÿt    s   ::1iûÿÿÿs#   No address associated with hostname(   R    R   RC   RB   R   R   R   R   R   R   R&   R   t   ValuesR   R?   R   R   R   R!   t   lent   popR>   t   append(   R0   t   hostRM   R>   RN   t   protot   flagst	   socktypest   socktype_protot   xt   yR&   t   ares_valuesR   RK   t   result4t   result6t   addrst   addrt   sockaddrt	   socktype4t   proto4t   destt	   socktype6t   proto6(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   _getaddrinfoœ   s\    !44	&'	+c         C` sc   x\ t  r^ |  j } y  |  j | | | | | | ƒ SWq t k
 rZ | |  j k r[ ‚  q[ q Xq Wd  S(   N(   RI   R&   Rf   R   (   R0   RT   RM   R>   RN   RU   RV   R&   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyR   â   s    		 c         C` s‚  t  r[ t | t ƒ r' | j d ƒ } q§ t | t t f ƒ s§ t d t | ƒ j ƒ ‚ q§ nL t | t	 ƒ r| | j d ƒ } n+ t | t ƒ s§ t d t | ƒ j ƒ ‚ n  t
 |  j ƒ } y! |  j j | | ƒ | j ƒ  SWn¤ t k
 r}|  j | d  d t d t ƒ} | s‚  n  | d d d } t | t	 ƒ rD| j d ƒ } n  | | k rV‚  n  | j ƒ  |  j j | | ƒ | j ƒ  SXd  S(	   NR@   s   Expected es(idna), not %sRA   s   Expected string, not %sR>   RN   i    iÿÿÿÿ(   R	   R    RB   RC   RD   RE   RF   RG   RH   R   R
   R   R&   t   gethostbyaddrR!   R   Rf   R   R   R   t   clear(   R0   t
   ip_addressRJ   RK   t   _ip_address(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   _gethostbyaddrë   s2    
c         C` sc   t  | t ƒ } xM t r^ |  j } y |  j | ƒ SWq t k
 rZ | |  j k r[ ‚  q[ q Xq Wd  S(   N(   R   R   RI   R&   Rk   R   (   R0   Ri   R&   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyRg     s    		c         C` s  t  | t ƒ s t d ƒ ‚ n  t  | t ƒ s< t d ƒ ‚ n  | d } t rn t  | t ƒ rn | j d ƒ } n  t  | t ƒ s™ t d t | ƒ j	 ƒ ‚ n  | d } t  | t ƒ sË t d t | ƒ ƒ ‚ n  t
 |  j ƒ } |  j | t | d ƒ d t d	 t ƒ} | st t j ƒ  Œ  n! t | ƒ d k r<t d
 ƒ ‚ n  | d \ } } }	 }
 } | t k r…t | ƒ d k r¦t d ƒ ‚ q¦n! | t k r¦| d  | d } n  |  j j | | | ƒ | j ƒ  \ } } | d  k rt rþt d ƒ } d | _ | ‚ n  d } n  | | f S(   Ns   an integer is requireds(   getnameinfo() argument 1 must be a tuplei    RA   s$   sockaddr[0] must be a string, not %si   s   port must be an integer, not %sR>   RN   s'   sockaddr resolved to multiple addressesi   s   IPv4 sockaddr must be 2 tuples,   nodename nor servname provided, or not knowni   t   0(   R    t   intRF   t   tupleR	   R   RC   R   RG   RH   R
   R   Rf   RB   R   R   R   t   syst   exc_infoRQ   R   R   R   R&   t   getnameinfoR!   R   R   t   errno(   R0   R`   RV   t   addressRM   RJ   RK   R>   t	   _socktypet   _protot   _namet   nodet   servicet   err(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   _getnameinfo  sB    

(			c         C` sW   xP t  rR |  j } y |  j | | ƒ SWq t k
 rN | |  j k rO ‚  qO q Xq Wd  S(   N(   RI   R&   Rz   R   (   R0   R`   RV   R&   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyRq   A  s    		N(   RH   t
   __module__t   __doc__R   R$   R   RI   R5   R7   R/   R;   R   R?   R<   R   Rf   R   Rk   Rg   Rz   Rq   (    (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyR   )   s   (				F			
	/RP   c           B` s5   e  Z d  d d d g Z d „  Z d „  Z d „  Z RS(   t   countR   R   RJ   c         C` s.   | |  _  g  |  _ d  |  _ t | ƒ |  _ d  S(   N(   R}   R   R   R   R
   RJ   (   R0   R   R}   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyR5   Q  s    			c         C` sf   |  j  d 8_  | j d  k r4 |  j j | j ƒ n | j |  _ |  j  d k rb |  j j d  ƒ n  d  S(   Ni   i    (	   R}   t	   exceptionR   R   RS   R4   R   RJ   t   switch(   R0   t   source(    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   __call__W  s    c         C` s<   |  j  j ƒ  |  j r |  j St d  k	 s/ t ‚ |  j ‚ d  S(   N(   RJ   R!   R   R   R   t   AssertionError(   R0   (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyR!   `  s
    	(   RH   R{   t	   __slots__R5   R   R!   (    (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyRP   K  s   			(*   R|   t
   __future__R    R   R   R'   Ro   t   _socketR   R   R   t   gevent._compatR   R   R   R	   t
   gevent.hubR
   R   t   gevent.socketR   R   R   R   R   R   R   t   gevent._configR   R   t   caresR   R   RO   R   RL   R   R   t   __all__R   t   objectRP   (    (    (    s3   lib/python2.7/site-packages/gevent/resolver/ares.pyt   <module>   s:   	ÿ #