��Yf�#�@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__..)�AssertionError�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)zQ Method to be run in sub-process; can be overridden in sub-class N)r#r%r')rrrr�runXs zBaseProcess.runcCs�|jdkstd��|jtj�ks<td��tjjd�s[td��t�|j |�|_|jj |_|`|` |`tj|�dS)z% Start child process Nzcannot start a process twicez:can only start a process object created by current processrz3daemonic processes are not allowed to have children)rrr"r r!rr�getr r�sentinel� _sentinelr#r%r'rr-)rrrr�start_s zBaseProcess.startcCs|jj�dS)zT Terminate process; sends SIGTERM signal or uses TerminateProcess() N)r� terminate)rrrrr:pszBaseProcess.terminatecCsk|jtj�ks!td��|jdk s<td��|jj|�}|dk rgtj|�dS)z5 Wait until child process terminates zcan only join a child processNzcan only join a started process)r"r r!rr�waitrr)rZtimeout�resrrrr*vs !zBaseProcess.joincCsa|tkrdS|jtj�ks1td��|jdkrDdS|jj�|jjdkS)z1 Return whether process is alive Tzcan only test a child processNF)rr"r r!rrr � returncode)rrrr�is_alive�s! zBaseProcess.is_alivecCs|jS)N)r+)rrrrr0�szBaseProcess.namecCs(t|t�std��||_dS)Nzname must be a string)� isinstancerrr+)rr0rrrr0�scCs|jjdd�S)z4 Return whether process is a daemon rF)rr6)rrrrr�szBaseProcess.daemoncCs,|jdkstd��||jdz daemon�)rr"r r!rr rBr(�int�_exitcode_to_namer6r)r+r)rZstatusrrr�__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)rIrNrOZ _start_methodZ_force_start_method� itertoolsr3r�setrZ_close_stdinrZ_finalizer_registry�clearZ_run_after_forkers�infor5Z_exit_function� SystemExitr1r?rJ�sys�stderr�writer� tracebackr0� print_exc�stdout�flush)rrNrOZold_processrB�erYrrr� _bootstrap�sD ! zBaseProcess._bootstrap)r)� __module__�__qualname__�__doc__rr4r5r9r:r*r>�propertyr0�setterrr@rBrDrCr7rLr^rrrrr>s* c@seZdZdd�ZdS)rAcCs>ddlm}|�dkr+td��tt|�ffS)NrM)�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rOrd� TypeErrorrA�bytes)rrdrrr� __reduce__s zAuthenticationString.__reduce__N)r)r_r`rgrrrrrAsrAc@seZdZdd�ZdS)�_MainProcesscCsLf|_d|_d|_d|_dttjd��ddi|_dS)NZMainProcessr@� Z semprefixz/mp)rr+r"rrAr �urandomr)rrrrr4(s z_MainProcess.__init__N)r)r_r`r4rrrrrh&srhrM�ZSIG�_) �__all__r rV�signalrQ�_weakrefsetr�path�abspath�getcwdZORIGINAL_DIR�OSErrorrrr �objectrrfrArhrr3rrRrrKr �__dict__�itemsr0Zsignumr,rrrr� s0 � ""