← back to Atmos Game

assets/gen/.venv/lib/python3.12/site-packages/httpcore/_sync/__pycache__/connection.cpython-312.pyc

55 lines

�

c�bj. ����ddlmZddlZddlZddlZddlZddlZddlmZddl	m
Z
mZmZddl
mZmZddlmZmZmZddlmZdd	lmZdd
lmZddlmZdd
lmZdZej>d�Z dd�Z!Gd�de�Z"y)�)�annotationsN�)�SyncBackend)�
SOCKET_OPTION�NetworkBackend�
NetworkStream)�ConnectError�ConnectTimeout)�Origin�Request�Response)�default_ssl_context)�Lock)�Trace�)�HTTP11Connection)�ConnectionInterfaceg�?zhttpcore.connectionc#�ZK�d��tj�D]}|d|zz���y�w)z�
    Generate a geometric sequence that has a ratio of 2 and starts with 0.

    For example:
    - `factor = 2`: `0, 2, 4, 8, 16, 32, 64, ...`
    - `factor = 3`: `0, 3, 6, 12, 24, 48, 96, ...`
    rrN)�	itertools�count)�factor�ns  �p/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_sync/connection.py�exponential_backoffrs,�����G�
�_�_�
���q�!�t�m���s�)+c���eZdZ									d																					dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Z	dd	�Z
dd
�Zdd�Zdd�Z
dd
�Z			d							dd�Zy)�HTTPConnectionNc���||_||_||_||_||_||_||_||_|	�
t�n|	|_	d|_
d|_t�|_
|
|_y)NF)�_origin�_ssl_context�_keepalive_expiry�_http1�_http2�_retries�_local_address�_udsr�_network_backend�_connection�_connect_failedr�
_request_lock�_socket_options)�self�origin�ssl_context�keepalive_expiry�http1�http2�retries�
local_address�uds�network_backend�socket_optionss           r�__init__zHTTPConnection.__init__'sy�����'���!1�����������
�+�����	�-�4�K�M�/�	
��8<���%*���!�V���-���c��|j|jj�s/td|jj�d|j����	|j
5|j��|j|�}|jd�}|duxr|j�dk(}|s|jr7|js+ddlm
}||j||j��|_n't|j||j��|_ddd�|jj%|�S#1swY�$xYw#t $r}d|_|�d}~wwxYw)	NzAttempted to send request to z on connection to �
ssl_object�h2r)�HTTP2Connection)r,�streamr.T)�can_handle_request�urlr,�RuntimeErrorrr)r'�_connect�get_extra_info�selected_alpn_protocolr"r!r0r;r r�
BaseExceptionr(�handle_request)r+�requestr<r9�http2_negotiatedr;�excs       rrDzHTTPConnection.handle_requestEsB���&�&�w�{�{�'9�'9�:��/����0B�0B�/C�CU�VZ�Vb�Vb�Uc�d��
�	��#�#��#�#�+�!�]�]�7�3�F�!'�!6�!6�|�!D�J�"�$�.�H�&�=�=�?�4�G�%�(�D�K�K����:�+:�#'�<�<�#)�-1�-C�-C�,��(�,<�#'�<�<�#)�-1�-C�-C�,��(�%$�6���.�.�w�7�7�7$�#��.�	�#'�D� ��I��	�s1�E�"B4D9�E�9E�>E�	E�	E�Ec�n�|jjdi�}|jjdd�}|jdd�}|j}tt��}		|j
��|jjjd�|jj|j||jd�}tdt||�5}|jjdi|��}	|	|_ddd�nX|j
||jd�}td	t||�5}|jj"di|��}	|	|_ddd�|jj$d
vr�|j&�
t)�n|j&}
|j*rddgndg}|
j-|�|
|xs%|jjjd�|d
�}tdt||�5}	j.di|��}	|	|_ddd�|	S	S#1swY��xYw#1swY��xYw#1swY	SxYw#t0t2f$r\|dkr�|dz}t5|�}tdt|�5}|jj7|�ddd�n#1swYnxYwYnwxYw��O)N�timeout�sni_hostname�connect)r�ascii)�host�portr2rIr5�connect_tcp)�pathrIr5�connect_unix_socket)�httpsswsszhttp/1.1r:)r-�server_hostnamerI�	start_tlsrr�retry�)�
extensions�getr#r�RETRIES_BACKOFF_FACTORr%rrM�decoderNr$r*r�loggerr&rO�return_valuerQ�schemerrr"�set_alpn_protocolsrTr	r
�next�sleep)
r+rE�timeoutsrJrI�retries_left�delays�kwargs�tracer<r-�alpn_protocols�delays
             rr@zHTTPConnection._connectis����%�%�)�)�)�R�8���)�)�-�-�n�d�C���,�,�y�$�/���}�}��$�,B�C���3
7��9�9�$� $��� 1� 1� 8� 8�� A� $��� 1� 1�)-�)<�)<�#*�*.�*>�*>��F��}�f�g�v�F�%�!B��!6�!6�!B�!B�!L�V�!L��-3��*�G�F�
!%�	�	�#*�*.�*>�*>��F�
�-�v�w����!J��!6�!6�!J�!J�"�$�"��.4��*�
��<�<�&�&�*<�<� �,�,�4�,�-�!�.�.� �
<@�;�;�j�$�%7�Z�L�N��2�2�>�B�(3�+7�,=��<�<�,�,�3�3�G�<�#*�	�F��{�F�G�V�D��!1��!1�!1�!;�F�!;��-3��*�E��
�v�
�GG�F�����.E��
�� �.�1�
7��1�$����!���V����7�F�G�V�<���)�)�/�/��6�=�<�<��
7��]s��)A1I�$H"�>5I�3$H.�B%I�<H:�	I� I�"H+�'I�.H7�3I�:I�?I�I�7J2�>J#�	J2�#J,	�(J2�1J2c� �||jk(S�N)r)r+r,s  rr=z!HTTPConnection.can_handle_request�s������%�%r7c��|j�6tdtdi�5|jj�ddd�yy#1swYyxYw)N�close)r'rr[rk�r+s rrkzHTTPConnection.close�sB�����'��w���b�1�� � �&�&�(�2�1�(�1�1�s�A�A
c���|j�E|jxr7|jjdk(xs
|jxr
|j
S|jj
�S)NrR)r'r"rr]r!r(�is_availablerls rrnzHTTPConnection.is_available�sf�����#�
���-��\�\�(�(�H�4�G�D�K�K��-��,�,�,�
�
���,�,�.�.r7c�f�|j�|jS|jj�Sri)r'r(�has_expiredrls rrpzHTTPConnection.has_expired�s/�����#��'�'�'����+�+�-�-r7c�f�|j�|jS|jj�Sri)r'r(�is_idlerls rrrzHTTPConnection.is_idle�s/�����#��'�'�'����'�'�)�)r7c�f�|j�|jS|jj�Sri)r'r(�	is_closedrls rrtzHTTPConnection.is_closed�s/�����#��'�'�'����)�)�+�+r7c�n�|j�|jrdSdS|jj�S)NzCONNECTION FAILED�
CONNECTING)r'r(�inforls rrwzHTTPConnection.info�s7�����#�*.�*>�*>�&�P�L�P����$�$�&�&r7c�X�d|jj�d|j��d�S)N�<z [z]>)�	__class__�__name__rwrls r�__repr__zHTTPConnection.__repr__�s(���4�>�>�*�*�+�2�d�i�i�k�]�"�=�=r7c��|SrirVrls r�	__enter__zHTTPConnection.__enter__�s���r7c�$�|j�yri)rk)r+�exc_type�	exc_value�	tracebacks    r�__exit__zHTTPConnection.__exit__�s
��	
�
�
�r7)	NNTFrNNNN)r,rr-zssl.SSLContext | Noner.zfloat | Noner/�boolr0r�r1�intr2�
str | Noner3r�r4zNetworkBackend | Noner5z%typing.Iterable[SOCKET_OPTION] | None�return�None)rErr�r
)rErr�r)r,rr�r�)r�r�)r�r�)r��str)r�r)NNN)r�ztype[BaseException] | Noner�zBaseException | Noner�ztypes.TracebackType | Noner�r�)r{�
__module__�__qualname__r6rDr@r=rkrnrprrrtrwr|r~r�rVr7rrr&s���.2�)-����$(��15�@D�.��.�+�.�'�	.�
�.��
.��.�"�.��.�/�.�>�.�
�.�<"8�H<7�|&�)�

/�.�
*�
,�
'�
>��
04�*.�04�	�,��(��.�	�

�r7r)r�floatr�ztyping.Iterator[float])#�
__future__rr�logging�ssl�types�typing�_backends.syncr�_backends.baserrr�_exceptionsr	r
�_modelsrrr
�_sslr�_synchronizationr�_tracer�http11r�
interfacesrrY�	getLoggerr[rrrVr7r�<module>r�sg��"���
��
�(�I�I�6�/�/�&�#��$�+���
��	�	�0�	1��
�x�(�xr7