�
E�g� � �h � d dl Z d dlmZmZ ddlmZ ddlmZ ddlm Z G d� de j
� � Z dS ) � N)�Optional�cast� )�ClientConnectionResetError)�
set_exception)� tcp_nodelayc �� � e Zd ZdZdej ddfd�Zedefd�� � Z edefd�� � Z
dd�Z dd �Z dd
�Z
dd �Zd ej ddfd
�Zdee ddfd�Zdd�ZdS )� BaseProtocol)�_loop�_paused�
_drain_waiter�_connection_lost�_reading_paused� transport�loop�returnNc �L � || _ d| _ d | _ d| _ d | _ d S �NF)r r r
r r )�selfr s �e/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/aiohttp/base_protocol.py�__init__zBaseProtocol.__init__ s+ � �04��
� �� �=A��� $�� �6:����� c � � | j duS )z&Return True if the connection is open.N)r �r s r � connectedzBaseProtocol.connected s � � �~�T�)�)r c � � | j S )N�r r s r �writing_pausedzBaseProtocol.writing_paused s
� ��|�r c �& � | j rJ �d| _ d S �NTr r s r �
pause_writingzBaseProtocol.pause_writing$ s � ��<� � � ��� � � r c � � | j sJ �d| _ | j }|�2d | _ |� � � s|� d � � d S d S d S r )r r
�done�
set_result�r �waiters r �resume_writingzBaseProtocol.resume_writing( sh � ��|���|� �� ��#�� � �!%�D� ��;�;�=�=�
(��!�!�$�'�'�'�'�'� � �
(�
(r c � � | j sH| j �C | j � � � n # t t t
f$ r Y nw xY wd| _ d S d S d S r )r r �
pause_reading�AttributeError�NotImplementedError� RuntimeErrorr s r r) zBaseProtocol.pause_reading2 sv � ��#� (���(B�
���,�,�.�.�.�.��"�$7� �F�
�
�
���
����#'�D� � � � (� (�(B�(B� �* �A�Ac � � | j rH| j �C | j � � � n # t t t
f$ r Y nw xY wd| _ d S d S d S r )r r �resume_readingr* r+ r, r s r r/ zBaseProtocol.resume_reading: sv � � � � )�D�N�$>�
���-�-�/�/�/�/��"�$7� �F�
�
�
���
����#(�D� � � � )� )�$>�$>r- r c �h � t t j |� � }t |d� � || _ d S r )r �asyncio� Transportr r )r r �trs r �connection_madez BaseProtocol.connection_madeB s/ � �
�'�#�Y�
/�
/���B�� � � �����r �excc �� � d | _ | j sd S | j }|�d S d | _ |� � � rd S |�|� d � � d S t |t
d� � |� � d S �NzConnection lost)r r r
r# r$ r �ConnectionError)r r5 r& s r �connection_lostz BaseProtocol.connection_lostG s� � � ����|� � �F��#�� �>� �F� !��� �;�;�=�=� � �F� �;� � � �d� #� #� #� #� #� �� � 1�2�2��
�
�
�
�
r c � �� K � | j �t d� � �| j sd S | j }|� | j � � � }|| _ t
j |� � � d {V �� d S r7 )r r r r
r �
create_futurer1 �shieldr% s r �
_drain_helperzBaseProtocol._drain_helper[ s| � � � � �>� !�,�->�?�?� ?��|� � �F��#�� �>��Z�-�-�/�/�F�!'�D� ��n�V�$�$�$�$�$�$�$�$�$�$�$r )r N)�__name__�
__module__� __qualname__� __slots__r1 �AbstractEventLoopr �property�boolr r r! r' r) r/ �
BaseTransportr4 r �
BaseExceptionr9 r= � r r r
r
s> � � � � � ��I�;�W� 6� ;�4� ;� ;� ;� ;� �*�4� *� *� *� �X�*� � �� � � � �X� � � � � �(� (� (� (�(� (� (� (�)� )� )� )� ��)>� �4� � � � �
�8�M�#:� �t� � � � �( %� %� %� %� %� %r r
) r1 �typingr r �client_exceptionsr �helpersr � tcp_helpersr �Protocolr
rG r r �<module>rM s� �� ���� !� !� !� !� !� !� !� !� 9� 9� 9� 9� 9� 9� "� "� "� "� "� "� $� $� $� $� $� $�[%� [%� [%� [%� [%�7�#� [%� [%� [%� [%� [%r