Ë
|
¸^i±< ã ón d Z ddlZddlZddlmZ ddlmZmZmZm Z ddl
|
Z
|
ddl m Z ddl mZmZmZ ddlmZ dd lmZmZ dd
|
lmZmZmZmZmZm Z dd l m Z m Z dd l m!Z! dd l"m#Z#m$Z$m%Z%m&Z& ejN dk\ rddlZ(nddl(Z( e
|
jR dd¬« G d d« « Z* e*dd¬« Z+ G d d« Z,y)z WebSocket client for asyncio.é N)Ú TracebackType)ÚAnyÚOptionalÚTypeÚcasté )ÚWebSocketDataQueue)Ú ClientErrorÚServerTimeoutErrorÚWSMessageTypeError)ÚClientResponse)Úcalculate_timeout_whenÚ
|
set_result)ÚWS_CLOSED_MESSAGEÚWS_CLOSING_MESSAGEÚWebSocketErrorÚ WSCloseCodeÚ WSMessageÚ WSMsgType)Ú_INTERNAL_RECEIVE_TYPESÚWebSocketWriter)Ú EofStream)ÚDEFAULT_JSON_DECODERÚDEFAULT_JSON_ENCODERÚ JSONDecoderÚ JSONEncoder)é é T)ÚfrozenÚslotsc óh e Zd Z ej ee d¬« Z ej ee d¬« Zy)ÚClientWSTimeoutN)ÚtypeÚdefault) Ú__name__Ú
|
__module__Ú __qualname__ÚattrÚibr ÚfloatÚ
|
ws_receiveÚws_close© ó õd H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/client_ws.pyr" r" % s. àh uo°tÔ<JØtwwH UO°TÔ:Hr. r" g $@)r+ r, c óô e Zd Zdddddededee ded ed
|
e d e d e
|
j d ee de de ddfdZdBdZdBdZdBdZdBdZdCdZdBdZdeddfdZdBdZdBdZede fd « Zedee fd « Zedee fd « Z ede fd « Z ede fd « Z dDd!ed"e de fd#Z dee fd$Z!dEd&e"ddfd'Z#dEd&e"ddfd(Z$ dDd&e"d)e%dee ddfd*Z&dDd+edee ddfd,Z'dDd+e"dee ddfd-Z( dDe)d.d+e dee d/e*ddfd0Z+e,jZ d%d1d2e d&e"de fd3Z.dDd ee de/fd4Z0dd5d ee defd6Z1dd5d ee de"fd7Z2e3dd8d9e4d ee de fd:Z5dFd;Z6de/fd<Z7dFd=Z8d>ee9e d?ee d@ee: ddfdAZ;y)GÚClientWebSocketResponseNr F)Ú heartbeatÚcompressÚclient_notakeoverÚreaderÚwriterÚprotocolÚresponseÚtimeoutÚ autocloseÚautopingÚloopr2 r3 r4 Úreturnc ó || _ |j | _ || _ || _ || _ d| _ d| _ d | _ || _ || _
|
|| _ | | _ d | _ d| _ |
|
| dz | _ d | _ || _ d| _ d | _ d | _ |
|
| _ | | _ d | _ | j1 « y )NFg g @)Ú _responseÚ
|
connectionÚ_connÚ_writerÚ_readerÚ _protocolÚ_closedÚ_closingÚ _close_codeÚ_timeoutÚ
|
_autocloseÚ _autopingÚ
|
_heartbeatÚ _heartbeat_cbÚ_heartbeat_whenÚ_pong_heartbeatÚ_pong_response_cbÚ_loopÚ_waitingÚ _close_waitÚ
|
_exceptionÚ _compressÚ_client_notakeoverÚ
|
_ping_taskÚ_reset_heartbeat) Úselfr5 r6 r7 r8 r9 r: r; r< r2 r3 r4 s r/ Ú__init__z ClientWebSocketResponse.__init__/ sÈ ð "Ø ×(Ñ(
|
à Ø Ø!Ø Ø Ø*.ÔØ Ø#Ø!Ø#Ø<@ÔØ&)Ô Ø Ð Ø#,¨s¡?DÔ Ø@DÔ Ø
|
Ø # Ø;?ÔØ37Ø!Ø"3Ô Ø8<à × Ñ Õ r. c óÚ | j « | j !| j j « d | _ | j "| j j « d | _ y y ©N)Ú_cancel_pong_response_cbrL ÚcancelrV ©rX s r/ Ú_cancel_heartbeatz)ClientWebSocketResponse._cancel_heartbeatZ sZ Ø ×%Ñ%Ô'Ø × Ñ Ð )Ø × Ñ × %Ñ %Ô 'Ø!%DÔ Ø ??Ð &Ø OO× "Ñ "Ô $Ø "DOð 'r. c ó` | j "| j j « d | _ y y r[ )rO r] r^ s r/ r\ z0ClientWebSocketResponse._cancel_pong_response_cbc s- Ø × !Ñ !Ð -Ø × "Ñ "× )Ñ )Ô +Ø%)DÕ "ð .r. c ób | j y | j « | j }|J | j }||j j
|
nd}|j « }t || j |« }|| _ | j "|j || j « | _ y y )Né ) rK r\ rP rA Ú
|
_connectorÚ_timeout_ceil_thresholdÚtimer rM rL Úcall_atÚ_send_heartbeat)rX r< ÚconnÚtimeout_ceil_thresholdÚnowÚwhens r/ rW z(ClientWebSocketResponse._reset_heartbeath s¦ Ø ??Ð "Ø Ø ×%Ñ%Ô'ØzzØÐ Ð Ð Øzzà7;Ð7GDOO× 3Ò 3ÈQð ð iikÜ% c¨4¯?©?Ð<RÓSØ #Ô Ø × Ñ Ð %ð "&§ ¡ ¨d°D×4HÑ4HÓ!IDÕ ð &r. c óò d | _ | j }|j « }|| j k r,|j | j | j
|
« | _ y | j }||j j nd}t || j |« }| j « |j || j « | _ | j j dt j" « }t$ j& dk\ rt) j* ||d¬« }n|j- |« }|j/ « s#|| _ |j3 | j4 « y | j5 |« y )Nrb r. )r é T)r< Ú eager_start)rL rP re rM rf rg rA rc rd r rN r\ Ú_pong_not_receivedrO rB Ú
|
send_framer ÚPINGÚsysÚ version_infoÚasyncioÚTaskÚ create_taskÚdonerV Úadd_done_callbackÚ_ping_task_done)rX r< rj rh ri rk ÚcoroÚ ping_tasks r/ rg z'ClientWebSocketResponse._send_heartbeat} s0 Ø !ÔØzzØiikØ ×%Ñ%Ò %à!%§ ¡ Ø×$Ñ$ d×&:Ñ&:ó"DÔ ð àzzà7;Ð7GDOO× 3Ò 3ÈQð ô & c¨4×+?Ñ+?ÐAWÓXØ ×%Ñ%Ô'Ø!%§ ¡ ¨d°D×4KÑ4KÓ!LÔ à||×&Ñ& s¬I¯N©NÓ;Ü × Ñ wÒ &ô T°À$ÔGIà ×(Ñ(¨Ó.Ià~~Ô Ø 'DOØ × 'Ñ '¨×(<Ñ(<Õ =à × Ñ Õ +r. c óx |j « s#|j « x}r| j |« d| _ y)z*Callback for when the ping task completes.N)Ú cancelledÚ exceptionÚ_handle_ping_pong_exceptionrV )rX ÚtaskÚexcs r/ ry z'ClientWebSocketResponse._ping_task_done s2 à~~Ô ¨D¯N©NÓ,<Ð%< SÐ%<Ø × ,Ñ ,¨SÔ 1Ø r. c óT | j t d| j d« « y )NzNo PONG received after z seconds)r r rN r^ s r/ ro z*ClientWebSocketResponse._pong_not_received¥ s) Ø ×(Ñ(Ü Ð!8¸×9MÑ9MÐ8NÈhÐ WÓ Xõ
|
r. r c óH | j ry| j « t j | _ || _ | j j « | j rC| j s6| j j t t j |d« d« yyy)z5Handle exceptions raised during ping/pong processing.Nr )rE Ú _set_closedr ÚABNORMAL_CLOSURErG rS r? ÚcloserQ rF rC Ú feed_datar r ÚERROR)rX r s r/ r z3ClientWebSocketResponse._handle_ping_pong_exceptionª sr à <<Ø Ø ×ÑÔÜ&×7Ñ7ÔØ Ø × Ñ Ô Ø == § ¢ Ø LL× "Ñ "¤9¬Y¯_©_¸cÀ4Ó#HÈ!Õ Lð "/=r. c ó2 d| _ | j « y)zdSet the connection to closed.
|
|
Cancel any heartbeat timers and set the closed flag.
|
TN)rE r_ r^ s r/ r z#ClientWebSocketResponse._set_closedµ s ð
|
Ø × Ñ Õ r. c ó2 d| _ | j « y)zfSet the connection to closing.
|
|
Cancel any heartbeat timers and set the closing flag.
|
TN)rF r_ r^ s r/ Ú _set_closingz$ClientWebSocketResponse._set_closing½ s ð
|
Ø × Ñ Õ r. c ó | j S r[ )rE r^ s r/ Úclosedz ClientWebSocketResponse.closedÅ s à||Ðr. c ó | j S r[ )rG r^ s r/ Ú
|
close_codez"ClientWebSocketResponse.close_codeÉ s à× Ñ Ð r. c ó | j S r[ )rD r^ s r/ r7 z ClientWebSocketResponse.protocolÍ ó à~~Ð r. c ó | j S r[ )rT r^ s r/ r3 z ClientWebSocketResponse.compressÑ r r. c ó | j S r[ )rU r^ s r/ r4 z)ClientWebSocketResponse.client_notakeoverÕ s à×&Ñ&Ð&r. Únamer$ c óz | j j }||S |j }||S |j ||« S )z$extra info from connection transport)r? r@ Ú transportÚget_extra_info)rX r r$ rh r s r/ r z&ClientWebSocketResponse.get_extra_infoÙ sB à~~×(Ñ(Ø <ØNØNN Ø Ð ØNØ×'Ñ'¨¨gÓ6Ð6r. c ó | j S r[ )rS r^ s r/ r~ z!ClientWebSocketResponse.exceptionã s ØÐ r. r. Úmessagec ót K | j j |t j « d { y 7 wr[ )rB rp r rq ©rX r s r/ Úpingz ClientWebSocketResponse.pingæ ó$ è ø Øll×%Ñ% g¬y¯~©~Ó>×>Ò>úó .8°6±8c ót K | j j |t j « d { y 7 wr[ )rB rp r ÚPONGr s r/ Úpongz ClientWebSocketResponse.pongé r r Úopcodec óZ K | j j |||« d{ y7 w)z Send a frame over the websocket.N)rB rp )rX r r¢ r3 s r/ rp z"ClientWebSocketResponse.send_frameì s$ è ø ð ll×%Ñ% g¨v°xÓ@×@Ò@ús !+£)¤+Údatac óä K t |t « st dt |« z « | j j |j d« t j |¬« d { y 7 w)Nz data argument must be str (%r)zutf-8©r3 ) Ú
|
isinstanceÚstrÚ TypeErrorr# rB rp Úencoder ÚTEXT©rX r¤ r3 s r/ Úsend_strz ClientWebSocketResponse.send_strò sZ è ø Ü$¤Ô$ÜÐ <¼tÀD»zÑ IÓJÐ JØll×%Ñ%Ø KKÓ ¤)§.¡.¸8ð &ó
|
÷
|
ò
|
ús A&A0Á(A.Á)A0c óÜ K t |t t t f« st dt |« z « | j j |t j |¬« d { y 7 w)Nz#data argument must be byte-ish (%r)r¦ )
|
r§ ÚbytesÚ bytearrayÚ
|
memoryviewr© r# rB rp r ÚBINARYr¬ s r/ Ú
|
send_bytesz"ClientWebSocketResponse.send_bytesù sQ è ø Ü$¤¬ ´:Ð >Ô?ÜÐ AÄDÈÃJÑ NÓOÐ OØll×%Ñ% d¬I×,<Ñ,<ÀxÐ%ÓP×PÒPús A"A,Á$A*Á%A,)Údumpsr´ c óR K | j ||« |¬« d { y 7 w)Nr¦ )r )rX r¤ r3 r´ s r/ Ú send_jsonz!ClientWebSocketResponse.send_jsonþ s" è ø ð mmE $K°(mÓ;×;Ò;ús '% ')Úcoder r· c óÆ K | j r}| j sq| j J | j j « | _ | j « | j j t d« | j d { | j ry| j « | j j ||« d { | j" r| j$ j « y t+ j, | j. j0 « 4 d { | j j3 « d { }d d d « d { j4 t6 j8 u r,|j: | _ | j$ j « y®7 7 Ý# t j $ r1 t j | _ | j$ j « t& $ r@}t j | _ || _ | j$ j « Y d }~yd }~ww xY w7 7 ó7 å# 1 d { 7 sw Y õxY w# t j $ r1 t j | _ | j$ j « t& $ r@}t j | _ || _ | j$ j « Y d }~yd }~ww xY ww)Nr FT) rQ rF rP Ú create_futurerR r rC r r rE r rB r rt ÚCancelledErrorr r
rG r? Ú ExceptionrS Ú async_timeoutr9 rH r, Úreadr# r ÚCLOSEr¤ )rX r· r r Úmsgs r/ r z ClientWebSocketResponse.close s3 è ø ð == § ¢ Ø::Ð)Ð )Ð)Ø #zz× 7Ñ 7Ó 9DÔ Ø × Ñ Ô Ø LL× "Ñ "Ô#5°qÔ 9Ø×"Ñ"× "Ð "à <<Øà ×ÑÔð
|
Ø,,×$Ñ$ T¨7Ó3× 3Ð 3ð × Ò Ø NN× Ñ Ô "Øàð Ü(×0Ñ0°· ± ×1GÑ1GÓH÷ 4ñ 4Ø $§ ¡ × 1Ñ 1Ó 3×3C÷4÷ 4ð xx9??Ñ*Ø#&§8¡8Ô Ø×$Ñ$Ô&Øð# ð- #ùð 4ùÜ×%Ñ%ò Ü *× ;Ñ ;DÔ Ø NN× Ñ Ô "Ø Üò Ü *× ;Ñ ;DÔ Ø !DOØ NN× Ñ Ô "Üûð úð4ùØ3øð4ø÷ 4÷ 4ñ 4ûä×)Ñ)ò Ü#.×#?Ñ#?Ô Ø×$Ñ$Ô&ØÜ ò Ü#.×#?Ñ#?Ô Ø"%Ø×$Ñ$Ô&Üûð üsÕ BK!ÂF$Â!K!Â* F) à F'Ã
|
F) Ã(K!Ã7-I Ä$H7Ä%I Ä( H>ÅH:ÅH>Å I ÅH<ÅI ÅA
|
K!Æ'F) Æ)A H4Ç46H/È*K!È/H4È4K!È7I È:H>È<I È>IÉI ÉIÉ I ÉA K Ê 6KËK!ËK Ë K!c ó K |xs | j j } | j r t d« | j rt
|
S | j r | j « d { t
|
S d| _ |rQt j |« 4 d { | j j « d { }d d d « d { n"| j j « d { }| j « d| _ | j rt | j d « jD tF vr|S |jD t0 jH u rS| jC « |jJ | _ | j s$| jL r| j « d { |S |jD t0 jN u r| jC « |S |jD t0 jP u r1| jR r%| jU |jJ « d {
|
|jD t0 jV u r| jR r4|S 7 í7 Á7 ¢7 # 1 d { 7 sw Y xY w7 # d| _ | j rt | j d « w w xY w# t j t j" f$ r t$ j& | _ t* $ rL t$ j, | _ | j « d { 7 t/ t0 j2 d d « cY S t4 $ r. | j7 « t$ j& | _ t
|
cY S t8 $ r[}|j: | _ | j |j: ¬« d { 7 t/ t0 j< |d « cY d }~S d }~wt> $ rj}|| _ | jC « t$ j& | _ | j « d { 7 t/ t0 j< |d « cY d }~S d }~ww xY w7 7 "w)NTz+Concurrent call to receive() is not allowedF)r· ),rH r+ rQ Ú RuntimeErrorrE r rF r r¼ r9 rC r½ rW rR r rt rº Ú TimeoutErrorr r
rG r ÚOKr r ÚCLOSEDr
|
r r r· r r» rS r r# r r¾ r¤ rI ÚCLOSINGrq rJ r¡ r )rX r9 Úreceive_timeoutr¿ r s r/ Úreceivez ClientWebSocketResponse.receive8 sA è ø Ø!Ò= T§]¡]×%=Ñ%=àØ}}Ü"Ð#PÓQÐQà||Ü(Ð(Ø Øjjl×"Ð"Ü(Ð(ð& =Ø $ ð;Ù&ô
|
$1×#8Ñ#8¸ Ó#I÷ <ñ <Ø(,¯ © ×(9Ñ(9Ó(;×";C÷<÷ <ð <ð %)§L¡L×$5Ñ$5Ó$7× 7Ø×)Ñ)Ô+à$)DMØ×'Ò'Ü" 4×#3Ñ#3°TÕ:ð0 xxÔ 6Ñ6ð
|
àxx9??Ñ*Ø×!Ñ!Ô#Ø#&§8¡8Ô Ø||¨¯ªØ **,×&Ð&ð Jð Y× .Ñ .Ñ.Ø×!Ñ!Ô#ð Jð Y^^Ñ+°·²Øii §¡Ó)×)Ð)ÙØY^^Ñ+°·²ÙàJð{ #ùð<ùØ";ùð<ù÷ <÷ <ò <úð 8úð %*DMØ×'Ò'Ü" 4×#3Ñ#3°TÕ:ð (ûä×*Ñ*¬G×,@Ñ,@ÐAò Ü#.×#?Ñ#?Ô ØÜ ò ?Ü#.§>¡>Ô Øjjl×"Ñ"Ü ¤×!1Ñ!1°4¸Ó>Ò>Ü ò )à× Ñ Ô"Ü#.×#?Ñ#?Ô Ü(Ò(Ü!ò =Ø#&§8¡8Ô Øjj c§h¡hjÓ/×/Ñ/Ü ¤§ ¡ °#°tÓ<Õ<ûÜ ò =Ø"%Ø×!Ñ!Ô#Ü#.×#?Ñ#?Ô Øjjl×"Ñ"Ü ¤§ ¡ °#°tÓ<Õ<ûð =úð 'ùð *ûs5 A$QÁ&IÁ'
|
QÁ2J' Á:I8 ÂIÂI8 Â I Â7IÂ8I Â< I8 ÃI Ã"I8 Ã*I5Ã+I8 Ã?*J' Ä)A<QÆ%P?Æ&A:QÈ QÈ!3QÉI8 ÉI É I8 É I2É%I( É&I2É- I8 É8,J$Ê$J' Ê'A)P<ÌLÌ P<Ì1QÌ33P<Í&QÍ(P<Í00OÎ N#Î! OÏ P<ÏQÏ P<Ï?P7ÐPÐ P7Ð1P<Ð2QÐ7P<Ð<QÑQ©r9 c óø K | j |« d { }|j t j ur&t d|j d|j
|
d« t t |j
|
« S 7 `w)NúReceived message ú:z is not WSMsgType.TEXT)rÇ r# r r« r r¤ r r¨ ©rX r9 r¿ s r/ Ú receive_strz#ClientWebSocketResponse.receive_str sg è ø ØLL Ó)×)Ø 889>>Ñ )Ü$Ø# C§H¡H :¨Q¨s¯x©x¨lÐ:PÐQóð ô CÓ"Ð"ð *úó A:A8A!A:c óø K | j |« d { }|j t j ur&t d|j d|j
|
d« t t |j
|
« S 7 `w)NrÊ rË z is not WSMsgType.BINARY)rÇ r# r r² r r¤ r r¯ rÌ s r/ Ú receive_bytesz%ClientWebSocketResponse.receive_bytes si è ø ØLL Ó)×)Ø 889×+Ñ+Ñ +Ü$Ø# C§H¡H :¨Q¨s¯x©x¨lÐ:RÐSóð ô E388Ó$Ð$ð *úrÎ )Úloadsr9 rÑ c óR K | j |¬« d { } ||« S 7 w)NrÈ )rÍ )rX rÑ r9 r¤ s r/ Ú receive_jsonz$ClientWebSocketResponse.receive_json s- è ø ð ×%Ñ%¨gÐ%Ó6×6ÙT{Ðð 7ús '% 'c ó | S r[ r- r^ s r/ Ú __aiter__z!ClientWebSocketResponse.__aiter__ s Ø r. c óÄ K | j « d { }|j t j t j t j
|
fv rt |S 7 Gwr[ )rÇ r# r r¾ rÅ rÄ ÚStopAsyncIteration)rX r¿ s r/ Ú __anext__z!ClientWebSocketResponse.__anext__ sG è ø ØLLN×"Ø 88 ¬×):Ñ):¼I×<LÑ<LÐMÑ MÜ$Ð $Ø
|
ð #ús A A AA c ó K | S wr[ r- r^ s r/ Ú
|
__aenter__z"ClientWebSocketResponse.__aenter__£ s è ø Ø ùs Úexc_typeÚexc_valÚexc_tbc ó@ K | j « d { y 7 wr[ )r )rX rÛ rÜ rÝ s r/ Ú __aexit__z!ClientWebSocketResponse.__aexit__¦ s è ø ð jjl×Òús )r= N)r zasyncio.Task[None]r= Nr[ )r. )r= r1 )<r% r& r' r r r r¨ r r" Úboolrt ÚAbstractEventLoopr* ÚintrY r_ r\ rW rg ry ro Ú BaseExceptionr r r Úpropertyr r r7 r3 r4 r r r~ r¯ r r¡ r rp r r³ r r r¶ r rà r r rÇ rÍ rÐ r r rÓ rÕ rØ rÚ r r rß r- r. r/ r1 r1 . sk ð &*ØØ"'ò) à"ð) ð ð) ð 3-ð ) ð
|
!ð ) ð !ð ) ð ð) ð ð) ð ×'Ñ'ð) ð E?ð) ð ð) ð ð) ð
|
ó ) óV#ó*ó
|
Jó* ,óD ó
|
ð
|
M¨}ð MÀó Mó!ó!ð ð ò ó ð ð ð H SMò ó ð ð ð ( 3-ò ó ð ð ð #ò ó ð ð ð' 4ò 'ó ð'ñ7 3ð 7°ð 7Àó 7ð 8 MÑ2ó ñ? %ð ?°$ó ?ñ? %ð ?°$ó ?ð LPñAØ ðAØ&/ðAØ;CÀC¹=ðAà óAñ
|
3ð
|
°(¸3±-ð
|
È4ó
|
ñQ Uð Q°h¸s±mð QÈtó Qð #'ð<ð
|
2ò <àð<ð 3-ð<ð
|
ð <ð
|
ó <ð *5¯ © È#ò / 3ð / À%ð / ÐRVó / ñbG X¨e¡_ð GÀ ó GðR ?Cò #¨H°U©Oð #Àsó #ð AEò %¨h°u©oð %Èó %ð 2Ø#'ò ð ðð % ð ð
|
|
ó óð ó ó ðà4 Ñ.Ñ/ðð -Ñ(ðð Ñ'ð ð
|
|
ô r. r1 )-Ú__doc__rt rr Útypesr Útypingr r r r r( Ú_websocket.readerr Úclient_exceptionsr
|
r r Ú client_reqrepr Úhelpersr r Úhttpr r r r r r Úhttp_websocketr r Ústreamsr Útypedefsr r r r rs r¼ Úsr" ÚDEFAULT_WS_CLIENT_TIMEOUTr1 r- r. r/ ú<module>rò s ðÙ #ã Û
|
Ý ß ,Ó ,ã å 1ß RÑ RÝ )ß 7÷÷ ÷ EÝ ÷ó ð ×ÑwÒ Ü#ãð t4Ô ÷;ð ;ó !ð;ñ
|
,°tÀdÔ KÐ ÷~ò ~r.
|
