� e f�#�@sydddgZddlZddlZddlZddlZddlmZyejjej ��Z Wnek r�dZ YnXdd�Zdd�Z dd �ZGd d�de�ZGdd�de�ZGd d�de�Ze�aejd�ae�a[iZxSeejj��D]<\ZZedd�dkr,dekr,eeeSsz'BaseProcess.__init__..)�next�_process_counterr� _identity�_config�copy�os�getpid�_parent_pidr�_target�tuple�_args�dict�_kwargs�type�__name__�join�_namer� _dangling�add)r�group�target�name�args�kwargsr�countrrr�__init__Gs #zBaseProcess.__init__cCs&|jr"|j|j|j�ndS)zQ Method to be run in sub-process; can be overridden in sub-class N)r"r$r&)rrrr�runXs zBaseProcess.runcCs9t�|j|�|_|jj|_tj|�dS)z% Start child process N)r rr�sentinel� _sentinelrr,)rrrr�start_s zBaseProcess.startcCs|jj�dS)zT Terminate process; sends SIGTERM signal or uses TerminateProcess() N)r� terminate)rrrrr8mszBaseProcess.terminatecCs2|jj|�}|dk r.tj|�ndS)z5 Wait until child process terminates N)r�waitrr)rZtimeout�resrrrr)sszBaseProcess.joincCs@|tkrdS|jdkr#dS|jj�|jjdkS)z1 Return whether process is alive TNF)rrr � returncode)rrrr�is_alive}s zBaseProcess.is_alivecCs|jS)N)r*)rrrrr/�szBaseProcess.namecCs ||_dS)N)r*)rr/rrrr/�scCs|jjdd�S)z4 Return whether process is a daemon rF)r�get)rrrrr�szBaseProcess.daemoncCs||jd�szBaseProcess.authkeycCst|�|jdN)�AuthenticationStringr)rr>rrrr>�scCs#|jdkr|jS|jj�S)zM Return exit code of process or `None` if it has yet to stop N)rr )rrrr�exitcode�szBaseProcess.exitcodecCs-|tkrtj�S|jo(|jjSdS)zU Return identifier (PID) of process or `None` if it has yet to start N)rrr r�pid)rrrr�ident�s zBaseProcess.identcCs0y|jSWntk r+td��YnXdS)z{ Return a file descriptor (Unix) or handle (Windows) suitable for waiting for process termination. zprocess not startedN)r6�AttributeError� ValueError)rrrrr5�s zBaseProcess.sentinelcCs�|tkrd}n]|jtj�kr3d}n?|jdkrKd}n'|jj�dk rl|j}nd}t|�tkr�|dkr�d}q�dt j ||�}ndt|�j|j||j r�dp�d fS) NZstarted�unknown�initialrZstoppedzstopped[%s]z<%s(%s, %s%s)>z daemon�)rr!rr rr r@r'�int�_exitcode_to_namer=r(r*r)rZstatusrrr�__repr__�s zBaseProcess.__repr__c(Cs�ddlm}m}z�y�|jdk r>|j|j�ntjd�at�a t jdk r�y#t jj�t tj�t _Wq�ttfk r�Yq�Xnt}|az|jj�|j�Wd~X|jd�z|j�d}Wd|j�XWn�tk r�}zd|js+d}nMt|jdt�rQ|jd}n't jjt|jd�d�d}WYdd}~Xn;d}ddl }t jjd|j!�|j"�YnXWd|jd|�t j#j$�t jj$�X|S)N�)�util�contextz child process calling self.run()r� zProcess %s: z process exiting with exitcode %d)%rGrLrMZ _start_methodZ_force_start_method� itertoolsr2r�setr�sys�stdin�close�openr�devnull�OSErrorrDrZ_finalizer_registry�clearZ_run_after_forkers�infor4Z_exit_function� SystemExitr0� isinstancerH�stderr�writer� tracebackr/� print_exc�stdout�flush)rrLrMZold_processr@�er]rrr� _bootstrap�sN ! zBaseProcess._bootstrap)r(� __module__�__qualname__�__doc__rr3r4r7r8r)r<�propertyr/�setterrr>r@rBrAr5rJrbrrrrr>s* c@seZdZdd�ZdS)r?cCsAddlm}|�dkr.td��ntt|�ffS)NrK)�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rMrh� TypeErrorr?�bytes)rrhrrr� __reduce__s zAuthenticationString.__reduce__N)r(rcrdrkrrrrr?sr?c@seZdZdd�ZdS)�_MainProcesscCsNf|_d|_d|_d|_ittjd��d6dd6|_dS)NZMainProcess� r>z/mpZ semprefix)rr*r!rr?r�urandomr)rrrrr3*s z_MainProcess.__init__N)r(rcrdr3rrrrrl(srlrK�ZSIG�_) �__all__rrQ�signalrO�_weakrefsetr�path�abspath�getcwdZORIGINAL_DIRrVrrr �objectrrjr?rlrr2rrPrrIr �__dict__�itemsr/Zsignumr+rrrr� s0 � ""