a nJh< ã@sFddlZddlmZmZddlmZddlmZGdd„dejƒZ dS)éN)ÚOptionalÚcasté)Ú set_exception)Ú tcp_nodelayc@s eZdZdZejddœdd„Zeedœdd„ƒZ ddœd d „Z ddœd d „Z ddœd d„Z ddœdd„Z ejddœdd„Zeeddœdd„Zddœdd„ZdS)Ú BaseProtocol)Ú_loopÚ_pausedÚ _drain_waiterZ_connection_lostÚ_reading_pausedÚ transportN)ÚloopÚreturncCs"||_d|_d|_d|_d|_dS©NF)rr r r r )Úselfr ©rúG/var/www/shaz/venv/lib/python3.9/site-packages/aiohttp/base_protocol.pyÚ__init__s zBaseProtocol.__init__)rcCs |jduS)z&Return True if the connection is open.N)r ©rrrrÚ connectedszBaseProtocol.connectedcCs|jr J‚d|_dS©NT)r rrrrÚ pause_writings zBaseProtocol.pause_writingcCs:|js J‚d|_|j}|dur6d|_| ¡s6| d¡dSr)r r ÚdoneÚ set_result©rÚwaiterrrrÚresume_writing#s zBaseProtocol.resume_writingc CsB|js>|jdur>z|j ¡Wntttfy6Yn0d|_dSr)r r Ú pause_readingÚAttributeErrorÚNotImplementedErrorÚ RuntimeErrorrrrrr-s zBaseProtocol.pause_readingc CsB|jr>|jdur>z|j ¡Wntttfy6Yn0d|_dSr)r r Úresume_readingrrr rrrrr!5s zBaseProtocol.resume_reading)r rcCs ttj|ƒ}t|dƒ||_dSr)rÚasyncioÚ Transportrr )rr ÚtrrrrÚconnection_made=s  zBaseProtocol.connection_made)ÚexcrcCs\d|_|jsdS|j}|dur"dSd|_| ¡r4dS|durH| d¡nt|tdƒ|ƒdS©NzConnection lost)r r r rrrÚConnectionError)rr&rrrrÚconnection_lostBs  ýzBaseProtocol.connection_lostcÃsJ|jstdƒ‚|jsdS|j}|dur6|j ¡}||_t |¡IdHdSr')rÚConnectionResetErrorr r rZ create_futurer"ÚshieldrrrrÚ _drain_helperVs zBaseProtocol._drain_helper)Ú__name__Ú __module__Ú __qualname__Ú __slots__r"ZAbstractEventLooprÚpropertyÚboolrrrrr!Z BaseTransportr%rÚ BaseExceptionr)r,rrrrrs  r) r"ÚtypingrrZhelpersrZ tcp_helpersrÚProtocolrrrrrÚs