a

�R�i4�@spdd
lZdd
l
Z
dd
lZdd
lZddlmZmZ
ejddd�
�
Z
ddd	�
Zdd
d�
Zdd
�Zdd�Zdd�Zd
S)�N�
)�	log_utils�utilsTcCsR|
pd
}
|
D]&}tj
�||�}tj
�|�
r|
Sq|rJtd�||
��
�
ndSdS)N)z	/usr/sbinz/sbinz/usr/binz/binz{0} could not be found at {1})�os�path�join�isfile�	Exception�format)�name�pathsZ	raise_exc�it�fname�r�3/usr/libexec/kcare/python/kcarectl/process_utils.py�find_cmds




rFc	Cs�|
r
tj
nd}|rtj
nd}tj||||d
�}|��\}}	|j}
|du
rRt�|�
}|du
rdt�|	�
}	t�t	�
d�
j|j||	d�|�
d��

|r�|
r�t�
|
|�}||_|	|_|�
|
||	fS)N)�stdout�stderr�shellz�
       Call result for `{cmd}`:
       exit code {exit_code}
       === STDOUT ===
       {stdout}
       === STDERR ===
       {stderr}
       === END ===
    �
 )Z	exit_coderr�cmd)�
subprocess�PIPE�Popen�communicate�
returncoder�nstrr�logdebug�textwrap�dedentr
r�CalledProcessError�outputr)�command�catch_stdout�catch_stderrr�checkrr�
pZstdout_capturedZstderr_captured�code�excrrr�run_commands,










�
��



r)cCst|d
|
d�\}}}|S)NT)r#r%)
r))�argsr%�
_rrrr�check_outputDs

r,c
	
Cs�z�d
ddddt|�
g}
t
|
dd�\}}}|rHtjdj|d	�
d
d�
WdS|��}d
ddd
dt|�
g}t
|dd�\}}}|r�tjdj|d	�
d
d�
WdS|��}t|�
|fWSty�
}
z&tjdj||d�d
d�
WYd}~dSd}~00dS)N�psz--no-headersz-o�ppidz-pT)
r#z3Could not retrieve process parent PID for PID {pid})
�pidF�
�	print_msg)NNZcommz-Could not retrieve process name for PID {pid}zJCould not retrieve process name and parent PID for PID {pid}, error: {err})r/�err)�strr)r�loginfor
�strip�intr	)	r/Zcmd_ppidr'rr+r.Zcmd_commr�
errr� _get_parent_pid_and_process_nameIs&












�r8c
st�
��
�f
d
d��
}
|
S)zMDecorator that logs parent process chain before calling the wrapped function.cst�
�|i|
�
�
S)
N)
�_log_all_parent_processes)r*�kwargs�
�funcrr�wrapperfs
z)log_all_parent_processes.<locals>.wrapper)�	functools�wraps)r<r=rr;r�log_all_parent_processescs
r@cCs�g}t�
�}
|
d
krF|
dkrFt|
�
\}}|�|
|f�

|dur@qF|}
qtjddd�
tt|�
�
D]:\}\}}d|d}tjdj||p�d	|p�d	d
�dd�
q`dS)Nrr
zAgent parent processes chain:Fr0�
-z->z{prefix} "{name}" (pid: {pid})�unknown)�prefixrr/)	r�getpidr8�appendrr4�	enumerate�reversedr
)Z
process_chainZcurrent_pidr.Zprocess_name�levelr/rrCrrrr9ns










�r9)NT)FFFF)
F)r>rrr�rr�Any�List�Optional�Tuple�Union�cachedrr)r,r8r@r9rrrr�<module>s




%