Ë
|
¸^i5 ã ój d dl Z d dlmZmZ ddlmZ ddlmZ ddlm Z G d de j « Z y) é N)ÚOptionalÚcasté )ÚClientConnectionResetError)Ú set_exception)Ú tcp_nodelayc óÂ e Zd ZdZdej
|
ddfdZedefd« Z edefd« Z
|
ddZ dd Z dd
|
Z dd Zd ej ddfd Zdee ddfdZddZy)Ú 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 õh H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/base_protocol.pyÚ__init__zBaseProtocol.__init__ s' Ø04
|
Ø Ø=AÔØ $Ô à6:ó c ó | j duS )z&Return True if the connection is open.N)r ©r s r Ú connectedzBaseProtocol.connected s ð ~~ TÐ)Ð)r c ó | j S )N©r r s r Úwriting_pausedzBaseProtocol.writing_paused s à||Ðr c ó. | j rJ d| _ y ©NTr r s r Ú pause_writingzBaseProtocol.pause_writing$ s Ø<<Ð Ð Ø r c ó | j sJ d| _ | j }|*d | _ |j « s|j d « y y y r )r r ÚdoneÚ
|
set_result©r Úwaiters r Úresume_writingzBaseProtocol.resume_writing( sO Ø||Ð|Ø à×#Ñ#Ø Ð Ø!%DÔ Ø;;=Ø×!Ñ! $Õ'ð !ð r c ó° | j s0| j # | j j « d| _ y y y # t t t
|
f$ r Y w xY wr )r r Ú pause_readingÚAttributeErrorÚNotImplementedErrorÚ RuntimeErrorr s r r) zBaseProtocol.pause_reading2 sX Ø×#Ò#¨¯©Ð(Bð Ø×,Ñ,Ô.ð $(DÕ ð )CÐ#øô #Ô$7¼ ÐFò Ùð úó > ¾AÁAc ó° | j r0| j # | j j « d| _ y y y # t t t
|
f$ r Y w xY wr )r r Úresume_readingr* r+ r, r s r r/ zBaseProtocol.resume_reading: 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_madeB s% Ü '×#Ñ# YÓ /ÜBÔ Ør Úexcc óÎ d | _ | j sy | j }|y d | _ |j « ry ||j d « y t |t d« |« y ©NzConnection lost)r r r r# r$ r ÚConnectionError)r r5 r& s r Úconnection_lostz BaseProtocol.connection_lostG sd à Ø||Ø Ø×#Ñ#Ø >Ø Ø !ÔØ ;;=Ø Ø ;Ø × Ñ dÕ #ä ØÜ Ð 1Ó2Øõ r c óð K | j t d« | j sy | j }|!| j j « }|| _ t j |« d { y 7 wr7 )r r r r r Ú create_futurer1 Úshieldr% s r Ú _drain_helperzBaseProtocol._drain_helper[ sb è ø Ø >>Ð !Ü,Ð->Ó?Ð ?Ø||Ø Ø×#Ñ#Ø >ØZZ×-Ñ-Ó/FØ!'DÔ ÜnnVÓ$×$Ò$ús A,A6Á.A4Á/A6)r N)Ú__name__Ú
|
__module__Ú __qualname__Ú __slots__r1 ÚAbstractEventLoopr ÚpropertyÚboolr r r! r' r) r/ Ú BaseTransportr4 r Ú BaseExceptionr9 r= © r r r
|
r
|
s¢ ðIð;W× 6Ñ 6ð ;¸4ó ;ð ð*4ò *ó ð*ð ð ò ó ð ó ó(ó(ó)ð ¨×)>Ñ)>ð À4ó ð
|
8¨MÑ#:ð ¸tó ô( %r r
|
) r1 Útypingr r Úclient_exceptionsr Úhelpersr Ú tcp_helpersr ÚProtocolr
|
rG r r ú<module>rM s( ðÛ ß !å 9Ý "Ý $ô[%7×#Ñ#õ [%r
|
