U -ec|@s*ddddgZddlZddlZddlZddlZddlZddlZddlZddlZz ddl Z Wne k rtddl Z YnXddl m Z ddl mZmZdd lmZejZz$ddlZdd lmZmZmZmZWn$e k rejd krdZYnXd Zd ZeZdZdgZe edr"dZedg7Zejd krd?Z;ejd krd@dAZhZ?dRdBdZ@n,ddlAZAe eAdCreAjBZCneAjDZCdSdDdZ@ejd kr dEdFZEdGdHZFeGe(eEdIdJZHdKdLZIeGe'eHndMdFZEdNdHZFeGe(eEdS)TClientListenerPipewaitN)util)AuthenticationErrorBufferTooShort) reduction) WAIT_OBJECT_0WAIT_ABANDONED_0 WAIT_TIMEOUTINFINITEwin32i g4@AF_INETAF_UNIXAF_PIPEcCsttdtj|SN monotonicgetattrtime)timeoutrX/var/www/html/Darija-Ai-Train/env/lib/python3.8/site-packages/multiprocess/connection.py _init_timeout>srcCsttdtj|kSrr)trrr_check_timeoutAsrcCsX|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_addressHsr+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_familyVs   r0cCsTt|tkrdSt|tkr*|dr*dSt|tks@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_typebs r7c@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__xsz_ConnectionBase.__init__cCs|jdk r|dSNr:_closer=rrr__del__s z_ConnectionBase.__del__cCs|jdkrtddS)Nzhandle is closed)r:OSErrorrErrr _check_closeds z_ConnectionBase._check_closedcCs|jstddS)Nzconnection is write-only)r;rGrErrr_check_readablesz_ConnectionBase._check_readablecCs|jstddS)Nzconnection is read-only)r<rGrErrr_check_writablesz_ConnectionBase._check_writablecCs"|jrd|_n|tddS)NFzbad message length)r<r;closerGrErrr_bad_message_lengthsz#_ConnectionBase._bad_message_lengthcCs |jdkS)z True if the connection is closedNr:rErrrclosedsz_ConnectionBase.closedcCs|jS)z"True if the connection is readable)r;rErrrr?sz_ConnectionBase.readablecCs|jS)z"True if the connection is writable)r<rErrrr@sz_ConnectionBase.writablecCs||jS)z+File descriptor or handle of the connection)rHr:rErrrfilenosz_ConnectionBase.filenocCs$|jdk r z |W5d|_XdS)zClose the connectionNrCrErrrrKs  z_ConnectionBase.closercCs||t|}|jdkr.tt|}t|}|dkrFtd||krVtd|dkrh||}n&|dkrztdn|||krtd|||||dS)z,Send the bytes data from a bytes-like objectrrzoffset is negativezbuffer length < offsetNzsize is negativezbuffer length < offset + size)rHrJ memoryviewitemsizebyteslenr( _send_bytes)r=bufoffsetsizemnrrr send_bytess"     z_ConnectionBase.send_bytescCs$|||t|dS)zSend a (picklable) objectN)rHrJrT_ForkingPicklerdumpsr=objrrrsendsz_ConnectionBase.sendcCsJ|||dk r(|dkr(td||}|dkrB||S)z7 Receive bytes data as a bytes object. Nrznegative maxlength)rHrIr( _recv_bytesrLgetvalue)r=Z maxlengthrUrrr recv_bytess z_ConnectionBase.recv_bytesc Cs||t|}|j}|t|}|dkr>tdn||krNtd|}|}|||krvt| | d| |||||||W5QRSQRXdS)zq Receive bytes data into a writeable bytes-like object. Return the number of bytes read. rznegative offsetzoffset too largeN) rHrIrPrQrSr(r`tellr raseekreadinto)r=rUrVrXrQZbytesizeresultrWrrrrecv_bytes_intos$        z_ConnectionBase.recv_bytes_intocCs&|||}t|S)zReceive a (picklable) object)rHrIr`r[loads getbuffer)r=rUrrrrecvsz_ConnectionBase.recvcCs||||S)z/Whether there is any input available to be read)rHrI_pollr=rrrrpollsz_ConnectionBase.pollcCs|SrBrrErrr __enter__sz_ConnectionBase.__enter__cCs |dSrBrKr=exc_type exc_valueexc_tbrrr__exit__ sz_ConnectionBase.__exit__)TT)rN)N)r)rk)__name__ __module__ __qualname__r:rArFrHrIrJrLpropertyrNr?r@rOrKrZr_rbrgrjrnrorurrrrr8us.       r8c@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||jdSrBrM)r=Z _CloseHandlerrrrDszPipeConnection._closec Cstj|j|dd\}}zHz,|tjkrBt|jgdt}|tksBt Wn| YnXW5|d\}}X|dks|t |t |kst dS)NT overlappedFr) _winapiZ WriteFiler:GetOverlappedResultERROR_IO_PENDINGWaitForMultipleObjectseventrr AssertionErrorcancelrS)r=rUoverrZnwrittenwaitresrrrrTs   zPipeConnection._send_bytesNc Cs2|jrd|_tS|dkr dnt|d}ztj|j|dd\}}dzHz,|tj krpt |jgdt}|tksptWn|YnXW5|d\}}|dkrt}|| |WS|tj kr| ||WSXWn:tk r$}z|jtjkrtnW5d}~XYnXtddS)NFTr{rz.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminr}ReadFiler:r~writeriZERROR_MORE_DATA_get_more_datarrrrr rrrGwinerrorERROR_BROKEN_PIPEEOFError RuntimeError) r=maxsizeZbsizerrZnreadfrerrrr`)s>      zPipeConnection._recv_bytescCs.|jst|jddkrdStt|g|S)NrT)rr} PeekNamedPiper:boolrrmrrrrlIs zPipeConnection._pollcCs|}t}||t|jd}|dks6t|dk rVt|||krV| tj |j|dd\}}| d\}}|dkst||kst|||S)NrrTr{) rirrrr}rr:rrSrLrr~)r=rrrUrleftrZrbytesrrrrOs    zPipeConnection._get_more_data)N) rvrwrx__doc__rr} CloseHandlerDrTr`rlrrrrrrzs rzc@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||jdSrBrMr=rDrrrrDfszConnection._closecCs||jdSrBrMrrrrrDkscCs8t|}||j|}||8}|dkr&q4||d}qdSNr)rSr:)r=rUr remainingrYrrr_sendps  zConnection._sendcCsbt}|j}|}|dkr^|||}t|}|dkrJ||krBtntd||||8}q|S)Nrzgot end of file during message)rrr:rSrrGr)r=rWreadrUr>rchunkrYrrr_recvys   zConnection._recvcCst|}|dkrHtdd}td|}||||||n8td|}|dkrr||||n|||dS)Ni!i!Qi@)rSstructpackr)r=rUrYZ pre_headerheaderrrrrTs        zConnection._send_bytesNcCs^|d}td|\}|dkr@|d}td|\}|dk rT||krTdS||S)Nrrr)rrunpackra)r=rrUrWrrrr`s  zConnection._recv_bytescCst|g|}t|SrB)rr)r=rrrrrrls zConnection._poll)N)rvrwrxrr}_multiprocessingZ closesocketrDr__writerj_readr$rKrrrrrTr`rlrrrrr_s  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||||_|dk rft|tsft d||_ dS)Nrauthkey should be a byte string) r7default_familyr+r0 PipeListener _listenerSocketListener isinstancerR TypeError_authkey)r=r6r*backlogauthkeyrrrrAs zListener.__init__cCs>|jdkrtd|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)rrGacceptrdeliver_challengeanswer_challenge)r=crrrrs    zListener.acceptcCs |j}|dk rd|_|dS)zA Close the bound socket or named pipe of `self`. N)rrK)r=ZlistenerrrrrKszListener.closecCs|jjSrB)r_addressrErrrr6szListener.addresscCs|jjSrB)r_last_acceptedrErrr last_acceptedszListener.last_acceptedcCs|SrBrrErrrroszListener.__enter__cCs |dSrBrprqrrrruszListener.__exit__)NNrN) rvrwrxrrArrKryr6rrorurrrrrs    cCsh|p t|}t||dkr&t|}nt|}|dk rHt|tsHtd|dk rdt||t|||S)z= Returns a connection to the address of a `Listener` rNr) r7r0 PipeClient SocketClientrrRrrr)r6r*rrrrrrs    TcCsj|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/ socketpair setblockingrdetachr$pipe)duplexs1s2c1c2Zfd1fd2rrrrs       c Cstd}|r*tj}tjtjB}tt}}ntj}tj}dt}}t||tjBtj Btj tj Btj Bd||tj tj}t||dtjtjtjtj}t|tj ddtj|dd}|d\} } | dkstt||d} t||d} | | fS) rrrrNTr{rr)r+r}PIPE_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~rrz) rr6ZopenmodeaccessZobsizeZibsizeZh1Zh2r|_rrrrrrrsV        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 |_ Wn t k r|jYnX||_d|_|dkrt|stj|tj|fdd|_nd|_dS)NposixrTrrargsZ exitpriority)r/r_socketr$name setsockopt SOL_SOCKET SO_REUSEADDRrbindlisten getsocknamerrGrKZ_familyrrr5Finalizeunlink_unlink)r=r6r*rrrrrAJs0       zSocketListener.__init__cCs&|j\}|_|dt|S)NT)rrrrrrr=srrrrcs zSocketListener.acceptcCs0z|jW5|j}|dk r*d|_|XdSrB)rrrK)r=rrrrrKhs zSocketListener.closeN)r)rvrwrxrrArrKrrrrrFs rc CsPt|}ttt|.}|d||t|W5QRSQRXdS)zO Return a connection object connected to the socket given by `address` TN)r7r/rrconnectrr)r6r*rrrrrrs   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_listenerrK)r=r6rrrrrAs zPipeListener.__init__Fc CsHtjtjB}|r|tjO}t|j|tjtjBtjBtj t t tj tj SrB) r}rrrrrrrrZPIPE_UNLIMITED_INSTANCESrrr)r=rflagsrrrrs   zPipeListener._new_handlec Cs|j||jd}ztj|dd}Wn0tk r^}z|jtjkrNW5d}~XYn\Xzrrrrresrrrrs(    zPipeListener.acceptcCs$td||D]}t|qdS)Nz closing listener with address=%r)rrr}r)queuer6r>rrrrs z$PipeListener._finalize_pipe_listener)N)F) rvrwrxrrArr staticmethodrrrrrrs  rc Cst}z6t|dt|tjtjBdtjtjtjtj}Wqt k rz}z |j tj tj fksht |rjW5d}~XYqXqqt|tjddt|S)zU Return a connection object connected to the pipe given by `address` rN)rr}Z WaitNamedPiperrrrrrrGrZERROR_SEM_TIMEOUTZERROR_PIPE_BUSYrrrrz)r6rhrrrrrs8  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)hmacrrRr(formatr1r$urandomMESSAGE_LENGTHrZ CHALLENGEnewdigestrbWELCOMEFAILUREr connectionrrmessager responserrrrs      rcCsddl}t|ts$tdt||d}|dtttksNt d||ttd}| ||d }| ||d}|t krtddS)Nrrrz message = %rrzdigest sent was rejected)rrrRr(rr1rbrSrrr r rZr rr rrrrs      rc@s$eZdZddZddZddZdS)ConnectionWrappercCs6||_||_||_dD]}t||}t|||qdS)N)rOrKrnrbrZ)_conn_dumps_loadsrsetattr)r=connr\rhattrr^rrrrAs  zConnectionWrapper.__init__cCs||}|j|dSrB)rrrZ)r=r^rrrrr_s zConnectionWrapper.sendcCs|j}||SrB)rrbrrrrrrj s zConnectionWrapper.recvN)rvrwrxrAr_rjrrrrrsrcCst|fdddddS)Nrutf-8) xmlrpclibr\encode)r^rrr _xml_dumpssrcCst|d\\}}|S)Nr)rrhdecode)rr^methodrrr _xml_loadssrc@seZdZddZdS) XmlListenercCs"ddlmat|}t|ttSr) xmlrpc.clientclientrrrrrrr]rrrrs  zXmlListener.acceptN)rvrwrxrrrrrrsrcOsddlmatt||ttSr)r r!rrrrr)rkwdsrrr XmlClients 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) listr}rr r rSr rr)ZhandlesrLreadyrrrr_exhaustive_wait(s    r'c s^|dkrt}n|dkrd}nt|dd}t|}ig}tt}z@|D]&}zt|d} Wn tk r||<YqPXzt | dd\}}Wn8tk r}zd|j}}|tkrƂW5d}~XYnX|t jkr||||j <qP|rjtddd krjz|d \}}Wn*tk rP}z |j}W5d}~XYnX|sjt |drjd|_ |d}qPt|}W5|D]}|q|D]}z|d\}}Wn6tk r}z|j}|tkrW5d}~XYnX|t j kr|j } ||dkrt |drd|_qXfd 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?TrrO)r)Fc3s|]}|VqdSrBr).0r)waithandle_to_objrr szwait..csg|]}|kr|qSrr)r+o) ready_objectsrr swait..)rintr$setrr~rGr _ready_errorsr}ZERROR_OPERATION_ABORTEDraddr.rrAttributeErrorr9rrrr,getwindowsversionr'keysupdate) object_listrZov_listZ ready_handlesrrrrr.rOr)r/r,rr>sh               PollSelectorc Cst}|D]}||tjq |dk rrrFdsrrrreduce_connections   rKcCs|}t|||SrBrr)rJr?r@sockrrrrIsrIcCsB|jr tjnd|jrtjndB}t||}t||j|jffSr) r?r}ZFILE_GENERIC_READr@ZFILE_GENERIC_WRITEr Z DupHandlerOrebuild_pipe_connection)rrdhrrrreduce_pipe_connections rPcCs|}t|||SrB)rrz)rOr?r@r>rrrrNsrNcCs t|}t||j|jffSrB)r ZDupFdrOrIr?r@)rdfrrrrKscCs|}t|||SrBrL)rQr?r@fdrrrrIs)NN)T)T)N)N)J__all__rr$r,r/rrr" itertoolsZ _multiprocessr ImportErrorr!rrr contextr ZForkingPicklerr[r}r r r rr-rZCONNECTION_TIMEOUTcountr'rZfamiliesr.rrr+r0r7r8rzrobjectrrrrrrrrrr r rrrrrrr#r'rZERROR_NETNAME_DELETEDr4rrAr;r?SelectSelectorrKrIr@rPrNrrrr s            PT=    ,, 8   P