File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/base_protocol.cpython-310.pyc
o
;jP � @ sp d dl Z d dlmZmZmZ ddlmZ ddlmZ ddl m
Z
er(ddl m Z e
eefZG dd � d e j�ZdS )
� N)�
TYPE_CHECKING�Any�cast� )�ClientConnectionResetError)�
set_exception)� tcp_nodelay)�
HttpParserc @ s� e Zd ZdZ d!dejddddfdd�Zedefd d
��Z edefd d ��Z
d"d
d�Z d"dd�Z d"dd�Z
defdd�Zd#deddfdd�Zdejddfdd�Zd edB ddfd d �Zd"d d �ZdS )$� BaseProtocol)�_loop�_paused�_parser�
_drain_waiterZ_connection_lost�_reading_paused� _upgraded� transportN�loop�parserzHttpParser[Any] | None�returnc C s. || _ d| _d | _d| _|| _d| _d | _d S �NF)r r r r r
r r )�selfr r � r �I/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/base_protocol.py�__init__ s
zBaseProtocol.__init__c C s
| j duS )z&Return True if the connection is open.N)r �r r r r � connected+ s
zBaseProtocol.connectedc C s | j S �N�r r r r r �writing_paused0 s zBaseProtocol.writing_pausedc C s | j rJ �d| _ d S �NTr r r r r �
pause_writing4 s
zBaseProtocol.pause_writingc C sB | j sJ �d| _ | j}|d ur d | _|�� s |�d � d S d S d S r )r r �done�
set_result�r �waiterr r r �resume_writing8 s
�zBaseProtocol.resume_writingc C sX d| _ | js| jd us
J �| j�� | jd ur*z| j�� W d S ty) Y d S w d S r )r r r
�
pause_readingr �PAUSE_RESUME_READING_ERRORSr r r r r& B s
��zBaseProtocol.pause_readingc C s dS )zEKeep the transport paused for protocol-specific reasons (overridden).Fr r r r r � _reading_paused_for_msg_queueP s z*BaseProtocol._reading_paused_for_msg_queueT�
resume_parserc C sj d| _ | js
|r
| �d� | j s/| �� s1| jd ur3z| j�� W n ty) Y nw d| _ d S d S d S d S )NF� )r r Z
data_receivedr( r �resume_readingr' )r r) r r r r+ T s
��
�
�zBaseProtocol.resume_readingr c C s t tj|�}t|d� || _d S r )r �asyncioZ Transportr r )r r �trr r r �connection_madej s
z BaseProtocol.connection_made�excc C s^ d | _ | jsd S | j}|d u rd S d | _|�� rd S |d u r%|�d � d S t|td�|� d S �NzConnection lost)r r r r! r" r �ConnectionError)r r/ r$ r r r �connection_losto s �z BaseProtocol.connection_lostc � sJ �| j d u r
td��| jsd S | j}|d u r | j�� }|| _|I d H d S r0 )r r r r r Z
create_futurer# r r r �
_drain_helper� s �
zBaseProtocol._drain_helperr )r N)T)�__name__�
__module__� __qualname__� __slots__r, ZAbstractEventLoopr �property�boolr r r r% r& r( r+ Z
BaseTransportr. �
BaseExceptionr2 r3 r r r r r
s, ���
�
r
)r, �typingr r r Zclient_exceptionsr Zhelpersr Z tcp_helpersr Z http_parserr �AttributeError�NotImplementedError� RuntimeErrorr' �Protocolr
r r r r �<module> s