File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/base_protocol.cpython-310.pyc
Back
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
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings