| Server IP : 127.0.0.1 / Your IP : 216.73.216.109 Web Server : Apache/2.4.54 (Win64) OpenSSL/1.1.1q PHP/8.1.10 System : Windows NT DESKTOP-E5T4RUN 10.0 build 19045 (Windows 10) AMD64 User : SERVERWEB ( 0) PHP Version : 8.1.10 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/cygwin64/lib/python3.9/site-packages/urllib3/__pycache__/ |
Upload File : |
a
�?�aӒ � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z
ddl m Z m
Z
mZmZmZmZmZmZ ddlmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z! ddl"m#Z# dd l$m%Z% dd
l&m'Z' dd l(m)Z) dd l*m+Z+ dd
l,m-Z- ddl.m/Z/ ddl0m1Z1 ddl2m3Z3 ddl4m5Z5 ddl6m7Z7 ddl8m9Z9 ddl:m;Z;m<Z< ddl:m=Z> ddl:m?Z?m@Z@ e#jAjBZBe�CeD�ZEeF� ZGG dd� deF�ZHejIejJhZKG dd� deHe)�ZLG dd � d eL�ZMd d � ZNd d � Z=dS )!� )�absolute_importN)�error��timeout� )� BaseSSLError�BrokenPipeError�DummyConnection�HTTPConnection�
HTTPException�HTTPSConnection�VerifiedHTTPSConnection�port_by_scheme)
�ClosedPoolError�EmptyPoolError�HeaderParsingError�HostChangedError�InsecureRequestWarning�LocationValueError�
MaxRetryError�NewConnectionError�
ProtocolError�
ProxyError�ReadTimeoutError�SSLError� TimeoutError)�six)�queue)�CertificateError)�RequestMethods)� HTTPResponse)�is_connection_dropped)� connection_requires_http_tunnel)� LifoQueue)�set_file_position)�assert_header_parsing)�Retry)�Timeout)�Url�_encode_target)�_normalize_host)�get_host� parse_urlc @ s> e Zd ZdZeZd dd�Zdd� Zdd� Zdd � Z d
d � Z
dS )
�ConnectionPoolNc C s0 |s t d��t|| jd�| _|�� | _|| _d S )NzNo host specified.��scheme)r r* r/ �host�lower� _proxy_host�port)�selfr0 r3 � r5 �:/usr/lib/python3.9/site-packages/urllib3/connectionpool.py�__init__J s
zConnectionPool.__init__c C s dt | �j| j| jf S )Nz%s(host=%r, port=%r))�type�__name__r0 r3 �r4 r5 r5 r6 �__str__R s zConnectionPool.__str__c C s | S �Nr5 r: r5 r5 r6 � __enter__U s zConnectionPool.__enter__c C s | � � dS )NF)�close)r4 �exc_typeZexc_valZexc_tbr5 r5 r6 �__exit__X s zConnectionPool.__exit__c C s d S r< r5 r: r5 r5 r6 r> ] s zConnectionPool.close)N) r9 �
__module__� __qualname__r/ r# �QueueClsr7 r; r= r@ r> r5 r5 r5 r6 r- < s
r- c
@ s� e Zd ZdZeZeZddej dddddddf
dd�Z
dd� Z d d d
�Z d d � Z
d
d� Zdd� Zdd� Zdd� Zedfdd�Zdd� Zdd� Zdd � Zdddd d eddddf
d d �ZdS )!�HTTPConnectionPool�httpNFr c K s� t �| ||� t�| |� || _t|t�s4t�|�}|d u rBtj}|| _ || _
| � |�| _ || _
| | _|
pli | _| | _t|�D ]}
| j �d � q~d| _d| _| | _| jr�| j�dg � | j| jd< | j| jd< d S )Nr Zsocket_options�proxy� proxy_config)r- r7 r �strict�
isinstancer' �
from_floatr& ZDEFAULTr �retriesrC �pool�blockrF �
proxy_headersrG �xrange�put�num_connections� num_requests�conn_kw�
setdefault)r4 r0 r3 rH r �maxsizerM �headersrK �_proxy�_proxy_headersZ
_proxy_configrS �_r5 r5 r6 r7 � s.
zHTTPConnectionPool.__init__c C sR | j d7 _ t�d| j | j| jp$d� | jf | j| j| jj| jd�| j ��}|S )Nr z(Starting new HTTP connection (%d): %s:%sZ80)r0 r3 r rH )
rQ �log�debugr0 r3 �
ConnectionClsr �connect_timeoutrH rS �r4 �connr5 r5 r6 � _new_conn� s ���z HTTPConnectionPool._new_connc C s� d }z| j j| j|d�}W n> ty6 t| d��Y n$ tjyX | jrTt| d��Y n0 |r�t|�r�t �
d| j � |� � t
|dd�dkr�d }|p�| �� S )N)rM r zPool is closed.z>Pool reached maximum size and no more connections are allowed.z Resetting dropped connection: %sZ auto_openr r )rL �getrM �AttributeErrorr r �Emptyr r! rZ r[ r0 r> �getattrr` )r4 r r_ r5 r5 r6 � _get_conn� s$ � z HTTPConnectionPool._get_connc C sZ z| j j|dd� W d S ty( Y n" tjyH t�d| j� Y n0 |rV|�� d S )NF�rM z2Connection pool is full, discarding connection: %s) rL rP rb r ZFullrZ �warningr0 r> r^ r5 r5 r6 � _put_conn s z HTTPConnectionPool._put_connc C s d S r< r5 r^ r5 r5 r6 �_validate_conn6 s z!HTTPConnectionPool._validate_connc C s d S r< r5 r^ r5 r5 r6 �_prepare_proxy< s z!HTTPConnectionPool._prepare_proxyc C s2 |t u r| j�� S t|t�r$|�� S t�|�S d S r< )�_Defaultr ZclonerI r' rJ )r4 r r5 r5 r6 � _get_timeout@ s
z HTTPConnectionPool._get_timeoutc C sj t |t�rt| |d| ��t|d�r>|jtv r>t| |d| ��dt|�v sVdt|�v rft| |d| ��d S )N�!Read timed out. (read timeout=%s)�errnoz timed outzdid not complete (read))rI �
SocketTimeoutr �hasattrrn �_blocking_errnos�str)r4 �err�url�
timeout_valuer5 r5 r6 �_raise_timeoutL s
�
��
�z!HTTPConnectionPool._raise_timeoutc
K s| | j d7 _ | �|�}|�� |j|_z| �|� W n< ttfyr } z | j|||jd� � W Y d }~n
d }~0 0 z2|r�|j ||fi |�� n|j
||fi |�� W nL t y� Y n< t y� } z$|j
t
jt
jt
jhvrނ W Y d }~n
d }~0 0 |j} t|dd ��rL| dk�r"t| |d| ��| tju �r@|j�t�� � n |j�| � zjz|jdd�}
W nT t�y� z |�� }
W n2 t �y� } zt � |d � W Y d }~n
d }~0 0 Y n0 W n> ttt f�y� } z | j||| d� � W Y d }~n
d }~0 0 t|dd �} t �!d
| j"| j#| j$||| |
j%|
j&� zt'|
j(� W nB t)tf�yv } z$t j*d | �+|�| dd � W Y d } ~ n
d } ~ 0 0 |
S )
Nr )rs rt ru �sockr rm T)� bufferingZ
_http_vsn_strzHTTP/?z%s://%s:%s "%s %s %s" %s %sz$Failed to parse headers (url=%s): %s)�exc_info),rR rl Z
start_connectr] r ri ro r rv Zrequest_chunked�requestr �IOErrorrn ZEPIPEZ ESHUTDOWNZ
EPROTOTYPE� read_timeoutrd r r' �DEFAULT_TIMEOUTrw Z
settimeout�socketZgetdefaulttimeoutZ getresponse� TypeError�
BaseExceptionr Z
raise_from� SocketErrorrZ r[ r/ r0 r3 �status�lengthr% �msgr rg �
_absolute_url)
r4 r_ �methodrt r �chunkedZhttplib_request_kw� timeout_obj�er| �httplib_responseZ http_versionZhper5 r5 r6 �
_make_requeste s�
�
� , � � z HTTPConnectionPool._make_requestc C s t | j| j| j|d�jS )N)r/ r0 r3 �path)r( r/ r0 r3 rt )r4 r� r5 r5 r6 r� � s z HTTPConnectionPool._absolute_urlc C sT | j d u rd S | j d }| _ z |jdd�}|r |�� q W n tjyN Y n0 d S )NFrf )rL ra r> r rc )r4 Zold_poolr_ r5 r5 r6 r> � s
zHTTPConnectionPool.closec C sx |� d�rdS t|�\}}}|d ur0t||d�}| jrF|sFt�|�}n| js^|t�|�kr^d }|||f| j| j| jfkS )N�/Tr. )�
startswithr+ r* r3 r ra r/ r0 )r4 rt r/ r0 r3 r5 r5 r6 � is_same_host� s
z HTTPConnectionPool.is_same_hostTc
K s< t |�}|j}|d u r | j}t|t�s8tj||| jd�}|
d u rL|
�dd�}
|rf| �|�sft | ||��|�
d�r�t � t
|��}n t � |j�}d }|
}t| j| j|�}|s�|�� }|�| j� d }d}t|| �} �z�z�| �|�}| j| d�}|j|_| jd u�o
t|dd � }|�r"|�r"| �|� | j ||||||| d�}|
�sD|nd }||
d < | j j |f| ||d
�|
��}d}W n� t �y� d}d}� Y n� t t!t"t#t$t%t&f�yF } z�d}t|t$t&f��r�t%|�}n>t|t"t'f��r�| j�r�t(d |�}nt|t"t!f��r
t#d |�}|j)|||| t*�+� d
d�}|�,� |}W Y d }~n
d }~0 0 W |�sb|�o\|�-� }d}|�r�| �.|� n*|�s�|�o�|�-� }d}|�r�| �.|� 0 |�s�t/�0d|||� | j1|||||||f|| |
| | d�|
��S |�o�|�2� }|�r�|j3dk�rd}z|j)|||| d�}W n* t4�yB |j5�r:|�6� � | Y S 0 |�6� |�7|� t/�8d||� | j1||||f||||| |
| | d�|
��S t9|�:d��} |�;||j3| ��r8z|j)|||| d�}W n* t4�y� |j<�r�|�6� � | Y S 0 |�6� |�,|� t/�8d|� | j1||||f||||| |
| | d�|
��S |S )N)�redirect�defaultZpreload_contentTr� Fr rw )r �bodyrV r� Zrequest_method)rL �
connectionrK zCannot connect to proxy.zConnection aborted.� )r �_poolZ _stacktracez1Retrying (%r) after connection broken by '%r': %s)r � pool_timeout� release_connr� �body_posi/ ZGET)�responser� zRedirecting %s -> %s)rK r� �assert_same_hostr r� r� r� r� z Retry-Afterz Retry: %s)=r, r/ rV rI r& Zfrom_intrK ra r� r r� r Z
ensure_strr) rt r" rF rG �copy�updaterN r$ rl re r] r rd rj r� � ResponseClsZ from_httplibr r r r� r r r r r r Z increment�sysry �sleepr> rh rZ rg �urlopenZget_redirect_locationr� r Zraise_on_redirectZ
drain_connZsleep_for_retryr[ �boolZ getheaderZis_retryZraise_on_status) r4 r� rt r� rV rK r� r� r r� r� r� r� Z response_kwZ
parsed_urlZdestination_schemer_ Zrelease_this_connZhttp_tunnel_requiredrs Z
clean_exitr� Zis_new_proxy_connr� Z
response_connr� r� Zredirect_locationZhas_retry_afterr5 r5 r6 r� sV m
�
�
���� �
� � ���
�
��
�
��
�zHTTPConnectionPool.urlopen)N)r9 rA rB r/ r
r\ r r� r' r} r7 r` re rh ri rj rl rv rk r� r� r> r� r� r5 r5 r5 r6 rD h sJ <�
6
' �
w�rD c sl e Zd ZdZeZddejdddddddddddddddfdd�Zdd� Z d d
� Z
d d � Z � fd
d�Z � Z
S )�HTTPSConnectionPool�httpsNFr c K s` t j| ||||||||| |
f i |�� | | _| | _|
| _|| _|| _|| _|| _|| _ || _
d S r< ) rD r7 �key_file� cert_file� cert_reqs� key_password�ca_certs� ca_cert_dir� ssl_version�assert_hostname�assert_fingerprint)r4 r0 r3 rH r rU rM rV rK rW rX r� r� r� r� r� r� r� r� r� rS r5 r5 r6 r7 r s0 � �z HTTPSConnectionPool.__init__c
C s@ t |t�r<|j| j| j| j| j| j| j| j | j
d� | j |_ |S )N)r� r� r� r� r� r� r� r� ) rI r
Zset_certr� r� r� r� r� r� r� r� r� r^ r5 r5 r6 �
_prepare_conn� s
�
z!HTTPSConnectionPool._prepare_connc C s2 |� | j| j| j� | jjdkr&d|_|�� d S )Nr� T)Z
set_tunnelr2 r3 rN rF r/ Ztls_in_tls_required�connectr^ r5 r5 r6 rj � s z"HTTPSConnectionPool._prepare_proxyc
C s� | j d7 _ t�d| j | j| jp$d� | jr8| jtu r@td��| j}| j}| jd urf| jj}| jj}| jf ||| j j
| j | j | j
| jd�| j��}| �|�S )Nr z)Starting new HTTPS connection (%d): %s:%sZ443zCCan't connect to HTTPS URL because the SSL module is not available.)r0 r3 r rH r� r� r� )rQ rZ r[ r0 r3 r\ r r rF r r] rH r� r� r� rS r� )r4 Z actual_hostZ actual_portr_ r5 r5 r6 r` � s8 ��
�� z HTTPSConnectionPool._new_connc s\ t t| ��|� t|dd �s$|�� |js<t�d|j t � t|dd �du rXt�dt � d S )Nrw z�Unverified HTTPS request is being made to host '%s'. Adding certificate verification is strongly advised. See: https://urllib3.readthedocs.io/en/1.26.x/advanced-usage.html#ssl-warningsZproxy_is_verifiedFz�Unverified HTTPS connection done to an HTTPS proxy. Adding certificate verification is strongly advised. See: https://urllib3.readthedocs.io/en/1.26.x/advanced-usage.html#ssl-warnings)
�superr� ri rd r� Z is_verified�warnings�warnr0 r r^ �� __class__r5 r6 ri � s ��
�z"HTTPSConnectionPool._validate_conn)r9 rA rB r/ r r\ r' r} r7 r� rj r` ri �
__classcell__r5 r5 r� r6 r� a s2 �
1$r� c K sR t | �\}}}|p t�|d�}|dkr:t|fd|i|��S t|fd|i|��S d S )N�P r� r3 )r+ r ra r� rD )rt �kwr/ r0 r3 r5 r5 r6 �connection_from_url s
r� c C s. t | |�} | �d�r*| �d�r*| dd� } | S )N�[�]r ���)�normalize_hostr� �endswith)r0 r/ r5 r5 r6 r* ' s
r* )OZ
__future__r rn Zloggingr~ r� r� r r� r ro r� r r r r
r r r
r �
exceptionsr r r r r r r r r r r r r Zpackagesr Zpackages.six.movesr Zpackages.ssl_match_hostnamer rz r r� r Zutil.connectionr! Z
util.proxyr" Z
util.queuer# Z util.requestr$ Z
util.responser% Z
util.retryr& Z util.timeoutr' Zutil.urlr( r) r* r� r+ r, ZmovesrO Z getLoggerr9 rZ �objectrk r- ZEAGAINZ EWOULDBLOCKrq rD r� r� r5 r5 r5 r6 �<module> sN (
<
) ~ +