File: //usr/local/lib/python3.9/site-packages/billiard/__pycache__/process.cpython-39.pyc
a
X>h/+ � @ s< d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z
ze j � e �
� �ZW n eyr dZY n0 g d�Zdd� Zdd� Zd d
� Zd d � Zefd
d�ZG dd� d�ZG dd� de�ZG dd� de�Ze� ae�d�a e � a [eZ i Z ej!�"� D ]0\Z#Z$e#dd� dk�r de#v�r e#e e$ < �q e� Z%dS )� N)�WeakSet��process)� BaseProcess�Process�current_process�active_childrenc C s t S )z@
Return process object representing the current process
)�_current_process� r
r
�:/usr/local/lib/python3.9/site-packages/billiard/process.pyr # s r c C s | a t_ d S �N)r �_mprocr r
r
r �_set_current_process* s r c C s* t t�D ] } | j�� d urt�| � qd S r )�list� _children�_popen�poll�discard)�pr
r
r �_cleanup/ s r c
C s* z | � � W n tttfy$ Y n0 d S r )�flush�AttributeError�EnvironmentError�NotImplementedError)�fr
r
r � _maybe_flush6 s r c C s* z
| � W n t y g Y S 0 tt�S )zN
Return list of process objects corresponding to live child processes
)� TypeErrorr r )r r
r
r r = s
r c @ s2 e Zd ZdZdd� Zddddi dfdd�Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
d5dd�Z dd� Z dd� Z
edd� �Zejdd� �Zedd � �Zejd d � �Zed d � �Zejd d � �Zed!d"� �Zed#d$� �ZeZed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �Zed-d.� �Zed/d0� �Zd1d2� Z d3d4� Z dS )6r z�
Process objects represent activity that is run in a separate process
The class is analogous to `threading.Thread`
c C s
t � �d S r )r ��selfr
r
r �_PopenP s zBaseProcess._PopenNr
c K s� |d u sJ d��t t�}tj|f | _tj�� | _t�� | _d | _ || _
t |�| _ t
|�| _|p�t| �jd d�dd� | jD �� | _|d ur�|| _td ur�t�| � d| _d S )Nz#group argument must be None for now�-�:c s s | ]}t |�V qd S r )�str)�.0�ir
r
r � <genexpr>` � z'BaseProcess.__init__.<locals>.<genexpr>F)�next�_process_counterr � _identity�_config�copy�os�getpid� _parent_pidr �_target�tuple�_args�dict�_kwargs�type�__name__�join�_name�daemon� _dangling�add�_controlled_termination) r �group�target�name�args�kwargsr8 Z_kw�countr
r
r �__init__S s$
��
zBaseProcess.__init__c C s | j r| j | ji | j�� dS )zQ
Method to be run in sub-process; can be overridden in sub-class
N)r/ r1 r3 r r
r
r �runi s zBaseProcess.runc C sR | j du sJ d��| jt�� ks(J d��t� | �| �| _ | j j| _t� | � dS )z%
Start child process
Nz cannot start a process twicez:can only start a process object created by current process)
r r. r, r- r r �sentinel� _sentinelr r: r r
r
r �startp s �
zBaseProcess.startc C s | j d ur| j �� d S r )r �closer r
r
r rG | s
zBaseProcess.closec C s | j �� dS )zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)r � terminater r
r
r rH � s zBaseProcess.terminatec C s d| _ | �� d S )NT)r; rH r r
r
r �terminate_controlled� s z BaseProcess.terminate_controlledc C sR | j t�� ksJ d��| jdus(J d��| j�|�}|durNt�| � | �� dS )z5
Wait until child process terminates
z can only join a child processNz can only join a started process)r. r, r- r �waitr r rG )r �timeout�resr
r
r r6 � s
zBaseProcess.joinc C sF | t u r dS | jt�� ks"J d��| jdu r0dS | j�� | jjdu S )z1
Return whether process is alive
Tz can only test a child processNF)r r. r, r- r r �
returncoder r
r
r �is_alive� s
zBaseProcess.is_alivec C s | j d u rdS | j �� d u S )NF�r r r r
r
r � _is_alive� s
zBaseProcess._is_alivec C s | j S r )r7 r r
r
r r> � s zBaseProcess.namec C s t |t�sJ d��|| _d S )Nzname must be a string)�
isinstancer" r7 )r r> r
r
r r> � s c C s | j �dd�S )z4
Return whether process is a daemon
r8 F�r* �getr r
r
r r8 � s zBaseProcess.daemonc C s | j du sJ d��|| jd< dS )z1
Set whether process is a daemon
Nzprocess has already startedr8 )r r* )r �daemonicr
r
r r8 � s c C s
| j d S )N�authkey)r* r r
r
r rU � s zBaseProcess.authkeyc C s t |�| jd< dS )z2
Set authorization key of process
rU N)�AuthenticationStringr* )r rU r
r
r rU � s c C s | j du r| j S | j �� S )zM
Return exit code of process or `None` if it has yet to stop
NrO r r
r
r �exitcode� s
zBaseProcess.exitcodec C s" | t u rt�� S | jo | jjS dS )zU
Return identifier (PID) of process or `None` if it has yet to start
N)r r, r- r �pidr r
r
r �ident� s zBaseProcess.identc C s( z| j W S ty" td��Y n0 dS )z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)rE r �
ValueErrorr r
r
r rD � s zBaseProcess.sentinelc C s t S r )r( r r
r
r �_counter� s zBaseProcess._counterc C s t S r )r r r
r
r r � s zBaseProcess._childrenc C s | j S r )rU r r
r
r �_authkey� s zBaseProcess._authkeyc C s | j S r )r8 r r
r
r � _daemonic� s zBaseProcess._daemonicc C s | j �d�S )N�tempdirrR r r
r
r �_tempdir� s zBaseProcess._tempdirc C s� | t u rd}n>| jt�� kr"d}n*| jd u r2d}n| j�� d urH| j}nd}t|�tu rv|dkrfd}ndt �
||� }dt| �j | j || j
r�dp�d f S )
N�started�unknown�initialr �stoppedz stopped[%s]z<%s(%s, %s%s)>z daemon� )r r. r, r- r r rW r4 �int�_exitcode_to_namerS r5 r7 r8 )r �statusr
r
r �__repr__ s
�zBaseProcess.__repr__c C sd ddl m}m} �z&�z&| jd ur.|�| j� t�d�at� a t
j d ur|zt
j � � t
tj�t
_ W n tttfyz Y n0 t}t| � tjjj}t|�� �}|�d � |D ]2}|r�t || tj �s�t� |�j D ] }|� � q�q�t!�"� t_#z|j$�%� |�&� W ~n~0 |�'d| j(� z| �)� d}W |�*� n
|�*� 0 W n� t+�y� } zv| j,�s\d}n\t | j,d t-��rz| j,d }n>t
j.�/t0| j,d �d � t1t
j.� t | j,d t0��r�dnd}W Y d } ~ nNd } ~ 0 d}|j2d| j3dd��s dd l4}
t
j.�/d | j3 � |
�5� Y n0 W |�'d
| j(|� t1t
j6� t1t
j.� n&|�'d
| j(|� t1t
j6� t1t
j.� 0 |S ) N� )�util�contextz#child process %s calling self.run()r �
z
Process %sT)�exc_infoz Process %s:
z#process %s exiting with exitcode %d)7rd rj rk Z
_start_methodZ_force_start_method� itertoolsrA r( �setr �sys�stdinrG �openr, �devnullr �OSErrorrZ r r �logging�Logger�manager�
loggerDictr �keys�appendrQ � PlaceHolder� getLogger�handlers�
createLock� threading�RLock�_lockZ_finalizer_registry�clearZ_run_after_forkers�inforX rC Z_exit_function�
SystemExitr? re �stderr�writer" r �errorr> � traceback� print_exc�stdout) r rj rk Z old_processrx Z logger_namesr> �handlerrW �excr� r
r
r �
_bootstrap st
�
.�
��
zBaseProcess._bootstrap)N) r5 �
__module__� __qualname__�__doc__r rB rC rF rG rH rI r6 rN rP �propertyr> �setterr8 rU rW rY rX rD r[ r r\ r] r_ rh r� r
r
r
r r I sX �
r c @ s e Zd Zdd� ZdS )rV c C s, ddl m} |� d u r td��tt| �ffS )Nri )�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)rk r� r rV �bytes)r r� r
r
r �
__reduce__e s
�z AuthenticationString.__reduce__N)r5 r� r� r� r
r
r
r rV c s rV c @ s e Zd Zdd� ZdS )� _MainProcessc C s2 d| _ d| _d | _d | _tt�d��dd�| _d S )Nr
� MainProcess� z/mp)rU Z semprefix)r) r7 r. r rV r, �urandomr* r r
r
r rB u s �z_MainProcess.__init__N)r5 r� r� rB r
r
r
r r� s s r� ri � ZSIG�_)&r, rp �signalrn ru r � _weakrefsetr �multiprocessingr r
�path�abspath�getcwdZ ORIGINAL_DIRrt �__all__r r r r r r r� rV r� r rA r( ro r r rf �__dict__�itemsr> �signumr9 r
r
r
r �<module>
s@