U
.e @ sn d dl mZ d dlZddlmZmZ ddlmZ dd Zej ddfd d
Z
d d Z d
d Z dd Z
e
dZdS ) )absolute_importN )NoWayToWaitForSocketError
wait_for_read )_appengine_environc C sN t | dd}|dkrdS |dkr$dS zt|ddW S tk
rH Y dS X dS )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 )Zconnr r G/usr/lib/python3.8/site-packages/pip/_vendor/urllib3/util/connection.pyis_connection_dropped s
r
c C s | \}}| dr |d}d}t }t|||tjD ]}|\} }
} } }
d}zNt| |
| }t|| |tjk r||| |r| | |
|
|W S tj k
r } z |}|dk r| d}W 5 d}~X Y q8X q8|dk r|t ddS )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)
startswithstripallowed_gai_familysocketZ getaddrinfoZ SOCK_STREAM_set_socket_options_GLOBAL_DEFAULT_TIMEOUTZ
settimeoutbindZconnecterrorclose)Zaddressr Zsource_addressZsocket_optionshostZporterrfamilyresZafZsocktypeprotoZ canonnameZsar er r r create_connection! s2
r c C s$ |d kr d S |D ]}| j | qd S )N)Z
setsockopt)r Zoptionsoptr r r r Y s r c C s t j} trt j} | S )zThis 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 ZAF_INETHAS_IPV6Z AF_UNSPEC)r r r r r a s r c C sb d}d}t rdS tjrRz"ttj}|| df d}W n tk
rP Y nX |r^| |S )z6 Returns True if the system can bind an IPv6 address. NFr T)r Zis_appengine_sandboxr has_ipv6ZAF_INET6r Exceptionr )r r r! r r r _has_ipv6l s r# z::1)Z
__future__r r waitr r Zcontribr r
r r r r r# r r r r r s
8