SfddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl m Z m Z ddlmZddlmZmZddlmZdd l mZ dd lmZejd krejZejZejZejZn#e$rejd krdZYnwxYwgd Zeed ZdZ dZ!ej"Z#dZ$dgZ%eedrdZ$e%dgz Z%ejd krdZ$e%dgz Z%e!fdZ&dZ'dZ(dZ)dZ*GddZ+GddZ,erGdde,Z-Gdde,Z.Gd d!Z/dGd"Z0d#Z1ejd krdHd&Z2ndHd'Z2Gd(d)Z3d*Z4ejd krGd+d,Z5ej6ej7ffd-Z8d.Z9d/Z:d0Z;d1ZGd4d5Z?d6Z@d7ZAGd8d9e/ZBd:ZCejd krd;ZDejEejFhZGdId<ZHneed=rd>ZInd?ZIdId@ZHejd kr0dAZJdBZKe jLe.eJdCZMdDZNe jLe-eMdSdEZJdFZKe jLe.eJdS)JN) reduction)util)AuthenticationErrorBufferTooShort) _billiard) setblocking send_offset monotonic)ForkingPickler)_winapiwin32)ClientListenerPipewaitpypy_version_infoi g4@AF_INETAF_UNIXAF_PIPEc$t|zSNr )timeouts E/var/www/html/env/lib/python3.11/site-packages/billiard/connection.py _init_timeoutrEs ;;  c&t|kSrr )ts r_check_timeoutr Is ;;?rc|dkrdS|dkr'tjdtjS|dkr>tjdt jt 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_addressr0Qs 9  kt7H7J7JKKKK 9  &< " T--@-@A'BGIKKK K.///rctjdkr|dkrtd|ztjdkr-|dkr)tt|std|zdSdSdS)zD Checks if the family is valid for the current environment. rrzFamily %s is not recognized.rN)sysplatformr-hasattrsocketr.s r_validate_familyr6`s |w6Y#6#67&@AAA |w6Y#6#6vv&& F;fDEE E#6#6 F Frct|tkrdSt|tur|drdSt|turdSt 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=msm  G}}y g#  '"4"4V"<"< y g#  y:WDEEErceZdZdZdS)_SocketContainerc||_dSrsock)selfrBs r__init__z_SocketContainer.__init__s  rN)__name__ __module__ __qualname__rDrrr?r?s#rr?ceZdZdZddZdZdZdZdZdZ e d Z e d Z e d Z d Zd ZddZdZddZddZdZddZdZdZdZdZdS)_ConnectionBaseNTct|tr%|j|_|j}|}|dkrt d|s|st d||_||_||_ dS)Nrzinvalid handlez6at least one of `readable` and `writable` must be True) isinstancer?rB_socketfileno __index__r-_handle _readable _writable)rChandlereadablewritables rrDz_ConnectionBase.__init__s f. / / *!;DL[''))F!!## A::-.. . J JHJJ J !!rc@|j|dSdSrrP_closerCs r__del__z_ConnectionBase.__del__s# < # KKMMMMM $ #rc2|jtddS)Nzhandle is closed)rPOSErrorrYs r _check_closedz_ConnectionBase._check_closeds! < ,-- - rc2|jstddS)Nzconnection is write-only)rQr\rYs r_check_readablez_ConnectionBase._check_readables%~ 6455 5 6 6rc2|jstddS)Nzconnection is read-only)rRr\rYs r_check_writablez_ConnectionBase._check_writables%~ 5344 4 5 5rcf|jrd|_n|td)NFzbad message length)rRrQcloser\rYs r_bad_message_lengthz#_ConnectionBase._bad_message_lengths1 > "DNN JJLLL*+++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.writablerirc8||jS)z+File descriptor or handle of the connection)r]rPrYs rrNz_ConnectionBase.filenos |rch|j* |d|_dS#d|_wxYwdS)zClose the connectionNrWrYs rrcz_ConnectionBase.closesB < # $ # t #### $ #s& /rc||t|}|jdkrtt |}t |}|dkrt d||krt d|||z }n-|dkrt d||z|krt d|||||zdS)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   sOO :>>588$$A FF A::122 2 v::566 6 <v:DD AXX/00 0 d]Q  <== = 6&4-/011111rc|||tj|dS)zSend a (picklable) objectN)r]rarrr dumpsrCobjs rsendz_ConnectionBase.sendsK   -c2233333rc||||dkrtd||}|||S)z7 Receive bytes data as a bytes object. Nrznegative maxlength)r]r_r- _recv_bytesrdgetvalue)rC maxlengthrss r recv_bytesz_ConnectionBase.recv_bytess}    Y]]122 2y)) ;  $ $ & & &||~~rcH||t|5}|j}|t |z}|dkrt d||krt d|}|}|||zkr!t| | d| |||z||z|z|cdddS#1swxYwYdS)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_intosj   __ zH#a&&(Hzz !2333("" !3444%%''F;;==D&4-''$V__%6%6777 KKNNN OOA("FTMh#>>   #                  sCDDDc|||}tj|S)zReceive a (picklable) object)r]r_rr loadbuf)rCrss rrecvz_ConnectionBase.recvsH    %c***rc|||||S)z/Whether there is any input available to be read)r]r__pollrCrs rpollz_ConnectionBase.polls8  zz'"""rc|SrrHrYs r __enter__z_ConnectionBase.__enter__ rc.|dSrrcrCexc_type exc_valueexc_tbs r__exit__z_ConnectionBase.__exit__ rcHt|||Sr)r rN)rCrsrts rr z_ConnectionBase.send_offset"s4;;==#v666rcJt||dSr)r rN)rCblockings rr z_ConnectionBase.setblocking%s DKKMM8,,,,,r)TT)rNr)r)r)rErFrGrPrDrZr]r_rardpropertyrgrTrUrNrcrxr}rrrrrrr r rHrrrJrJsG " " " " ...666555,,,$$X$XX $$$2222*444    4+++#### 777-----rrJcDeZdZdZdZejfdZdZd dZ dZ dZ dS) 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&||jdSrrf)rC _CloseHandles rrXzPipeConnection._close3s L & & & & &rctj|j|d\}} |tjkr.tj|jgdt }|tksJn#|xYw| d\}}n#| d\}}wxYw|dksJ|t|ksJdS)NT overlappedFr) r WriteFilerPERROR_IO_PENDINGWaitForMultipleObjectseventINFINITE WAIT_OBJECT_0cancelGetOverlappedResultrq)rCrsoverrwaitresnwrittens rrrzPipeConnection._send_bytes6s' cdKKKGB ='222%< E855G#m3333   " 6 6t < < ## 6 6t < < #<<<<!8888s3xx''''''s>A B A77BB-Nc|jrd|_tjS|dnt|d} t j|j|d\}} |tjkr.t j|j gdt}|tksJn#| xYw| d\}}|dkr>>&  @BB BsgF?>BD1B--D10AF? %F?0F?1AF;F?(F;8F?:F;;F?? G+ G&&G+c|js#tj|jddkrdSt t |g|S)NrT)rr PeekNamedPiperPboolrrs rrzPipeConnection._pollhsI' )$,77:a??tdVW--.. .rc|}tj}||t j|jd}|dksJ|*t||z|kr|t j |j|d\}}| d\}}|dksJ||ksJ|||S)NrrTr) rrrrrrrPrqrdrr)rCrrrsrleftrrbytess rrzPipeConnection._get_more_datans,,..C A GGCLLL(66q9D!8888"s3xx$'@'@((***&t|TdKKKGB0066KFC!8888T>>>> GGBLLNN # # #Hrr) rErFrG__doc__rr CloseHandlerXrrrrrrHrrrr+s  #&-&9 ' ' ' ' ( ( ( B B B BD / / /     rrceZdZdZerejfdZejZ ej Z ne j fdZe jZ e jZ e fdZe fdZefdZd dZd ZdS) Connectionzo Connection class based on an arbitrary file descriptor (Unix only), or a socket handle (Windows). c&||jdSrrfrCrXs rrXzConnection._close F4< rc&||jdSrrfrs rrXzConnection._closerrc t|} ||j|}||z}|dkrdS||d}nI#tttjf$r*}t |ddtjkrYd}~nd}~wwxYwt)NTrerrno) rqrPr\IOErrorr5errorgetattrrEINTR)rCrsr remainingrwexcs r_sendzConnection._sendsHH   E$,,, Q >>E!""gWfl3   3..%+==>====  s;B A<<Bctj}|j}|}|dkr |||}t|}|dkr||krtt d||||z}nI#t ttj f$r*}t|ddtj krYd}~nd}~wwxYw|dk|S)Nrzgot end of file during messager) rrrPrqrr\rrr5rrrr) rCrureadrsrSrchunkrwrs r_recvzConnection._recvsjll !mm VY// JJ66 D((&%&FGGG %   Q Wfl3   3..%+==>==== !mm s A<<C B==Cc*t|}tjd|}|dkr,||||dSt ||r|}|||zdS)N!ii@)rqstructpackrrLtobytes)rCrsrnrwheaders rrrzConnection._send_bytess HHT1%% u99 JJv    JJsOOOOO #z** $kkmm JJv| $ $ $ $ $rNc|d}tjd|\}|||krdS||S)Nr)rrunpackr)rCrrsrus rrzConnection._recv_bytessQjjmm dCLLNN33  4'>>4zz$rcBt|g|}t|Sr)rr)rCrrs rrzConnection._polls $ ! !Awwrr)rErFrGrrr closesocketrXr}_writer_readr)rcrrrrrnrrrrrHrrrr~s   ) 5 ! ! ! ! " ! ! ! !%     %*+5%%%%$    rrcbeZdZdZd dZdZdZedZedZ d Z d Z dS) rz Returns a listener object. This is a wrapper for a bound socket which is 'listening' for connections, or for a Windows named pipe. Nrc8|p|ot|pt}|pt|}t||dkrt |||_nt ||||_|$t|tstd||_ dS)Nrauthkey should be a byte string) r=default_familyr0r6 PipeListener _listenerSocketListenerrLrp TypeError_authkey)rCr<r/backlogauthkeys rrDzListener.__init__sH4|G44H9G 6.v66   Y  )'7;;DNN+GVWEEDN  z'5'A'A =>> > rc|jtd|j}|jr*t ||jt ||j|S)zz Accept a connection on the bound socket or named pipe of `self`. Returns a `Connection` object. Nzlistener is closed)rr\acceptrdeliver_challengeanswer_challenge)rCcs rrzListener.acceptsa > !.// / N ! ! # # = / a / / / Q . . .rcR|j}|d|_|dSdS)zA Close the bound socket or named pipe of `self`. N)rrc)rClisteners rrczListener.closes6>  !DN NN      rc|jjSr)r_addressrYs rzListener.s DN$;rc|jjSr)r_last_acceptedrYs rrzListener.s $.*Grc|SrrHrYs rrzListener.__enter__rrc.|dSrrrs rrzListener.__exit__rr)NNrN) rErFrGrrDrrcrr< last_acceptedrrrHrrrrs       h;;<)>&4&  Wfl3   3..%+==>====   d&))$$$s!%A+ A&&A+c |j|j}|d|_|dSdS#|j}|d|_|wwxYwr)rMrcrH)rCrGs rrczSocketListener.closesr  L   \F!# "!\F!# "s 9AN)r)rErFrGrrDrrcrHrrrrqsP    0 % % %rrct|}tjtt|}|d||t t |S)zO Return a connection object connected to the socket given by `address` T)r=r5rr connectrr)r<r/rJs rr r sb' " "F gff--..AMM$IIg fQii  rc>eZdZdZddZd dZdZedZdS) rz0 Representation of a named pipe Nc||_|dg|_d|_t jd|jt j|tj|j|jfd|_ dS)NT)firstz listener created with address=%rrr;) r _new_handle _handle_queuerr sub_debugrFr_finalize_pipe_listenerrc)rCr<rs rrDzPipeListener.__init__su#DM"&"2"2"2">">!?D "&D  N=t} M M Ml:($-8qDJJJrFc .tjtjz}|r|tjz}tj|j|tjtjztjztj tttj tj Sr) rr r&r'r%rr(r)r*PIPE_UNLIMITED_INSTANCESr#r+r,)rCrPflagss rrQzPipeListener._new_handlesp.1MME ?>>* u)G,II!"0'7,gl  rcd|j||jd} t j|d} t j|jgdtn.#| t j |xYw | d\}}|dksJnR#| d\}}|dksJwxYw#t$r }|j tjkrYd}~nd}~wwxYwt|S)NrTrF)rRappendrQpoprr0rrrrrrr\r ERROR_NO_DATAr)rCrSrr7rrs rrzPipeListener.acceptsZ   % %d&6&6&8&8 9 9 9'++A..F $-fFFF $2 E85555IIKKK'/// 5 33D99FAs!88888 33D99FAs!88888888   :!66676666  "&)) )s6C6!BC+B,,C"C36 D DD cbtjd||D]}tj|dS)Nz closing listener with address=%r)rrSrr)queuer<rSs rrTz$PipeListener._finalize_pipe_listenersB N=w G G G , ,#F++++ , ,rr)F) rErFrGrrDrQr staticmethodrTrHrrrrsp           * * *.  , ,  , , ,rrc t} tj|dtj|tjtjzdtjtjtjtj}n1#t$r#}|j |vst|rYd}~nd}~wwxYwtj |tj ddt|S)zU Return a connection object connected to the pipe given by `address` rrN)rr WaitNamedPiper-r!r"r,r.r&r\rr r/r)r)r<_ignorerhrs rr r s OO  %gt444&W1G4IIw|W%:0',    :W,,q0A0A,-,,,,   ' w,dD   a   sA.B B- B((B-s #CHALLENGE#s #WELCOME#s #FAILURE#cddl}t|tsJtjt }|t|z|||d }| d}||kr|tdS|ttd)Nrmd5zdigest received was wrong)hmacrLrpr)urandomMESSAGE_LENGTHrx CHALLENGEnewdigestrWELCOMEFAILUREr connectionrrhmessagermresponses rrrsKKK gu % %%% %j((G)g-... XXgw . . 5 5 7 7F$$S))H6g&&&&&g&&&!"=>>>rcddl}t|tsJ|d}|dt t t ks Jd|z|t t d}|||d}|||d}|tkrtddS)Nrrgz message = %rrfzdigest sent was rejected) rhrLrprrqrkrlrmrxrnrrps rrrsKKK gu % %%% %##C((G ?C NN? #y 0 0 0.72J 0 0 0c)nnoo&G XXgw . . 5 5 7 7F&!!!$$S))H7!"<===rc eZdZdZdZdZdS)ConnectionWrapperc|||_||_||_dD]#}t||}t |||$dS)N)rNrcrrrx)_conn_dumps_loadsrsetattr)rCconnrzloadsattrr|s rrDzConnectionWrapper.__init__2sT   K % %D$%%C D$ $ $ $ $ % %rcd||}|j|dSr)ryrxrx)rCr|rJs rr}zConnectionWrapper.send:s/ KK   a     rc^|j}||Sr)rxrrz)rCrJs rrzConnectionWrapper.recv>s% J ! ! # #{{1~~rN)rErFrGrDr}rrHrrrvrv0sA%%%!!!rrvcjt|fdddd}|dS)Nrutf-8) xmlrpclibrzencode)r|os r _xml_dumpsrCs/tT155A 88G  rcjt|d\\}}|S)Nr)rr}decode)rJr|methods r _xml_loadsrHs*__QXXg%6%677NFSF JrceZdZdZdS) XmlListenercxddlmat|}t |t tSNr) xmlrpc.clientclientrrrrvrrr{s rrzXmlListener.acceptOs7))))))ood## j*===rN)rErFrGrrHrrrrMs#>>>>>rrcXddlmatt |i|t t Sr)rrrrvrrr)r<kwdss r XmlClientrVs3%%%%%% VT2T22J K KKrct|}g}|rtj|d|}|tkrnt|cxkrtt |zkrnn |tz}nDt |cxkrt t |zkrnn |t z}ntd|||||dzd}d}||S)NFzShould not get hererr) listrr WAIT_TIMEOUTrrqWAIT_ABANDONED_0rrY)handlesrLreadyress r_exhaustive_waitras MM 0E7CCCl""#>>>> A(>>>>>>}$!SDDDD+;c!ff+DDDDDD''"#8999 LL3 #'(( AG  rc |t}n|dkrd}nt|dzdz}t|}i g}t t} |D]} t |d} t j|dd\}}n(#t$r}|j}|tvrYd}~nd}~wwxYw|t j kr | || |j < |d}#t$r| |<YwxYwt! |}|D]}||D]} |d\} }n(#t$r}|j}|tvrYd}~nd}~wwxYw|t jkr? |j } ||dkrt+|drd|_n#|D]}||D]} |d\} }n(#t$r}|j}|tvrYd}~nd}~wwxYw|t jkr? |j } ||dkrt+|drd|_wxYw  fd|D fd |DS) Wait till an object in object_list is ready/readable. Returns list of those objects in object_list which are ready/readable. Nrr`g?rNTrc3(K|] }|V dSrrH).0rcwaithandle_to_objs r zwait..s)IIa.q1IIIIIIrcg|]}|v| SrHrH)rp ready_objectss r zwait..s#===a!}*<*<*<*<*-C-C-E-EwOOM    8 833D99FAss*C-//0////'999)"(3A!%%a(((axx#1&:;;837A0 8     8 833D99FAss*C-//0////'999)"(3A!%%a(((axx#1&:;;837A0 8 IIII=IIIIII====;====sG< D1!BG< B8B3.G<3B88A G<!D'$G<&D''%G<*F F( F##F(<J-H43J-4 I >I J-I AJ-rc|t|dz}i}tj}|D]O}||tjt |dr|||<J|||<Pg}||D]A\}}|tjzrtd|z| ||B|S)Nr`rNzinvalid file descriptor %i) rselectrregisterPOLLINr4rNPOLLNVALr-rY)fdsrfd_mappollsterfdlsrs rrrs"gn--F{}}H $ $!!"fm4442x(($*,F299;;''!#F2JJB%]]733 & & E6?*H$%AB%FGGG &*%%%%Irc<tj|gg|dSr)r)rrs rrrs=b"g66q9 9rc|'|dkrt|dSt|z} t||S#tttjf$r }|jt jkrYd}~nd}~wwxYw||tz }d)rNr)rr r\rr5rrr)rrdeadliners rrrs  !||[!,,,$;;0 1 ['222Wfl3   7ek))*)))) ""Y[[0 1s<A8A33A8c|}tj|tjtj5}ddlm}||}t||j |j ffcdddS#1swxYwYdS)Nr)resource_sharer) rNr5fromfdr SOCK_STREAMr%r DupSocketrebuild_connectionrTrU)r|rSrJrdss rreduce_connectionrs ]66>63E F F J! ) ) ) ) ) ) **1--B%DM4='II J J J J J J J J J J J J J J J J J Js1A==BBcf|}tt|||Sr)rr)rrTrUrBs rrrs'yy{{&,,(;;;rc|jr tjnd|jr tjndz}t j||}t||j|jffSr) rTrFILE_GENERIC_READrUFILE_GENERIC_WRITEr DupHandlerNrebuild_pipe_connection)r|r2dhs rreduce_pipe_connectionrs^04 D7,,115E7--AG   7 7&T]DM(JJJrc>tt|||Sr)rr)rrTrUs rrrsfRjj(H===rcztj|}t||j|jffSr)rDupFdrNrrTrU)r|dfs rrrs/ _T[[]] + +!B t}#EEErc>tt|||Sr)rr)rrTrUs rrrs&**h999r)NN)TFFr)Orrr)r2r5rrr& itertoolsr%rrrr_extrcompatr r timer r rr3rrrr ImportError__all__r4is_pypyr#CONNECTION_TIMEOUTcountr,rfamiliesrr r0r6r=r?rJrrrrrrrr rERROR_SEM_TIMEOUTERROR_PIPE_BUSYr rjrkrnrorrrvrrrrrrERROR_NETNAME_DELETEDrrrrrrrrrHrrrsF 11111111,,,,,,,,%%%%%% $  |w- "3+ # |w GGG 1 0 0 '#* + +  !!  ; 769N  H<7N  H-!!!! 0 0 0 F F F F F F( _-_-_-_-_-_-_-_-D RPPPPPPPPfOOOOOOOOl55555555p    *"""<7.((((^////////d!!!<76,6,6,6,6,6,6,6,p&-%>%,%<%>!!!!>    ? ? ? > > >"&  >>>>>(>>>LLL<7(.0MNMC>C>C>C>C>Nwvv:    $ : : :11110<7JJJ<<<Iz#4555KKK >>>I~'=>>>>>FFF:::Iz#455555sBBB