ÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂ U ¡ê,aÅ{ã@sddddgZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl mZddl mZm Z dd lmZejZz$ddlZdd lmZmZmZmZWn$ek rÊejdkrÂ‚dZYnXdZd Ze ¡ZdZdgZeedƒrþdZedg7ZejdkrdZedg7Zefdd„Z dd„Z!dd„Z"dd„Z#dd„Z$Gdd„dƒZ%erhGdd„de%ƒZ&Gdd „d e%ƒZ'Gd!d„de(ƒZ)dOd"d„Z*ejdkrªdPd$d„Z+n dQd%d„Z+Gd&d'„d'e(ƒZ,d(d)„Z-ejdkrðGd*d+„d+e(ƒZ.d,d-„Z/d.Z0d/Z1d0Z2d1Z3d2d3„Z4d4d5„Z5Gd6d7„d7e(ƒZ6d8d9„Z7d:d;„Z8Gdd?„Z:ejdkrtd@dA„Z;ejdRdBd„Z?n,ddl@Z@ee@dCƒre@jAZBne@jCZBdSdDd„Z?ejdkrædEdF„ZDdGdH„ZEe Fe'eD¡dIdJ„ZGdKdL„ZHe Fe&eG¡ndMdF„ZDdNdH„ZEe Fe'eD¡dS)TÚClientÚListenerÚPipeÚwaitéNé)Úutil)ÚAuthenticationErrorÚBufferTooShort)Ú reduction)Ú WAIT_OBJECT_0ÚWAIT_ABANDONED_0ÚWAIT_TIMEOUTÚINFINITEÚwin32i g4@ÚAF_INETÚAF_UNIXÚAF_PIPEcCst ¡|S©N©ÚtimeÚ monotonic)Útimeout©rú?/opt/alt/python38/lib64/python3.8/multiprocessing/connection.pyÚ _init_timeout;srcCst ¡|kSrr)ÚtrrrÚ_check_timeout>srcCsX|dkrdS|dkr&tjdt ¡dS|dkrLtjdt ¡ttƒfddStd ƒ‚dS) Nr)Z localhostrrz listener-)ÚprefixÚdirrz\\.\pipe\pyc-%d-%d-Úzunrecognized family) ÚtempfileZmktemprZget_temp_dirÚosÚgetpidÚnextÚ _mmap_counterÚ ValueError©ÚfamilyrrrÚarbitrary_addressEsÿÿr(cCsJtjdkr|dkrtd|ƒ‚tjdkrF|dkrFtt|ƒsFtd|ƒ‚dS)NrrzFamily %s is not recognized.r)ÚsysÚplatformr%ÚhasattrÚsocketr&rrrÚ_validate_familySs r-cCsTt|ƒtkrdSt|ƒtkr*| d¡r*dSt|ƒtks@t |¡rDdStd|ƒ‚dS)Nrz\\rrzaddress type of %r unrecognized)ÚtypeÚtupleÚstrÚ startswithrÚis_abstract_socket_namespacer%)ÚaddressrrrÚaddress_type_sr4c@s¾eZdZdZd+dd„Zdd„Zdd„Zd d „Zdd„Zd d„Z e dd„ƒZe dd„ƒZe dd„ƒZ dd„Zdd„Zd,dd„Zdd„Zd-dd„Zd.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)ÚselfÚhandleÚreadableÚwritablerrrÚ__init__usÿz_ConnectionBase.__init__cCs|jdk r| ¡dSr©r7Ú_close©r:rrrÚ__del__‚s z_ConnectionBase.__del__cCs|jdkrtdƒ‚dS)Nzhandle is closed)r7ÚOSErrorrArrrÚ _check_closed†s z_ConnectionBase._check_closedcCs|jstdƒ‚dS)Nzconnection is write-only)r8rCrArrrÚ_check_readableŠsz_ConnectionBase._check_readablecCs|jstdƒ‚dS)Nzconnection is read-only)r9rCrArrrÚ_check_writableŽsz_ConnectionBase._check_writablecCs"|jrd|_n| ¡tdƒ‚dS)NFzbad message length)r9r8ÚcloserCrArrrÚ_bad_message_length’sz#_ConnectionBase._bad_message_lengthcCs |jdkSr©r7rArrrÚclosed™sz_ConnectionBase.closedcCs|jSr)r8rArrrr<žsz_ConnectionBase.readablecCs|jSr)r9rArrrr=£sz_ConnectionBase.writablecCs| ¡|jSr)rDr7rArrrÚfileno¨sz_ConnectionBase.filenocCs$|jdk r z| ¡W5d|_XdSrr?rArrrrGs z_ConnectionBase.closercCs¨| ¡| ¡t|ƒ}|jdkr.tt|ƒƒ}t|ƒ}|dkrFtdƒ‚||krVtdƒ‚|dkrh||}n&|dkrztdƒ‚n|||krŽtdƒ‚| ||||…¡dS)Nrrzoffset is negativezbuffer length < offsetzsize is negativezbuffer length < offset + size)rDrFÚ memoryviewÚitemsizeÚbytesÚlenr%Ú_send_bytes)r:ÚbufÚoffsetÚsizeÚmÚnrrrÚ send_bytesµs" z_ConnectionBase.send_bytescCs$| ¡| ¡| t |¡¡dSr)rDrFrPÚ_ForkingPicklerÚdumps©r:ÚobjrrrÚsendÊsz_ConnectionBase.sendcCsJ| ¡| ¡|dk r(|dkr(tdƒ‚| |¡}|dkrB| ¡| ¡S)Nrznegative maxlength)rDrEr%Ú_recv_bytesrHÚgetvalue)r:Z maxlengthrQrrrÚ recv_bytesÐs z_ConnectionBase.recv_bytesc Cs¸| ¡| ¡t|ƒ–}|j}|t|ƒ}|dkr>tdƒ‚n||krNtdƒ‚| ¡}| ¡}|||krvt| ¡ƒ‚| d¡| ||||||…¡|W5QR£SQRXdS)Nrznegative offsetzoffset too large)rDrErLrMrOr%r\Útellr r]ÚseekÚreadinto)r:rQrRrTrMZbytesizeÚresultrSrrrÚrecv_bytes_intoÝs$ ÿz_ConnectionBase.recv_bytes_intocCs&| ¡| ¡| ¡}t | ¡¡Sr)rDrEr\rWÚloadsÚ getbuffer)r:rQrrrÚrecvösz_ConnectionBase.recvçcCs| ¡| ¡| |¡Sr)rDrEÚ_poll©r:rrrrÚpollýsz_ConnectionBase.pollcCs|SrrrArrrÚ __enter__sz_ConnectionBase.__enter__cCs| ¡dSr©rG©r:Úexc_typeÚ exc_valueZexc_tbrrrÚ__exit__sz_ConnectionBase.__exit__)TT)rN)N)r)rg)Ú__name__Ú __module__Ú__qualname__r7r>rBrDrErFrHÚpropertyrJr<r=rKrGrVr[r^rcrfrjrkrprrrrr5rs. r5c@s@eZdZdZejfdd„Zdd„Zd dd„Zd d „Z dd„Z dS)ÚPipeConnectionFcCs||jƒdSrrI)r:Z_CloseHandlerrrr@szPipeConnection._closec Cshtj|j|dd\}}z ÿ ÿ zPipeConnection._recv_bytescCs.|jst |j¡ddkrdStt|g|ƒƒS)NrT)r‚rxÚ PeekNamedPiper7ÚboolrrirrrrhFs ÿzPipeConnection._pollcCs€| ¡}t ¡}| |¡t |j¡d}|dk rJt|ƒ||krJ| ¡tj |j|dd\}}| d¡\}}| | ¡¡|S)NrTrv)rerƒr„r‡rxrr7rOrHr†ry)r:r~rrQrŽÚleftrZrbytesrrrrˆLs zPipeConnection._get_more_data)N)rqrrrsr‚rxÚCloseHandler@rPr\rhrˆrrrrrus ruc@sxeZdZer(ejfdd„ZejZej Z nejfdd„Zej ZejZ efdd„Ze fdd„Zdd „Zddd„Zd d„Zd S)Ú ConnectioncCs||jƒdSrrI©r:r@rrrr@cszConnection._closecCs||jƒdSrrIr•rrrr@hscCs8t|ƒ}||j|ƒ}||8}|dkr&q4||d…}qdS©Nr)rOr7)r:rQr‡Ú remainingrUrrrÚ_sendmszConnection._sendcCsbt ¡}|j}|}|dkr^|||ƒ}t|ƒ}|dkrJ||krBt‚ntdƒ‚| |¡||8}q|S)Nrzgot end of file during message)rƒr„r7rOr‹rCr‡)r:rSÚreadrQr;r—ÚchunkrUrrrÚ_recvvs zConnection._recvcCs„t|ƒ}|dkrHt dd¡}t d|¡}| |¡| |¡| |¡n8t d|¡}|dkrr| |¡| |¡n| ||¡dS)Niÿÿÿú!iéÿÿÿÿú!Qi@)rOÚstructZpackr˜)r:rQrUZ pre_headerÚheaderrrrrP†s zConnection._send_bytesNcCs^| d¡}t d| ¡¡\}|dkr@| d¡}t d| ¡¡\}|dk rT||krTdS| |¡S)Nérœrérž)r›rŸZunpackr])r:rrQrSrrrr\s zConnection._recv_bytescCst|g|ƒ}t|ƒSr)rr‘)r:rÚrrrrrh§szConnection._poll)N)rqrrrsrxÚ_multiprocessingZclosesocketr@r[Z_writerfZ_readr!rGr‡r™r˜r›rPr\rhrrrrr”\s r”c@sNeZdZddd„Zdd„Zdd„Zed d „ƒZedd„ƒZd d„Z dd„Z dS)rNrcCsp|p|rt|ƒpt}|pt|ƒ}t|ƒ|dkr>t||ƒ|_nt|||ƒ|_|dk rft|tƒsft dƒ‚||_ dS©Nrzauthkey should be a byte string)r4Údefault_familyr(r-ÚPipeListenerÚ _listenerÚSocketListenerÚ isinstancerNÚ TypeErrorÚ_authkey)r:r3r'ÚbacklogÚauthkeyrrrr>·sÿzListener.__init__cCs>|jdkrtdƒ‚|j ¡}|jr:t||jƒt||jƒ|S)Nzlistener is closed)r¨rCÚacceptr¬Údeliver_challengeÚanswer_challenge)r:Úcrrrr¯Çs zListener.acceptcCs |j}|dk rd|_| ¡dSr)r¨rG)r:ZlistenerrrrrGÕszListener.closecCs|jjSr)r¨Ú_addressrArrrr3ÞszListener.addresscCs|jjSr)r¨Ú_last_acceptedrArrrÚ last_acceptedâszListener.last_acceptedcCs|SrrrArrrrkæszListener.__enter__cCs| ¡dSrrlrmrrrrpészListener.__exit__)NNrN)rqrrrsr>r¯rGrtr3rµrkrprrrrr°s cCsh|p t|ƒ}t|ƒ|dkr&t|ƒ}nt|ƒ}|dk rHt|tƒsHtdƒ‚|dk rdt||ƒt||ƒ|Sr¥) r4r-Ú PipeClientÚSocketClientrªrNr«r±r°)r3r'r®r²rrrrís TcCsj|r>t ¡\}}| d¡| d¡t| ¡ƒ}t| ¡ƒ}n$t ¡\}}t|dd}t|dd}||fS)NTF©r=©r<)r,Z socketpairÚsetblockingr”Údetachr!Úpipe)ÚduplexÚs1Ús2Úc1Úc2Zfd1Zfd2rrrrs c Csâtdƒ}|r*tj}tjtjB}tt}}ntj}tj}dt}}t ||tjBtj Btj tjBtjBd||tj tj¡}t ||dtjtjtjtj¡}t |tjdd¡tj|dd}| d¡\} } t||d}t||d}||fS)NrrrTrvr¸r¹)r(rxÚPIPE_ACCESS_DUPLEXÚGENERIC_READÚ GENERIC_WRITEÚBUFSIZEZPIPE_ACCESS_INBOUNDÚCreateNamedPipeÚFILE_FLAG_OVERLAPPEDÚFILE_FLAG_FIRST_PIPE_INSTANCEÚPIPE_TYPE_MESSAGEÚPIPE_READMODE_MESSAGEÚ PIPE_WAITÚNMPWAIT_WAIT_FOREVERÚNULLÚ CreateFileÚ OPEN_EXISTINGÚSetNamedPipeHandleStateÚConnectNamedPiperyru) r½r3ZopenmodeÚaccessZobsizeZibsizeZh1Zh2rwÚ_rrÀrÁrrrrsT ÿ ÿù þÿc@s&eZdZd dd„Zdd„Zdd„ZdS) r©rcCsÈt tt|ƒ¡|_zRtjdkr2|j tjtjd¡|j d¡|j |¡|j |¡|j ¡|_Wn t k r„|j ¡‚YnX||_d|_|dkr¾t |¡s¾tj|tj|fdd|_nd|_dS)NÚposixrTrr©ÚargsZexitpriority)r,ÚgetattrÚ_socketr!ÚnameZ setsockoptZ SOL_SOCKETZSO_REUSEADDRrºZbindZlistenZgetsocknamer³rCrGZ_familyr´rr2ÚFinalizeÚunlinkÚ_unlink)r:r3r'rrrrr>Gs0 ÿ ÿ zSocketListener.__init__cCs&|j ¡\}|_| d¡t| ¡ƒS©NT)rØr¯r´rºr”r»©r:Úsrrrr¯`s zSocketListener.acceptcCs0z|j ¡W5|j}|dk r*d|_|ƒXdSr)rÜrØrG)r:rÛrrrrGeszSocketListener.closeN)r)rqrrrsr>r¯rGrrrrr©Cs r©c CsPt|ƒ}t tt|ƒ¡.}| d¡| |¡t| ¡ƒW5QR£SQRXdSrÝ)r4r,r×rºZconnectr”r»)r3r'rßrrrr·os r·c@s4eZdZddd„Zddd„Zdd„Zed d „ƒZdS) r§NcCsL||_|jddg|_d|_t d|j¡tj|tj|j|jfdd|_ dS)NT)Úfirstz listener created with address=%rrrÕ) r³Ú_new_handleÚ _handle_queuer´rÚ sub_debugrÚr§Ú_finalize_pipe_listenerrG)r:r3rrrrr>ƒs þzPipeListener.__init__Fc CsHtjtjB}|r|tjO}t |j|tjtjBtjBtj t t tjtj¡Sr) rxrÂrÇrÈrÆr³rÉrÊrËZPIPE_UNLIMITED_INSTANCESrÅrÌrÍ)r:ràÚflagsrrrráŽs ÿûzPipeListener._new_handlec Cs¶|j | ¡¡|j d¡}ztj|dd}Wn0tk r^}z|jtjkrN‚W5d}~XYnPXzrár¯Ústaticmethodrärrrrr§s r§c Csœtƒ}z6t |d¡t |tjtjBdtjtjtjtj¡}Wq‚t k rz}z |j tjtjfksht |ƒrj‚W5d}~XYqXq‚q‚t |tjdd¡t|ƒS)Néèr)rrxZ WaitNamedPiperÎrÃrÄrÍrÏrÇrCr‰ZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrrÐrÊru)r3rÚhrrrrr¶·s8 ýÿÿÿr¶és#CHALLENGE#s #WELCOME#s #FAILURE#cCs‚ddl}t|tƒs$td t|ƒ¡ƒ‚t t¡}| t |¡| ||d¡ ¡}| d¡}||krl| t¡n| t¡tdƒ‚dS)Nrú Authkey must be bytes, not {0!s}Úmd5ézdigest received was wrong)ÚhmacrªrNr%Úformatr.r!ÚurandomÚMESSAGE_LENGTHrVÚ CHALLENGEÚnewÚdigestr^ÚWELCOMEÚFAILUREr©Z connectionr®rðÚmessageröZresponserrrr°Üs ÿ r°cCsxddl}t|tƒs$td t|ƒ¡ƒ‚| d¡}|ttƒd…}| ||d¡ ¡}| |¡| d¡}|tkrtt dƒ‚dS)Nrrírïrîzdigest sent was rejected)rðrªrNr%rñr.r^rOrôrõrörVr÷rrùrrrr±ës ÿ r±c@s$eZdZdd„Zdd„Zdd„ZdS)ÚConnectionWrappercCs6||_||_||_dD]}t||ƒ}t|||ƒqdS)N)rKrGrjr^rV)Ú_connÚ_dumpsÚ_loadsr×Úsetattr)r:ÚconnrXrdÚattrrZrrrr>þs zConnectionWrapper.__init__cCs| |¡}|j |¡dSr)rýrürV)r:rZrßrrrr[s zConnectionWrapper.sendcCs|j ¡}| |¡Sr)rür^rþrÞrrrrfs zConnectionWrapper.recvN)rqrrrsr>r[rfrrrrrûýsrûcCst |fdddd¡ d¡S)Nrúutf-8)Ú xmlrpclibrXÚencode)rZrrrÚ _xml_dumpssrcCst | d¡¡\\}}|S)Nr)rrdÚdecode)rßrZÚmethodrrrÚ _xml_loadssrc@seZdZdd„ZdS)ÚXmlListenercCs"ddlmat |¡}t|ttƒSr–)Ú xmlrpc.clientÚclientrrr¯rûrrrYrrrr¯s zXmlListener.acceptN)rqrrrsr¯rrrrr sr cOsddlmatt||ŽttƒSr–)r rrrûrrr)rÖÚkwdsrrrÚ XmlClientsr cCs®t|ƒ}g}|rªt |d|¡}|tkr*qªn\t|krFtt|ƒkrTnn |t8}n2t|krptt|ƒkr~nn |t8}ntdƒ‚| ||¡||dd…}d}q|S)NFzShould not get hererr) Úlistrxr{r rrOrrŒræ)ZhandlesrÚLÚreadyrèrrrÚ_exhaustive_wait%s rc s^|dkrt}n|dkrd}nt|ddƒ}t|ƒ}i‰g}tƒ‰tƒ}z@|D]&}zt|dƒ} Wn tk r„|ˆ| ¡<YqPXzt | ƒdd¡\}}Wn8tk rÖ}zd|j}}|tkrÆ‚W5d}~XYnX|t jkrø| |¡|ˆ|j<qP|rjt ¡dd…dkrjz| d ¡\}}Wn*tk rP}z |j}W5d}~XYnX|sjt |dƒrjd|_ˆ |¡d}qPtˆ ¡|ƒ}W5|D]}| ¡q|D]Œ}z| d¡\}}Wn6tk rð}z|j}|tkrà‚W5d}~XYnX|t j kr¤ˆ|j}ˆ |¡|dkr¤t |dƒr¤d|_q¤Xˆ ‡fd d„|Dƒ¡‡fdd „|DƒS)Nrrêgà?Tr‚rKé)érFc3s|]}ˆ|VqdSrr)Ú.0rë)Úwaithandle_to_objrrÚ †szwait..csg|]}|ˆkr|‘qSrr)rÚo)Ú ready_objectsrrÚ ‡súwait..)rÚintrÚsetr}ryrCr‰Ú _ready_errorsrxZERROR_OPERATION_ABORTEDr|Úaddr+r‚r×ÚAttributeErrorr6r†rzrær)ZgetwindowsversionrÚkeysÚupdate) Úobject_listrZov_listZ ready_handlesr~rÓrrrrKr)rrrr;sh ÚPollSelectorc Cs˜tƒˆ}|D]}| |tj¡q|dk r4t ¡|}| |¡}|r\dd„|DƒW5QR£S|dk r4|t ¡}|dkr4|W5QR£Sq4W5QRXdS)NcSsg|]\}}|j‘qSr)Zfileobj)rÚkeyZeventsrrrr¥srr)Ú _WaitSelectorÚregisterÚ selectorsZ EVENT_READrrZselect)r"rZselectorrZZdeadlinerrrrr•s c CsZ| ¡}t |tjtj¡6}ddlm}| |¡}t||j |j ffW5QR£SQRXdS)Nr)Úresource_sharer)rKr,ZfromfdrZSOCK_STREAMrr(Z DupSocketÚrebuild_connectionr<r=)rr;rßr(ÚdsrrrÚreduce_connection±s r+cCs| ¡}t| ¡||ƒSr©r»r”)r*r<r=Zsockrrrr)·sr)cCsB|jrtjnd|jrtjndB}t | ¡|¡}t||j|jffSr–) r<rxZFILE_GENERIC_READr=ZFILE_GENERIC_WRITEr Z DupHandlerKÚrebuild_pipe_connection)rrÒÚdhrrrÚreduce_pipe_connection¼s ÿr/cCs| ¡}t|||ƒSr)r»ru)r.r<r=r;rrrr-Ásr-cCs t | ¡¡}t||j|jffSr)r ZDupFdrKr)r<r=)rÚdfrrrr+ÇscCs| ¡}t|||ƒSrr,)r0r<r=Úfdrrrr)Ês)NN)T)T)N)N)IÚ__all__rƒr!r)r,rŸrr Ú itertoolsr¤rrrr Úcontextr ZForkingPicklerrWrxrrr rÚImportErrorr*rÅZCONNECTION_TIMEOUTÚcountr$r¦Zfamiliesr+rrr(r-r4r5rur”Úobjectrrrr©r·r§r¶rórôr÷rør°r±rûrrr r rrŠZERROR_NETNAME_DELETEDrrr'r#r%ZSelectSelectorr+r)r&r/r-rrrrÚ s¢ PT= ,,8 P