Ë
|
|
çúh ã ó@ d dl Z d dlZd dlZd dlmZ d dlmZmZ ddlmZm Z ddl
|
m Z e e j iZe r;d dlZ eed« r deej" < deej$ < ndeej& < eej+ « « ZdZ e« Zd Z G d
|
d « Zy) é N)ÚSEEK_END)ÚOptionalÚUnioné )ÚConnectionErrorÚ TimeoutError)Ú SSL_AVAILABLEÚSSLWantReadErrorz Connection closed by server.s
|
c óÎ e Zd Zdej dedefdZdefdZdedfd e e d
|
e
|
ee f d e e de fd Z d
|
ede fd Zd edefdZdefdZdefdZdeddfdZddZddZy)Ú SocketBufferÚsocketÚsocket_read_sizeÚsocket_timeoutc ó` || _ || _ || _ t j « | _ y ©N)Ú_sockr r ÚioÚBytesIOÚ_buffer)Úselfr r r s õh H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/_parsers/socket.pyÚ__init__zSocketBuffer.__init__ s( ð
|
Ø 0Ô Ø ,ÔÜzz| ó Úreturnc ó¶ | j j « }| j j dt « }| j j |« ||z
|
S )z3
|
Remaining unread length of buffer
|
r )r ÚtellÚseekr )r ÚposÚends r Ú unread_byteszSocketBuffer.unread_bytes& sH ð ll× Ñ Ó!Øll× Ñ ¤8Ó,Ø ×Ñ#Ô ØSyÐr NTÚlengthÚtimeoutÚraise_on_timeoutc ó< | j }| j }d}|t u}| j }|j « } |j dt « |r|j |« | j j |« }
|
t |
|
t « r t |
|
« dk( rt t « |j |
|
« t |
|
« } || z }|||kD rr |j | « |r |j | j « yy# t j" $ r? |r t% d« Y |j | « |r |j | j « yyt& $ r} t( j+ | j, d« } |sC| j. | k( r4Y d } ~ |j | « |r |j | j « yyt d| j0 « d } ~ ww xY w# |j | « |r |j | j « w w xY w)Nr TzTimeout reading from socketFéÿÿÿÿz!Error while reading from socket: )r r ÚSENTINELr r r r Ú
|
settimeoutÚrecvÚ
|
isinstanceÚbytesÚlenr Ú SERVER_CLOSED_CONNECTION_ERRORÚwriter r r" r ÚNONBLOCKING_EXCEPTIONSÚ#NONBLOCKING_EXCEPTION_ERROR_NUMBERSÚgetÚ __class__ÚerrnoÚargs)r r! r" r# Úsockr ÚmarkerÚcustom_timeoutÚbufÚ current_posÚdataÚ data_lengthÚexÚalloweds r Ú_read_from_socketz SocketBuffer._read_from_socket/ sÛ ð zzØ ×0Ñ0ÐØØ ¬Ð0àllØhhj Ø HÔ Ù Ø OOGÔ $ð 5ØØzzÐ'7Ó8ä d¤EÔ*¬s°4«y¸Aª~Ü)Ô*HÓIÐIØ $Ü ! $i Ø+Ñ%àÐ%¨&°6ª/Ø Øð HH[Ô !Ù Ø × 3Ñ 3Õ4ð øô ~~ò Ù Ü"Ð#@ÓAÐAØð HH[Ô !Ù Ø × 3Ñ 3Õ4ð ô &ò Qô
|
:×=Ñ=¸b¿l¹lÈBÓOGÙ#¨¯©°GÒ(;Û ð HH[Ô !Ù Ø × 3Ñ 3Õ4ð ô "Ð$EÀbÇgÁgÀYÐ"OÓPÐ Pûð Qûð HH[Ô !Ù Ø × 3Ñ 3Õ4ð ús= Á)A2D Ä G'Ä,G* Å G'Å%1G"ÆG* Ç
|
G"Ç"G'Ç'G* Ç*1Hc ó^ t | j « « xs | j |d¬« S )NF)r" r# )Úboolr r= )r r" s r Úcan_readzSocketBuffer.can_read^ s5 ÜD×%Ñ%Ó'Ó(ò
|
¨D×,BÑ,Bبeð -Có -
|
ð
|
r c óÊ |dz }| j j |« }|t |« z
|
}|r/| j |« || j j |« z }|d d S )Nr éþÿÿÿ)r Úreadr+ r= )r r! r9 Úmissings r rC zSocketBuffer.readc sc Ø!à||× Ñ Ó(Ø3t9Ñ$Ù à × "Ñ " 7Ô +Ø DLL×%Ñ% gÓ.Ñ .DØCRyÐr c óà | j }|j « }|j t « s9| j « ||j « z }|j t « s9|d d S )NrB )r ÚreadlineÚendswithÚSYM_CRLFr= )r r7 r9 s r rF zSocketBuffer.readlinen sZ ØllØ||~Ø--¤Ô)à × "Ñ "Ô $Ø CLLNÑ "Dð --¤Õ)ð
|
CRyÐr c ó6 | j j « S )z+
|
Get current read position
|
)r r ©r s r Úget_poszSocketBuffer.get_posx s ð ||× Ñ Ó"Ð"r r c ó: | j j |« y)zO
|
Rewind the buffer to a specific position, to re-start reading
|
N)r r )r r s r ÚrewindzSocketBuffer.rewind~ s ð ×Ñ#Õ r c óì | j « }|dkD ry|dkD r#| j j « }|| d |d| | j j |« | j j d« y)zH
|
After a successful read, purge the read part of buffer
|
r N)r r Ú getbufferÚtruncater )r ÚunreadÚviews r ÚpurgezSocketBuffer.purge sn ð ×"Ñ"Ó$ð
|
A:Ø à A:à<<×)Ñ)Ó+DØ & ND&MØ × Ñ fÔ%Ø ×Ñ!Õ r c ót | j j « d | _ d | _ y # t $ r Y w xY wr )r ÚcloseÚ Exceptionr rJ s r rU zSocketBuffer.close s= ð Ø LL× Ñ Ô ð Ø
|
øô ò ñ ð ús + « 7¶7)r N)Ú__name__Ú
|
__module__Ú __qualname__r ÚintÚfloatr r r& r r Úobjectr? r= r@ r* rC rF rK rM rS rU © r r r r sÒ ð$Ø mmð$Ø7:ð$ØLQó$ðcó ð !%Ø(0Ø+/ñ -5à ð-5ð uf}Ñ%ð-5ð # 4.ð -5ð
|
|
ó -5ð^
|
ð
|
¨$ó
|
ð
|
3ð 5ó ð%ó ð#ó #ð #ð $ó ó ô& r r ) r2 r r r Útypingr r Ú
|
exceptionsr r Úutilsr ÚBlockingIOErrorÚ EWOULDBLOCKr/ ÚsslÚhasattrr
|
ÚSSLWantWriteErrorÚSSLErrorÚtupleÚkeysr. r, r\ r& rH r r] r r ú<module>ri s ðÛ Û Û Ý ß "ç 6Ý !à'6¸×8IÑ8IÐ&JÐ #áÛásÐ&Ô'ØDEÐ+¨C×,@Ñ,@ÑAØEFÐ+¨C×,AÑ,AÒBà<=Ð+¨C¯L©LÑ9á Ð B× GÑ GÓ IÓJÐ à!?Ð Ù 8à ÷Eò Er
|
