File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/__pycache__/stalekey.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Zddl Ze� e �Z dd� Zdd� Zdd� Zd d � Zd d � Zddd�ZdS )a� An engine that uses presence detection to keep track of which minions have been recently connected and remove their keys if they have not been connected for a certain period of time. Requires that the :conf_master:`minion_data_cache` option be enabled. .. versionadded:: 2017.7.0 :configuration: Example configuration: .. code-block:: yaml engines: - stalekey: interval: 3600 expire: 86400 � Nc C s t �d�sdS dS )NZminion_data_cache)Fz8stalekey engine requires minion_data_cache to be enabledT)�__opts__�get� r r �I/opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/stalekey.py� __virtual__% s r c C s@ t j�t��} | �� }|d W d � S 1 sw Y dS )z Get the keys �minionsN)�salt�key�get_keyr Zall_keys)�keysr r r r � _get_keys+ s $�r c C sD t j�t�}| D ]}t�d|� |�dt jj� |�g� ||= q|S )z Delete the keys zRemoving stale key for %sz key.delete) r �wheel� WheelClientr �log�info�cmd�utils� stringutils� to_unicode)� stale_keysr r �kr r r � _delete_keys4 s r c C s� d}i }t j�| �rdz;tjj�| d��!}tjj�|�}|D ]}tjj � |�}|| ||< q W d � n 1 s7w Y W ||fS W ||fS t yc } zd}t � d| |� W Y d}~||fS d}~ww ||fS )z- Read minion data from presence file F�rbNTz#Could not open presence file %s: %s)�os�path�existsr r �files�fopen�msgpack�loadr r �OSErrorr �error)� presence_filer! r �fZ_minionsZminionZ_minion�er r r �_read_presence@ s* � � � ���r% c C s� d}z%t jj�| d��}t jj�||� W d � W |S 1 s w Y W |S tyC } zd}t�d| |� W Y d}~|S d}~ww )z, Write minion data to presence file F�wbNTz'Could not write to presence file %s: %s) r r r r r �dumpr r r! )r" r r! r# r$ r r r �_write_presenceW s �����r( � �: c C s� t jj�t�}d�td �}t j�t�} t� d� i }t |�\}}|r*t � | � qt � }t � � }|�� } |D ]} | |vrB||| < q7| | v rJ||| < q7t� d� g } |�� D ]\} } || | kre| �| � qV| rmt| |�}t||�}t � | � q)z Start the engine z {}/presence.pZcachedirTz Checking for present minionsz%Finished checking for present minions)r r r Z CkMinionsr �formatr r r �debugr% �time�sleepr Z connected_ids�items�appendr r( ) �intervalZexpireZckr" r r r! Z minion_keys�nowZpresent�mr �seenr r r �starte s< � � �r5 )r) r* )�__doc__�loggingr r- Z salt.configr Zsalt.keyZsalt.utils.filesZsalt.utils.minionsZsalt.utils.msgpackZ salt.wheel� getLogger�__name__r r r r r% r( r5 r r r r �<module> s"
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings