File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/__pycache__/minion.cpython-310.pyc
o
�N�gy � @ sj d Z ddlZddlZddlZddlZddlZddlZddlZe� e
�Z dd� Z dd� Z
dd� Zd d
� ZdS ) z
Utility functions for minions
� Nc C sz g }t j�| d d�}t j�|�s|S t �|�D ]"}t j�||�}zt|| �}|dur0|�|� W q ty: Y qw |S )z0
Return the running jobs on this minion
�cachedir�procN)�os�path�join�isdir�listdir�_read_proc_file�append�OSError)�opts�retZproc_dir�fn_r �data� r �E/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/minion.py�running s
� �r c C s� t j�| d d|d�}t j�|�}t j�|�s t �|� tjj� |d��}|�
tj � |�� W d � dS 1 s9w Y dS )z(
Write job information to cache
r Z minion_jobszreturn.pzw+bN)
r r r �dirnamer �makedirs�salt�utils�files�fopen�write�payload�dumps)r �jidr
r Zjdir�fp_r r r �
cache_jobs( s
"�r c C sj t �� j}t�� }tjj�| d��9}|� � }|�
� |r#tj � |�}n zt�
| � W n ty9 t�d| � Y nw W d � dS W d � n1 sMw Y t|t�sYdS tjj�|d �s{zt�
| � W dS tyz t�d| � Y dS w |�d�r�|�d�|kr�dS n||�d�|kr�zt�
| � W dS ty� t�d| � Y dS w d�|�d�|�d��}|�d�|ks�||kr�dS |�d�dd � t �� D �v p�|d
d � t �� D �v }|s�|d d � t �� D �v }|�szt�
| � W dS t�y t�d| � Y dS w t|��s3|�d�}|�rt�d |� zt�
| � W dS t�y2 t�d| � Y dS w |S )
z0
Return a dict of JID metadata, or None
�rbz Unable to remove proc file %s.N�pid�multiprocessingz {}-Job-{}r c S � g | ]}|j �qS r ��name��.0�xr r r �
<listcomp>^ s �z#_read_proc_file.<locals>.<listcomp>c S r" r r# r% r r r r( ` � c S r" r r# r% r r r r( b r) z7PID %s exists but does not appear to be a salt process.)� threading�current_threadr$ r �getpidr r r r �read�closer �loads�remover �log�debug�
isinstance�dict�processZ
os_is_running�get�format� enumerate�_check_cmdline�warning) r r r+ r r �bufr Z thread_name�foundr r r r 4 s�
�� �
��
� ���� ��
��r c C s� t jj�� sdS | �d�}|sdS tj�d�sdS tj�d|� d��}tj� |�s+dS z-t jj
� |d��}d|� � v rE W d � W dS W d � W d S 1 sQw Y W d S t
yb Y dS w )
a9
In some cases where there are an insane number of processes being created
on a system a PID can get recycled or assigned to a non-Salt process.
On Linux this fn checks to make sure the PID we are checking on is actually
a Salt process.
For non-Linux systems we punt and just return True
Tr Fz/procz/proc/z/cmdliner s saltN)r r �platformZis_linuxr6 r r r r �isfiler r r- r )r r r r r r r r9 v s(
�&� �r9 )�__doc__�loggingr r* Z salt.payloadr Zsalt.utils.filesZsalt.utils.platformZsalt.utils.process� getLogger�__name__r1 r r r r9 r r r r �<module> s
B