U .e++@sBddlZddlZddlZddlZddlZddlZddlmZddlm Z zej e ZWnek rtdZYnXddddgZddZd d Zd d Zd dZefddZGdddZGdddeZGdddeZeaedaea[eZiZ ej!"D]0\Z#Z$e#dddkrde#kre#e e$ <qeZ%dS)N)WeakSetprocess BaseProcessProcesscurrent_processactive_childrencCstS)z@ Return process object representing the current process )_current_processr r 4/tmp/pip-unpacked-wheel-39f38r4u/billiard/process.pyr#scCs|at_dSN)r _mprocrr r r _set_current_process*srcCs*ttD]}|jdk rt|qdSr )list _children_popenpolldiscard)pr r r _cleanup/s rc Cs,z |Wntttfk r&YnXdSr )flushAttributeErrorEnvironmentErrorNotImplementedError)fr r r _maybe_flush6s rcCs,z |Wntk r"gYSXttS)zN Return list of process objects corresponding to live child processes ) TypeErrorrr)rr r r r=s   c@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` cCs tdSr )rselfr r r _PopenPszBaseProcess._PopenNr c Ks|dkstdtt}tj|f|_tj|_t|_ d|_ ||_ t ||_ t||_|pt|jdddd|jD|_|dk r||_tdk rt|d|_dS)Nz#group argument must be None for now-:css|]}t|VqdSr )str).0ir r r `sz'BaseProcess.__init__..F)AssertionErrornext_process_counterr _identity_configcopyosgetpid _parent_pidr_targettuple_argsdict_kwargstype__name__join_namedaemon _danglingadd_controlled_termination) rgrouptargetnameargskwargsr8Z_kwcountr r r __init__Ss$     zBaseProcess.__init__cCs|jr|j|j|jdS)zQ Method to be run in sub-process; can be overridden in sub-class N)r/r1r3rr r r runiszBaseProcess.runcCsR|jdkstd|jtks(tdt|||_|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,r-rrsentinel _sentinelrr:rr r r startps  zBaseProcess.startcCs|jdk r|jdSr )rcloserr r r rG|s zBaseProcess.closecCs|jdS)zT Terminate process; sends SIGTERM signal or uses TerminateProcess() N)r terminaterr r r rHszBaseProcess.terminatecCsd|_|dS)NT)r;rHrr r r terminate_controlledsz BaseProcess.terminate_controlledcCsR|jtkstd|jdk s(td|j|}|dk rFt||dS)z5 Wait until child process terminates zcan only join a child processNzcan only join a started process) r.r,r-r&rwaitrrrG)rtimeoutresr r r r6s   zBaseProcess.joincCsF|tkr dS|jtks"td|jdkr0dS|j|jjdkS)z1 Return whether process is alive Tzcan only test a child processNF)r r.r,r-r&rr returncoderr r r is_alives  zBaseProcess.is_alivecCs|jdkrdS|jdkS)NFrrrr r r _is_alives zBaseProcess._is_alivecCs|jSr )r7rr r r r>szBaseProcess.namecCst|tstd||_dS)Nzname must be a string) isinstancer"r&r7)rr>r r r r>scCs|jddS)z4 Return whether process is a daemon r8Fr*getrr r r r8szBaseProcess.daemoncCs |jdkstd||jd<dS)z1 Set whether process is a daemon Nzprocess has already startedr8)rr&r*)rdaemonicr r r r8scCs |jdS)Nauthkey)r*rr r r rUszBaseProcess.authkeycCst||jd<dS)z2 Set authorization key of process rUN)AuthenticationStringr*)rrUr r r rUscCs|jdkr|jS|jS)zM Return exit code of process or `None` if it has yet to stop NrOrr r r exitcodes zBaseProcess.exitcodecCs"|tkrtS|jo|jjSdS)zU Return identifier (PID) of process or `None` if it has yet to start N)r r,r-rpidrr r r identszBaseProcess.identcCs*z|jWStk r$tdYnXdS)z{ Return a file descriptor (Unix) or handle (Windows) suitable for waiting for process termination. zprocess not startedN)rEr ValueErrorrr r r rDszBaseProcess.sentinelcCstSr )r(rr r r _counterszBaseProcess._countercCstSr )rrr r r rszBaseProcess._childrencCs|jSr )rUrr r r _authkeyszBaseProcess._authkeycCs|jSr )r8rr r r _daemonicszBaseProcess._daemoniccCs |jdS)NtempdirrRrr r r _tempdirszBaseProcess._tempdircCs|tkrd}n>|jtkr"d}n*|jdkr2d}n|jdk rH|j}nd}t|tkrv|dkrfd}ndt ||}dt|j |j ||j rdpd fS) Nstartedunknowninitialrstoppedz stopped[%s]z<%s(%s, %s%s)>z daemon)r r.r,r-rrrWr4int_exitcode_to_namerSr5r7r8)rstatusr r r __repr__s"   zBaseProcess.__repr__c Cs6ddlm}m}zz|j dk r.| |j t da tatjdk r~ztjttjt_Wntttfk r|YnXt}t|tjjj}t|}| d|D]2}|rt!||tj"st#|j$D] }|%qqt&'t_(z|j)*|+W5~X|d|jz|-d}W5|,XWnt.k r} zn| j/sVd}n\t!| j/dt0rt| j/d}n>tj1t2| j/ddttjt!| j/dt2rdnd}W5d} ~ XYnFd}|j3d|j4dd sddl5} tj1d |j4| 6YnXW5|d|j|ttjttjX|S) N)utilcontextz#process %s exiting with exitcode %dz#child process %s calling self.run()r z Process %sT)exc_infoz Process %s: )7rdrjrkinforXrsysstdoutstderrZ _start_methodZ_force_start_method itertoolsrAr(setrstdinrGopenr,devnullrOSErrorrZr rloggingLoggermanager loggerDictrkeysappendrQ PlaceHolder getLoggerhandlers createLock threadingRLock_lockZ_finalizer_registryclearZ_run_after_forkersZ_exit_functionrC SystemExitr?rewriter"errorr> traceback print_exc) rrjrkrWZ old_processr{Z logger_namesr>handlerexcrr r r _bootstrapsl               *  zBaseProcess._bootstrap)N)r5 __module__ __qualname____doc__rrBrCrFrGrHrIr6rNrPpropertyr>setterr8rUrWrYrXrDr[rr\r]r_rhrr r r r rIs\                  c@seZdZddZdS)rVcCs,ddlm}|dkrtdtt|ffS)Nri)get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rkrrrVbytes)rrr r r __reduce__es   zAuthenticationString.__reduce__N)r5rrrr r r r rVcsrVc@seZdZddZdS) _MainProcesscCs2d|_d|_d|_d|_ttddd|_dS)Nr MainProcess z/mp)rUZ semprefix)r)r7r.rrVr,urandomr*rr r r rBus z_MainProcess.__init__N)r5rrrBr r r r rssrriZSIG_)&r,rosignalrrrxr _weakrefsetrmultiprocessingrr pathabspathgetcwdZ ORIGINAL_DIRrw__all__rrrrrrrrVrr rAr(rsrrrf__dict__itemsr>signumr9r r r r  s@