o Df/+@s6ddlZddlZddlZddlZddlZddlZddlmZddlm Z z ej e ZWn ey9dZYnwgdZddZddZd d Zd d Zefd dZGdddZGdddeZGdddeZeaedaea[eZiZ ej!"D]\Z#Z$e#dddkrde#vre#e e$ <qeZ%dS)N)WeakSetprocess) BaseProcessProcesscurrent_processactive_childrencCtS)z@ Return process object representing the current process )_current_processr r I/home/ubuntu/webapp/venv/lib/python3.10/site-packages/billiard/process.pyr#srcCs|at_dSN)r _mprocrr r r _set_current_process*srcCs*ttD]}|jdurt|qdSr )list _children_popenpolldiscard)pr r r _cleanup/s  rc Cs*z|WdStttfyYdSwr )flushAttributeErrorEnvironmentErrorNotImplementedError)fr r r _maybe_flush6s rcCs(z|WttStygYSw)zN Return list of process objects corresponding to live child processes ) TypeErrorrr)rr r r r=s  rc@s2eZdZdZddZddddidfddZdd Zd d Zd d ZddZ ddZ d5ddZ ddZ ddZ eddZejddZeddZejddZeddZejd dZed!d"Zed#d$ZeZed%d&Zed'd(Zed)d*Zed+d,Zed-d.Zed/d0Zd1d2Zd3d4ZdS)6rz Process objects represent activity that is run in a separate process The class is analogous to `threading.Thread` cCstr )rselfr r r _PopenPszBaseProcess._PopenNr c Ks|dusJdtt}tj|f|_tj|_t|_d|_ ||_ t ||_ t ||_|pAt|jdddd|jD|_|durJ||_tdurSt|d|_dS)Nz#group argument must be None for now-:css|]}t|VqdSr )str).0ir r r `sz'BaseProcess.__init__..F)next_process_counterr _identity_configcopyosgetpid _parent_pidr_targettuple_argsdict_kwargstype__name__join_namedaemon _danglingadd_controlled_termination) rgrouptargetnameargskwargsr8_kwcountr r r __init__Ss$      zBaseProcess.__init__cCs"|jr|j|ji|jdSdS)zQ Method to be run in sub-process; can be overridden in sub-class N)r/r1r3rr r r runiszBaseProcess.runcCsR|jdus Jd|jtksJdt|||_|jj|_t |dS)z% Start child process Nzcannot start a process twicez:can only start a process object created by current process) rr.r,r-rr sentinel _sentinelrr:rr r r startps  zBaseProcess.startcCs|jdur |jdSdSr )rcloserr r r rH|s zBaseProcess.closecCs|jdS)zT Terminate process; sends SIGTERM signal or uses TerminateProcess() N)r terminaterr r r rIszBaseProcess.terminatecCsd|_|dS)NT)r;rIrr r r terminate_controlleds z BaseProcess.terminate_controlledcCsV|jtks Jd|jdusJd|j|}|dur)t||dSdS)z5 Wait until child process terminates zcan only join a child processNzcan only join a started process)r.r,r-rwaitrrrH)rtimeoutresr r r r6s   zBaseProcess.joincCsF|turdS|jtksJd|jdurdS|j|jjduS)z1 Return whether process is alive Tzcan only test a child processNF)r r.r,r-rr returncoderr r r is_alives   zBaseProcess.is_alivecCs|jdurdS|jduS)NFrrrr r r _is_alives zBaseProcess._is_alivecC|jSr )r7rr r r r>szBaseProcess.namecCst|ts Jd||_dS)Nzname must be a string) isinstancer#r7)rr>r r r r>s cCs|jddS)z4 Return whether process is a daemon r8Fr*getrr r r r8szBaseProcess.daemoncCs |jdus Jd||jd<dS)z1 Set whether process is a daemon Nzprocess has already startedr8)rr*)rdaemonicr r r r8scCs |jdS)Nauthkey)r*rr r r rWs zBaseProcess.authkeycCst||jd<dS)z2 Set authorization key of process rWN)AuthenticationStringr*)rrWr r r rWscCs|jdur|jS|jS)zM Return exit code of process or `None` if it has yet to stop NrPrr r r exitcodes  zBaseProcess.exitcodecCs|turtS|jo|jjS)zU Return identifier (PID) of process or `None` if it has yet to start )r r,r-rpidrr r r identszBaseProcess.identcCs z|jWStytdw)z{ Return a file descriptor (Unix) or handle (Windows) suitable for waiting for process termination. zprocess not started)rFr ValueErrorrr r r rEs  zBaseProcess.sentinelcCr r )r(rr r r _counterzBaseProcess._countercCr r )rrr r r rr^zBaseProcess._childrencCrRr )rWrr r r _authkeyzBaseProcess._authkeycCrRr )r8rr r r _daemonicr`zBaseProcess._daemoniccCs |jdS)NtempdirrTrr r r _tempdirs zBaseProcess._tempdircCs|turd}n|jtkrd}n|jdurd}n |jdur$|j}nd}t|tur;|dkr3d}ndt ||}dt|j |j ||j rHdpId fS) Nstartedunknowninitialrstoppedz stopped[%s]z<%s(%s, %s%s)>z daemon)r r.r,r-rrrYr4int_exitcode_to_namerUr5r7r8)rstatusr r r __repr__s   zBaseProcess.__repr__c Csddlm}m}z7z|jdur||jtdata t j dur=z t j t tjt _ Wn tttfy<Ynwt}t|tjjj}t|}|d|D]}|rat||tjsnt|jD]}| qgqUt!"t_#z |j$%|&W~n~w|'d|j(z |)d}W|*n|*wWnyt+y} z8| j,sd}n,t| j,dt-r| j,d}nt j./t0| j,ddt1t j.t| j,dt0rdnd}WYd} ~ nOd} ~ wd}|j2d|j3ddsddl4} t j./d |j3| 5YW|'d |j(|t1t j6t1t j.|SW|'d |j(|t1t j6t1t j.|SW|'d |j(|t1t j6t1t j.|S|'d |j(|t1t j6t1t j.w) N)utilcontextz#child process %s calling self.run()r z Process %sT)exc_infoz Process %s: z#process %s exiting with exitcode %d)7rhrnro _start_method_force_start_method itertoolsrBr(setrsysstdinrHopenr,devnullrOSErrorr\r rloggingLoggermanager loggerDictrkeysappendrS PlaceHolder getLoggerhandlers createLock threadingRLock_lock_finalizer_registryclear_run_after_forkersinforZrD_exit_function SystemExitr?ristderrwriter#rerrorr> traceback print_excstdout) rrnro old_processr~ logger_namesr>handlerrYexcrr r r _bootstraps                       zBaseProcess._bootstrapr )r5 __module__ __qualname____doc__r rCrDrGrHrIrJr6rOrQpropertyr>setterr8rWrYr[rZrEr]rr_rarcrlrr r r r rIsZ                     rc@eZdZddZdS)rXcCs,ddlm}|durtdtt|ffS)Nrm)get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rorrrXbytes)rrr r r __reduce__es  zAuthenticationString.__reduce__N)r5rrrr r r r rXc rXc@r) _MainProcesscCs2d|_d|_d|_d|_ttddd|_dS)Nr MainProcess z/mp)rW semprefix)r)r7r.rrXr,urandomr*rr r r rCus  z_MainProcess.__init__N)r5rrrCr r r r rsrrrmSIG_)&r,rvsignalrtr{r _weakrefsetrmultiprocessingrrpathabspathgetcwd ORIGINAL_DIRrz__all__rrrrrrrrXrr rBr(rurrrj__dict__itemsr>signumr9r r r r sF