Ë
    CØïiµ
  ã                   óR   — d dl Z d dlmZmZ ddlmZ  G d„ de j                  «      Zy)é    N)ÚOptionalÚcasté   )Útcp_nodelayc                   ó¬   — e Zd ZdZdej
                  ddfd„Zedefd„«       Z	dd„Z
dd„Zdd	„Zdd
„Zdej                  ddfd„Zdee   ddfd„Zdd„Zy)ÚBaseProtocol)Ú_loopÚ_pausedÚ_drain_waiterÚ_connection_lostÚ_reading_pausedÚ	transportÚloopÚreturnNc                 óJ   — || _         d| _        d | _        d| _        d | _        y ©NF)r	   r
   r   r   r   )Úselfr   s     úO/var/www/html/aiagents/fe/lib/python3.12/site-packages/aiohttp/base_protocol.pyÚ__init__zBaseProtocol.__init__   s'   € Ø04ˆŒ
ØˆŒØ=AˆÔØ$ˆÔà6:ˆ�ó    c                 ó   — | j                   duS )z&Return True if the connection is open.N)r   ©r   s    r   Ú	connectedzBaseProtocol.connected   s   € ð �~‰~ TÐ)Ð)r   c                 ó.   — | j                   rJ ‚d| _         y ©NT)r
   r   s    r   Úpause_writingzBaseProtocol.pause_writing   s   € Ø—<’<ÐÐØˆ�r   c                 óž   — | j                   sJ ‚d| _         | j                  }|�*d | _        |j                  «       s|j                  d «       y y y r   )r
   r   ÚdoneÚ
set_result©r   Úwaiters     r   Úresume_writingzBaseProtocol.resume_writing"   sO   € Ø�|Š|Ðˆ|ØˆŒà×#Ñ#ˆØÐØ!%ˆDÔØ—;‘;”=Ø×!Ñ! $Õ'ð !ð r   c                 ó°   — | j                   s0| j                  �#	 | j                  j                  «        d| _         y y y # t        t        t
        f$ r Y Œ w xY wr   )r   r   Úpause_readingÚAttributeErrorÚNotImplementedErrorÚRuntimeErrorr   s    r   r$   zBaseProtocol.pause_reading,   sX   € Ø×#Ò#¨¯©Ð(BðØ—‘×,Ñ,Ô.ð $(ˆDÕ ð )CÐ#øô #Ô$7¼ÐFò Ùðúó   š> ¾AÁAc                 ó°   — | j                   r0| j                  �#	 | j                  j                  «        d| _         y y y # t        t        t
        f$ r Y Œ w xY wr   )r   r   Úresume_readingr%   r&   r'   r   s    r   r*   zBaseProtocol.resume_reading4   sW   € Ø×Ò D§N¡NÐ$>ðØ—‘×-Ñ-Ô/ð $)ˆDÕ ð %?Ðøô #Ô$7¼ÐFò Ùðúr(   r   c                 ó^   — t        t        j                  |«      }t        |d«       || _        y r   )r   ÚasyncioÚ	Transportr   r   )r   r   Útrs      r   Úconnection_madezBaseProtocol.connection_made<   s%   € Ü”'×#Ñ# YÓ/ˆÜ�B˜ÔØˆ�r   Úexcc                 óÄ   — d | _         | j                  sy | j                  }|€y d | _        |j                  «       ry |€|j	                  d «       y |j                  |«       y )N)r   r
   r   r   r   Úset_exception)r   r0   r!   s      r   Úconnection_lostzBaseProtocol.connection_lostA   s[   € àˆŒØ�|Š|ØØ×#Ñ#ˆØˆ>ØØ!ˆÔØ�;‰;Œ=ØØˆ;Ø×Ñ˜dÕ#à× Ñ  Õ%r   c              ƒ   óð   K  — | j                   st        d«      ‚| j                  sy | j                  }|€!| j                  j                  «       }|| _        t        j                  |«      ƒ d {  –—†  y 7 Œ­w)NzConnection lost)r   ÚConnectionResetErrorr
   r   r	   Úcreate_futurer,   Úshieldr    s     r   Ú_drain_helperzBaseProtocol._drain_helperQ   s_   è ø€ Ø�~Š~Ü&Ð'8Ó9Ð9Ø�|Š|ØØ×#Ñ#ˆØˆ>Ø—Z‘Z×-Ñ-Ó/ˆFØ!'ˆDÔÜ�n‰n˜VÓ$×$Ò$ús   ‚A,A6Á.A4Á/A6)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Ñ6ð ;¸4ó ;ð ð*˜4ò *ó ð*óó(ó(ó)ð¨×)>Ñ)>ð À4ó ð
& 8¨MÑ#:ð &¸tó &ô 	%r   r   )r,   Útypingr   r   Útcp_helpersr   ÚProtocolr   rB   r   r   ú<module>rF      s"   ðÛ ß !å $ôS%�7×#Ñ#õ S%r   