��]�#�@svdddgZddlZddlZddlZddlZddlmZyejjej ��Z Wnek r�dZ YnXdd�Zdd�Z dd �ZGd d�de�ZGdd�de�ZGd d�de�Ze�aejd�ae�a[iZxPeejj��D]9\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�dS)N)r"r$r&)rrrr�runXs zBaseProcess.runcCsKt�|j|�|_|jj|_|`|`|`tj |�dS)N) r rr�sentinel� _sentinelr"r$r&rr,)rrrr�start_s zBaseProcess.startcCs|jj�dS)N)r� terminate)rrrrr8pszBaseProcess.terminatecCs/|jj|�}|dk r+tj|�dS)N)r�waitrr)r�timeout�resrrrr)vszBaseProcess.joincCs@|tkrdS|jdkr#dS|jj�|jjdkS)NTF)rrr � returncode)rrrr�is_alive�s zBaseProcess.is_alivecCs|jS)N)r*)rrrrr/�szBaseProcess.namecCs ||_dS)N)r*)rr/rrrr/�scCs|jjdd�S)NrF)r�get)rrrrr�szBaseProcess.daemoncCs||jdz daemon�)rr!rr rr rBr'�int�_exitcode_to_namer>r(r*r)r�statusrrr�__repr__�s zBaseProcess.__repr__c Cs�ddlm}m}zgy�|jdk r;|j|j�tjd�at�a |j �t}|az|jj �|j�Wd~X|jd�z|j�d}Wd|j�XWn�tk rA}zd|js�d}nMt|jdt�r|jd}n'tjjt|jd�d�d}WYdd}~Xn;d}ddl}tjjd|j�|j�YnXWd|jd|�tjj�tjj�X|S)N�)�util�contextz child process calling self.run()r� zProcess %s: z process exiting with exitcode %d)rKrQrR� _start_method�_force_start_method� itertoolsr2r�setr�_close_stdinr�_finalizer_registry�clear�_run_after_forkers�infor4�_exit_function� SystemExitr0� isinstancerL�sys�stderr�writer� tracebackr/� print_exc�stdout�flush)rrQrR�old_processrB�ercrrr� _bootstrap�sD ! zBaseProcess._bootstrap)r(� __module__�__qualname__rr3r4r7r8r)r=�propertyr/�setterrr@rBrDrCr5rOrirrrrr>s( c@seZdZdd�ZdS)rAcCs>ddlm}|�dkr+td��tt|�ffS)NrP)�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rRrn� TypeErrorrA�bytes)rrnrrr� __reduce__s zAuthenticationString.__reduce__N)r(rjrkrqrrrrrAsrAc@seZdZdd�ZdS)�_MainProcesscCsLf|_d|_d|_d|_dttjd��ddi|_dS)N�MainProcessr@� � semprefixz/mp)rr*r!rrAr�urandomr)rrrrr3(s z_MainProcess.__init__N)r(rjrkr3rrrrrr&srrrP�ZSIG�_) �__all__rr`�signalrV�_weakrefsetr�path�abspath�getcwd�ORIGINAL_DIR�OSErrorrrr �objectrrprArrrr2rrWrrMr �__dict__�itemsr/�signumr+rrrr� s0 � ""