/ i:ddlZddlZddlZddlmZddlmZmZddlmZm Z ddl m Z e ej iZe r/ddlZeedrdeej<deej<n deej<eeZdZeZd ZGd d ZdS) N)SEEK_END)OptionalUnion)ConnectionError TimeoutError) SSL_AVAILABLESSLWantReadErrorzConnection closed by server.s c eZdZdejdedefdZdefdZdedfd e ed e ee fd e e de fd Z d ede fd Zd edefdZdefdZdefdZdeddfdZddZddZdS) SocketBuffersocketsocket_read_sizesocket_timeoutc`||_||_||_tj|_dSN)_sockrrioBytesIO_buffer)selfr rrs C:\Users\Dell Inspiron 16\Desktop\tws\AgrotaPowerBi\back-agrota-powerbi\mcp-client-agrota\venv\Lib\site-packages\redis/_parsers/socket.py__init__zSocketBuffer.__init__s, 0,z|| returnc|j}|jdt}|j|||z S)z3 Remaining unread length of buffer r)rtellseekr)rposends r unread_byteszSocketBuffer.unread_bytes&sNl!!l8,, #SyrNTlengthtimeoutraise_on_timeoutcz|j}|j}d}|tu}|j}|} |dt |r|| ||} t| tr't| dkrtt|| t| } || z }|||kr || |r||jdSdS#t j$rH|rt%dY|| |r||jdSdSt&$r} t(| jd} |sD| j| kr9Yd} ~ || |r||jdSdStd| jd} ~ wwxYw#|| |r||jwwxYw)NrTzTimeout reading from socketFz!Error while reading from socket: )rrSENTINELrrrr settimeoutrecv isinstancebyteslenrSERVER_CLOSED_CONNECTION_ERRORwriterr r"rNONBLOCKING_EXCEPTIONS#NONBLOCKING_EXCEPTION_ERROR_NUMBERSget __class__errnoargs)rr!r"r#sockrmarkercustom_timeoutbuf current_posdata data_lengthexalloweds r_read_from_socketzSocketBuffer._read_from_socket/s z0 0lhhjj  H  % OOG $ $ $ 5 yy!122dE**Js4yyA~~)*HIII $!$ii +%%&6// HH[ ! ! ! 5 344444 5 5~    B"#@AAA HH[ ! ! ! 5 344444 5 5& Q Q Q :==blBOOG# G(;(;uuu HH[ ! ! ! 5 344444 5 5""Obg"O"OPP P Q HH[ ! ! ! 5 34444 5s=(BD"" HH8 H-G>.H'G>>HH4H:crt|p||dS)NF)r"r#)boolr r=)rr"s rcan_readzSocketBuffer.can_read^s@D%%''(( D,B,Be-C- -  rc|dz}|j|}|t|z }|r2||||j|z }|ddS)Nr)rreadr+r=)rr!r9missings rrCzSocketBuffer.readcst!|  ((3t99$  /  " "7 + + + DL%%g.. .DCRCyrc |j}|}|tsE|||z }|tE|ddS)NrB)rreadlineendswithSYM_CRLFr=)rr7r9s rrFzSocketBuffer.readlinenstl||~~--)) #  " " $ $ $ CLLNN "D--)) # CRCyrc4|jS)z+ Get current read position )rrrs rget_poszSocketBuffer.get_posxs|  """rrc:|j|dS)zO Rewind the buffer to a specific position, to re-start reading N)rr)rrs rrewindzSocketBuffer.rewind~s  #rc|}|dkrdS|dkr)|j}|| d|d|<|j||jddS)zH After a successful read, purge the read part of buffer rN)r r getbuffertruncater)runreadviews rpurgezSocketBuffer.purges""$$ A:: F A::<))++D &ND&M f%%% !rcx |jn#t$rYnwxYwd|_d|_dSr)rclose ExceptionrrJs rrUzSocketBuffer.closesT  L       D    s  )))rN)__name__ __module__ __qualname__r intfloatrr r&rrobjectr?r=r@r*rCrFrKrMrSrUrrr r s}$m$7:$LQ$$$$c!%(0+/ -5-5 -5uf}%-5#4. -5  -5-5-5-5^  $    3 5    %##### #$ &      rr )r2rr rtypingrr exceptionsrrutilsr BlockingIOError EWOULDBLOCKr/sslhasattrr SSLWantWriteErrorSSLErrortuplekeysr.r,r\r&rHr r]rrrisC """"""""66666666!!!!!!'68I&J#>JJJws&''>DE+C,@AEF+C,ABB<=+CL9BGGIIJJ!? 688 EEEEEEEEEEr