File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/__pycache__/state.cpython-310.pyc
Back
o ;j�= � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Zddl m Z e� e �Ze� Zed�Zdd� Zdd� Zd d � Zd d � Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Z dd� Z dd � Z d$d d �Z d%d d!�Z d"d#� Z!dS )&zC Utility functions for state functions .. versionadded:: 2018.3.0 � N)�CommandExecutionErrorzAabcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789._-c C sR | du rdS t | ttf�rd�dd� | D ��} t| �} | s dS d�dd� | D ��S )uU Return a filesystem-safe identifier for a master. In multimaster, each Minion has its own opts["master"] string. The string may contain characters (``:`` for host:port, ``/`` for IPv6 zone ids, etc.) that are not valid in path components on every OS we support — Windows in particular rejects ``:`` in filenames. N�_default�,c s s � | ]}t |�V qd S �N)�str)�.0�m� r �D/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/state.py� <genexpr>' s � z&_sanitize_master_id.<locals>.<genexpr>� c s s � | ] }|t v r |nd V qdS )�_N)�_SAFE_MASTER_CHARS)r �cr r r r + s � )� isinstance�list�tuple�joinr )�masterr r r �_sanitize_master_id s r c C s t j�| d dt| �d���S )z5 Return the per-master queue base directory. �cachedirZqueuesr )�os�pathr r �get��optsr r r �queue_base_dir. s �r c C � t j�t| �d�S )z5 Return the per-master queue lock file path. z queue.lock�r r r r r r r r �queue_lock_path7 � r c C r )z4 Return the per-master job queue directory. Z job_queuer r r r r � job_queue_dir> r r! c C r )z6 Return the per-master state queue directory. Z state_queuer r r r r �state_queue_dirE r r" c C sJ t | �}z tjtj�|�dd� W n ty Y nw tjjj ||dd�S )z& Acquire the state queue lock T��exist_oki�Q )�lock_fn�timeout) r r �makedirsr �dirname�OSError�salt�utils�filesZ wait_lock�r Z lock_pathr r r �acquire_queue_lockL s �r. c C sL t | �}z tjtj�|�dd� W n ty Y nw tjjj ||ddd�S )z3 Acquire the job queue lock asynchronously Tr# g @g�������?)r% r& �sleep) r r r' r r( r) r* r+ r, Z await_lockr- r r r �acquire_async_queue_lock[ s ��r0 c C s� g }t j�| d d�}t j�|�s|S zt �|�}W n' tyA } z|jtjtjtj fv r.� t � d||� |W Y d}~S d}~ww |D ]�}t j�||�}zZt j j�|d�� }|�� }W d � n1 sew Y |snW qDzt j�|�} W n ty� Y W qDw t| t�s�W qD| �d�} | s�W qDt j j�| �r�| �dd��d �r�|�| � W qD ttfy� } zt|t�r�|jtjtjfv r�� W Y d}~qDd}~ww |S ) z� Return a list of active state jobs from the proc directory. Unlike saltutil.is_running, this does NOT filter out the current process. r �procz$Unable to list proc directory %s: %sN�rb�pid�funr zstate.) r r r �isdir�listdirr) �errnoZEMFILEZENFILEZENOMEM�log�errorr* r+ r, Zfopen�read�payload�loads� NameErrorr �dictr �processZ os_is_running� startswith�append� ValueError) r �retZproc_dirZ proc_files�excZfn_r Zfp_�buf�datar3 r r r �get_active_statesj sT �� � � � ��rG c C sn g }t |�}t| �t| �fD ]f}tj�|�sqzDt�|�D ]<}|�d�s)|�d�rY|�d�rY|dd� � d�}t |�dkrY|d }t |�dkrPd� |dd� �}|� |d d d �� q W q t yt } z t�d ||� W Y d}~qd}~ww |rx |D ]:} | �d �} | du r�qz|du r�|� | � qzzt| �t|�kr�W qzt| �t|�k r�|� | � W qz ttfy� Y qzw |S )z� Check for prior running states that would block the execution of the current job. Returns a list of blocking jobs. Zqueued_Zrunning_z.pN���r � � z state.applyr )�jidr4 r3 z%Unable to list queue directory %s: %srK )r r" r! r r �existsr6 r@ �endswith�split�lenr rA r) r8 r9 r r rB � TypeError) r rK Z active_jobsrC Z queue_dir�fn�partsZjob_jidrD rF Zdata_jidr r r �check_prior_running_states� s\ ��� ����� ��rS c C s d� | �S )zJ Generate the running dict tag string from the low data structure z/{0[state]}_|-{0[__id__]}_|-{0[name]}_|-{0[fun]})�format)�lowr r r �gen_tag� s rV c C s. g }d| v r t j�| �}nd| i}|�� D ]\}}||d kr q|�� D ]o\}}t|t�r2|�d�r3q$t|t�s9q$d}|D ]} t| t�sEq=| � dd�du }|rQ nq=|sUq$|D ];} t| t�s_qW| �� D ].\} } | dkrlqc| D ]"} | �� D ]\} }||d kr�| |� d| �ks�qt|� |||f� qtqnqcqWq$q|S ) zK For a particular low chunk, search relevant onfail related states �_|-�__id__�__FZ onfail_stopTZonfail�state) r* rZ � split_low_tag�itemsr r r@ r r> r rA )Zsid� highstate�onfails�st�fstateZfchunks�mod_�fchunkZonfail_handledZfdataZknobZfvalueZfreqs�fmodZfidr r r �search_onfail_requisites� sP � �����!rd c C s� d}| rg|rg|rgt |t�rgt| |�}|rg|D ]P}|\}}} |�� D ]>\} } d| v r0tj�| �} n| �d| �} | s<td��| |d�} || d kr_|| d kr_| �dt �}|dv rY|}|d u r_ nq!|du rfd }q|S ) a� When a state fail and is part of a highstate, check if there is onfail requisites. When we find onfail requisites, we will consider the state failed only if at least one of those onfail requisites also failed Returns: True: if onfail handlers succeeded False: if one on those handler failed None: if the state does not have onfail requisites NrW rX z no state id)rX rZ rZ �result)FTF) r r> rd r\ r* rZ r[ r rB �_empty)�state_id� state_result�runningr] Znretr^ �handlerr` ra rb ZrstateidZrstater_ Zid_Zofresultr r r �check_onfail_requisites! s0 ��rk Fc C s� t | t�sdS | s dS d}| �� D ]K\}}t}d|kr t}|s&t ||�s&d}|rLt |t�rL|�dt�}|du r:d}n|tu rLt |t�rL|rLt|d|d�}|sWtt||| |��}|s\ |S q|S )zf Check the total return value of the run and determine if the running dict has any issues FTZ __extend__re )�recurser] ) r r> r\ r r rf � check_result�boolrk )ri rl r] rC rg rh Z expected_typere r r r rm L s4 ��rm c C s� |s|d }|d du r|d | d< |d }t |t�s |g}| �dg � t | d t�r3| d �|� n| d r?| d d7 < | d d�|�7 < |d r\| �di � |d | d |< | S )a Update an existing state return (`original_return`) in place with another state return (`sub_return`), i.e. for a subresource. Returns: dict: The updated state return. The existing state return does not need to have all the required fields, as this is meant to be called from the internals of a state function, but any existing data will be kept and respected. It is important after using this function to check the return value to see if it is False, in which case the main state should return. Prefer to check `_ret['result']` instead of `ret['result']`, as the latter field may not yet be populated. Code Example: .. code-block:: python def state_func(name, config, alarm=None): ret = {'name': name, 'comment': '', 'changes': {}} if alarm: _ret = __states__['subresource.managed'](alarm) __utils__['state.merge_subreturn'](ret, _ret) if _ret['result'] is False: return ret �namere FZcomment� Zchanges)r r � setdefault�extendr )Zoriginal_returnZ sub_returnZsubkeyZ sub_commentr r r �merge_subreturnr s" rs c K s� t �| �} d|v rtjj|d | d�S d|v r<|d }|dur<t|t�s(t|�}| d r6|| d kr6td��|d | d< d|v sF| �dd �re|�d�pO|�d�}|durat|t�sat|�| d< | S || d< | S ) zR Return a copy of the opts for use, optionally load a local config on top Z localconfig)�defaults�saltenvNZ lock_saltenvz2lock_saltenv is enabled, saltenv cannot be changed� pillarenvZpillarenv_from_saltenvF) �copy�deepcopyr* ZconfigZ minion_configr r r r )r �kwargsru rv r r r � get_sls_opts� s( � �rz )FNr )"�__doc__rw r7 �loggingr Z salt.payloadr* Z salt.stateZsalt.utils.filesZsalt.utils.processZsalt.exceptionsr � getLogger�__name__r8 �objectrf � frozensetr r r r r! r" r. r0 rG rS rV rd rk rm rs rz r r r r �<module> s< � 7H1 + & 7
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings