File: //usr/lib64/python3.9/site-packages/borg/helpers/__pycache__/process.cpython-39.opt-1.pyc
a
HZ�h�: � @ sv d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z ddl m
Z
mZmZmZ ddlmZ e� ZddlmZmZmZmZ e jdd� �Zd d
� Ze jd d �d
d��ZG dd� de �Z G dd� de �Z G dd� de �Z G dd� de �Z e jdd� �Z!dd� Z"G dd � d �Z#e#� Z$d d � Z%d*e&d �d!d"�Z'ej(fd#d$�Z)d+d%d&�Z*e jd,d(d)��Z+dS )-� N� )� __version__)�is_win32�is_linux�
is_freebsd� is_darwin)�
create_logger)� EXIT_SUCCESS� EXIT_WARNING�EXIT_SIGNAL_BASE�Errorc
c s@ ddl m} | � }t�� }|r�t}zVz|d fV W n* ty\ } z|j}W Y d }~n
d }~0 0 W t�d| � t� |� nt�d| � t� |� 0 t�
� t�� }|r�t� d� t� d� t� d� t� d� t�
tjtj�}t�|d� t�|d� | � }z$||fV W t� d� t�|d� nt� d� t�|d� 0 d S )Nr )�get_process_idz:Daemonizing: Foreground process (%s, %s, %s) is now dying.r �/� )�platformr
�os�forkr �_ExitCodeException� exit_code�logger�debug�_exit�setsid�chdir�close�open�devnull�O_RDWR�dup2)r
�old_id�pidr �e�fd�new_id� r$ �:/usr/lib64/python3.9/site-packages/borg/helpers/process.py�
_daemonize s< �
�
r& c C s6 t � � \} }| |fW d � S 1 s(0 Y dS )zsDetach process from controlling terminal and run in background
Returns: old and new get_process_id tuples
N)r& )r r# r$ r$ r% � daemonize7 s r' � )�timeoutc c s� t � ���\}}|du �r�t�d| � t}tdtt����F tdtt���� tdtt���� z�z| dkrtt �
| � W n� ty� Y n� ty� t }Y n� ty� t�d| � t d }Y nZ t
�y } z2t�d d
�t�|j||j�� � t }W Y d}~nd}~0 0 t�d � t }W t|��n
t|��0 W d � n1 �sH0 Y W d � n1 �sh0 Y W d � n1 �s�0 Y tj}t�d | � z�z||fV W nR t
�y } z8tj}t�d
d
�t�|j||j�� � |�W Y d}~nd}~0 0 t�d| � W zt�|d |� W nH t
�yv } z.t�dd
�t�|j||j�� � W Y d}~n
d}~0 0 n`zt�|d |� W nH t
�y� } z.t�dd
�t�|j||j�� � W Y d}~n
d}~0 0 0 W d � n1 �s�0 Y dS )aD Like daemonize(), but as context manager.
The with-body is executed in the background process,
while the foreground process survives until the body is left
or the given timeout is exceeded. In the latter case a warning is
reported by the foreground.
Context variable is (old_id, new_id) get_process_id tuples.
An exception raised in the body is reported by the foreground
as a warning as well as propagated outside the body in the background.
In case of a warning, the foreground exits with exit code EXIT_WARNING
instead of EXIT_SUCCESS.
NzQDaemonizing: Foreground process (%s, %s, %s) is waiting for background process...�SIGINT�SIGHUP�SIGTERMr z=Daemonizing: Foreground process (%s, %s, %s) received SIGINT.r zEDaemonizing: Foreground process received an exception while waiting:
� zGDaemonizing: Background process did not respond (timeout). Is it alive?z;Daemonizing: Background process (%s, %s, %s) is starting...zDDaemonizing: Background process raised an exception while starting:
z9Daemonizing: Background process (%s, %s, %s) has started.r zHDaemonizing: Trying to kill the foreground process raised an exception:
)r& r r r �signal_handler�raising_signal_handler�KeyboardInterrupt�SigHup�SigTerm�time�sleepr
r �
BaseExceptionZwarning�join� traceback�format_exception� __class__�
__traceback__r �signalr, r+ r �kill�error)r) r r# r r! Zsig_to_foregroundr$ r$ r% � daemonizing@ sd
� � �
t�� ��r> c @ s e Zd Zdd� ZdS )r c C s
|| _ d S �N)r )�selfr r$ r$ r% �__init__� s z_ExitCodeException.__init__N)�__name__�
__module__� __qualname__rA r$ r$ r$ r% r � s r c @ s e Zd ZdZdS )�SignalExceptionz*base class for all signal-based exceptionsN�rB rC rD �__doc__r$ r$ r$ r% rE � s rE c @ s e Zd ZdZdS )r1 zraised on SIGHUP signalNrF r$ r$ r$ r% r1 � s r1 c @ s e Zd ZdZdS )r2 zraised on SIGTERM signalNrF r$ r$ r$ r% r2 � s r2 c
c sd t | t�rtt| d�} | dur*t�| |�}z dV W | dur`t�| |� n| dur^t�| |� 0 dS )a�
when entering context, set up signal handler <handler> for signal <sig>.
when leaving context, restore original signal handler.
<sig> can bei either a str when giving a signal.SIGXXX attribute name (it
won't crash if the attribute name does not exist as some names are platform
specific) or a int, when giving a signal number.
<handler> is any handler value as accepted by the signal.signal(sig, handler).
N)�
isinstance�str�getattrr; )Zsig�handlerZ orig_handlerr$ r$ r% r. � s
�r. c s � fdd�}|S )Nc s t � | t j� � �d S r? )r; �SIG_IGN)�sig_no�frame��exc_clsr$ r% rK � s z'raising_signal_handler.<locals>.handlerr$ )rP rK r$ rO r% r/ � s r/ c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )�
SigIntManagerc C s0 d| _ d| _d| _td| j�| _d| _d | _d S )NFr* i -1)�_sig_int_triggered�_action_triggered� _action_doner. rK �ctx�debounce_interval�last�r@ r$ r$ r% rA � s zSigIntManager.__init__c C s | j S r? )rR rX r$ r$ r% �__bool__� s zSigIntManager.__bool__c C s | j S r? )rS rX r$ r$ r% �action_triggered� s z SigIntManager.action_triggeredc C s | j S r? )rT rX r$ r$ r% � action_done� s zSigIntManager.action_donec C s d| _ d| _d S )NFT)rS rT rX r$ r$ r% �action_completed� s z SigIntManager.action_completedc C sL t �� }| jd u r&|| _d| _d| _n"|| j | jkrH| �d d d � t�d S )NT)r3 � monotonic_nsrW rR rS rV �__exit__r0 )r@ rM �stackZnowr$ r$ r% rK � s
zSigIntManager.handlerc C s | j �� d S r? )rU � __enter__rX r$ r$ r% r` � s zSigIntManager.__enter__c C s | j r | j �|||� d | _ d S r? )rU r^ )r@ Zexception_typeZexception_valuer7 r$ r$ r% r^ � s zSigIntManager.__exit__N) rB rC rD rA rY rZ r[ r\ rK r` r^ r$ r$ r$ r% rQ � s rQ c C s t � t jt j� dS )aW
Ignore SIGINT, see also issue #6912.
Ctrl-C will send a SIGINT to both the main process (borg) and subprocesses
(e.g. ssh for remote ssh:// repos), but often we do not want the subprocess
getting killed (e.g. because it is still needed to cleanly shut down borg).
To avoid that: Popen(..., preexec_fn=ignore_sigint)
N)r; r* rL r$ r$ r$ r% �
ignore_sigint� s
ra r- )�cmd_linec
K s� zt �| �}|std��W n4 tyN } z t�d||� W Y d}~dS d}~0 0 t�d||� ztj|fi |��W S ty� t�d||d � Y dS t y� t�d||d � Y dS 0 dS )as
Handle typical errors raised by subprocess.Popen. Return None if an error occurred,
otherwise return the Popen object.
*cmd_line* is split using shlex (e.g. 'gzip -9' => ['gzip', '-9']).
Log messages will be prefixed with *log_prefix*; if set, it should end with a space
(e.g. log_prefix='--some-option: ').
Does not change the exit code.
z&an empty command line is not permittedz%s%sNz%scommand line: %sz%sexecutable not found: %sr z%spermission denied: %s)
�shlex�split�
ValueErrorr r= r �
subprocess�Popen�FileNotFoundError�PermissionError)rb �
log_prefix�kwargsZcommand�ver$ r$ r% �popen_with_error_handling s
rm c C s" t | d�o | �� o t p dtjv S )N�isattyZANSICON)�hasattrrn r r �environ)r" r$ r$ r% � is_terminal! s rq c C s� t |dur|ntj�}| rpd}|�|d �}|dur>|||< n2|�|�}|durpttdd�rpttd�rp|�|� |�dd� t|d< |S ) a
Prepare the environment for a subprocess we are going to create.
:param system: True for preparing to invoke system-installed binaries,
False for stuff inside the pyinstaller environment (like borg, python).
:param env: optionally give a environment dict here. if not given, default to os.environ.
:return: a modified copy of the environment
NZLD_LIBRARY_PATHZ_ORIG�frozenFZ_MEIPASSZBORG_PASSPHRASEZ BORG_VERSION) �dictr rp �getrJ �sysro �popr )�system�envZlp_keyZlp_origZlpr$ r$ r% �prepare_subprocess_env% s
ry Tc
c sp | rr|}|}t dd�}|r2t| tj|d|td�}nt| tj|d|td�}|s\td| � d���|rf|jn|j}| }z�z
|V W n. ty� t �
d� | r�|� � d }� Y n0 d}W |r�|� � | �rlt �
d
� |�
� } t �
d | � |r�|� � |�rl| �rltd | | f ��n^|�r |� � | �rjt �
d
� |�
� } t �
d | � |�rN|� � |�rj| �rjtd | | f ��0 d S )
NT)rw zfilter-process: )�stdout�stdinrj rx �
preexec_fn)r{ rz rj rx r| zfilter z: process creation failedz Exception, killing the filter...Fz"Done, waiting for filter to die...z filter cmd exited with code %dzfilter %s failed, rc=%d)ry rm rf �PIPEra r rz r{ � Exceptionr r r< r �wait)
�cmd�streamZ stream_closeZinboundZ
filter_streamZfilter_stream_closerx �procZborg_succeeded�rcr$ r$ r% �create_filter_processK sX
�
�
�
r� )r- )N)T),�
contextlibr Zos.path�rerc r; rf ru r3 r7 r- r Z
platformflagsr r r r r r Zhelpersr r
r r �contextmanagerr& r' r> r5 r rE r1 r2 r. r/ rQ Zsig_intra rI rm rz rq ry r� r$ r$ r$ r% �<module> sD
! E
9
&