a xd@sxddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl m Z ddl mZmZddlmZddlmZmZdd lmZdd l mZzdd lmZWn"eyejd krڂdZYn&0ejd krejZejZejZejZgd Ze edZ!dZ"dZ#e $Z%dZ&dgZ'e edrNdZ&e'dg7Z'ejd krhdZ&e'dg7Z'e#fddZ(ddZ)ddZ*ddZ+ddZ,Gddde-Z.Gd d!d!e-Z/erGd"d#d#e/Z0Gd$d%d%e/Z1Gd&d'd'e-Z2d^d(d)Z3d*d+Z4ejd krd_d.d/Z5n d`d0d/Z5Gd1d2d2e-Z6d3d4Z7ejd krfGd5d6d6e-Z8ej9ej:ffd7d8Z;d9ZdZ@d?d@ZAGdAdBdBe-ZBdCdDZCdEdFZDGdGdHdHe2ZEdIdJZFejd krdKdLZGejHejIhZJdadMdNZKn(e edOrdPdQZLndRdQZLdbdSdNZKejd krXdTdUZMdVdWZNe Oe1eMdXdYZPdZd[ZQe Oe0ePnd\dUZMd]dWZNe Oe1eMdS)c)absolute_importN) reduction)util)AuthenticationErrorBufferTooShort) _billiard) setblocking send_offset monotonic)ForkingPickler)_winapiwin32)ClientListenerPipewaitpypy_version_infoi g4@AF_INETAF_UNIXAF_PIPEcCs t|SNr )timeoutrK/var/www/html/Ranjet/env/lib/python3.9/site-packages/billiard/connection.py _init_timeoutHsrcCs t|kSrr )trrr_check_timeoutLsrcCsX|dkr dS|dkr&tjdtdS|dkrLtjdtttfddStd d S) z? Return an arbitrary free address for the given family r) localhostrrz listener-)prefixdirrz\\.\pipe\pyc-%d-%d-zunrecognized familyN) tempfilemktemprZ get_temp_dirosgetpidnext _mmap_counter ValueErrorfamilyrrrarbitrary_addressTsr,cCsJtjdkr|dkrtd|tjdkrF|dkrFtt|sFtd|dS)zD Checks if the family is valid for the current environment. rrzFamily %s is not recognized.rN)sysplatformr)hasattrsocketr*rrr_validate_familycs   r1cCsJt|tkrdSt|tur*|dr*dSt|tur:dStd|dS)z] Return the types of the address This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE' rz\\rrzaddress type of %r unrecognizedN)typetuplestr startswithr))addressrrr address_typeps  r7c@seZdZddZdS)_SocketContainercCs ||_dSrsock)selfr:rrr__init__sz_SocketContainer.__init__N)__name__ __module__ __qualname__r<rrrrr8sr8c@seZdZdZd/ddZddZddZd d Zd d Zd dZ e ddZ e ddZ e ddZ ddZddZd0ddZddZd1ddZd2d d!Zd"d#Zd3d%d&Zd'd(Zd)d*Zd+d,Zd-d.ZdS)4_ConnectionBaseNTcCsZt|tr|j|_|j}|}|dkr4td|sD|sDtd||_||_||_ dS)Nrzinvalid handlez6at least one of `readable` and `writable` must be True) isinstancer8r:_socketfileno __index__r)_handle _readable _writable)r;handlereadablewritablerrrr<s  z_ConnectionBase.__init__cCs|jdur|dSrrE_closer;rrr__del__s z_ConnectionBase.__del__cCs|jdurtddS)Nzhandle is closed)rEOSErrorrMrrr _check_closeds z_ConnectionBase._check_closedcCs|jstddS)Nzconnection is write-only)rFrOrMrrr_check_readablesz_ConnectionBase._check_readablecCs|jstddS)Nzconnection is read-only)rGrOrMrrr_check_writablesz_ConnectionBase._check_writablecCs"|jrd|_n|tddS)NFzbad message length)rGrFcloserOrMrrr_bad_message_lengthsz#_ConnectionBase._bad_message_lengthcCs |jduS)z True if the connection is closedNrErMrrrclosedsz_ConnectionBase.closedcCs|jS)z"True if the connection is readable)rFrMrrrrIsz_ConnectionBase.readablecCs|jS)z"True if the connection is writable)rGrMrrrrJsz_ConnectionBase.writablecCs||jS)z+File descriptor or handle of the connection)rPrErMrrrrCsz_ConnectionBase.filenocCs*|jdur&z|Wd|_nd|_0dS)zClose the connectionNrKrMrrrrSs  z_ConnectionBase.closercCs||t|}|jdkr.tt|}t|}|dkrFtd||krVtd|durh||}n&|dkrztdn|||krtd|||||dS)z,Send the bytes data from a bytes-like objectrrzoffset is negativezbuffer length < offsetNzsize is negativezbuffer length < offset + size)rPrR memoryviewitemsizebyteslenr) _send_bytes)r;bufoffsetsizemnrrr send_bytess"     z_ConnectionBase.send_bytescCs$|||t|dS)zSend a (picklable) objectN)rPrRr[r dumpsr;objrrrsendsz_ConnectionBase.sendcCsJ|||dur(|dkr(td||}|durB||S)z7 Receive bytes data as a bytes object. Nrznegative maxlength)rPrQr) _recv_bytesrTgetvalue)r;Z maxlengthr\rrr recv_bytess z_ConnectionBase.recv_bytescCs||t|}|j}|t|}|dkr>tdn||krNtd|}|}|||krvt| | d| |||||||WdS1s0YdS)zq Receive bytes data into a writeable bytes-like object. Return the number of bytes read. rznegative offsetzoffset too largeN) rPrQrWrXrZr)rftellrrgseekreadinto)r;r\r]r_rXZbytesizeresultr^rrrrecv_bytes_intos$      z_ConnectionBase.recv_bytes_intocCs"|||}t|S)zReceive a (picklable) object)rPrQrfr Zloadbuf)r;r\rrrrecvsz_ConnectionBase.recvcCs||||S)z/Whether there is any input available to be read)rPrQ_pollr;rrrrpollsz_ConnectionBase.pollcCs|SrrrMrrr __enter__sz_ConnectionBase.__enter__cCs |dSrrSr;exc_type exc_valueexc_tbrrr__exit__"sz_ConnectionBase.__exit__cCst|||Sr)r rC)r;r\r]rrrr %sz_ConnectionBase.send_offsetcCst||dSr)r rC)r;blockingrrrr (sz_ConnectionBase.setblocking)TT)rN)N)r)ro)r=r>r?rEr<rNrPrQrRrTpropertyrVrIrJrCrSrarerhrmrnrrrsryr r rrrrr@s2       r@c@sDeZdZdZdZejfddZddZddd Z d d Z d d Z 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. FcCs||jdSrrU)r;Z _CloseHandlerrrrL6szPipeConnection._closec Cstj|j|dd\}}zVz,|tjkrBt|jgdt}|tksBJWn|Yn0W| d\}}n| d\}}0|dksJ|t |ksJdS)NT overlappedFr) rZ WriteFilerEERROR_IO_PENDINGWaitForMultipleObjectseventINFINITE WAIT_OBJECT_0cancelGetOverlappedResultrZ)r;r\overrwaitresZnwrittenrrrr[9s     zPipeConnection._send_bytesNc Cs|jrd|_tS|dur dnt|d}ztj|j|dd\}}zz,|tjkrpt|j gdt }|t kspJWn| Yn0W| d\}}|dkrt}|||WS|tjkr|||WSnh| d\}}|dkrt}|||YWS|tjkr>|||YWS0Wn<ty~}z"|jtjkrhtnWYd}~n d}~00tddS)NFTr}rz.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminrReadFilerErrrrrrrwrite getbufferZERROR_MORE_DATA_get_more_datarOwinerrorERROR_BROKEN_PIPEEOFError RuntimeError) r;maxsizeZbsizerrrZnreadferrrrfIsL        zPipeConnection._recv_bytescCs.|jst|jddkrdStt|g|S)NrT)rr PeekNamedPiperEboolrrqrrrrpks zPipeConnection._pollcCs|}t}||t|jd}|dks6J|durVt|||krV|tj |j|dd\}}| d\}}|dksJ||ksJ|||S)NrrTr}) rrrrrrrErZrTrr)r;rrr\rleftrZrbytesrrrrqs    zPipeConnection._get_more_data)N) r=r>r?__doc__rr CloseHandlerLr[rfrprrrrrr|.s "r|c@seZdZdZer,ejfddZejZ ej Z ne j fddZe jZ e jZ e fddZe fddZefd d Zdd d ZddZd S) Connectionzo Connection class based on an arbitrary file descriptor (Unix only), or a socket handle (Windows). cCs||jdSrrUr;rLrrrrLszConnection._closecCs||jdSrrUrrrrrLsc Cs~t|}z||j|}Wn@tttjfyX}z t|ddtjkrDWYd}~qd}~00||8}|dkrlqz||d}qdS)Nerrnor) rZrErOIOErrorr0errorgetattrrEINTR)r;r\r remainingr`excrrr_sendszConnection._sendc Cst}|j}|}|dkrz|||}Wn@tttjfyh}z t|ddtj krTWYd}~qd}~00t |}|dkr||krt ntd| |||8}q|S)Nrrzgot end of file during message) rrrErOrr0rrrrrZrr) r;r^readr\rHrchunkrr`rrr_recvs"  zConnection._recvcCsVt|}td|}|dkr2||||n t||rD|}|||dS)N!ii@)rZstructpackrrAtobytes)r;r\rWr`headerrrrr[s    zConnection._send_bytesNcCs:|d}td|\}|dur0||kr0dS||S)Nr)rrunpackrg)r;rr\r^rrrrfs  zConnection._recv_bytescCst|g|}t|Sr)rr)r;rrrrrrps zConnection._poll)N)r=r>r?rrrZ closesocketrLre_writern_readr%rSrrrrrWr[rfrprrrrrs    rc@sReZdZdZdddZddZdd Zed d Zed d Z d dZ ddZ 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. NrcCsp|p|rt|pt}|pt|}t||dkr>t|||_nt||||_|durft|tsft d||_ dS)Nrauthkey should be a byte string) r7default_familyr,r1 PipeListener _listenerSocketListenerrArY TypeError_authkey)r;r6r+backlogauthkeyrrrr<s  zListener.__init__cCs>|jdurtd|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)rrOacceptrdeliver_challengeanswer_challenge)r;crrrrs    zListener.acceptcCs |j}|durd|_|dS)zA Close the bound socket or named pipe of `self`. N)rrS)r;ZlistenerrrrrSszListener.closecCs|jjSr)r_addressrMrrrzListener.cCs|jjSr)r_last_acceptedrMrrrrrcCs|SrrrMrrrrsszListener.__enter__cCs |dSrrtrurrrry szListener.__exit__)NNrN) r=r>r?rr<rrSr{r6Z last_acceptedrsryrrrrrs   rcCsh|p t|}t||dkr&t|}nt|}|durHt|tsHtd|durdt||t|||S)z= Returns a connection to the address of a `Listener` rNr) r7r1 PipeClient SocketClientrArYrrr)r6r+rrrrrrs    rcCst|dr|St|S)Ndetach)r/rr8r9rrrr$s rTFc Cs|rBt\}}|| || tt|}tt|}n@t\}}|r\t|d|rjt|dt|dd}t|dd}||fS)L Returns pair of connection objects at either end of a pipe rFrJrI)r0 socketpairr rrr%pipe) duplex rnonblock wnonblocks1s2c1c2Zfd1fd2rrrr.s         rc Cs|r Jd|rJdtd}|rBtj}tjtjB}tt}}ntj}tj}dt}}t||tjBtj Btj tj Btj Bd||tj tj}t||dtjtjtjtj} t| tj ddtj|dd} | d\} } | dksJt||d } t| |d }| |fS) rz"rnonblock not supported on windowsz"wnonblock not supported on windowsrrrNTr}rr)r,rPIPE_ACCESS_DUPLEX GENERIC_READ GENERIC_WRITEBUFSIZEZPIPE_ACCESS_INBOUNDCreateNamedPipeFILE_FLAG_OVERLAPPEDFILE_FLAG_FIRST_PIPE_INSTANCEPIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITNMPWAIT_WAIT_FOREVERNULL CreateFile OPEN_EXISTINGSetNamedPipeHandleStateConnectNamedPiperr|)rrrr6ZopenmodeaccessZobsizeZibsizeh1h2r~_rrrrrrrEsB             c@s*eZdZdZd ddZddZddZd S) rzO Representation of a socket which is bound to an address and listening rcCsttt||_zRtjdkr2|jtjtjd|jd|j ||j ||j |_ Wnt y|jYn0||_d|_|dkrtj|tj|fdd|_nd|_dS)NposixrTrrargsZ exitpriority)r0rrBr%name setsockopt SOL_SOCKET SO_REUSEADDRr bindlisten getsocknamerrOrSZ_familyrrFinalizeunlink_unlink)r;r6r+rrrrr<xs(        zSocketListener.__init__c Cspz|j\}|_WqZtttjfyT}z t|ddtj kr@WYd}~qd}~00qZq| dt t |S)NrT) rBrrrOrr0rrrrr rr)r;srrrrrs zSocketListener.acceptcCsJz(|jW|j}|durFd|_|n|j}|durDd|_|0dSr)rBrSr)r;rrrrrSs zSocketListener.closeN)r)r=r>r?rr<rrSrrrrrts  rcCs8t|}ttt|}|d||tt|S)zO Return a connection object connected to the socket given by `address` T)r7r0rr connectrr)r6r+rrrrrs   rc@s8eZdZdZd ddZd ddZdd Zed d ZdS)rz0 Representation of a named pipe NcCsL||_|jddg|_d|_td|jtj|tj|j|jfdd|_ dS)NT)firstz listener created with address=%rrr) r _new_handle _handle_queuerr sub_debugrr_finalize_pipe_listenerrS)r;r6rrrrr<s zPipeListener.__init__Fc CsHtjtjB}|r|tjO}t|j|tjtjBtjBtj t t tj tj Sr) rrrrrrrrrZPIPE_UNLIMITED_INSTANCESrrr)r;rflagsrrrrs   zPipeListener._new_handlec Cs|j||jd}ztj|dd}Wn2ty`}z|jtjkrLWYd}~n~d}~00zVzt |j gdt Wn | t |Yn0W|d\}}|dksJn|d\}}|dksJ0t|S)NrTr}F)rappendrpoprrrOrZ ERROR_NO_DATArrrrrrr|)r;rHrrrrrrrrs(     zPipeListener.acceptcCs$td||D]}t|qdS)Nz closing listener with address=%r)rrrr)queuer6rHrrrrs z$PipeListener._finalize_pipe_listener)N)F) r=r>r?rr<rr staticmethodrrrrrrs  rc Cst}z6t|dt|tjtjBdtjtjtjtj}Wq|t yt}z |j |vs^t |r`WYd}~qd}~00q|qt |tj ddt|S)zU Return a connection object connected to the pipe given by `address` rN)rrZ WaitNamedPiperrrrrrrOrrrrr|)r6_ignorerhrrrrrs"    rs #CHALLENGE#s #WELCOME#s #FAILURE#cCstddl}t|tsJtt}|t||||d }| d}||kr^|t n|t t ddS)Nrmd5zdigest received was wrong)hmacrArYr%urandomMESSAGE_LENGTHra CHALLENGEnewdigestrhWELCOMEFAILUREr connectionrr messagerresponserrrrs    rcCsddl}t|tsJ|d}|dtttks@Jd||ttd}|||d}|||d}|t krt ddS)Nrrz message = %rrzdigest sent was rejected) r rArYrhrZr r rrarrrrrrr"s    rc@s$eZdZddZddZddZdS)ConnectionWrappercCs6||_||_||_dD]}t||}t|||qdS)N)rCrSrrrhra)_conn_dumps_loadsrsetattr)r;connrbloadsattrrdrrrr<5s  zConnectionWrapper.__init__cCs||}|j|dSr)rrra)r;rdrrrrre=s zConnectionWrapper.sendcCs|j}||Sr)rrhr)r;rrrrrnAs zConnectionWrapper.recvN)r=r>r?r<rernrrrrr3srcCst|fdddd}|dS)Nrutf-8) xmlrpclibrbencode)rdorrr _xml_dumpsFsr!cCst|d\\}}|S)Nr)rrdecode)rrdmethodrrr _xml_loadsKsr$c@seZdZddZdS) XmlListenercCs"ddlmat|}t|ttSNr) xmlrpc.clientclientrrrrr!r$rcrrrrRs  zXmlListener.acceptN)r=r>r?rrrrrr%Psr%cOs"ddlmatt|i|ttSr&)r'r(rrrr!r$)rkwdsrrr XmlClientYs r*cCst|}g}|rt|d|}|tkr*qn\t|krFtt|krTnn |t8}n2t|krptt|kr~nn |t8}ntd|||||dd}d}q |S)NFzShould not get hererr) listrr WAIT_TIMEOUTrrZWAIT_ABANDONED_0rr)ZhandlesrLreadyresrrr_exhaustive_waitds    r1c s|durt}n|dkrd}nt|dd}t|}ig}tt}zn|D]}zt|d}Wnty||<YqP0zt|dd\}}Wn4t y}z|j }|t vrWYd}~n d}~00|tj kr| |||j<qP|d}qPt|}W|D]}|q|D]}z|d\} }Wn8t yv}z|j }|t vrbWYd}~n d}~00|tjkr(|j}||dkr(t|dr(d|_q(n|D]}|q|D]}z|d\} }Wn8t y }z|j }|t vr WYd}~n d}~00|tjkr҈|j}||dkrt|drd|_q0fdd |Dfd d |DS) Wait till an object in object_list is ready/readable. Returns list of those objects in object_list which are ready/readable. Nrrg?rCTrc3s|]}|VqdSrr).0r)waithandle_to_objrr rzwait..csg|]}|vr|qSrr)r3p) ready_objectsrr rzwait..)rintr+setrAttributeErrorrDrrrOr _ready_errorsrrraddr1keysrrZERROR_OPERATION_ABORTEDr/rupdate) object_listrZov_listZ ready_handlesr rCrrrrr)r7r4rrzsx                     rrrcCs|durt|d}i}t}|D]2}||tjt|drN|||<q$|||<q$g}||D],\}}|tj@rtd|| ||qf|S)NrrCzinvalid file descriptor %i) r9selectrrregisterPOLLINr/rCPOLLNVALr)r)fdsrZfd_mapZpollsterfdZlsrrrrrps     rpcCst|gg|dSr&)rA)rErrrrrpsc Cs|dur$|dkrt|dSt|}z t||WStttjfyj}z|jtjkrVWYd}~n d}~00|dur$|t}q$dS)r2Nr)rpr rOrr0rrr)r@rdeadlinerrrrrs    cCsf|}t|tjtj8}ddlm}||}t||j |j ffWdS1sX0YdS)Nr)resource_sharer) rCr0fromfdr SOCK_STREAMr"rHZ DupSocketrebuild_connectionrIrJ)rrHrrHdsrrrreduce_connections   rMcCs|}tt|||Sr)rr)rLrIrJr:rrrrKsrKcCsB|jr tjnd|jrtjndB}t||}t||j|jffSr&) rIrZFILE_GENERIC_READrJZFILE_GENERIC_WRITErZ DupHandlerCrebuild_pipe_connection)rrdhrrrreduce_pipe_connections rPcCstt|||Sr)r|r)rOrIrJrrrrNsrNcCs t|}t||j|jffSr)rZDupFdrCrKrIrJ)rdfrrrrMscCstt|||Sr)rr)rQrIrJrrrrK s)NN)TFF)TFF)N)N)R __future__rrrr%r-r0rArr# itertoolsr"rrrrZ_extrcompatr r Zfiver r r ImportErrorr.rr-r,r__all__r/Zis_pypyrZCONNECTION_TIMEOUTcountr(rZfamiliesrrr,r1r7objectr8r@r|rrrrrrrrZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrr r rrrrrr!r$r%r*r1rZERROR_NETNAME_DELETEDr<rrprMrKrBrPrNrrrr s                 #SV8    /2 8     G