3 � f�#�@sdddgZddlZddlZddlZddlZddlmZyejjej ��Z Wnek rbdZ YnXdd�Zdd�Z dd �ZGd d�de�ZGdd�de�ZGd d�de�Ze�aejd�ae�a[iZxSsz'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)zQ Method to be run in sub-process; can be overridden in sub-class N)r"r$r&)rrrr�runXszBaseProcess.runcCs6t�|j|�|_|jj|_|`|`|`tj |�dS)z% Start child process N) r rr�sentinel� _sentinelr"r$r&rr,)rrrr�start_s zBaseProcess.startcCs|jj�dS)zT Terminate process; sends SIGTERM signal or uses TerminateProcess() N)r� terminate)rrrrr8pszBaseProcess.terminatecCs"|jj|�}|dk rtj|�dS)z5 Wait until child process terminates N)r�waitrr)rZtimeout�resrrrr)vszBaseProcess.joincCsB|tkrdS|jdkrdS|jj�}|dkr0dStj|�dSdS)z1 Return whether process is alive TNF)rrr rr)r� returncoderrr�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<dS)z1 Set whether process is a daemon rN)r)rZdaemonicrrrr�scCs |jdS)N�authkey)r)rrrrr>�szBaseProcess.authkeycCst|�|jd<dS)z2 Set authorization key of process r>N)�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�s zBaseProcess.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�szBaseProcess.identcCs(y|jStk 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�szBaseProcess.sentinelcCs�|tkrd}n>|jtj�kr"d}n*|jdkr2d}n|jj�dk rH|j}nd}t|�tkrv|dkrfd}ndt j ||�}dt|�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 CsJddlm}m}�zy||jdk r,|j|j�tjd�at�a |j �t}|az|jj �|j�Wd~X|jd�z|j�d}Wd|j�XWn�tk r�}zL|js�d}n:t|jdt�r�|jd}ntjjt|jd�d�d}WYdd}~Xn2d}ddl}tjjd|j�|j�YnXWd|jd|�|j�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�setrZ_close_stdinrZ_finalizer_registry�clearZ_run_after_forkers�infor4Z_exit_function� SystemExitr0� isinstancerH�sys�stderr�writer� tracebackr/� print_excZ_flush_std_streams)rrLrMZold_processr@�erXrrr� _bootstrap�sB zBaseProcess._bootstrap)N)r(� __module__�__qualname__�__doc__rr3r4r7r8r)r<�propertyr/�setterrr>r@rBrAr5rJr[rrrrr>s* c@seZdZdd�ZdS)r?cCs,ddlm}|�dkrtd��tt|�ffS)NrK)�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rMra� TypeErrorr?�bytes)rrarrr� __reduce__s zAuthenticationString.__reduce__N)r(r\r]rdrrrrr?sr?c@seZdZdd�ZdS)�_MainProcesscCs2f|_d|_d|_d|_ttjd��dd�|_dS)NZMainProcess� z/mp)r>Z semprefix)rr*r!rr?r�urandomr)rrrrr3-sz_MainProcess.__init__N)r(r\r]r3rrrrre+srerK�ZSIG�_) �__all__rrU�signalrO�_weakrefsetr�path�abspath�getcwdZORIGINAL_DIR�OSErrorrrr �objectrrcr?rerr2rrPrrIr �__dict__�itemsr/Zsignumr+rrrr� s2 `