← Back
Editing: base_protocol.cpython-311.pyc
� �|oi� � �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
Save File
Cancel