Ë
|
¸^iK ã ó U d Z ddlZddlZddlmZ ddlmZmZmZm Z m
|
Z
|
m Z ddl m Z ddlmZ ddlmZmZ dd lmZ d
|
d lmZmZmZ d
|
d lmZmZmZm Z m Z eD ch c]
|
} e | « c} Z ee e e d < d
|
Z!dZ"dZ#dZ$e jJ Z&e jN Z(dZ)e jT jV Z,e jN jV Z-e jJ jV Z.e j^ jV Z0e jb jV Z2e jf jV Z4dZ5dZ6dZ7dZ8d
|
Z9e:jv Z<e Z= G d d« Z> G d d« Z?yc c} w )z0Reader for WebSocket protocol versions 13 and 8.é N)Údeque)ÚDequeÚFinalÚOptionalÚSetÚTupleÚUnioné )Ú BaseProtocol)ÚZLibDecompressor)Ú _EXC_SENTINELÚ set_exception)Ú EofStreamé )ÚUNPACK_CLOSE_CODEÚ UNPACK_LEN3Úwebsocket_mask)ÚWS_DEFLATE_TRAILINGÚWebSocketErrorÚ WSCloseCodeÚ WSMessageÚ WSMsgTypeÚALLOWED_CLOSE_CODESé é éÿÿÿÿ)Tó )Fr c ó¶ e Zd ZdZdededej ddfdZde fdZ
|
de e fd Z efd
|
e d ej ddfd Zdd ZddZddZdefdZdefdZy)ÚWebSocketDataQueuezmWebSocketDataQueue resumes and pauses an underlying stream.
|
|
It is a destination for WebSocket data.
|
ÚprotocolÚlimitÚloopÚreturnNc óö d| _ || _ |dz | _ || _ d| _ d | _ d | _ t « | _ | j j | _
|
| j j | _ y )Nr r
|
F) Ú_sizeÚ _protocolÚ_limitÚ_loopÚ_eofÚ_waiterÚ
|
_exceptionr Ú_bufferÚpopleftÚ _get_bufferÚappendÚ _put_buffer)Úselfr r! r" s õn H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/_websocket/reader_c.pyÚ__init__zWebSocketDataQueue.__init__< sf ð
|
Ø!Øai Ø
|
Ø Ø7; Ø6:Ü5:³W Ø <<×/Ñ/ÔØ <<×.Ñ.Õr c ó | j S ©N)r) ©r1 s r2 Úis_eofzWebSocketDataQueue.is_eofJ s ØyyÐr c ó | j S r5 )r+ r6 s r2 Ú exceptionz WebSocketDataQueue.exceptionM s ØÐ r ÚexcÚ exc_causec óf d| _ || _ | j x}d | _ t |||« y y ©NT)r) r+ r* r )r1 r: r; Úwaiters r2 r z WebSocketDataQueue.set_exceptionP s9 ð
|
Ø ØllÐ "FÐ /Ø DLÜ & # yÕ 1ð 0r c ót | j x}y d | _ |j « s|j d « y y r5 )r* ÚdoneÚ
|
set_result)r1 r> s r2 Ú_release_waiterz"WebSocketDataQueue._release_waiter[ s7 ØllÐ "FÐ +Ø Ø Ø{{}Ø × Ñ dÕ #ð r c ó@ d| _ | j « d | _ y r= )r) rB r+ r6 s r2 Úfeed_eofzWebSocketDataQueue.feed_eofb s Ø Ø × Ñ Ô Ø r c ó
|
| xj |z c_ | j ||f« | j « | j | j kD r2| j j
|
s| j j « y y y r5 )r% r0 rB r' r& Ú_reading_pausedÚ pause_reading©r1 ÚdataÚsizes r2 Ú feed_dataz WebSocketDataQueue.feed_datag sc Ø
|
|
dÑ
|
Ø ×Ñ$ Ô&Ø × Ñ Ô Ø :: Ò #¨D¯N©N×,JÒ,JØ NN× (Ñ (Õ *ð -KÐ #r c ó` K | j s^| j sR| j rJ | j j « | _ | j d { | j « S | j « S 7 $# t
|
j t
|
j f$ r d | _ w xY wwr5 ) r, r) r* r( Ú create_futureÚasyncioÚCancelledErrorÚ TimeoutErrorÚ_read_from_bufferr6 s r2 ÚreadzWebSocketDataQueue.readn s è ø Ø|| D§I¢IØ||Ð #Ð#Ø ::×3Ñ3Ó5DLð Øll×"Ð"ð ×%Ñ%Ó'Ð't×%Ñ%Ó'Ð'ð #ùÜ×*Ñ*¬G×,@Ñ,@ÐAò Ø # Øð üs0 AB.Á A? ÁA=ÁA? Á B.Á=A? Á?,B+Â+B.c ó< | j rs| j « \ }}| xj |z c_ | j | j k r0| j j
|
r| j j « |S | j | j t r5 ) r, r. r% r' r& rF Úresume_readingr+ r rH s r2 rQ z$WebSocketDataQueue._read_from_buffery ss Ø <<Ø ×)Ñ)Ó+JD$Ø JJ$Ñ JØzzDKKÒ'¨D¯N©N×,JÒ,JØ×-Ñ-Ô/ØKØ ??Ð &Ø//Ð !Ür ©r# N)rI r rJ Ú
|
cython_intr# N)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r ÚintrN ÚAbstractEventLoopr3 Úboolr7 r Ú BaseExceptionr9 r Úbuiltinsr rB rD rK r rR rQ © r r2 r r 6 s¢ ñð
|
/Ø$ð /Ø-0ð /Ø;B×;TÑ;Tð /à ó /ð ó ð 8 MÑ2ó ð -:ñ 2à ð 2ð ×)Ñ)ð 2ð
|
ó 2ó$ó ó
|
+ð (Ió (ð 9ô r r c
|
ó e Zd Z ddedededdfdZddZdee e
|
e f de ee f fd Z d
|
ed eeef d ee e
|
f d eeef ddf
|
dZde ddfdZy)ÚWebSocketReaderÚqueueÚ max_msg_sizeÚcompressr# Nc ó0 || _ || _ d | _ t « | _ t
|
| _ t | _ d| _ t | _
|
g | _ d| _ d| _ d| _ d | _ d| _ d| _ t$ | _ d | _ || _ y )NFr r )rc Ú _max_msg_sizeÚ_excÚ bytearrayÚ_partialÚ READ_HEADERÚ_stateÚOP_CODE_NOT_SETÚ_opcodeÚ
|
_frame_finÚ _frame_opcodeÚ_payload_fragmentsÚ_frame_payload_lenÚ_tailÚ _has_maskÚ _frame_maskÚ_payload_bytes_to_readÚ_payload_len_flagÚCOMPRESSED_NOT_SETÚ _compressedÚ_decompressobjÚ _compress)r1 rc rd re s r2 r3 zWebSocketReader.__init__ s ð
|
Ø )Ôà)- Ü! Ü! ä + Ø Ü"1ÔØ/1Ô Ø"#Ô à
|
Ø Ø,0ÔØ&'Ô#Ø!"Ô Ü 2ÔØ:>ÔØ!r c ó8 | j j « y r5 )rc rD r6 s r2 rD zWebSocketReader.feed_eof s Ø
|
|
×ÑÕ r rI c óü t |« t ur t |« }| j d|fS | j |« t S # t $ r-}|| _ t | j |« t cY d }~S d }~ww xY wr= ) ÚtypeÚbytesrh Ú
|
_feed_dataÚ Exceptionr rc ÚEMPTY_FRAME_ERRORÚ EMPTY_FRAME)r1 rI r: s r2 rK zWebSocketReader.feed_data¥ ss ô :UÑ "Ü;Dà 99Ð Ø:Ð ð %Ø OODÔ !ô Ðøô ò %ØDIÜ $** cÔ *Ü$Õ $ûð %ús ®A Á A;Á"A6Á0A;Á6A;ÚfinÚopcodeÚpayloadÚ
|
compressedc ó6
|
|t t t hv r|t k( r-| j t k( rt t j d« |s|t k7 r|| _ | xj |z c_ | j r_t | j « | j k\ r=t t j dt | j « d| j « y t | j « }|t k( r| j }t | _ n |r t t j d|« |r*| j |z }| j j « n|}| j rKt |« | j k\ r3t t j dt |« d| j « |r°| j st d¬« | _ | j j! |t" z | j r| j dz n | j « }| j r^t |« | j kD rFt t j d| j « t% |« t& u r|}n t' |« }|t k( rM |j) d « }| j. j1 t3 t4 t6 |d f« t |« « y | j. j1 t3 t4 t8 |d f« t |« « y |t: k( rãt |« d k\ rrt= |d d « d }
|
|
|
dk r%|
|
t> vr t t j d|
|
« |d d j) d « } t3 t4 t@ jB |
|
| f« } nF|r#t t j d| d| d|« t3 t4 t@ jB d d f« } | j. j1 | d « y |tD k( rGt3 t4 t@ jF |d f« } | j. j1 | t |« « y |tH k( rGt3 t4 t@ jJ |d f« } | j. j1 | t |« « y t t j d|« # t* $ r } t t j, d
|
« | d } ~ ww xY w# t* $ r } t t j, d
|
« | d } ~ ww xY w)Nz*Continuation frame for non started messagez Message size z exceeds limit z8The opcode in non-fin frame is expected to be zero, got T)Úsuppress_deflate_headerr z(Decompressed message exceeds size limit zutf-8zInvalid UTF-8 text messageÚ r
|
r i¸ zInvalid close code: zInvalid close frame: ú zUnexpected opcode=)&Ú OP_CODE_TEXTÚOP_CODE_BINARYÚOP_CODE_CONTINUATIONrn rm r r ÚPROTOCOL_ERRORrj rg ÚlenÚMESSAGE_TOO_BIGr] Úclearrz r Údecompress_syncr r~ r ÚdecodeÚUnicodeDecodeErrorÚ INVALID_TEXTrc rK Ú TUPLE_NEWr ÚWS_MSG_TYPE_TEXTÚWS_MSG_TYPE_BINARYÚ OP_CODE_CLOSEr r r ÚCLOSEÚ OP_CODE_PINGÚPINGÚ OP_CODE_PONGÚPONG) r1 r r
r r Ú has_partialÚassembled_payloadÚpayload_mergedÚtextr: Ú
|
close_codeÚ close_messageÚmsgs r2 Ú _handle_framez WebSocketReader._handle_frame· s© ð l¤NÔ4HÐIÒ IàÔ-Ò-°$·,±,Ä/Ò2QÜ$Ü ×.Ñ.Ø@óð ñ àÔ 1Ò1Ø#)DLØ Ñ( Ø×%Ò%¬#¨d¯m©mÓ*<À×@RÑ@RÒ*RÜ(Ü#×3Ñ3Ø'¬¨D¯M©MÓ(:Ð';ð <)Ø)-×);Ñ);Ð(<ð>óð ð
|
ä t}}Ó-KØÔ-Ò-Ø Ü . ñ Ü$Ü ×.Ñ.ð'Ø'- jð2óð ñ Ø$(§M¡M°GÑ$;Ð!Ø ×#Ñ#Õ%à$+Ð!à×!Ò!¤cÐ*;Ó&<À×@RÑ@RÒ&RÜ$Ü ×/Ñ/Ø#¤CÐ(9Ó$:Ð#;ð <%Ø%)×%7Ñ%7Ð$8ð:óð ñ Ø×*Ò*Ü*:ÐSWÔ*XDÔ'ð "&×!4Ñ!4×!DÑ!DØ%Ô(;Ñ;ð ×-Ò-ð ×*Ñ*¨QÒ.à !× /Ñ /ó "ð ×%Ò%¬#¨nÓ*=À×@RÑ@RÒ*RÜ(Ü#×3Ñ3ØBÀ4×CUÑCUÐBVÐWóð ô Ð'Ó(¬EÑ1Ø!2ä!&Ð'8Ó!9à Ò%ð Ø)×0Ñ0°Ó9Dð
|
|
×$Ñ$Ü iÔ*:¸DÀ"Ð)EÓFÜÓ'õð
|
|
|
×$Ñ$Ü iÔ*<¸nÈbÐ)QÓRÜÓ'õð }Ò $Ü7|qÒ Ü .¨w°r¸¨{Ó ;¸AÑ >
|
Ø Ò$¨Ô;NÑ)NÜ(Ü#×2Ñ2Ø.¨z¨lÐ;óð ð Ø$+¨A¨B K×$6Ñ$6°wÓ$?Mô
|
¤ ¬I¯O©O¸ZÈ Ð+WÓXÙÜ$Ü ×.Ñ.Ø+¨C¨5°°&°¸¸7¸+ÐFóð ô
|
¤ ¬I¯O©O¸QÀÐ+CÓDà JJ× Ñ aÕ (Ø |Ò #ÜI¬ ¯©¸ÀÐ'DÓECØ JJ× Ñ ¤c¨'£lÕ 3Ø |Ò #ÜI¬ ¯©¸ÀÐ'DÓECØ JJ× Ñ ¤c¨'£lÕ 3ä Ü×*Ñ*Ð.@ÀÀ
|
Ð,Kóð øôc *ò Ü(Ü#×0Ñ0Ð2Nóà ð ûð ûô8 *ò Ü(Ü#×0Ñ0Ð2Nóà ð ûð ús0 ÊS Í-S/ Ó S,Ó S'Ó'S,Ó/ TÓ8TÔTc óð | j r| j |z dc}| _ d}t |« }|} | j t k( rJ||z
|
dk rn|| }||dz }|dz }|dz dz }|dz dz }|dz dz } |dz dz }
|
|d z } | s|
|
s|r&| j st t j d
|
« | dkD r |dk( rt t j d « |dz dz } |d z } | dkD r | d kD rt t j d« | j s| j t k( r|rt nt | _ n |rt t j d
|
« t |« | _ | | _ t | « | _ | | _ t" | _ | j t" k( r| j }|dk( r*||z
|
dk rn || }||dz }|dz }|dz |z | _ n0|dkD r$||z
|
dk rnqt' ||« d | _ |dz }n|| _ | j rt( nt* | _ | j t( k( r'||z
|
dk rn|||dz | _ |dz }t* | _ | j t* k( rã||z
|
}| j$ |k\ r|}| xj$ |z c_ n|| j$ z }d| _ | j. }| xj. ||z
|
z c_ |}|}| j$ dk7 r | j0 j3 ||| « nL|r«| j0 j3 ||| « | j rK| j, J t5 dj7 | j0 « « }t9 | j, |« |}ndj7 | j0 « }| j0 j; « nY| j rH| j, J ||| }t= |« t4 ur t5 |« }t9 | j, |« |}n||| }| j? | j | j || j « d| _ t | _ ,||k r ||| | _ yd| _ y)z&Return the next frame from the socket.r r r
|
r é é é r é z*Received frame with non-zero reserved bitsz!Received fragmented control frameé é} z5Control frame payload cannot be larger than 125 bytesé~ é N) rs r rl rk r{ r r r ro ry rx ÚCOMPRESSED_TRUEÚCOMPRESSED_FALSEr] rp rt rw ÚREAD_PAYLOAD_LENGTHrv r ÚREAD_PAYLOAD_MASKÚ READ_PAYLOADru rr rq r/ ri Újoinr r r~ r§ )r1 rI Ú start_posÚdata_lenÚ data_cstrÚ
|
first_byteÚ second_byter Úrsv1Úrsv2Úrsv3r
Úhas_maskÚlengthÚlen_flagÚ chunk_lenÚ f_end_posÚ had_fragmentsÚ f_start_posÚpayload_bytearrayr s r2 r zWebSocketReader._feed_dataD s¤ à ::Ø #zz¨DÑ 0°#Ð D$*à Üt9Ø àà{{kÓ)ØiÑ'¨!Ò+ÙØ & yÑ 1
|
Ø '¨ °A© Ñ 6 ØQ à! Q¨!Ñ+Ø" a¨1Ñ,Ø" a¨1Ñ,Ø" a¨1Ñ,Ø# cÑ)ñ 4¡D°· ² Ü(Ü#×2Ñ2ØDóð ð
|
C< C¨1¢HÜ(Ü#×2Ñ2Ø;óð ð
|
(¨1Ñ ,°Ñ1Ø$ tÑ+ð C< F¨S¢LÜ(Ü#×2Ñ2ØOóð ð ?? d×&6Ñ&6Ô:LÒ&LÙ:>¥ÔDTDÕ$ÙÜ(Ü#×2Ñ2ØDóð ô
|
#' s£)Ø%+Ô"Ü!% h£ Ø)/Ô&Ü 1 ð {{Ô 1Ò1Ø ×1Ñ1Øs?Ø )Ñ+¨aÒ/Ù Ø!*¨9Ñ!5JØ"+¨I¸©MÑ":KØ NIØ2<À±/ÀKÑ2ODÕ/Ø ^Ø )Ñ+¨aÒ/Ù Ü2=¸dÀIÓ2NÈqÑ2QDÔ/Ø NIà2:DÔ/à37·>²>Õ /Ä| ð {{Ô /Ò/ØiÑ'¨!Ò+ÙØ#,¨Y¸ÀQ¹ Ð#GÔ ØQ Ü * à{{lÓ*Ø $ yÑ 0 Ø×.Ñ.°)Ò;Ø (IØ×/Ò/°9Ñ<Ö/à )¨D×,GÑ,GÑ GIØ23DÔ/à $× 7Ñ 7 Ø×'Ò'¨9°yÑ+@Ñ@Õ'Ø ' Ø % à×.Ñ.°!Ò3ð ×+Ñ+×2Ñ2°9¸[ÈÐ3SÔTÙñ !à×+Ñ+×2Ñ2°9¸[ÈÐ3SÔTØ~~Ø #× /Ñ /Ð ;Ð;Ð ;Ü,5°c·h±h¸t×?VÑ?VÓ6WÓ,XÐ)Ü& t×'7Ñ'7Ð9JÔKØ"3à"%§(¡(¨4×+BÑ+BÓ"CØ×+Ñ+×1Ñ1Õ3Ø^^Ø ×+Ñ+Ð7Ð7Ð7Ø(1°+¸iÐ(HÐ%ÜÐ -Ó.´iÑ?ô -6Ð6GÓ,HÐ)Ü" 4×#3Ñ#3Ð5FÔGØ /Gà '¨ °IÐ >Gà×"Ñ"ØOO T×%7Ñ%7¸À$×BRÑBRôð +,Ô'Ü ) ñ] ðb 7@À(Ò6JYy¨Ð2
|
ÐPS
|
r )TrU )rW rX rY r r[ r] r3 rD r r ri Ú
|
memoryviewr rK rV r§ r r` r r2 rb rb
sÊ àMQñ"Ø'ð"Ø7:ð"ØFJð"à ó"ó2 ð Ø% ¨JÐ6Ñ7ðà tU{Ñ óð$Kà ðKð c:oÑ&ðKð uiÐ'Ñ(ð Kð
|
#z/Ñ*ð Kð
|
ó KðZZTuð ZT¨ô ZTr rb )@rZ rN r_ Ú collectionsr Útypingr r r r r r Ú base_protocolr Úcompression_utilsr Úhelpersr r Ústreamsr r r r Úmodelsr r r r r r[ r Ú__annotations__rk r³ r´ rµ ÚBINARYr ÚTEXTr rm Ú CONTINUATIONÚvaluer r r r r r r r r r r rx r² r± ÚtupleÚ__new__r rV r rb )Úis 0r2 ú<module>r× s8 ðÚ 6ã Û Ý ß <× <å (Ý 0ß 2Ý ß CÑ C÷õ ð 9DÖ'D°1©¨AÒ'DÐ U3s8_Ó Dð ØÐ ØÐ Ø à ×%Ñ%Ð Ø >>Ð ð Ø ×-Ñ-×3Ñ3Ð Ø~~×#Ñ# Ø×!Ñ!×'Ñ'Ø×%Ñ% Ø~~×#Ñ# Ø~~×#Ñ# à Ð Ø àÐ ØÐ Øà MM à
|
÷Lñ L÷^YTò YTùòa (Es ÁE
|
