| Server IP : 192.158.238.246 / Your IP : 3.138.170.222 Web Server : LiteSpeed System : Linux uniform.iwebfusion.net 4.18.0-553.27.1.lve.1.el8.x86_64 #1 SMP Wed Nov 20 15:58:00 UTC 2024 x86_64 User : jenniferflocom ( 1321) PHP Version : 8.1.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/cloudlinux/venv/lib/python3.11/site-packages/aiohttp/__pycache__/ |
Upload File : |
�
��bg�
� �P � d dl Z d dlmZmZ ddlmZ G d� de j � � ZdS )� N)�Optional�cast� )� tcp_nodelayc � � e Zd ZdZdej ddfd�Zedefd�� � Z dd�Z
dd�Z dd �Z dd
�Z
d ej ddfd �Zd
ee 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 �L/opt/cloudlinux/venv/lib64/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 rJ �d| _ d S �NT)r
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_reading, 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_reading4 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_made< s/ � �
�'�#�Y�
/�
/���B�� � � �����r �excc �� � d | _ | j sd S | j }|�d S d | _ |� � � rd S |�|� d � � d S |� |� � d S )N)r r
r r r �
set_exception)r r0 r! s r �connection_lostz BaseProtocol.connection_lostA s� � � ����|� � �F��#�� �>� �F� !��� �;�;�=�=� � �F� �;� � � �d� #� #� #� #� #� � � �� %� %� %� %� %r c � �� K � | j st d� � �| j sd S | j }|� | j � � � }|| _ t
j |� � � d {V �� d S )NzConnection lost)r �ConnectionResetErrorr
r r �
create_futurer, �shieldr s r �
_drain_helperzBaseProtocol._drain_helperQ s~ � � � ��~� :�&�'8�9�9� 9��|� � �F��#�� �>��Z�-�-�/�/�F�!'�D� ��n�V�$�$�$�$�$�$�$�$�$�$�$r )r N)�__name__�
__module__� __qualname__� __slots__r, �AbstractEventLoopr �property�boolr r r" r$ r* �
BaseTransportr/ r �
BaseExceptionr3 r8 � r r r r s � � � � � ��I�;�W� 6� ;�4� ;� ;� ;� ;� �*�4� *� *� *� �X�*� � � � �(� (� (� (�(� (� (� (�)� )� )� )� ��)>� �4� � � � �
&�8�M�#:� &�t� &� &� &� &� %� %� %� %� %� %r r )r, �typingr r � tcp_helpersr �Protocolr rB r r �<module>rF sy �� ���� !� !� !� !� !� !� !� !� $� $� $� $� $� $�S%� S%� S%� S%� S%�7�#� S%� S%� S%� S%� S%r