o
    ~#i|                     @   sR   d dl Z d dlmZmZ ddlmZ ddlmZ ddlm	Z	 G dd de j
ZdS )	    N)Optionalcast   )ClientConnectionResetError)set_exception)tcp_nodelayc                   @   s   e Zd ZdZdejddfddZedefddZ	dd	d
Z
dddZdddZdddZdejddfddZdee ddfddZdddZdS )BaseProtocol)_loop_paused_drain_waiter_connection_lost_reading_paused	transportloopreturnNc                 C   s"   || _ d| _d | _d| _d | _d S NF)r	   r
   r   r   r   )selfr    r   \/var/www/GraceOrthoHospital/venv_grace/lib/python3.10/site-packages/aiohttp/base_protocol.py__init__   s
   
zBaseProtocol.__init__c                 C   s
   | j duS )z&Return True if the connection is open.N)r   r   r   r   r   	connected   s   
zBaseProtocol.connectedc                 C   s   | j rJ d| _ d S NT)r
   r   r   r   r   pause_writing    s   

zBaseProtocol.pause_writingc                 C   sB   | j sJ d| _ | j}|d urd | _| s|d  d S d S d S r   )r
   r   done
set_resultr   waiterr   r   r   resume_writing$   s   
zBaseProtocol.resume_writingc              
   C   sJ   | j s!| jd ur#z| j  W n tttfy   Y nw d| _ d S d S d S r   )r   r   pause_readingAttributeErrorNotImplementedErrorRuntimeErrorr   r   r   r   r   .      
zBaseProtocol.pause_readingc              
   C   sJ   | j r!| jd ur#z| j  W n tttfy   Y nw d| _ d S d S d S r   )r   r   resume_readingr    r!   r"   r   r   r   r   r$   6   r#   zBaseProtocol.resume_readingr   c                 C   s    t tj|}t|d || _d S r   )r   asyncio	Transportr   r   )r   r   trr   r   r   connection_made>   s   

zBaseProtocol.connection_madeexcc                 C   s^   d | _ | jsd S | j}|d u rd S d | _| rd S |d u r%|d  d S t|td| d S NzConnection lost)r   r
   r   r   r   r   ConnectionError)r   r)   r   r   r   r   connection_lostC   s    zBaseProtocol.connection_lostc                    sL   | j std| jsd S | j}|d u r| j }|| _t|I d H  d S r*   )r   r   r
   r   r	   create_futurer%   shieldr   r   r   r   _drain_helperW   s   
zBaseProtocol._drain_helper)r   N)__name__
__module____qualname__	__slots__r%   AbstractEventLoopr   propertyboolr   r   r   r   r$   BaseTransportr(   r   BaseExceptionr,   r/   r   r   r   r   r   	   s    	




r   )r%   typingr   r   client_exceptionsr   helpersr   tcp_helpersr   Protocolr   r   r   r   r   <module>   s    