£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyʦ•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~芩ÊǍí`ÔÑ©ú뙵'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶êםӼ㞪éUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£Ôϯrs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowЍø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! a XC?h.@s2gdZddlZddlZddlZddlZddlZddlmZzej e Z Wne yfdZ Yn0ddZ ddZdd Zd d ZGd d d eZGdddeZGdddeZGdddeZdaeaedaea[iZeej D]0\Z!Z"e!dddkrde!vrde!ee" <qeZ#dS)) BaseProcesscurrent_processactive_childrenparent_processN)WeakSetcCstSN)_current_processr r ^z'BaseProcess.__init__..)next_process_counterr _identity_configcopyosgetpid _parent_pidname _parent_namer_closed_targettuple_argsdict_kwargstype__name__join_namer _danglingadd)rgrouptargetr'argskwargsrcountr r r __init__Ps     zBaseProcess.__init__cCs|jrtddS)Nzprocess object is closed)r) ValueErrorrr r r _check_closedcszBaseProcess._check_closedcCs|jr|j|ji|jdSr)r*r,r.rr r r rungszBaseProcess.runcCs>|t|||_|jj|_|`|`|`t |dSr) r<r rrsentinel _sentinelr*r,r.r r4rr r r startns    zBaseProcess.startcCs||jdSr)r<r terminaterr r r rAszBaseProcess.terminatecCs||jdSr)r<rkillrr r r rBszBaseProcess.killcCs*||j|}|dur&t|dSr)r<rwaitr r)rtimeoutresr r r r1s zBaseProcess.joincCsJ||turdS|jdur"dS|j}|dur8dSt|dSdS)NTF)r<rrrr r)r returncoder r r is_alives   zBaseProcess.is_alivecCsH|jdur>|jdur td|jd|_|`t|d|_dS)Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)rrr;closer?r rr)rr r r rHs   zBaseProcess.closecCs|jSrr2rr r r r'szBaseProcess.namecCs ||_dSrrI)rr'r r r r'scCs|jddS)NrF)r"getrr r r rszBaseProcess.daemoncCs||jd<dS)Nrr")rZdaemonicr r r rscCs |jdSNauthkeyrKrr r r rMszBaseProcess.authkeycCst||jd<dSrL)AuthenticationStringr")rrMr r r rMscCs"||jdur|jS|jSr)r<rrrr r r exitcodes zBaseProcess.exitcodecCs*||turtS|jo$|jjSdSr)r<rr$r%rpidrr r r identszBaseProcess.identcCs2|z|jWSty,tddYn0dS)Nzprocess not started)r<r?AttributeErrorr;rr r r r>s  zBaseProcess.sentinelcCsd}|turd}nL|jrd}n@|jtkr2d}n,|jdurBd}n|j}|durZd}nd}t|jd|j g}|jdur| d|jj | d|j| ||durt ||}| d ||jr| d d d |S) NZstartedclosedunknowninitialZstoppedzname=%rzpid=%sz parent=%sz exitcode=%srz<%s> )rr)r&r$r%rrr/r0r2appendrP_exitcode_to_namerJrr1)rrOZstatusinfor r r __repr__s0      zBaseProcess.__repr__c Csddlm}m}z`z|jdur,||jtdata | t }|a t |j |j|atjrntz|j|W~n~0|dz|d}W|n |0Wnty }zJ|jdurd}n.t|jtr|j}ntj t!|jdd}WYd}~n:d}~0d}ddl"}tj d|j#|$Yn0Wt%|d||&n t%|d||&0|S)N)utilcontextz child process calling self.run()r z Process %s: z process exiting with exitcode %d)'r\r]Z _start_methodZ_force_start_method itertoolsr9r setr Z _close_stdinr_ParentProcessr(r&r threadingZ_HAVE_THREAD_NATIVE_IDZ main_threadZ_set_native_idZ_finalizer_registryclearZ_run_after_forkersrYr=Z_exit_function SystemExitcode isinstanceintsysstderrwriter tracebackr' print_excZ _shutdownZ_flush_std_streams)rZparent_sentinelr\r]Z old_processrOerlr r r _bootstrap"sT            zBaseProcess._bootstrap)N)N)r0 __module__ __qualname__rr:r<r=r@rArBr1rGrHpropertyr'setterrrMrOrQrPr>rZror r r r rGsB            rc@seZdZddZdS)rNcCs,ddlm}|durtdtt|ffS)Nr[)get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r]rt TypeErrorrNbytes)rrtr r r __reduce__Xs   zAuthenticationString.__reduce__N)r0rprqrwr r r r rNWsrNc@s6eZdZddZddZeddZd dd ZeZdS) rbcCs4d|_||_||_d|_d|_d|_||_i|_dS)Nr F)r!r2_pidr&rr)r?r")rr'rPr>r r r r:hsz_ParentProcess.__init__cCsddlm}||jgdd SNr)rC)rDZmultiprocessing.connectionrCr?)rrCr r r rGrs z_ParentProcess.is_alivecCs|jSr)rxrr r r rQvsz_ParentProcess.identNcCs ddlm}||jg|ddSryrz)rrDrCr r r r1zs z_ParentProcess.join)N) r0rprqr:rGrrrQr1rPr r r r rbfs    rbc@seZdZddZddZdS) _MainProcesscCs8d|_d|_d|_d|_d|_ttddd|_dS)Nr Z MainProcessF z/mp)rMZ semprefix) r!r2r&rr)rNr$urandomr"rr r r r:s z_MainProcess.__init__cCsdSrr rr r r rHsz_MainProcess.closeN)r0rprqr:rHr r r r r{sr{r[ZSIG_r)$__all__r$risignalr`rcZ _weakrefsetrpathabspathgetcwdZ ORIGINAL_DIROSErrorrrrr objectrrvrNrbr{rrr9r rar rXr __dict__itemsr'Zsignumr3r r r r  s<     !