
Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­Â�Â­
<!DOCTYPE html>
<html>
3
ÝPf�  ã               @   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   )Zconnr   © r   ú /usr/lib/python3.6/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ÚsocketZgetaddrinfoZSOCK_STREAMÚ_set_socket_optionsÚ_GLOBAL_DEFAULT_TIMEOUTZ
settimeoutÚbindZconnectÚerrorÚclose)Zaddressr   Zsource_addressZsocket_optionsÚhostZportÚerrÚfamilyÚresZafZsocktypeÚprotoZ	canonnameZsar   Úer   r   r   Úcreate_connection$   s2    






r   c             C   s(   |d krd S x|D ]}| j |Ž  qW d S )N)Z
setsockopt)r   Z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   ZAF_INETÚHAS_IPV6Z	AF_UNSPEC)r   r   r   r   r   `   s    r   c             C   sV   d}d}t jrFy"t j t jƒ}|j| dfƒ d}W n tk
rD   Y nX |rR|jƒ  |S )z6 Returns True if the system can bind an IPv6 address. NFr   T)r   Úhas_ipv6ZAF_INET6r   Ú	Exceptionr   )r   r   r!   r   r   r   Ú	_has_ipv6k   s    r#   z::1)Z
__future__r   r   Úwaitr   Z	selectorsr   r   r   r   r   r   r   r#   r    r   r   r   r   Ú<module>   s   3