File: //home/arjun/projects/env/lib64/python3.10/site-packages/billiard/__pycache__/util.cpython-310.pyc
o
!we� � @ sV d dl Z d dlZd dlZd dlZzd dlZW n
ey# d dlZY nw zd dlmZ W n
ey9 dd� ZY nw d dl m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZ ddlmZ g d�Zd ZdZd Z d
Z d Z d Z d
Z dZ!dZ"dZ#dZ$da%da&dd� Z'dd� Z(dd� Z)dd� Z*dd � Z+d d � Z,d d � Z-d)d!d"�Z.d#d$� Z/d%d&� Z0d'd(� Z1dS )*� N)� _args_from_interpreter_flagsc C st ddddddddd d
d �
} g }| � � D ]\}}ttj|�}|d kr*|�d
|| � qtjD ] }|�d| � q.|S )zrReturn a list of command-line arguments reproducing the current
settings in sys.flags and sys.warnoptions.�d�O�B�s�S�E�v�b�R�3)
�debug�optimize�dont_write_bytecode� no_user_site�no_site�ignore_environment�verbose�
bytes_warning�hash_randomization� py3k_warningr �-z-W)�items�getattr�sys�flags�append� warnoptions)� flag_opt_map�args�flag�optr � r" �F/home/arjun/projects/env/lib/python3.10/site-packages/billiard/util.pyr s( � �
r )
�_afterfork_registry�_afterfork_counter�_exit_function�_finalizer_registry�_finalizer_counter�Finalize�ForkAwareLocal�ForkAwareThreadLock� get_temp_dir�
is_exiting�register_after_fork�_run_after_forkers�_run_finalizers� )� get_errno)� sub_debugr
�info� sub_warning�
get_logger�
log_to_stderrr, r. r- r) r+ r* �SUBDEBUG�
SUBWARNING� � �
� � � �( �multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc O �& t rt jt| g|�R i |�� d S d S �N)�_logger�logr8 ��msgr �kwargsr" r" r# r3 ` � �r3 c O rB rC )rD rE �DEBUGrF r" r" r# r
e rI r
c O rB rC )rD rE �INFOrF r" r" r# r4 j rI r4 c O rB rC )rD rE r9 rF r" r" r# r5 o rI r5 c O rB rC )rD rE �WARNINGrF r" r" r# �warnings rI rM c O rB rC )rD rE �ERRORrF r" r" r# �errorw rI rO c C s� ddl } | �� zMtsH| �t�adt_| �td� | �td� t t
d�r/t
� t � t
�
t � n t
j�t di f� t
j�t di f� W | �� tS W | �� tS W | �� tS | �� w )z0
Returns logger used by multiprocessing
r Nr8 r9 �
unregisterr" )�logging� _acquireLockrD � getLogger� LOGGER_NAME� propagate� addLevelNamer8 r9 �hasattr�atexitrP r& �register�
_exithandlers�remover � _releaseLock)rQ r" r" r# r6 | s,
��
�r6 c C sJ ddl }t� }|�t�}|�� }|�|� |�|� | r!|�| � dat S )zB
Turn on logging and add a handler which prints to stderr
r NT)
rQ r6 � Formatter�DEFAULT_LOGGING_FORMAT�
StreamHandler� setFormatter�
addHandler�setLevel�_log_to_stderrrD )�levelrQ �logger� formatter�handlerr" r" r# r7 � s
r7 c C s� t j�d�s t� �z:dt jv r-t�� } | �d� | �d�}| � d�}|�
t |� |d W S t �
� }t j�d�}|�
t t �|�� |jW S tyM t� �w )zE
Return the current value of the parent process death signal
�linux�cffi� int prctl (int __option, ...);zint *Nr � libc.so.6)r �platform�
startswith�OSError�modulesri �FFI�cdef�new�dlopen�prctl�PR_GET_PDEATHSIG�ctypes�c_int�cdll� LoadLibrary�byref�value� Exception)�ffi�arg�C�sig�libcr" r" r# �
get_pdeathsig� s"
�r� c
C s� t j�d�s
td��z2dt jv r+t�� }|�d� |�d�}|� t
|� d| �� W dS t j
�d�}|� t
t �| �� W dS tyM } ztd�|�d}~ww ) am
Set the parent process death signal of the calling process to sig
(either a signal value in the range 1..maxsig, or 0 to clear).
This is the signal that the calling process will get when its parent dies.
This value is cleared for the child of a fork(2) and
(since Linux 2.4.36 / 2.6.23) when executing a set-user-ID or set-group-ID binary.
rh z$pdeathsig is only supported on linuxri rj N�intrk z(An error occured while setting pdeathsig)r rl rm rn ro ri rp rq rs rt �PR_SET_PDEATHSIG�castrv rx ry rw r| )r� r} r r� �er" r" r# �
set_pdeathsig� s
��r� c s t �� �� fdd��}|S )z&
Automatic retry after EINTR.
c
sJ z� | i |��W S t y# } zt|�tjkr� W Y d }~nd }~ww qrC )rn r2 �errno�EINTR)r rH �exc��funcr" r# �wrapped� s ����z _eintr_retry.<locals>.wrapped)� functools�wraps)r� r� r" r� r# � _eintr_retry� s r� rC )2r r� r� rX ri � ImportErrorrv �
subprocessr �multiprocessing.utilr$ r% r& r' r( r) r* r+ r, r- r. r/ r0 �compatr2 �__all__ru r� �NOTSETr8 rJ rK r9 rL rN rT r^ rD rc r3 r
r4 r5 rM rO r6 r7 r� r� r� r" r" r" r# �<module> sR � �<