Ë
|
|
çúh+ ã óv d dl Z d dlZd dlZd dlmZ d dlmZmZmZm Z m
|
Z
|
ej j dk\ r ej j dk\ rd dl mZ nd dlmZ ddlmZmZmZ dd lmZ dd
|
lmZ d d lmZmZmZmZ d d lm Z m Z m Z m Z e « Z! G d de d¬« Z" G d dee« Z# G d dee« Z$y)é N)Ú getLogger)ÚCallableÚListÚOptionalÚ TypedDictÚUnioné é )Útimeouté )ÚConnectionErrorÚInvalidResponseÚ
|
RedisError)Ú
|
EncodableT)ÚHIREDIS_AVAILABLEé )ÚAsyncBaseParserÚ AsyncPushNotificationsParserÚ
|
BaseParserÚPushNotificationsParser)Ú#NONBLOCKING_EXCEPTION_ERROR_NUMBERSÚNONBLOCKING_EXCEPTIONSÚSENTINELÚ SERVER_CLOSED_CONNECTION_ERRORc óZ e Zd ZU eegef ed< eegef ed< ee ed< ee ed< y)Ú_HiredisReaderArgsÚ protocolErrorÚ
|
replyErrorÚencodingÚerrorsN)Ú__name__Ú
|
__module__Ú __qualname__r ÚstrÚ ExceptionÚ__annotations__r © ó õi H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/_parsers/hiredis.pyr r " s:
ØSE 9Ð ,Ñ-Ó-Ø# Ð)Ñ*Ó*ØsmÓØ SMÔr( r F)Útotalc óH e Zd ZdZd Zd Zd Zd Zd Zd Z e
|
dfd Z d d
|
Z y ) Ú_HiredisParserz*Parser class for connections using Hiredisc ó® t s t d« || _ t |« | _ | j
|
| _ d | _ d | _ d | _ d | _
|
y )NzHiredis is not installed) r r Úsocket_read_sizeÚ bytearrayÚ_bufferÚhandle_pubsub_push_responseÚpubsub_push_handler_funcÚ node_moving_push_handler_funcÚ maintenance_push_handler_funcÚ invalidation_push_handler_funcÚ _hiredis_PushNotificationType)Úselfr. s r) Ú__init__z_HiredisParser.__init__, sT Ý Ü Ð 7Ó8Ð 8Ø 0Ô Ü Ð!1Ó2 Ø(,×(HÑ(HÔ%Ø-1Ô*Ø-1Ô*Ø.2Ô+Ø-1Õ*r( c óD | j « y # t $ r Y y w xY w©N)Ú on_disconnectr% ©r7 s r) Ú__del__z_HiredisParser.__del__7 s% ð Ø × Ñ Õ øÜò Ù ð ús c óV t d« }|j dt |« z « |S ©NÚ push_responsezPush response: ©r Údebugr$ ©r7 ÚresponseÚloggers r) r1 z*_HiredisParser.handle_pubsub_push_response= s' Ü?Ó+Ø Ð&¬¨X« Ñ6Ô7Ør( c ó dd l }|j | _ |j | _ t | j
|
|j j t d}|j j r|j j |d< |j di |¤| _ t | _ |j | _ y # t $ r
|
d | _ Y y w xY w)Nr )r r r Ú notEnoughDatar r' )ÚhiredisÚ_sockÚsocket_timeoutÚ_socket_timeoutr Ú parse_errorÚencoderÚencoding_errorsÚNOT_ENOUGH_DATAÚdecode_responsesr ÚReaderÚ_readerÚ_next_responseÚPushNotificationr6 ÚAttributeError)r7 Ú
|
connectionÚkwargsrH s r) Ú
|
on_connectz_HiredisParser.on_connectB s³ Ûà ×%Ñ%
|
Ø )× 8Ñ 8Ô ä ,Ø ×*Ñ*Ø ×(Ñ(×8Ñ8Ü ,ñ
|
ð × Ñ × .Ò .Ø!+×!3Ñ!3×!<Ñ!<F:Ñ Ø%w~~Ñ/¨Ñ/ Ü -Ôð 6Ø18×1IÑ1IDÕ .øÜ ò 6à15DÖ .ð 6ús Â&B8 Â8C Ã
|
C c ó6 d | _ d | _ t | _ y r: )rI rR rO rS r< s r) r; z _HiredisParser.on_disconnectY s Ø
|
Ø Ü -Õr( c óæ | j st t « | j t u rD| j j « | _ | j t u r| j |d¬« S y)NF)r Úraise_on_timeoutT)rR r r rS rO ÚgetsÚread_from_socket)r7 r s r) Úcan_readz_HiredisParser.can_read^ s_ Ø||Ü!Ô"@ÓAÐ Aà × Ñ ¤/Ñ 1Ø"&§,¡,×"3Ñ"3Ó"5DÔ Ø×"Ñ"¤oÑ5Ø×,Ñ,°WÈuÐ,ÓUÐUØr( Tc ó | j }|t u} |r|j |« | j j | j « }|dk( rt t « | j j | j d|« |r |j | j « yy# t j $ r. |r t d« Y |r |j | j « yyt $ rq}t j |j d« }|s2|j" |k( r#Y d }~|r |j | j « yyt d|j$ « d }~ww xY w# |r |j | j « w w xY w)Nr TzTimeout reading from socketFéÿÿÿÿz!Error while reading from socket: )rI r Ú
|
settimeoutÚ recv_intor0 r r rR ÚfeedrK Úsocketr Ú TimeoutErrorr r ÚgetÚ __class__ÚerrnoÚargs)r7 r r[ ÚsockÚcustom_timeoutÚbufflenÚexÚalloweds r) r] z _HiredisParser.read_from_socketh sZ ØzzØ ¬Ð0ð 6Ù Ø Ô(Øjj×*Ñ*¨4¯<©<Ó8GØ!|Ü%Ô&DÓEÐEØ LL× Ñ dll¨A¨wÔ 7ð ñ Ø × 4Ñ 4Õ5ð øô ~~ò Ù Ü"Ð#@ÓAÐAØñ Ø × 4Ñ 4Õ5ð ô &ò Qô
|
:×=Ñ=¸b¿l¹lÈBÓOGÙ#¨¯©°GÒ(;Û ñ Ø × 4Ñ 4Õ5ð ô "Ð$EÀbÇgÁgÀYÐ"OÓPÐ Pûð Qûñ Ø × 4Ñ 4Õ5ð ús< A3B) Â) E"à E% Ã)E"Ã11E Ä"E% ÅE Å E"Å"E% Å% Fc óT | j st t « | j t urc| j }t | _ | j
|
>t || j
|
« r(| j |« }|r|S | j ||¬« S |S |r | j j d« }n| j j « }|t u rQ| j « |r | j j d« }n| j j « }|t u rQt |t « r|| j
|
>t || j
|
« r(| j |« }|r|S | j ||¬« S t |t « r|rt |d t « r|d |S )N©Údisable_decodingÚ push_requestFr ) rR r r rS rO r6 Ú
|
isinstanceÚhandle_push_responseÚ read_responser\ r] Úlist©r7 rq rr rD s r) ru z _HiredisParser.read_response s Ø||Ü!Ô"@ÓAÐ Að × Ñ ¤oÑ 5Ø×*Ñ*HÜ"1DÔ Ø×1Ñ1Ð=Ä*Ø$×<Ñ<ôCð ×4Ñ4°XÓ>ñ Ø#Oà×)Ñ)Ø%5Ø!-ð *ó ð ð Oá Ø||×(Ñ(¨Ó/Hà||×(Ñ(Ó*Hà/Ñ)Ø × !Ñ !Ô #Ù Ø <<×,Ñ,¨UÓ3à <<×,Ñ,Ó.ð /Ò)ô h¤Ô 0ØNØ × /Ñ /Ð ;Ä
|
Ø d×8Ñ8ôA
|
ð ×0Ñ0°Ó:HÙØ Ø×%Ñ%Ø!1Ø )ð &ó ð ô x¤Ô &ÙÜ8 A;¬Ô8à1+Ð Ør( N©FF) r! r" r# Ú__doc__r8 r= r1 rX r; r^ r r] ru r' r( r) r, r, ) s4 Ù0ò 2òò ò
|
6ò..ò
|
ð (0À$ó 6ô<8r( r, c
|
ór e Zd ZdZdZdef fd Zd Zd Zd Z d Z
|
d Z dd
|
e d e d e eee f fd Z xZS )Ú_AsyncHiredisParserzBAsync implementation of parser class for connections using Hiredis)rR r. c ó t s t d« t | |¬« d | _ | j
|
| _ d | _ d | _ y )NzHiredis is not available.)r. ) r r Úsuperr8 rR r1 r2 r5 r6 )r7 r. rg s r) r8 z _AsyncHiredisParser.__init__Æ sH ø Ý Ü Ð 8Ó9Ð 9Ü ÑÐ*:ÐÔ;Ø Ø(,×(HÑ(HÔ%Ø.2Ô+Ø-1Õ*r( c ó^ K t d« }|j dt |« z « |S wr? rA rC s r) r1 z/_AsyncHiredisParser.handle_pubsub_push_responseÏ s+ è ø Ü?Ó+Ø Ð&¬¨X« Ñ6Ô7Øùs +-c ó| dd l }|j | _ t | j t
|
d}|j j r2|j j |d< |j j |d< |j di |¤| _ d| _ t |dd « | _ y # t $ r
|
d | _ Y y w xY w)Nr )r r rG r r TrT r' )rH rR Ú_streamr rL rO rM rP r rN rQ Ú
|
_connectedÚgetattrr6 rU )r7 rV rH rW s r) rX z _AsyncHiredisParser.on_connectÔ s´ Ûà!×)Ñ) ä ,Ø ×*Ñ*Ü ,ñ&
|
ð
|
× Ñ × .Ò .Ø!+×!3Ñ!3×!<Ñ!<F:Ñ Ø )× 1Ñ 1× AÑ AF8Ñ à%w~~Ñ/¨Ñ/ Ø ð 6Ü18ØÐ+¨Tó2DÕ .øô ò 6à15DÖ .ð 6ús ÂB( Â(B;Â:B;c ó d| _ y )NF)r r< s r) r; z!_AsyncHiredisParser.on_disconnectì s Ø r( c óf K | j st t « | j j « t
|
ury t d« 4 d { | j « d { cd d d « d { S 7 -7 7 # 1 d { 7 sw Y y xY w# t j $ r Y yw xY ww)NTr F)
|
r r r rR r\ rO Ú async_timeoutr] Úasynciore r< s r) Úcan_read_destructivez(_AsyncHiredisParser.can_read_destructiveï s è ø ØÜ!Ô"@ÓAÐ AØ <<× Ñ Ó ¤oÑ 5Øð Ü$ QÓ'÷ 5ñ 5Ø !× 2Ñ 2Ó 4×4÷ 5÷ 5ò 5øØ4øð 5ø÷ 5÷ 5ñ 5ûä×#Ñ#ò Ùð üs =B1Á B ÁA=ÁB ÁBÁ'A?Á(BÁ+ B Á7BÁ8B Á<B1Á=B Á?BÂB ÂBÂ B Â
|
BÂB ÂB1ÂB ÂB.Â+B1Â-B.Â.B1c óä K | j j | j « d { }|rt |t « st t « d | j j |« y7 Bw)NT) r ÚreadÚ
|
_read_sizers Úbytesr r rR rc )r7 Úbuffers r) r] z$_AsyncHiredisParser.read_from_socketú sW è ø Ø||×(Ñ(¨¯ © Ó9×9ÙZ¨´Ô 6Ü!Ô"@ÓAÀtÐ KØ ×Ñ&Ô!ð ð :ús )A0«A.¬AA0rq rr Úreturnc ó° K | j st t « d |r | j j d« }n| j j « }|t
|
u rY| j « d { |r | j j d« }n| j j « }|t
|
u rYt |t « r|| j Nt || j « r8| j |« d { }|s| j ||¬« d { S |S t |t « r|rt |d t « r|d |S 7 Ý7 Q7 6w)NFrp r ) r r r rR r\ rO r] rs r6 rt ru rv rw s r) ru z!_AsyncHiredisParser.read_response s@ è ø ð Ü!Ô"@ÓAÀtÐ Ká Ø||×(Ñ(¨Ó/Hà||×(Ñ(Ó*Hà/Ñ)Ø×'Ñ'Ó)× )Ð )Ù Ø <<×,Ñ,¨UÓ3à <<×,Ñ,Ó.ð /Ò)ô h¤Ô 0ØNØ × /Ñ /Ð ;Ä
|
Ø d×8Ñ8ôA
|
ð "× 6Ñ 6°xÓ @×@HÙ Ø !× /Ñ /Ø%5ÀLð 0ó ÷ ð ð ä x¤Ô &ÙÜ8 A;¬Ô8à1+Ð Øð7 *øð Aøðús> A0EÁ2EÁ3AEÂ8AEÄ EÄ EÄ EÄ 3EÅEÅErx )r! r" r# ry Ú __slots__Úintr8 r1 rX r; r r] Úboolr r r ru Ú __classcell__)rg s @r) r{ r{ Á sc ø ÙLà Ið2¨õ 2òò
|
6ò0 ò òð DIñ*Ø $ð*Ø<@ð*à z4
|
Ñ+Ð+Ñ ,÷*r( r{ )%r rd ÚsysÚloggingr Útypingr r r r r Ú version_infoÚmajorÚminorr r
Ú
|
exceptionsr r r r Úutilsr Úbaser r r r r r r r ÚobjectrO r r, r{ r' r( r) ú<module>r s ðÛ Û Û
|
Ý ß =Õ =à×Ñ×ÑQÒ 3×#3Ñ#3×#9Ñ#9¸RÒ#?Þ0å6ç EÑ EÝ Ý %÷ó ÷ ó ñ (ô¨%õ ôUZÐ!8ô Uôpl/Ð+Gõ lr(
|
