
    F/jP                         d dl Z d dlmZmZmZ ddlmZ ddlmZ ddl	m
Z
 erddlmZ eeefZ G d d	e j"                        Zy)
    N)TYPE_CHECKINGAnycast   )ClientConnectionResetError)set_exception)tcp_nodelay)
HttpParserc                       e Zd ZdZ	 ddej
                  ddddfdZedefd       Z	edefd	       Z
dd
ZddZddZdefdZddeddfdZdej                   ddfdZdedz  ddfdZddZy)BaseProtocol)_loop_paused_parser_drain_waiter_connection_lost_reading_paused	_upgraded	transportNloopparserzHttpParser[Any] | Nonereturnc                 f    || _         d| _        d | _        d| _        || _        d| _        d | _        y NF)r   r   r   r   r   r   r   )selfr   r   s      S/var/www/html/maxservice/venv/lib/python3.12/site-packages/aiohttp/base_protocol.py__init__zBaseProtocol.__init__   s7     15
:>$37    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                   S Nr   r   s    r   writing_pausedzBaseProtocol.writing_paused0   s    ||r   c                 .    | j                   rJ d| _         y NTr#   r   s    r   pause_writingzBaseProtocol.pause_writing4   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_writing8   sO    |||##!%D;;=!!$' ! r   c                     d| _         | j                  s(| j                  J | j                  j                          | j                  	 | j                  j                          y y # t
        $ r Y y w xY wr&   )r   r   r   pause_readingr   PAUSE_RESUME_READING_ERRORSr   s    r   r/   zBaseProtocol.pause_readingB   sk    #~~<<+++LL&&(>>%,,. & /  s   	A% %	A10A1c                      y)zEKeep the transport paused for protocol-specific reasons (overridden).F r   s    r   _reading_paused_for_msg_queuez*BaseProtocol._reading_paused_for_msg_queueP   s    r   resume_parserc                    d| _         | j                  s|r| j                  d       | j                   sA| j                         s0| j                  #	 | j                  j                          d| _         y y y y # t        $ r Y w xY w)NFr   )r   r   data_receivedr3   r   resume_readingr0   )r   r4   s     r   r7   zBaseProtocol.resume_readingT   s    $ ~~-s#
 $$668*--/
 $)D  + 9 % /  s   A5 5	B Br   c                 ^    t        t        j                  |      }t        |d       || _        y r&   )r   asyncio	Transportr	   r   )r   r   trs      r   connection_madezBaseProtocol.connection_madej   s%    '##Y/Br   excc                     d | _         | j                  sy | j                  }|y d | _        |j                         ry ||j	                  d        y t        |t        d      |       y NzConnection lost)r   r   r   r)   r*   r   ConnectionError)r   r=   r,   s      r   connection_lostzBaseProtocol.connection_losto   sd    ||##>!;;=;d# 12r   c                    K   | j                   t        d      | j                  sy | j                  }|!| j                  j                         }|| _        | d {    y 7 wr?   )r   r   r   r   r   create_futurer+   s     r   _drain_helperzBaseProtocol._drain_helper   sW     >>!,->??||##>ZZ--/F!'Ds   AA#A!A#r"   )r   N)T)__name__
__module____qualname__	__slots__r9   AbstractEventLoopr   propertyboolr    r$   r'   r-   r/   r3   r7   BaseTransportr<   BaseExceptionrA   rD   r2   r   r   r   r      s    	I SW
8--
87O
8	
8 *4 * *   (t )D )D ),)>)> 4 
=4#7 D (	r   r   )r9   typingr   r   r   client_exceptionsr   helpersr   tcp_helpersr	   http_parserr
   AttributeErrorNotImplementedErrorRuntimeErrorr0   Protocolr   r2   r   r   <module>rW      sA     + + 9 " $'  ./BLQ y7## yr   