B
    @)H[  ã               @   sn   d dl mZ d dlZddlmZ ddlmZmZ dd„ Zej	ddfdd	„Z
d
d„ Zdd„ Zdd„ ZedƒZdS )é    )Úabsolute_importNé   )Úwait_for_read)Ú
HAS_SELECTÚSelectorErrorc             C   sV   t | ddƒ}|dkrdS |dkr$dS ts,dS ytt|dd�ƒS  tk
rP   dS X dS )a   
    Returns True if the connection is dropped and should be closed.

    :param conn:
        :class:`httplib.HTTPConnection` object.

    Note: For platforms like AppEngine, this will always return ``False`` to
    let the platform handle connection recycling transparently for us.
    ÚsockFNTg        )Útimeout)Úgetattrr   Úboolr   r   )Úconnr   © r   údC:\Users\HIRONO~1\AppData\Local\Temp\pip-install-qz7kpjmn\pip\pip\_vendor\urllib3\util\connection.pyÚis_connection_dropped   s    
r   c             C   sô   | \}}|  d¡r| d¡}d}tƒ }x²t |||tj¡D ]œ}|\}	}
}}}d}yHt |	|
|¡}t||ƒ |tjk	r~| |¡ |rŒ| 	|¡ | 
|¡ |S  tjk
rÔ } z|}|dk	rÄ| ¡  d}W dd}~X Y q:X q:W |dk	ræ|‚t d¡‚dS )ad  Connect to *address* and return the socket object.

    Convenience function.  Connect to *address* (a 2-tuple ``(host,
    port)``) and return the socket object.  Passing the optional
    *timeout* parameter will set the timeout on the socket instance
    before attempting to connect.  If no *timeout* is supplied, the
    global default timeout setting returned by :func:`getdefaulttimeout`
    is used.  If *source_address* is set it must be a tuple of (host, port)
    for the socket to bind as a source address before making the connection.
    An host of '' or port 0 tells the OS to use the default.
    ú[z[]Nz!getaddrinfo returns an empty list)Ú
startswithÚstripÚallowed_gai_familyÚsocketÚgetaddrinfoÚSOCK_STREAMÚ_set_socket_optionsÚ_GLOBAL_DEFAULT_TIMEOUTÚ
settimeoutÚbindÚconnectÚerrorÚclose)Úaddressr   Úsource_addressÚsocket_optionsÚhostÚportÚerrÚfamilyÚresÚafÚsocktypeÚprotoÚ	canonnameÚsar   Úer   r   r   Úcreate_connection$   s2    






r+   c             C   s(   |d krd S x|D ]}| j |Ž  qW d S )N)Ú
setsockopt)r   ÚoptionsÚoptr   r   r   r   X   s    
r   c              C   s   t j} trt j} | S )z³This function is designed to work in the context of
    getaddrinfo, where family=socket.AF_UNSPEC is the default and
    will perform a DNS search for both IPv6 and IPv4 records.)r   ÚAF_INETÚHAS_IPV6Ú	AF_UNSPEC)r#   r   r   r   r   `   s    r   c             C   sV   d}d}t jrFy"t   t j¡}| | df¡ d}W n tk
rD   Y nX |rR| ¡  |S )z6 Returns True if the system can bind an IPv6 address. NFr   T)r   Úhas_ipv6ÚAF_INET6r   Ú	Exceptionr   )r    r   r2   r   r   r   Ú	_has_ipv6k   s    r5   z::1)Ú
__future__r   r   Úwaitr   Ú	selectorsr   r   r   r   r+   r   r   r5   r0   r   r   r   r   Ú<module>   s   3