← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/__pycache__/trio.cpython-312.pyc
57 lines
�
c�bjl � � � d dl mZ d dlZd dlZd dlZddlmZmZmZm Z m
Z
m Z m Z m
Z
ddlmZmZmZ G d� de� Z G d � d
e� Zy) � )� annotationsN� )� ConnectError�ConnectTimeout�ExceptionMapping� ReadError� ReadTimeout�
WriteError� WriteTimeout�map_exceptions� )�
SOCKET_OPTION�AsyncNetworkBackend�AsyncNetworkStreamc �\ � e Zd Zd d�Zd
d d�Zd
d d�Zd
d�Z d dd�Zdd�Zdd�Z y)�
TrioStreamc � � || _ y �N)�_stream��self�streams �n/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/trio.py�__init__zTrioStream.__init__ s � � �� � Nc � � K � |� t d� n|}t j t t j t
t j t
i}t |� 5 t j |� 5 | j j |�� � d { ��� }|cd d d � cd d d � S 7 �# 1 sw Y nxY w d d d � y # 1 sw Y y xY w�w)N�inf)� max_bytes) �float�trio� TooSlowErrorr �BrokenResourceErrorr �ClosedResourceErrorr �
fail_afterr � receive_some)r r �timeout�timeout_or_inf�exc_map�datas r �readzTrioStream.read s� � �� �)0� ��u� �g�� � � �{� � $� $�i� � $� $�i�%
��
�G�
$�� � � �0�$(�L�L�$=�$=� �$=�$R� R��� 1�0� %�
$� R�� 1�0��0� %�
$�
$�sN �AC�C�1 B,�B*�B,� C�
C�*B,�,B5 �1C�9 C�C �Cc � � K � |sy |� t d� n|}t j t t j t
t j t
i}t |� 5 t j |� 5 | j j |�� � d { ��� d d d � d d d � y 7 �# 1 sw Y �xY w# 1 sw Y y xY w�w)Nr )r) ) r r r! r r" r
r# r r$ r �send_all)r �bufferr& r' r( s r �writezTrioStream.write% s� � �� �� �)0� ��u� �g�� � � �|� � $� $�j� � $� $�j�%
��
�G�
$�� � � �0��l�l�+�+��+�8�8�8� 1� %�
$�8�� 1�0�� %�
$�sH �A C� B8�4 B,�B*�B,�B8�! C�*B,�,B5 �1B8�8C�=Cc � �T K � | j j � � d { ��� y 7 ��wr )r �aclose)r s r r0 zTrioStream.aclose3 s � �� ��l�l�!�!�#�#�#�s � (�&�(c � � K � |� t d� n|}t j t t j t
i}t j | j ||dd�� }t |� 5 t j |� 5 |j � � d { ��� d d d � d d d � t |� S 7 � # 1 sw Y � xY w# t $ r }| j � � d { ���7 |�d }~ww xY w# 1 sw Y t |� S xY w�w)Nr TF)� ssl_context�server_hostname�https_compatible� server_side)r r r! r r" r � SSLStreamr r r$ � do_handshake� Exceptionr0 r )r r2 r3 r& r' r( �
ssl_stream�excs r � start_tlszTrioStream.start_tls6 s� � �� � *1� ��u� �g�� � � �~� � $� $�l�%
�� �^�^� �L�L�#� +� !� �
�
� �G�
$�
��_�_�^�4�$�1�1�3�3�3� 5� %� �*�%�%� 4�� 5�4�� �
��k�k�m�#�#�� ��
�� %� �*�%�%�sr �A)D�+C0�-C�B8�B6�B8�C�#D�6B8�8C �=C� C-�
C(� C#�!C(�(C-�-C0�0D�5Dc �v � |dk( r:t | j t j � r| j j S |dk( r(| j � j j � S |dk( r(| j � j j � S |dk( ru| j }t |t j � r'|j }t |t j � r�'t |t j � sJ �|j S |dk( r!| j d� }|j � S y )N�
ssl_object� client_addr� server_addr�socket� is_readable)
�
isinstancer r r6 � _ssl_object�_get_socket_streamr@ � getsockname� getpeername�transport_stream� SocketStream�get_extra_inforA )r �infor r@ s r rI zTrioStream.get_extra_infoQ s� � � �<� �J�t�|�|�T�^�^�$L� �<�<�+�+� +� �=� ��*�*�,�3�3�?�?�A� A� �=� ��*�*�,�3�3�?�?�A� A� �8� ��\�\�F� �V�T�^�^�4� �0�0�� �V�T�^�^�4� �f�d�&7�&7�8� 8�8��=�=� � �=� ��(�(��2�F��%�%�'� '�r c �� � | j }t |t j � r'|j }t |t j � r�'t |t j
� sJ �|S r )r rB r r6 rG rH r s r rD z TrioStream._get_socket_streame sO � �� � ����� � �0��,�,�F� ��� � �0��&�$�"3�"3�4�4�4��
r )r ztrio.abc.Stream�return�Noner )r �intr& � float | NonerL �bytes)r- rP r& rO rL rM )rL rM �NN)r2 zssl.SSLContextr3 �
str | Noner& rO rL r )rJ �strrL z
typing.Any)rL ztrio.SocketStream)
�__name__�
__module__� __qualname__r r* r. r0 r; rI rD � r r r r sS � � �
� 9� $� '+� $� &�#�&� $�&� � &�
� &�6�(r r c �V � e Zd Z d dd�Z d dd�Zd d�Zy)
� TrioBackendNc � �� K � |�g }|� t d� n|}t j t t j t
t t
i}t |� 5 t j |� 5 t j |||�� � d { ��� }|D ] } |j | � � d d d � d d d � t � S 7 �6# 1 sw Y � xY w# 1 sw Y t � S xY w�w)Nr )�host�port�
local_address) r r r! r r" r �OSErrorr r$ �open_tcp_stream�
setsockoptr )
r r[ r\ r& r] �socket_optionsr' r( r �options
r � connect_tcpzTrioBackend.connect_tcpn s� � �� � � !� �N�)0� ��u� �g�� � � �~� � $� $�l� �\�%
��
�G�
$�� � � �0�04�0D�0D� �D�
�1� +�� -�F�%�F�%�%�v�.� -� 1� %� �&�!�!� +�� 1�0�� %� �&�!�!�sH �AC"�C �+ C �B>�C �#C �+C"�>C � C �C � C �C"c � �� K � |�g }|� t d� n|}t j t t j t
t t
i}t |� 5 t j |� 5 t j |� � d { ��� }|D ] } |j |� � d d d � d d d � t � S 7 �6# 1 sw Y � xY w# 1 sw Y t � S xY w�w)Nr ) r r r! r r" r r^ r r$ �open_unix_socketr` r )r �pathr& ra r' r( r rb s r �connect_unix_socketz TrioBackend.connect_unix_socket� s� � �� � � !� �N�)0� ��u� �g�� � � �~� � $� $�l� �\�%
��
�G�
$�� � � �0�04�0E�0E�d�0K�*K�� ,�F�%�F�%�%�v�.� -� 1� %�
�&�!�!� +L�� 1�0�� %�
�&�!�!�sH �AC �C �+B=�B;�B=� C �(C �;B=�=C �C � C �C c � �J K � t j |� � d { ��� y 7 ��wr )r �sleep)r �secondss r ri zTrioBackend.sleep� s � �� ��j�j��!�!�!�s �#�!�#)NNN) r[ rS r\ rN r& rO r] rR ra �%typing.Iterable[SOCKET_OPTION] | NonerL r rQ )rf rS r& rO ra rk rL r )rj r rL rM )rT rU rV rc rg ri rW r r rY rY m s� � �
!%�$(�@D�
"��"� �"� � "�
"� "� >�
"�
�"�< !%�@D� "��"� �"� >� "�
� "�*"r rY )�
__future__r �ssl�typingr � _exceptionsr r r r r r
r r �baser r r r rY rW r r �<module>rq sF �� "�
�
� � � � � I� H�U�#� U�p2"�%� 2"r