File manager - Edit - /opt/gsutil/third_party/urllib3/src/urllib3/__pycache__/poolmanager.cpython-39.pyc
Back
a '�of�Y � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlmZ d dlm Z ddl m Z m Z ddl mZ ddlmZ dd lmZmZmZ dd lmZmZmZmZ dd lmZ dd l m Z dd l m Z ddl m!Z! ddl"m#Z# ddl$m%Z%m&Z& ej'r�d dl(Z(d dl)m*Z* g d�Z+e�,e-�Z.dZ/dZ0G dd� dej1�Z2dddd�dd�Z3e�4e3e2�e�4e3e2�d �Z5eed �Z6G d d � d e�Z7G d d � d e7�Z8d!d"d d#�d$d%�Z9dS )&� )� annotationsN)� TracebackType)�urljoin� )�HTTPHeaderDict�RecentlyUsedContainer)�RequestMethods)� ProxyConfig)�HTTPConnectionPool�HTTPSConnectionPool�port_by_scheme)�LocationValueError� MaxRetryError�ProxySchemeUnknown�URLSchemeUnknown)�BaseHTTPResponse)�_TYPE_SOCKET_OPTIONS)� connection_requires_http_tunnel)�Retry)�Timeout)�Url� parse_url)�Self)� PoolManager� ProxyManager�proxy_from_url) �key_file� cert_file� cert_reqs�ca_certs� ca_cert_data� ssl_version�ssl_minimum_version�ssl_maximum_version� ca_cert_dir� ssl_context� key_password�server_hostnamei @ c @ s� e Zd ZU dZded< ded< ded< ded< d ed < d ed < d ed< ded< ded< ded< ded< ded< ded< ded< ded< ded< ded < d ed < ded < d ed!< d"ed#< d ed$< d%ed&< d'ed(< d ed)< d*ed+< ded,< ded-< ded.< d/S )0�PoolKeyz� All known keyword arguments that could be provided to the pool manager, its pools, or the underlying connections. All custom key schemes should include the fields in this key at a minimum. �strZ key_schemeZkey_host� int | NoneZkey_portz Timeout | float | int | NoneZ key_timeoutzRetry | bool | int | NoneZ key_retriesz bool | NoneZ key_blockztuple[str, int] | NoneZkey_source_address� str | NoneZ key_key_fileZkey_key_passwordZ key_cert_fileZ key_cert_reqsZ key_ca_certszstr | bytes | NoneZkey_ca_cert_datazint | str | NoneZkey_ssl_versionzssl.TLSVersion | NoneZkey_ssl_minimum_versionZkey_ssl_maximum_versionZkey_ca_cert_dir�ssl.SSLContext | NoneZkey_ssl_contextZ key_maxsizez!frozenset[tuple[str, str]] | NoneZ key_headers� Url | NoneZ key__proxyZkey__proxy_headers�ProxyConfig | NoneZkey__proxy_configz_TYPE_SOCKET_OPTIONS | NoneZkey_socket_optionsZkey__socks_optionszbool | str | NoneZkey_assert_hostnameZkey_assert_fingerprintZkey_server_hostname� key_blocksizeN)�__name__� __module__� __qualname__�__doc__�__annotations__� r5 r5 �:/opt/gsutil/third_party/urllib3/src/urllib3/poolmanager.pyr( 8 s< r( z type[PoolKey]�dict[str, typing.Any])� key_class�request_context�returnc C s� |� � }|d �� |d< |d �� |d< dD ],}||v r,|| dur,t|| �� �||< q,|�d�}|durxt|�|d< t|�� �D ]}|�|�|d| < q�| j D ]}||vr�d||< q�|�d�du r�t |d< | f i |��S )a� Create a pool key out of a request context dictionary. According to RFC 3986, both the scheme and host are case-insensitive. Therefore, this function normalizes both before constructing the pool key for an HTTPS request. If you wish to change this behaviour, provide alternate callables to ``key_fn_by_scheme``. :param key_class: The class to use when constructing the key. This should be a namedtuple with the ``scheme`` and ``host`` keys at a minimum. :type key_class: namedtuple :param request_context: A dictionary-like object that contain the context for a request. :type request_context: dict :return: A namedtuple that can be used as a connection pool key. :rtype: PoolKey �scheme�host)�headers�_proxy_headersZ_socks_optionsN�socket_optionsZkey_r/ ) �copy�lower� frozenset�items�get�tuple�list�keys�pop�_fields�_DEFAULT_BLOCKSIZE)r8 r9 �context�keyZ socket_opts�fieldr5 r5 r6 �_default_key_normalizer_ s" rN ��http�httpsc s e Zd ZU dZdZded< dZded< d@dd d d d �� fd d� Zdd�dd�Zddddd�dd�Z dAddddd d �d d �Z d d�d d!�Z dBd#d$d#dd d%�d&d'�Z d(d d)�d*d+�Z d,d(d d-�d.d/�ZdCddd d0�d1d2�Zdd(d3�d4d5�Zd6d7d8�d9d:�ZdDddd7d d<d=�d>d?�Z� ZS )Er aV Allows for arbitrary requests while transparently keeping track of necessary connection pools for you. :param num_pools: Number of connection pools to cache before discarding the least recently used pool. :param headers: Headers to include with all requests, unless other headers are given explicitly. :param \**connection_pool_kw: Additional parameters are used to create fresh :class:`urllib3.connectionpool.ConnectionPool` instances. Example: .. code-block:: python import urllib3 http = urllib3.PoolManager(num_pools=2) resp1 = http.request("GET", "https://google.com/") resp2 = http.request("GET", "https://google.com/mail") resp3 = http.request("GET", "https://yahoo.com/") print(len(http.pools)) # 2 Nr- �proxyr. � proxy_config� �int� typing.Mapping[str, str] | None� typing.Any�None)� num_poolsr= �connection_pool_kwr: c s4 t � �|� || _| t|�| _t| _t�� | _d S �N)�super�__init__rZ r �pools�pool_classes_by_scheme�key_fn_by_schemer@ )�selfrY r= rZ �� __class__r5 r6 r] � s zPoolManager.__init__r )r: c C s | S r[ r5 �ra r5 r5 r6 � __enter__� s zPoolManager.__enter__ztype[BaseException] | NonezBaseException | NonezTracebackType | Noneztyping.Literal[False])�exc_type�exc_val�exc_tbr: c C s | � � dS )NF)�clear)ra rf rg rh r5 r5 r6 �__exit__� s zPoolManager.__exit__r) � dict[str, typing.Any] | Noner )r; r< �portr9 r: c C sx | j | }|du r | j�� }|�d�du r2t|d< dD ]}|�|d� q6|dkrftD ]}|�|d� qT|||fi |��S )a� Create a new :class:`urllib3.connectionpool.ConnectionPool` based on host, port, scheme, and any additional pool keyword arguments. If ``request_context`` is provided, it is provided as keyword arguments to the pool class used. This method is used to actually create the connection pools handed out by :meth:`connection_from_url` and companion methods. It is intended to be overridden for customization. N� blocksize)r; r< rl rP )r_ rZ r@ rD rJ rH � SSL_KEYWORDS)ra r; r< rl r9 Zpool_clsrL �kwr5 r5 r6 � _new_pool� s zPoolManager._new_poolc C s | j �� dS )z� Empty our store of pools and direct them all to close. This will not affect in-flight connections, but they will not be re-used after completion. N)r^ ri rd r5 r5 r6 ri s zPoolManager.clearrP r+ r* �r< rl r; � pool_kwargsr: c C sT |s t d��| �|�}|p d|d< |s:t�|d �� d�}||d< ||d< | �|�S )a� Get a :class:`urllib3.connectionpool.ConnectionPool` based on the host, port, and scheme. If ``port`` isn't given, it will be derived from the ``scheme`` using ``urllib3.connectionpool.port_by_scheme``. If ``pool_kwargs`` is provided, it is merged with the instance's ``connection_pool_kw`` variable and used to create the new connection pool, if one is needed. zNo host specified.rP r; �P rl r< )r �_merge_pool_kwargsr rD rA �connection_from_context)ra r< rl r; rr r9 r5 r5 r6 �connection_from_host s z PoolManager.connection_from_hostr7 )r9 r: c C sX d|v r t �dt� |�d� |d �� }| j�|�}|sBt|��||�}| j||d�S )z� Get a :class:`urllib3.connectionpool.ConnectionPool` based on the request context. ``request_context`` must at least contain the ``scheme`` key and its value must be a key in ``key_fn_by_scheme`` instance variable. �strictzdThe 'strict' parameter is no longer needed on Python 3+. This will raise an error in urllib3 v2.1.0.r; �r9 ) �warnings�warn�DeprecationWarningrH rA r` rD r �connection_from_pool_key)ra r9 r; Zpool_key_constructor�pool_keyr5 r5 r6 ru 1 s � z#PoolManager.connection_from_contextr( )r} r9 r: c C s� | j j�f | j �|�}|r,|W d � S |d }|d }|d }| j||||d�}|| j |< W d � n1 st0 Y |S )a Get a :class:`urllib3.connectionpool.ConnectionPool` based on the provided pool key. ``pool_key`` should be a namedtuple that only contains immutable objects. At a minimum it must have the ``scheme``, ``host``, and ``port`` fields. Nr; r< rl rx )r^ �lockrD rp )ra r} r9 �poolr; r< rl r5 r5 r6 r| J s (z$PoolManager.connection_from_pool_key)�urlrr r: c C s t |�}| j|j|j|j|d�S )a� Similar to :func:`urllib3.connectionpool.connection_from_url`. If ``pool_kwargs`` is not provided and a new pool needs to be constructed, ``self.connection_pool_kw`` is used to initialize the :class:`urllib3.connectionpool.ConnectionPool`. If ``pool_kwargs`` is provided, it is used instead. Note that if a new pool does not need to be created for the request, the provided ``pool_kwargs`` are not used. )rl r; rr )r rv r< rl r; )ra r� rr �ur5 r5 r6 �connection_from_urld s �z PoolManager.connection_from_url)�overrider: c C sT | j �� }|rP|�� D ]8\}}|du rFz ||= W qN tyB Y qN0 q|||< q|S )a Merge a dictionary of override values for self.connection_pool_kw. This does not modify self.connection_pool_kw and returns a new dict. Any keys in the override dictionary with a value of ``None`` are removed from the merged dictionary. N)rZ r@ rC �KeyError)ra r� Zbase_pool_kwargsrL �valuer5 r5 r6 rt v s z PoolManager._merge_pool_kwargsr �bool)� parsed_urlr: c C s" | j du rdS t| j | j|j� S )z� Indicates if the proxy requires the complete destination URL in the request. Normally this is only needed when not using an HTTP CONNECT tunnel. NF)rR r rS r; )ra r� r5 r5 r6 �!_proxy_requires_url_absolute_form� s �z-PoolManager._proxy_requires_url_absolute_formTr ��methodr� �redirectro r: c K s� t |�}|jdu r"tjdtdd� | j|j|j|jd�}d|d< d|d< d |vrZ| j|d < | � |�rz|j ||fi |��}n|j ||j fi |��}|o�|� � }|s�|S t ||�}|jd kr�d }d|d < t|d ��� |d < |�d �} t| t�s�tj| |d�} | j�rN|�|��sN|d �� } |d D ]"} | �� | jv �r"| �| d� �q"| |d < z| j||||d�} W n* t�y� | j �r�|� � � | Y S 0 | |d < ||d< t � d||� |� � | j ||fi |��S )aN Same as :meth:`urllib3.HTTPConnectionPool.urlopen` with custom cross-host redirect logic and only sends the request-uri portion of the ``url``. The given ``url`` parameter must be absolute, such that an appropriate :class:`urllib3.connectionpool.ConnectionPool` can be chosen for it. Na URLs without a scheme (ie 'https://') are deprecated and will raise an error in a future version of urllib3. To avoid this DeprecationWarning ensure all URLs start with 'https://' or 'http://'. Read more in this issue: https://github.com/urllib3/urllib3/issues/2920� )�category� stacklevel)rl r; F�assert_same_hostr� r= i/ �GET�body�retries)r� )�response�_poolzRedirecting %s -> %s) r r; ry rz r{ rv r< rl r= r� �urlopen� request_uri�get_redirect_locationr �statusr �_prepare_for_method_changerD � isinstancer �from_int�remove_headers_on_redirect� is_same_hostr@ rA rH � incrementr �raise_on_redirect� drain_conn�log�info) ra r� r� r� ro r� �connr� �redirect_locationr� Z new_headers�headerr5 r5 r6 r� � s\ � � zPoolManager.urlopen)rT N)N)NrP N)N)T)r0 r1 r2 r3 rR r4 rS r] re rj rp ri rv ru r| r� rt r� r� � __classcell__r5 r5 rb r6 r � s. ! � �& � � �r c s� e Zd ZdZd!dddddd d d d d d� � fdd� Zd"d dd ddd�� fdd� Zd#dddd�dd�Zd$ddd d d d �� fd d � Z� ZS )%r a> Behaves just like :class:`PoolManager`, but sends all requests through the defined proxy, using the CONNECT method for HTTPS URLs. :param proxy_url: The URL of the proxy to be used. :param proxy_headers: A dictionary containing headers that will be sent to the proxy. In case of HTTP they are being sent with each request, while in the HTTPS/CONNECT case they are sent only once. Could be used for proxy authentication. :param proxy_ssl_context: The proxy SSL context is used to establish the TLS connection to the proxy when using HTTPS proxies. :param use_forwarding_for_https: (Defaults to False) If set to True will forward requests to the HTTPS proxy to be made on behalf of the client instead of creating a TLS tunnel via the CONNECT method. **Enabling this flag means that request and response headers and content will be visible from the HTTPS proxy** whereas tunneling keeps request and response headers and content private. IP address, target hostname, SNI, and port are always visible to an HTTPS proxy even when this flag is disabled. :param proxy_assert_hostname: The hostname of the certificate to verify against. :param proxy_assert_fingerprint: The fingerprint of the certificate to verify against. Example: .. code-block:: python import urllib3 proxy = urllib3.ProxyManager("https://localhost:3128/") resp1 = proxy.request("GET", "https://google.com/") resp2 = proxy.request("GET", "https://httpbin.org/") print(len(proxy.pools)) # 1 resp3 = proxy.request("GET", "https://httpbin.org/") resp4 = proxy.request("GET", "https://twitter.com/") print(len(proxy.pools)) # 3 rT NFr) rU rV r, r� z"None | str | typing.Literal[False]r+ rW rX ) � proxy_urlrY r= � proxy_headers�proxy_ssl_context�use_forwarding_for_https�proxy_assert_hostname�proxy_assert_fingerprintrZ r: c s� t |t�r&|j� d|j� d|j� �} n|} t| �} | jdvrFt| j��| jsft�| jd�} | j | d�} | | _ |pri | _ || _ t ||||�| _| j | d< | j | d< | j| d< t� j||fi | �� d S ) Nz://�:rO rs )rl �_proxyr> � _proxy_config)r� r r; r< rl r r r rD �_replacerR r� r� r rS r\ r] ) ra r� rY r= r� r� r� r� r� rZ Z str_proxy_urlrR rl rb r5 r6 r] # s, � zProxyManager.__init__rP r* rk r rq c s< |dkr t � j||||d�S t � j| jj| jj| jj|d�S )NrQ )rr )r\ rv rR r< rl r; )ra r< rl r; rr rb r5 r6 rv L s ��z!ProxyManager.connection_from_hostztyping.Mapping[str, str])r� r= r: c C s0 ddi}t |�j}|r ||d< |r,|�|� |S )z� Sets headers needed by proxies: specifically, the Accept and Host headers. Only sets headers not provided by the user. �Acceptz*/*�Host)r �netloc�update)ra r� r= Zheaders_r� r5 r5 r6 �_set_proxy_headers\ s z ProxyManager._set_proxy_headersTr r� c sR t |�}t| j| j|j�s8|�d| j�}| �||�|d< t� j ||fd|i|��S )z@Same as HTTP(S)ConnectionPool.urlopen, ``url`` must be absolute.r= r� ) r r rR rS r; rD r= r� r\ r� )ra r� r� r� ro r� r= rb r5 r6 r� m s zProxyManager.urlopen)rT NNNFNN)NrP N)N)T) r0 r1 r2 r3 r] rv r� r� r� r5 r5 rb r6 r � s" 9 �&, � � �r r) rW )r� ro r: c K s t f d| i|��S )Nr� )r )r� ro r5 r5 r6 r | s r ):� __future__r � functools�logging�typingry �typesr � urllib.parser � _collectionsr r �_request_methodsr � connectionr �connectionpoolr r r � exceptionsr r r r r� r Zutil.connectionr Z util.proxyr � util.retryr � util.timeoutr Zutil.urlr r � TYPE_CHECKING�sslZtyping_extensionsr �__all__� getLoggerr0 r� rn rJ � NamedTupler( rN �partialr` r_ r r r r5 r5 r5 r6 �<module> sH '< � L
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.04 |
proxy
|
phpinfo
|
Settings