V.jddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z m Z ddlmZddlmZmZddlmZdd l mZ dd lmZej.d k(r1ej0Zej2Zej4Zej6Z gd Zeed ZdZ dZ!ejDZ#dZ$dgZ%eedrdZ$e%dgz Z%ej.d k(rdZ$e%dgz Z%e!fdZ&dZ'dZ(dZ)dZ*GddZ+GddZ,er Gdde,Z-Gdde,Z.Gd d!Z/dEd"Z0d#Z1ej.d k7rdFd$Z2ndFd%Z2Gd&d'Z3d(Z4ej.d k(r%Gd)d*Z5ejlejnffd+Z8d,Z9d-Z:d.Z;d/ZGd2d3Z?d4Z@d5ZAGd6d7e/ZBd8ZCej.d k(r d9ZDejejhZGdGd:ZHneed;rd<ZInd=ZIdGd>ZHej.d k(r3d?ZJd@ZKe je.eJdAZMdBZNe je-eMydCZJdDZKe je.eJy#e$rej.d k(rdZYwxYw)HN) reduction)util)AuthenticationErrorBufferTooShort) _billiard) setblocking send_offset monotonic)ForkingPickler)_winapiwin32)ClientListenerPipewaitpypy_version_infoi g4@AF_INETAF_UNIXAF_PIPEct|zSNr )timeouts UC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\billiard/connection.py _init_timeoutrEs ;  ct|kDSrr )ts r_check_timeoutr Is ;?rc|dk(ry|dk(r)tjdtjS|dk(r;tjdt j t tfzdStd ) z? Return an arbitrary free address for the given family r) localhostrrz listener-)prefixdirrz\\.\pipe\pyc-%d-%d-zunrecognized family) tempfilemktempr get_temp_dirosgetpidnext _mmap_counter ValueErrorfamilys rarbitrary_addressr0Qsy 9 kt7H7H7JKK 9 &< " T--@A'BGIK K.//rctjdk7r|dk(rtd|ztjdk(r%|dk(rtt|std|zyyy)zD Checks if the family is valid for the current environment. rrzFamily %s is not recognized.rN)sysplatformr-hasattrsocketr.s r_validate_familyr6`sc ||w6Y#67&@AA ||w6Y#6vv&;fDE E'$7rct|tk(ryt|tur|jdryt|turyt d|z)z] Return the types of the address This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE' rz\\rrzaddress type of %r unrecognized)typetuplestr startswithr-)addresss r address_typer=msO  G} g# '"4"4V"< g# :WDEErceZdZdZy)_SocketContainerc||_yrsock)selfrBs r__init__z_SocketContainer.__init__s  rN)__name__ __module__ __qualname__rDrrr?r?srr?ceZdZdZddZdZdZdZdZdZ e dZ e d Z e d Z d Zd Zdd ZdZddZddZdZddZdZdZdZdZy)_ConnectionBaseNct|tr+|j|_|jj }|j }|dkr t d|s |s t d||_||_||_ y)Nrzinvalid handlez6at least one of `readable` and `writable` must be True) isinstancer?rB_socketfileno __index__r-_handle _readable _writable)rChandlereadablewritables rrDz_ConnectionBase.__init__sw f. /!;;DL[['')F!!# A:-. .HJ J !!rc>|j|jyyrrP_closerCs r__del__z_ConnectionBase.__del__s << # KKM $rc2|j tdy)Nzhandle is closed)rPOSErrorrYs r _check_closedz_ConnectionBase._check_closeds << ,- - rc2|js tdy)Nzconnection is write-only)rQr\rYs r_check_readablez_ConnectionBase._check_readables~~45 5rc2|js tdy)Nzconnection is read-only)rRr\rYs r_check_writablez_ConnectionBase._check_writables~~34 4rct|jrd|_td|jtd)NFzbad message length)rRrQcloser\rYs r_bad_message_lengthz#_ConnectionBase._bad_message_lengths5 >>"DN*++ JJL*++rc|jduS)z True if the connection is closedNrPrYs rclosedz_ConnectionBase.closeds||t##rc|jS)z"True if the connection is readable)rQrYs rrTz_ConnectionBase.readable~~rc|jS)z"True if the connection is writable)rRrYs rrUz_ConnectionBase.writablerirc:|j|jS)z+File descriptor or handle of the connection)r]rPrYs rrNz_ConnectionBase.filenos ||rcf|j |jd|_yy#d|_wxYw)zClose the connectionNrWrYs rrcz_ConnectionBase.closes1 << # $ # $ $ s' 0cz|j|jt|}|jdkDrtt |}t |}|dkr t d||kr t d|||z }n#|dkr t d||z|kDr t d|j||||zy)z,Send the bytes data from a bytes-like objectrrzoffset is negativezbuffer length < offsetNzsize is negativezbuffer length < offset + size)r]ra memoryviewitemsizebyteslenr- _send_bytes)rCbufoffsetsizemns r send_bytesz_ConnectionBase.send_bytess   sO ::>58$A F A:12 2 v:56 6 <v:D AX/0 0 d]Q <= = 6&4-01rc|j|j|jtj|y)zSend a (picklable) objectN)r]rarrr dumpsrCobjs rsendz_ConnectionBase.sends3   --c23rc|j|j||dkr td|j|}||j |j S)z7 Receive bytes data as a bytes object. rznegative maxlength)r]r_r- _recv_bytesrdgetvalue)rC maxlengthrss r recv_bytesz_ConnectionBase.recv_bytessa    Y]12 2y) ;  $ $ &||~rc|j|jt|5}|j}|t |z}|dkr t d||kDr t d|j }|j}|||zkrt|j|jd|j|||z||z|z|cdddS#1swYyxYw)zq Receive bytes data into a writeable bytes-like object. Return the number of bytes read. rznegative offsetzoffset too largeN) r]r_rnrorqr-rtellrrseekreadinto)rCrsrtrvrobytesizeresultrus rrecv_bytes_intoz_ConnectionBase.recv_bytes_intos   _zzH#a&(Hz !233(" !344%%'F;;=D&4-'$V__%677 KKN OOA("FTMh#> #__s B+C!!C*c|j|j|j}tj|S)zReceive a (picklable) object)r]r_rr loadbuf)rCrss rrecvz_ConnectionBase.recvs9   %%c**rcd|j|j|j|S)z/Whether there is any input available to be read)r]r__pollrCrs rpollz_ConnectionBase.polls)  zz'""rc|SrrHrYs r __enter__z_ConnectionBase.__enter__ rc$|jyrrcrCexc_type exc_valueexc_tbs r__exit__z_ConnectionBase.__exit__  rc8t|j||Sr)r rN)rCrsrts rr z_ConnectionBase.send_offset"s4;;=#v66rc8t|j|yr)r rN)rCblockings rr z_ConnectionBase.setblocking%sDKKM8,r)TT)rNr)r)g)rErFrGrPrDrZr]r_rardpropertyrgrTrUrNrcrxr}rrrrrrr r rHrrrJrJsG " .65,$$ $2*4 4+# 7-rrJcLeZdZdZdZej fdZdZd dZ dZ dZ y) PipeConnectionz Connection class based on a Windows named pipe. Overlapped I/O is used, so the handles must have been created with FILE_FLAG_OVERLAPPED. Fc(||jyrrf)rC _CloseHandles rrXzPipeConnection._close3s  &rctj|j|d\}} |tjk(r1tj|j gdt }|tk(sJ|jd\}}|dk(sJ|t|k(sJy#|jxYw#|jd\}}wxYw)NT overlappedFr) r WriteFilerPERROR_IO_PENDINGWaitForMultipleObjectseventINFINITE WAIT_OBJECT_0cancelGetOverlappedResultrq)rCrsoverrwaitresnwrittens rrrzPipeConnection._send_bytes6s'' cdKGB ='222%<< E85G#m333 !# 6 6t < #!8O8s3x' ''    " 6 6t < #sABB**B--CNc|jrd|_tjS|dn t|d} t j |j |d\}}d}d} |tjk(r1t j|jgdt}|tk(sJ|jd\} }|dk(r6tj} | j|j!| }n&|tj"k(r|j%||} ||S|| t/d#t$r}|j|}Yd}~d}~wwxYw#|jd\} }|dk(r6tj} | j|j!| }w|tj"k(r|j%||}wwxYw#t&$r)}|j(tj*k(rt,d}~wwxYw)NFTrrz.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminrReadFilerPrrrrr Exceptionrrwrite getbufferERROR_MORE_DATA_get_more_datar\winerrorERROR_BROKEN_PIPEEOFError RuntimeError) rCmaxsizebsizerrr exc_to_raiserenreadfs rrzPipeConnection._recv_bytesFs&&*/'zz|#&C4E%.. eGB"F#'LF'":"::&-&D&D!# E8'=G#*m#;;#; &(%;%;D%A s!8 " AGGBLLN3%&F G$;$;;%)%8%8W%EF)% #/**0@B B)%) '( )&(%;%;D%A s!8 " AGGBLLN3%&F G$;$;;%)%8%8W%EF< zzW%>%>>& sV)G#AD0'A8G G0 E9E EEEA7GG H$G??Hc|js%tj|jddk7ryt t |g|S)NrT)rr PeekNamedPiperPboolrrs rrzPipeConnection._pollns>''))$,,7:a?dVW-. .rc|j}tj}|j|t j |j d}|dkDsJ|!t||z|kDr|jt j|j |d\}}|jd\}}|dk(sJ||k(sJ|j|j|S)NrrTr) rrrrrrrPrqrdrr)rCrrrsrleftrrbytess rrzPipeConnection._get_more_datats,,.C A GGCL((6q9D!8O8"s3x$'@((*&&t||TdKGB006KFC!8O8T> !> GGBLLN #Hrr) rErFrG__doc__rr CloseHandlerXrrrrrrHrrrr+s3 #&-&9&9 ' ( & BP / rrceZdZdZer(ej fdZejZ ejZ n'e jfdZe jZ e jZ e fdZe fdZefdZd dZd Zy) Connectionzo Connection class based on an arbitrary file descriptor (Unix only), or a socket handle (Windows). c(||jyrrfrCrXs rrXzConnection._close 4<< rc(||jyrrfrs rrXzConnection._closerrct|} ||j|}||z}|dk(ry||d}%#tttj f$r)}t |ddtjk7rYd}~Cd}~wwxYw)Nrerrno) rqrPr\IOErrorr5errorgetattrrEINTR)rCrsr remainingrwexcs r_sendzConnection._sendsH  $,,, Q >!"gWfll3 3.%++=> s2A9A44A9ctj}|j}|}|dkDrL |||}t|}|dk(r||k(rtt d|j |||z}|dkDrL|S#t ttjf$r)}t|ddtjk7rYd}~Jd}~wwxYw)Nrzgot end of file during messager) rrrPrqrr\rrr5rrrr) rCrureadrsrSrchunkrwrs r_recvzConnection._recvsjjl !m VY/ J6 D(&%&FGG % Q !m Wfll3 3.%++=> s A66B=B88B=ct|}tjd|}|dkDr#|j||j|yt ||r|j }|j||zy)N!ii@)rqstructpackrrLtobytes)rCrsrnrwheaders rrrzConnection._send_bytessb HT1% u9 JJv  JJsO #z*kkm JJv| $rNc|jd}tjd|j\}|||kDry|j|S)Nr)rrunpackr)rCrrsrus rrzConnection._recv_bytessEjjm dCLLN3  4'>zz$rc2t|g|}t|Sr)rr)rCrrs rrzConnection._polls $ !Awrr)rErFrGrrr closesocketrXr}_writer_readr)rcrrrrrnrrrrrHrrrrsp  ) 5 5 ! " !%  %*+5%$ rrcTeZdZdZd dZdZdZedZedZ dZ d Z y) rz Returns a listener object. This is a wrapper for a bound socket which is 'listening' for connections, or for a Windows named pipe. Nc|xs|xr t|xst}|xs t|}t||dk(rt |||_nt ||||_|t|ts td||_ y)Nrauthkey should be a byte string) r=default_familyr0r6 PipeListener _listenerSocketListenerrLrp TypeError_authkey)rCr<r/backlogauthkeys rrDzListener.__init__sH4|G4H9G 6.v6 Y )'7;DN+GVWEDN  z'5'A=> > rc|j td|jj}|jr,t ||jt ||j|S)zz Accept a connection on the bound socket or named pipe of `self`. Returns a `Connection` object. zlistener is closed)rr\acceptrdeliver_challengeanswer_challenge)rCcs rrzListener.acceptsT >> !./ / NN ! ! # == a / Q .rcP|j}|d|_|jyy)zA Close the bound socket or named pipe of `self`. N)rrc)rClisteners rrczListener.closes)>>  !DN NN  rc.|jjSr)r_addressrYs rzListener.sDNN$;$;rc.|jjSr)r_last_acceptedrYs rrzListener. s$..*G*Grc|SrrHrYs rrzListener.__enter__ rrc$|jyrrrs rrzListener.__exit__rr)NNrN) rErFrGrrDrrcrr< last_acceptedrrrHrrrrs8  ;tj}tjtjz}t t }}n(tj }tj}dt }}tj||tjztjztjtjztjzd||tjtj}tj||dtjtj tjtj} tj"| tjddtj$|d} | j'd\} } | dk(sJt)|| } t)| | }| |fS) rz"rnonblock not supported on windowsz"wnonblock not supported on windowsrrrNTrrr)r0rPIPE_ACCESS_DUPLEX GENERIC_READ GENERIC_WRITEBUFSIZEPIPE_ACCESS_INBOUNDCreateNamedPipeFILE_FLAG_OVERLAPPEDFILE_FLAG_FIRST_PIPE_INSTANCEPIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITNMPWAIT_WAIT_FOREVERNULL CreateFile OPEN_EXISTINGSetNamedPipeHandleStateConnectNamedPiperr)rrrr<openmodeaccessobsizeibsizeh1h2r_rrrs rrrHsBBB}BBB}#I. 11H))G,A,AAF$gFF22H**FFF  $ $ X < <<  1 12  % %(E(E E     vvw;; LL    VQ g.C.C  ( (',,  '' --tT --bTB //53axx B 0 B 02v rc$eZdZdZddZdZdZy)rzO Representation of a socket which is bound to an address and listening ctjtt||_ tjdk(r9|jj tj tjd|jjd|jj||jj||jj|_ ||_d|_|dk(r.t#j$|tj&|fd|_yd|_y#t$r|jjwxYw)NposixrTrrargs exitpriority)r5rrMr)name setsockopt SOL_SOCKET SO_REUSEADDRr bindlisten getsocknamerr\rc_familyrrFinalizeunlink_unlink)rCr<r/rs rrDzSocketListener.__init__{s}}WVV%<=  ww'! ''(9(9(.(;(;Q@ LL $ $T * LL  g & LL   ( LL446DM " Y ==biiwjqDL DL  LL    s B&4&  d&)$$ Wfll3 3.%++=> s"A B)B  Bc |jj|j}|d|_|yy#|j}|d|_|wwxYwr)rMrcrI)rCrHs rrczSocketListener.closes[  LL   \\F!# "\\F!# "s :AN)r)rErFrGrrDrrcrHrrrrws 0 %rrct|}tjtt|}|jd|j |t t |S)zO Return a connection object connected to the socket given by `address` T)r=r5rr connectrr)r<r/rKs rrrsJ' "F gff-.AMM$IIg fQi  rc6eZdZdZddZddZdZedZy) rz0 Representation of a named pipe Nc||_|jdg|_d|_t j d|jt j |tj|j|jfd|_ y)NT)firstz listener created with address=%rrr<) r _new_handle _handle_queuerr sub_debugrGr_finalize_pipe_listenerrc)rCr<rs rrDzPipeListener.__init__sl#DM"&"2"2"2">!?D "&D  NN=t}} Ml::(($--8qDJrc ~tjtjz}|r|tjz}tj|j |tj tjztjztjtttjtjSr) rr!r'r(r&rr)r*r+PIPE_UNLIMITED_INSTANCESr$r,r-)rCrQflagss rrRzPipeListener._new_handles..1M1MME>>>** u))G,I,II!!"00'7,,gll  rch|jj|j|jjd} t j |d} t j |jgdt |jd\}}|dk(sJt|S#|jt j|xYw#|jd\}}|dk(sJwxYw#t$r2}|jtjk7rYd}~t|Sd}~wwxYw)NrTrF)rSappendrRpoprr1rrrrrrr\r ERROR_NO_DATAr)rCrSrr8rrs rrzPipeListener.accepts    % %d&6&6&8 9''++A.F $--fF $22 E85 33D9FAs!8O8!&) )IIK''/33D9FAs!8O8 ::!6!667"&) )! s0C6&B++(CCC36 D1?D,,D1chtjd||D]}tj|y)Nz closing listener with address=%r)rrTrr)queuer<rSs rrUz$PipeListener._finalize_pipe_listeners) NN=w G##F+ rr)F) rErFrGrrDrRr staticmethodrUrHrrrrs*    *.  ,  ,rrc t} tj|dtj|tjtj zdtj tjtjtj } tj|tjddt|S#t$r$}|j|vs t|rYd}~nd}~wwxYw)zU Return a connection object connected to the pipe given by `address` rN)rr WaitNamedPiper.r"r#r-r/r'r\rr r0r*r)r<_ignorerhrs rr r s O %%gt4&&W11G4I4IIw||W%:%:00',, '' w,,dD a   ::W,q0A1B sBC C4C//C4s #CHALLENGE#s #WELCOME#s #FAILURE#cjddl}t|tsJtjt }|j t|z|j||dj}|jd}||k(r|j ty|j ttd)Nrmd5zdigest received was wrong)hmacrLrpr)urandomMESSAGE_LENGTHrx CHALLENGEnewdigestrWELCOMEFAILUREr connectionrrimessagernresponses rrrs gu %% %jj(G)g-. XXgw . 5 5 7F$$S)H6g&g&!"=>>rcjddl}t|tsJ|jd}|dt t t k(s Jd|z|t t d}|j ||dj}|j||jd}|tk7r tdy)Nrrhz message = %rrgzdigest sent was rejected) rirLrprrqrlrmrnrxrorrqs rrr%s gu %% %##C(G ?C N #y 0J.72JJ 0c)no&G XXgw . 5 5 7F&!$$S)H7!"<==rceZdZdZdZdZy)ConnectionWrappercn||_||_||_dD]}t||}t |||y)N)rNrcrrrx)_conn_dumps_loadsrsetattr)rCconnrzloadsattrr|s rrDzConnectionWrapper.__init__8s:   KD$%C D$ $Lrc\|j|}|jj|yr)rzryrx)rCr|rKs rr}zConnectionWrapper.send@s" KK  a rcX|jj}|j|Sr)ryrr{)rCrKs rrzConnectionWrapper.recvDs" JJ ! ! #{{1~rN)rErFrGrDr}rrHrrrwrw6s%!rrwcXtj|fdddd}|jdS)Nrutf-8) xmlrpclibrzencode)r|os r _xml_dumpsrIs)tT15A 88G rcXtj|jd\\}}|S)Nr)rr~decode)rKr|methods r _xml_loadsrNs$__QXXg%67NFSF JrceZdZdZy) XmlListenercbddlmatj |}t |t tSNr) xmlrpc.clientclientrrrrwrrr{s rrzXmlListener.acceptUs")ood# j*==rN)rErFrGrrHrrrrSs>rrcJddlmatt |i|t t Sr)rrrrwrrr)r=kwdss r XmlClientr\s% VT2T2J KKrct|}g}|rtj|d|}|tk(r |St|cxkrtt |zkr nn |tz}nAt |cxkrt t |zkrn td|t z}n td|j||||dzd}d}|r|S)NFzShould not get hererr) listrr WAIT_TIMEOUTrrqWAIT_ABANDONED_0rrZ)handlesrLreadyress r_exhaustive_waitrgs M00E7CCl" #> A(>>}$!SD+;c!f+DD##899''"#899 LL3 #'( AG rc~ |t}n|dkrd}nt|dzdz}t|}i g}t}t} |D]v} t |d} t j |dd\}}|t jk(r!|j| |j<d|j|d}xt! j#|}|D]}|j%|D]e} |j'd\} }|t j(k7s, |j}|j||dk(sRt+|ds_d|_g |j/ fd|D|D cgc] } | |vs|  c} S#t$r } | j}|tvrYd} ~ 8d} ~ wwxYw#t$r| |j<YwxYw#t$r} | j}|tvrYd} ~ d} ~ wwxYw#|D]}|j%|D]} |j'd\} }n+#t$r} | j}|tvrYd} ~ nd} ~ wwxYw|t j(k7sX |j}|j||dk(s~t+|dsd|_wxYwcc} w) Wait till an object in object_list is ready/readable. Returns list of those objects in object_list which are ready/readable. Nrrag?rNTrc3(K|] }| ywrrH).0rdwaithandle_to_objs r zwait..sI=a.q1=s)rintrsetrrrr\r _ready_errorsrrZraddAttributeErrorrOrkeysrrERROR_OPERATION_ABORTEDr4rupdate) object_listrov_list ready_objects ready_handlesrrNrrrr8prs @rrr}s ?G q[G'D.3./G;'   - 8 $$Q1F "")"2"268Q"EC g666r*67)"((3 &))!,"#+!.-->-C-C-EwOM 33D9FAs '999)"((3A!%%a(ax#1&:;37A0 I=II&=;a!}*<;==M#"jjm3!4" &978%akkm49<**C-/0 33D9FAs**C-/0'999)"((3A!%%a(ax#1&:;37A0">sH F:F:A#H:G= J:J: F7F2,H2F77H:GHGH H&HHJ7&H;:J7; I# I J7I# #J7:%J7 J7- J7rc|t|dz}i}tj}|D]G}|j|tjt |dr|||j <C|||<Ig}|j|D]:\}}|tjzrtd|z|j||<|S)NrarNzinvalid file descriptor %i) rselectrregisterPOLLINr4rNPOLLNVALr-rZ)fdsrfd_mappollsterfdlsrs rrrs"gn-F{{}H!!"fmm42x(*,F299;'!#F2J  B%]]73 E6??*$%AB%FGG &*%4Irc8tj|gg|dSr)r)rrs rrrs==b"g6q9 9rc||dkr t|dSt|z} t||S#tttj f$r(}|j t jk7rYd}~nd}~wwxYw| tz }f)rNr)rr r\rr5rrr)rrdeadliners rrrs  !|[!,,$;0 ['22Wfll3 77ekk)* ""Y[0s /A5 A00A5c |j}tj|tjtj5}ddlm}|j|}t||j|jffcdddS#1swYyxYw)Nr)resource_sharer) rNr5fromfdr SOCK_STREAMr%r DupSocketrebuild_connectionrTrU)r}rSrKrdss rreduce_connectionrs` ]]66>>63E3E F! ) **1-B%DMM4=='IIG F Fs 6BB cN|j}tt|||Sr)rr)rrTrUrBs rrrs yy{&,(;;rc|jrtjnd|jrtjndz}t j |j|}t||j|jffSr) rTrFILE_GENERIC_READrUFILE_GENERIC_WRITEr DupHandlerNrebuild_pipe_connection)r}r3dhs rreduce_pipe_connectionrs^04 7,,1157--AG   7&T]]DMM(JJJrc.tt|||Sr)rr)rrTrUs rrrsfRj(H==rctj|j}t||j|j ffSr)rDupFdrNrrTrU)r}dfs rrr s0 __T[[] +!B t}}#EEErc.tt|||Sr)rr)rrTrUs rrrs&*h99r)NN)TFFr)Orrr)r2r5rrr& itertoolsr%rrrr_extrcompatr r timer r rr3rrrr ImportError__all__r4is_pypyr$CONNECTION_TIMEOUTcountr,rfamiliesrr r0r6r=r?rJrrrrrrrrrERROR_SEM_TIMEOUTERROR_PIPE_BUSYr rkrlrorprrrwrrrrrrERROR_NETNAME_DELETEDrrrrrrrrrHrrrs 1,% $  ||w-- "33++ ## 0 #* +  !  ; 69N  H<<7N  H-! 0 F F( _-_-D VVrOOl55p *"<<7.(^//d!<<76,6,p&-%>%>%,%<%<%>!>    ? >"&  >(>L<<7(..0M0MNMC>Nvv $ :10<<7J<Iz#45K >I~'=>F:Iz#45c ||w GsII65I6