File: //home/arjun/projects/env/lib/python3.10/site-packages/billiard/__pycache__/process.cpython-310.pyc
o
!we/+ � @ s6 d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z
z
e j � e �
� �ZW n ey9 dZY nw 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 ]\Z#Z$e#dd� dkr�de#vr�e#e e$ < q�e� Z%dS )� N)�WeakSet��process)� BaseProcess�Process�current_process�active_childrenc C � t S )z@
Return process object representing the current process
)�_current_process� r r �I/home/arjun/projects/env/lib/python3.10/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 d S tttfy Y d S w r
)�flush�AttributeError�EnvironmentError�NotImplementedError)�fr r r � _maybe_flush6 s
�r c C s( z| � W tt�S t y g Y S w )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 � �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
|�| _|pAt| �jd d�dd� | jD �� | _|d urJ|| _td urSt�| � 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>` s � 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 �_kw�countr r r �__init__S s$
��
zBaseProcess.__init__c C s" | j r| j | ji | j�� dS 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 s J d��| jt�� ksJ 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 d S r
)r �closer r r r rH | s
�zBaseProcess.closec C s | j �� dS )zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)r � terminater r r r rI � s zBaseProcess.terminatec C s d| _ | �� d S )NT)r; rI r r r r �terminate_controlled� s z BaseProcess.terminate_controlledc C sV | j t�� ks J d��| jdusJ d��| j�|�}|dur)t�| � | �� dS 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 rH )r �timeout�resr r r r6 � s
�zBaseProcess.joinc C sF | t u rdS | jt�� ksJ d��| jdu rdS | 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 � | j S r
)r7 r r r r r> � s zBaseProcess.namec C s t |t�s J 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 s J 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 rW � s
zBaseProcess.authkeyc C s t |�| jd< dS )z2
Set authorization key of process
rW N)�AuthenticationStringr* )r rW r r r rW � 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
NrP r r r r �exitcode� s
zBaseProcess.exitcodec C s | t u rt�� S | jo| jjS )zU
Return identifier (PID) of process or `None` if it has yet to start
)r
r, r- r �pidr r r r �ident� s zBaseProcess.identc C s z| j W S ty td��w )z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not started)rF r �
ValueErrorr r r r rE � s
�zBaseProcess.sentinelc C r r
)r( r r r r �_counter� � zBaseProcess._counterc C r r
)r r r r r r � r^ zBaseProcess._childrenc C rR r
)rW r r r r �_authkey� � zBaseProcess._authkeyc C rR r
)r8 r r r r � _daemonic� r` zBaseProcess._daemonicc C s | j �d�S )N�tempdirrT r r r r �_tempdir� s zBaseProcess._tempdirc C s� | t u rd}n | jt�� krd}n| jd u rd}n
| j�� d ur$| j}nd}t|�tu r;|dkr3d}ndt �
||� }dt| �j | j || j
rHdpId f S )
N�started�unknown�initialr �stoppedz stopped[%s]z<%s(%s, %s%s)>z daemon� )r
r. r, r- r r rY r4 �int�_exitcode_to_namerU r5 r7 r8 )r �statusr r r �__repr__ s
�zBaseProcess.__repr__c C s� ddl m}m} �z7z�| jd ur|�| j� t�d�at� a t
j d ur=z
t
j � � t
tj�t
_ W n tttfy< Y nw t}t| � tjjj}t|�� �}|�d � |D ]}|rat || tj �snt� |�j D ]}|� � qgqUt!�"� t_#z |j$�%� |�&� W ~n~w |�'d| j(� z | �)� d}W |�*� n|�*� w W ny t+y� } z8| j,s�d}n,t | j,d t-�r�| j,d }n t
j.�/t0| j,d �d � t1t
j.� t | j,d t0�r�dnd}W Y d } ~ nOd } ~ w d}|j2d| j3dd��sdd l4}
t
j.�/d | j3 � |
�5� Y W |�'d
| j(|� t1t
j6� t1t
j.� |S W |�'d
| j(|� t1t
j6� t1t
j.� |S W |�'d
| j(|� t1t
j6� t1t
j.� |S |�'d
| j(|� t1t
j6� t1t
j.� w ) N� )�util�contextz#child process %s calling self.run()r �
z
Process %sT)�exc_infoz Process %s:
z#process %s exiting with exitcode %d)7rh rn ro �
_start_method�_force_start_method� itertoolsrB r( �setr �sys�stdinrH �openr, �devnullr �OSErrorr\ r
r �logging�Logger�manager�
loggerDictr �keys�appendrS � PlaceHolder� getLogger�handlers�
createLock� threading�RLock�_lock�_finalizer_registry�clear�_run_after_forkers�inforZ rD �_exit_function�
SystemExitr? ri �stderr�writer# r �errorr> � traceback� print_exc�stdout) r rn ro � old_processr~ � logger_namesr> �handlerrY �excr� r r r �
_bootstrap s�
�
�
�
���
��
���
��
zBaseProcess._bootstrapr
) r5 �
__module__� __qualname__�__doc__r rC rD rG rH rI rJ r6 rO rQ �propertyr> �setterr8 rW rY r[ rZ rE r] r r_ ra rc rl r� r r r r r I sZ
�
r c @ � e Zd Zdd� ZdS )rX c C s, ddl m} |� d u rtd��tt| �ffS )Nrm )�get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)ro r� r rX �bytes)r r� r r r �
__reduce__e s
�z AuthenticationString.__reduce__N)r5 r� r� r� r r r r rX c � rX c @ r� )� _MainProcessc C s2 d| _ d| _d | _d | _tt�d��dd�| _d S )Nr � MainProcess� z/mp)rW � semprefix)r) r7 r. r rX r, �urandomr* r r r r rC u s �z_MainProcess.__init__N)r5 r� r� rC r r r r r� s r� r� rm � �SIG�_)&r, rv �signalrt r{ r� � _weakrefsetr �multiprocessingr r �path�abspath�getcwd� ORIGINAL_DIRrz �__all__r r r r r r r� rX r� r
rB r( ru r r rj �__dict__�itemsr> �signumr9 r r r r �<module> sF �
�