File: //opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/__pycache__/__init__.cpython-310.pyc
o
�N�g�
� @ sZ d Z ddlZddlZddlZddlZddlZe�e�Zddd�Z G dd� dej
j j �Z
dS )z�
Initialize the engines system. This plugin system allows for
complex services to be encapsulated within the salt plugin environment
� Nc C sd t jj| |d�}| d dkrt jj| |d�}ng }t jj| ||d�}t jj| ||||d�}| �dg �}t|t�rAdd� |� � D �}t jj
� � rMd }d }d }|D ]`}t|t�rat t
|� � ��\}} nd } d }
| d urzd
| v rzd �| d
�} |}
| d
= n|� d �} | |v r�|| } |
r�d
| j� d|
� d�}
nd
| j� d�}
t�d|
� |jt| | | |||f|
d� qOd S )z)
Fire up the configured engines!
��proxy�__role�master��utils�r r �enginesc S s g | ]\}}||i�qS � r
)�.0�k�vr
r
�I/opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/__init__.py�
<listcomp> s z!start_engines.<locals>.<listcomp>NZ
engine_modulez{}.startz.startzEngine(z, name=�)z Starting %s)�args�name)�salt�loaderr �runner� minion_modsr �get�
isinstance�dict�items�platform�spawning_platform�next�iter�format�
__module__�log�infoZ add_process�Engine)�optsZproc_mgrr r �runners�funcsr Z engines_opt�engineZ engine_optsZ engine_name�funZ
start_funcr r
r
r �
start_engines sH
���r) c s( e Zd ZdZ� fdd�Zdd� Z� ZS )r# z3
Execute the given engine in a new process
c s: t � jdi |�� || _|| _|| _|| _|| _|| _dS )z-
Set up the process executor
Nr
)�super�__init__r$ �configr( r& r% r )�selfr$ r( r, r& r% r �kwargs�� __class__r
r r+ G s
zEngine.__init__c C s� t jj| j| jd�| _t jj�� r4| jd dkr$t jj| j| jd�| _ng | _t jj | j| j| jd�| _
t jj | j| j
| j| j| jd�| _ | j
pIi }z| j | j d
i |�� W d S tyk tjd| jdd� Y d S w ) z)
Run the master service!
r r r r r z%s could not be started!T)�exc_infoNr
)r r r r$ r r r r r% r r& r r' r, r( � Exceptionr! �criticalr )r- r. r
r
r �runS s* ��
��z
Engine.run)�__name__r � __qualname__�__doc__r+ r4 �
__classcell__r
r
r/ r r# B s r# )N)r7 �loggingr Z salt.loaderZsalt.utils.platformZsalt.utils.process� getLoggerr5 r! r) r �processZSignalHandlingProcessr# r
r
r
r �<module> s
2