3
]ð]  ã               @   sn   d dl mZ d dlZddlmZmZ ddl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é   )ÚNoWayToWaitForSocketErrorÚwait_for_readé   )Ú_appengine_environc             C   sJ   t | ddƒ}|dkrdS |dkr$dS yt|dd�S  tk
rD   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   r   )Úconnr   © r   ú:/tmp/pip-build-irfnccat/urllib3/urllib3/util/connection.pyÚis_connection_dropped   s    
r   c             C   sô   | \}}|j dƒr|jdƒ}d}tƒ }x²tj|||tjƒD ]œ}|\}	}
}}}d}yHtj|	|
|ƒ}t||ƒ |tjk	r~|j|ƒ |rŒ|j	|ƒ |j
|ƒ |S  tjk
rÔ } z|}|dk	rÄ|jƒ  d}W Y dd}~X q:X q:W |dk	ræ|‚tj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   Y   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   a   s    r   c             C   sb   d}d}t jƒ rdS tjrRy"tjtjƒ}|j| dfƒ d}W n tk
rP   Y nX |r^|jƒ  |S )z6 Returns True if the system can bind an IPv6 address. NFr   T)r   Zis_appengine_sandboxr   Úhas_ipv6ÚAF_INET6r   Ú	Exceptionr   )r    r   r2   r   r   r   Ú	_has_ipv6l   s    r5   z::1)Ú
__future__r   r   Úwaitr   r   Úcontribr   r   r   r+   r   r   r5   r0   r   r   r   r   Ú<module>   s   4