a |c}@sgdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z m Z ddlmZejZz$ddlZddlmZmZmZmZWn"eyejdkrdZYn0d Zd ZeZd Zd gZeed rd Zed g7Zejdkrd Zed g7ZefddZ ddZ!ddZ"ddZ#ddZ$GdddZ%erbGddde%Z&Gddde%Z'Gddde(Z)dPd d!Z*ejdkrdQd#d$Z+n dRd%d$Z+Gd&d'd'e(Z,d(d)Z-ejdkrGd*d+d+e(Z.d,d-Z/d.Z0d/Z1d0Z2d1Z3d2d3Z4d4d5Z5Gd6d7d7e(Z6d8d9Z7d:d;Z8Gdd?Z:ejdkrnd@dAZ;ejdSdBdCZ?n,ddl@Z@ee@dDre@jAZBne@jCZBdTdEdCZ?ejdkrdFdGZDdHdIZEeFe'eDdJdKZGdLdMZHeFe&eGndNdGZDdOdIZEeFe'eDdS)U)ClientListenerPipewaitN)util)AuthenticationErrorBufferTooShort) reduction) WAIT_OBJECT_0WAIT_ABANDONED_0 WAIT_TIMEOUTINFINITEwin32i g4@AF_INETAF_UNIXAF_PIPEcCs t|SNtime monotonic)timeoutr+lib/python3.9/multiprocessing/connection.py _init_timeout;srcCs t|kSrr)trrr_check_timeout>srcCsv|dkr dS|dkrDtjr2dtdttStjdtdS|dkrjtjd tttfd dSt d d S) z? Return an arbitrary free address for the given family r)Z localhostrrz listener--z listener-)prefixdirrz\\.\pipe\pyc-%d-%d-zunrecognized familyN) rZabstract_sockets_supportedosgetpidnext _mmap_countertempfileZmktempZ get_temp_dir ValueErrorfamilyrrrarbitrary_addressEsr)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_familyXs   r.cCsTt|tkrdSt|tur*|dr*dSt|tus@t|rDdStd|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 startswithris_abstract_socket_namespacer&)addressrrr address_typeds r5c@seZdZdZd+ddZddZddZd d Zd d Zd dZ e ddZ e ddZ e ddZ ddZddZd,ddZddZd-ddZd.d d!Zd"d#Zd/d%d&Zd'd(Zd)d*ZdS)0_ConnectionBaseNTcCs>|}|dkrtd|s(|s(td||_||_||_dS)Nrzinvalid handlez6at least one of `readable` and `writable` must be True) __index__r&_handle _readable _writable)selfhandlereadablewritablerrr__init__zsz_ConnectionBase.__init__cCs|jdur|dSrr8_closer;rrr__del__s z_ConnectionBase.__del__cCs|jdurtddS)Nzhandle is closed)r8OSErrorrBrrr _check_closeds z_ConnectionBase._check_closedcCs|jstddS)Nzconnection is write-only)r9rDrBrrr_check_readablesz_ConnectionBase._check_readablecCs|jstddS)Nzconnection is read-only)r:rDrBrrr_check_writablesz_ConnectionBase._check_writablecCs"|jrd|_n|tddS)NFzbad message length)r:r9closerDrBrrr_bad_message_lengthsz#_ConnectionBase._bad_message_lengthcCs |jduS)z True if the connection is closedNr8rBrrrclosedsz_ConnectionBase.closedcCs|jS)z"True if the connection is readable)r9rBrrrr=sz_ConnectionBase.readablecCs|jS)z"True if the connection is writable)r:rBrrrr>sz_ConnectionBase.writablecCs||jS)z+File descriptor or handle of the connection)rEr8rBrrrfilenosz_ConnectionBase.filenocCs*|jdur&z|Wd|_nd|_0dS)zClose the connectionNr@rBrrrrHs  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)rErG memoryviewitemsizebyteslenr& _send_bytes)r;bufoffsetsizemnrrr send_bytess"     z_ConnectionBase.send_bytescCs$|||t|dS)zSend a (picklable) objectN)rErGrQ_ForkingPicklerdumpsr;objrrrsendsz_ConnectionBase.sendcCsJ|||dur(|dkr(td||}|durB||S)z7 Receive bytes data as a bytes object. Nrznegative maxlength)rErFr& _recv_bytesrIgetvalue)r;Z maxlengthrRrrr 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) rErFrMrNrPr&r]tellr r^seekreadinto)r;rRrSrUrNZbytesizeresultrTrrrrecv_bytes_intos$        z_ConnectionBase.recv_bytes_intocCs&|||}t|S)zReceive a (picklable) object)rErFr]rXloads getbuffer)r;rRrrrrecvsz_ConnectionBase.recvcCs||||S)z/Whether there is any input available to be read)rErF_pollr;rrrrpollsz_ConnectionBase.pollcCs|SrrrBrrr __enter__sz_ConnectionBase.__enter__cCs |dSrrHr;exc_type exc_valueZexc_tbrrr__exit__ sz_ConnectionBase.__exit__)TT)rN)N)r)rh)__name__ __module__ __qualname__r8r?rCrErFrGrIpropertyrKr=r>rLrHrWr\r_rdrgrkrlrqrrrrr6ws.       r6c@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||jdSrrJ)r;Z _CloseHandlerrrrAszPipeConnection._closec Cstj|j|dd\}}zVz,|tjkrBt|jgdt}|tksBJWn|Yn0W| d\}}n| d\}}0|dksJ|t |ksJdS)NT overlappedFr) _winapiZ WriteFiler8ERROR_IO_PENDINGWaitForMultipleObjectseventrr cancelGetOverlappedResultrP)r;rRoverrwaitresZnwrittenrrrrQs     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)NFTrwrz.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminryReadFiler8rzr{r|rr r}r~writerfZERROR_MORE_DATA_get_more_datarDwinerrorERROR_BROKEN_PIPEEOFError RuntimeError) r;maxsizeZbsizerrrZnreadferrrr]+sH         zPipeConnection._recv_bytescCs.|jst|jddkrdStt|g|S)NrT)rry PeekNamedPiper8boolrrjrrrriKs zPipeConnection._pollcCs|}t}||t|jd}|dks6J|durVt|||krV|tj |j|dd\}}| d\}}|dksJ||ksJ|||S)NrrTrw) rfrrrryrr8rPrIrr~)r;rrrRrleftrZrbytesrrrrQs    zPipeConnection._get_more_data)N) rrrsrt__doc__rry CloseHandlerArQr]rirrrrrrvs rvc@s|eZdZdZer,ejfddZejZ ej Z ne j fddZe jZ e jZ e fddZe fddZd d Zdd d ZddZd S) Connectionzo Connection class based on an arbitrary file descriptor (Unix only), or a socket handle (Windows). cCs||jdSrrJr;rArrrrAhszConnection._closecCs||jdSrrJrrrrrAmscCs8t|}||j|}||8}|dkr&q4||d}qdSNr)rPr8)r;rRr remainingrVrrr_sendrs  zConnection._sendcCsbt}|j}|}|dkr^|||}t|}|dkrJ||krBtntd||||8}q|S)Nrzgot end of file during message)rrr8rPrrDr)r;rTreadrRr<rchunkrVrrr_recv{s   zConnection._recvcCst|}|dkrHtdd}td|}||||||n8td|}|dkrr||||n|||dS)Ni!i!Qi@)rPstructZpackr)r;rRrVZ pre_headerheaderrrrrQs        zConnection._send_bytesNcCs^|d}td|\}|dkr@|d}td|\}|durT||krTdS||S)Nrrr)rrZunpackr^)r;rrRrTrrrr]s  zConnection._recv_bytescCst|g|}t|Sr)rr)r;rrrrrris zConnection._poll)N)rrrsrtrry_multiprocessingZ closesocketrAr\Z_writergZ_readr!rHrrrrrQr]rirrrrras  rc@sReZdZdZdddZddZdd Zed d Zed d Z ddZ 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) r5default_familyr)r. PipeListener _listenerSocketListener isinstancerO TypeError_authkey)r;r4r(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)rrDacceptrdeliver_challengeanswer_challenge)r;crrrrs    zListener.acceptcCs |j}|durd|_|dS)zA Close the bound socket or named pipe of `self`. N)rrH)r;ZlistenerrrrrHszListener.closecCs|jjSr)r_addressrBrrrr4szListener.addresscCs|jjSr)r_last_acceptedrBrrr last_acceptedszListener.last_acceptedcCs|SrrrBrrrrlszListener.__enter__cCs |dSrrmrnrrrrqszListener.__exit__)NNrN) rrrsrtrr?rrHrur4rrlrqrrrrrs    rcCsh|p t|}t||dkr&t|}nt|}|durHt|tsHtd|durdt||t|||S)z= Returns a connection to the address of a `Listener` rNr) r5r. PipeClient SocketClientrrOrrr)r4r(rrrrrrs    rTcCsj|r>t\}}|d|dt|}t|}n$t\}}t|dd}t|dd}||fS)L Returns pair of connection objects at either end of a pipe TFr>r=)r-Z socketpair setblockingrdetachr!pipe)duplexs1s2c1c2Zfd1Zfd2rrrr s       rc Cstd}|r*tj}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) rrrrNTrwrr)r)ryPIPE_ACCESS_DUPLEX GENERIC_READ GENERIC_WRITEBUFSIZEZPIPE_ACCESS_INBOUNDCreateNamedPipeFILE_FLAG_OVERLAPPEDFILE_FLAG_FIRST_PIPE_INSTANCEPIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITNMPWAIT_WAIT_FOREVERNULL CreateFile OPEN_EXISTINGSetNamedPipeHandleStateConnectNamedPiper~rv) rr4ZopenmodeaccessZobsizeZibsizeZh1Zh2rx_rrrrrrrs>           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|_|dkrt|stj|tj|fdd|_nd|_dS)NposixrTrrargsZ exitpriority)r-getattr_socketr!nameZ setsockoptZ SOL_SOCKETZ SO_REUSEADDRrZbindZlistenZ getsocknamerrDrHZ_familyrrr3Finalizeunlink_unlink)r;r4r(rrrrr?Ls(        zSocketListener.__init__cCs&|j\}|_|dt|S)NT)rrrrrrr;srrrres zSocketListener.acceptcCsJz(|jW|j}|durFd|_|n|j}|durDd|_|0dSr)rrHr)r;rrrrrHjs zSocketListener.closeN)r)rrrsrtrr?rrHrrrrrHs rcCs\t|}ttt|0}|d||t|WdS1sN0YdS)zO Return a connection object connected to the socket given by `address` TN)r5r-rrZconnectrr)r4r(rrrrrts   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_listenerrH)r;r4rrrrr?s zPipeListener.__init__Fc CsHtjtjB}|r|tjO}t|j|tjtjBtjBtj t t tj tj Sr) ryrrrrrrrrZPIPE_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)NrTrwF)rappendrpopryrrDrZ ERROR_NO_DATAr{r|rr}rr~rv)r;r<rrresrrrrrrs(     zPipeListener.acceptcCs$td||D]}t|qdS)Nz closing listener with address=%r)rrryr)Zqueuer4r<rrrrs z$PipeListener._finalize_pipe_listener)N)F) rrrsrtrr?rr staticmethodrrrrrrs  rc Cst}z6t|dt|tjtjBdtjtjtjtj}Wqt y|}z(|j tj tj fvsft |rhWYd}~qd}~00qqt|tjddt|S)zU Return a connection object connected to the pipe given by `address` rN)rryZ WaitNamedPiperrrrrrrDrZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrrrrv)r4rhrrrrrs*    rs #CHALLENGE#s #WELCOME#s #FAILURE#cCsddl}t|ts$tdt|tt}| t || ||d }| d}||krl| tn| ttddS)Nr Authkey must be bytes, not {0!s}md5zdigest received was wrong)hmacrrOr&formatr/r!urandomMESSAGE_LENGTHrW CHALLENGEnewdigestr_WELCOMEFAILURErZ connectionrrmessagerZresponserrrrs      rcCsddl}t|ts$tdt||d}|dtttksNJd||ttd}| ||d }| ||d}|t krt ddS)Nrrrz message = %rrzdigest sent was rejected)rrrOr&rr/r_rPrrrrWrrrrrrrs      rc@s$eZdZddZddZddZdS)ConnectionWrappercCs6||_||_||_dD]}t||}t|||qdS)N)rLrHrkr_rW)_conn_dumps_loadsrsetattr)r;connrYreattrr[rrrr?s  zConnectionWrapper.__init__cCs||}|j|dSr)rrrW)r;r[rrrrr\ s zConnectionWrapper.sendcCs|j}||Sr)rr_rrrrrrg s zConnectionWrapper.recvN)rrrsrtr?r\rgrrrrrsrcCst|fdddddS)Nrutf-8) xmlrpclibrYencode)r[rrr _xml_dumpssrcCst|d\\}}|S)Nr)rredecode)rr[methodrrr _xml_loadssr c@seZdZddZdS) XmlListenercCs"ddlmat|}t|ttSr) xmlrpc.clientclientrrrrrr rZrrrrs  zXmlListener.acceptN)rrrsrtrrrrrr sr cOs"ddlmatt|i|ttSr)r r rrrrr )rkwdsrrr XmlClients rcCst|}g}|rt|d|}|tkr*qn\t|krFtt|krTnn |t8}n2t|krptt|kr~nn |t8}ntd|||||dd}d}q |S)NFzShould not get hererr) listryr{r r rPr rr)ZhandlesrLreadyrrrr_exhaustive_wait*s    rc s |durt}n|dkrd}nt|dd}t|}ig}tt}z|D](}zt|d}Wnty||<YqP0zt|dd\}}Wn:t y}z"d|j }}|t vr‚WYd}~n d}~00|tj kr| |||j<qP|rltdddkrlz|d \} }Wn,t yR}z|j }WYd}~n d}~00|slt|d rld|_|d}qPt|}W|D]}|q|D]}z|d\} }Wn8t y}z|j }|t vrނWYd}~n d}~00|tjkr|j}||dkrt|d rd|_qn|D]}|q:|D]}z|d\} }Wn8t y}z|j }|t vrWYd}~n d}~00|tjkrN|j}||dkrNt|d rNd|_qN0fd d |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?rLT)rFrc3s|]}|VqdSrr).0r)waithandle_to_objrr zwait..csg|]}|vr|qSrr)ro) ready_objectsrr rwait..)rintrsetrAttributeErrorr7ryrrDr _ready_errorsrzrr|r*Zgetwindowsversionr~r,raddrkeysr}ZERROR_OPERATION_ABORTEDupdate) object_listrZov_listZ ready_handlesrrLrrrrr)rrrr@s                       r PollSelectorcCst}|D]}||tjq |dur4t|}||}|r^dd|DWdS|dur4|t}|dkr4|WdSq4Wdn1s0YdS)rNcSsg|]\}}|jqSr)Zfileobj)rkeyZeventsrrrrrrr) _WaitSelectorregister selectorsZ EVENT_READrrZselect)r&rZselectorr[Zdeadlinerrrrrs   cCsf|}t|tjtj8}ddlm}||}t||j |j ffWdS1sX0YdS)Nr)resource_sharer) rLr-ZfromfdrZ SOCK_STREAMr r,Z DupSocketrebuild_connectionr=r>)rr<rr,dsrrrreduce_connections   r/cCs|}t|||Srrr)r.r=r>Zsockrrrr-sr-cCsB|jr tjnd|jrtjndB}t||}t||j|jffSr) r=ryZFILE_GENERIC_READr>ZFILE_GENERIC_WRITEr Z DupHandlerLrebuild_pipe_connection)rrdhrrrreduce_pipe_connections r3cCs|}t|||Sr)rrv)r2r=r>r<rrrr1sr1cCs t|}t||j|jffSr)r ZDupFdrLr-r=r>)rdfrrrr/scCs|}t|||Srr0)r4r=r>fdrrrr-s)NN)T)T)N)N)I__all__rr!r*r-rrr% itertoolsrr rrr contextr ZForkingPicklerrXryr r r r ImportErrorr+rZCONNECTION_TIMEOUTcountr$rZfamiliesr,rrr)r.r5r6rvrobjectrrrrrrrrrrrrrrrr r rrrZERROR_NETNAME_DELETEDr"rr+r'r)ZSelectSelectorr/r-r*r3r1rrrr s           PT=    ,, 8   P