File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/__pycache__/libvirt_events.cpython-310.pyc
Back
o ;j�T � @ s� d Z ddlZddlZddlZe�e�Zzddl Z W n e y$ dZ Y nw dd� Z ddddd d �Z e e d �r9d Znd Zd ddddddddddddddefd d d d d d!d"d#fd$d%d&d'd �Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Zd6d7� Zd8d9� Zd:d;� Zd<d=� Zd>d?� Zd@dA� Z dBdC� Z dDdE� Z dFdG� Z dHdI� Z dJdK� Z!dLdM� Z"dNdO� Z#dPdQ� Z$dRdS� Z%dTdU� Z&dVdW� Z'dXdY� Z(dZd[� Z)d\d]� Z*d^d_� Z+d`da� Z,dbdc� Z-ddde� Z.dfdg� Z/dhdi� Z0djdk� Z1dldm� Z2dndo� Z3dpdq� Z4drds� Z5dtdu� Z6dydwdx�Z7dS )za� An engine that listens for libvirt events and resends them to the salt event bus. The minimal configuration is the following and will listen to all events on the local hypervisor and send them with a tag starting with ``salt/engines/libvirt_events``: .. code-block:: yaml engines: - libvirt_events Note that the automatically-picked libvirt connection will depend on the value of ``uri_default`` in ``/etc/libvirt/libvirt.conf``. To force using another connection like the local LXC libvirt driver, set the ``uri`` property as in the following example configuration. .. code-block:: yaml engines: - libvirt_events: uri: lxc:/// tag_prefix: libvirt filters: - domain/lifecycle - domain/reboot - pool Filters is a list of event types to relay to the event bus. Items in this list can be either one of the main types (``domain``, ``network``, ``pool``, ``nodedev``, ``secret``), ``all`` or a more precise filter. These can be done with values like <main_type>/<subtype>. The possible values are in the CALLBACK_DEFS constant. If the filters list contains ``all``, all events will be relayed. Be aware that the list of events increases with libvirt versions, for example network events have been added in libvirt 1.2.1 and storage events in 2.0.0. Running the engine on non-root ------------------------------ Running this engine as non-root requires a special attention, which is surely the case for the master running as user `salt`. The engine is likely to fail to connect to libvirt with an error like this one: [ERROR ] authentication unavailable: no polkit agent available to authenticate action 'org.libvirt.unix.monitor' To fix this, the user running the engine, for example the salt-master, needs to have the rights to connect to libvirt in the machine polkit config. A polkit rule like the following one will allow `salt` user to connect to libvirt: .. code-block:: javascript polkit.addRule(function(action, subject) { if (action.id.indexOf("org.libvirt") == 0 && subject.user == "salt") { return polkit.Result.YES; } }); :depends: libvirt 1.0.0+ python binding .. versionadded:: 2019.2.0 � Nc C s2 t du rd} n t �� dk rd} nd} t| � | fS )z8 Only load if libvirt python binding is present Nzlibvirt module not foundi@B zlibvirt >= 1.0.0 required� )�libvirtZ getVersion�bool)�msg� r �O/opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/libvirt_events.py� __virtual__P s r ZdomainEventRegisterAnyZnetworkEventRegisterAnyZstoragePoolEventRegisterAnyZnodeDeviceEventRegisterAnyZsecretEventRegisterAny)�domain�network�pool�nodedev�secretZ VIR_DOMAIN_EVENT_ID_BLOCK_JOB_2Z VIR_DOMAIN_EVENT_ID_BLOCK_JOB�� lifecycleN)ZrebootN)Z rtc_changeN)ZwatchdogN)ZgraphicsN)Zio_errorZ#VIR_DOMAIN_EVENT_ID_IO_ERROR_REASON)Z control_errorN)Z disk_changeN)Z tray_changeN)ZpmwakeupN)Z pmsuspendN)Zballoon_changeN)Zpmsuspend_diskN)Zdevice_removedNZ block_job)ZtunableN)Zagent_lifecycleN)Z device_addedN)Zmigration_iterationN)Z job_completedN)Zdevice_removal_failedN)Zmetadata_changeN)Zblock_thresholdN)r ))r Z#VIR_STORAGE_POOL_EVENT_ID_LIFECYCLE)ZrefreshZ!VIR_STORAGE_POOL_EVENT_ID_REFRESH))r Z"VIR_NODE_DEVICE_EVENT_ID_LIFECYCLE)�updateZ VIR_NODE_DEVICE_EVENT_ID_UPDATE)r )Z value_changedNc C s2 d� | �d�d t| �d��dkrdf�S df�S )z^ Get the part before the first '_' or the end of attr including the potential '_' r �_r � )�join�split�len)�attrr r r �_compute_subprefix� s 2r c s� � fdd�t jD �}dd� |D ���fdd��D �}�fdd�|�� D ���fdd�|D �}|D ]}|tt d�� |f��krJ|�� �d d �}| S q0d S ) z� Convert the libvirt enum integer value into a human readable string. :param prefix: start of the libvirt attribute to look for. :param value: integer to convert to string c s& g | ]}|� � �r|t� �d � �qS )N)� startswithr ��.0r ��prefixr r � <listcomp>� s ��z,_get_libvirt_enum_string.<locals>.<listcomp>c S s g | ]}t |��qS r �r �r �pr r r r � s c s i | ]}|� � |��qS r )�countr ��prefixesr r � <dictcomp>� s z,_get_libvirt_enum_string.<locals>.<dictcomp>c s6 g | ]\}}|d ks|� d�r|dd� � v r|�qS )r r N���)�endswith)r r r! r" r r r � s "�c s g | ] }t |�� vr|�qS r r r )� sub_prefixesr r r � s r r � �unknown)r �__dict__�items�getattrr �lower�replace)r �valueZ attributes�counts�filtered� candidate�namer )r r# r' r �_get_libvirt_enum_string� s" � � ��r4 c C s< t d| �}|dkr |dfS d|�� � d�}t ||�}||fS )zX Convert event and detail numeric values into a tuple of human readable strings ZVIR_DOMAIN_EVENT_r) r )r4 �upper)�event�detailZ event_namer Z detail_namer r r �_get_domain_event_detail� s r8 c C s� | d }| d }| d }t j�|�� �}|jg}|jr!|�|j� |j�d�}|r.|�|� d� |�} d|�� i} | � |� d� || ||f�} t � d�dkr^t jj�t t d ��| | � d S td | | � d S ) aP Convenience function adding common data to the event and sending it on the salt event bus. :param opaque: the opaque data that is passed to the callback. This is a dict with 'prefix', 'object' and 'event' keys. :param conn: libvirt connection :param data: additional event data dict to send r �objectr6 �/�uriZ__roleZmasterZsock_dirz event.sendN)�urllib�parse�urlparse�getURI�scheme�netloc�append�path�stripr r Z__opts__�get�salt�utilsr6 Zget_master_eventZ fire_eventZ__salt__) �opaque�conn�data� tag_prefixZ object_typeZ event_typer; Zuri_tagrC Zuri_strZall_data�tagr r r �_salt_send_event� s& �rM c C s8 |� � |�� |�� d�|d�}|�|� t| ||� dS )a� Helper function send a salt event for a libvirt domain. :param opaque: the opaque data that is passed to the callback. This is a dict with 'prefix', 'object' and 'event' keys. :param conn: libvirt connection :param domain: name of the domain related to the event :param event: name of the event :param event_data: additional event data dict to send )r3 �id�uuid)r r6 N)r3 �ID� UUIDStringr rM )rH rI r r6 Z event_datarJ r r r �_salt_send_domain_event� s �� rR c C s, t ||�\}}t|| ||d ||d�� dS )z) Domain lifecycle events handler r6 )r6 r7 N)r8 rR )rI r r6 r7 rH Z event_strZ detail_strr r r �_domain_event_lifecycle_cb s �rS c C � t || ||d i � dS )z& Domain reboot events handler r6 N�rR �rI r rH r r r �_domain_event_reboot_cb � rW c C � t || ||d d|i� dS )z* Domain RTC change events handler r6 � utcoffsetNrU )rI r rZ rH r r r �_domain_event_rtc_change_cb � �r[ c C s" t || ||d dtd|�i� dS )z( Domain watchdog events handler r6 �actionZVIR_DOMAIN_EVENT_WATCHDOG_N�rR r4 )rI r r] rH r r r �_domain_event_watchdog_cb$ s �r_ c C s( t || ||d ||td|�|d�� dS )z) Domain I/O Error events handler r6 ZVIR_DOMAIN_EVENT_IO_ERROR_)ZsrcPath�devr] �reasonNr^ )rI r ZsrcpathZdevaliasr] ra rH r r r �_domain_event_io_error_cb1 s ��rb c sL d� � fdd�}t || ||d t� |�||�||�|dd� |D �d�� dS ) z( Domain graphics events handler ZVIR_DOMAIN_EVENT_GRAPHICS_c s$ t � � d�| d �| d | d d�S )zC transform address structure into event data piece Z _ADDRESS_�family�node�service)rc rd re )r4 )�addrr r r � get_addressK s �z._domain_event_graphics_cb.<locals>.get_addressr6 c S s g | ] }|d |d d��qS )r r )�typer3 r )r �itemr r r r _ s z-_domain_event_graphics_cb.<locals>.<listcomp>)�phase�local�remoteZ authScheme�subjectNr^ ) rI r rj rk rl Zauthrm rH rg r r r �_domain_event_graphics_cbC s ��rn c C rT )z- Domain control error events handler r6 NrU rV r r r � _domain_event_control_error_cbd rX ro c C s( t || ||d |||td|�d�� dS )z+ Domain disk change events handler r6 ZVIR_DOMAIN_EVENT_DISK_)Z oldSrcPathZ newSrcPathr` ra Nr^ )rI r Zold_srcZnew_srcr` ra rH r r r � _domain_event_disk_change_cbk s ��rp c C s$ t || ||d |td|�d�� dS )z+ Domain tray change events handler r6 Z VIR_DOMAIN_EVENT_TRAY_CHANGE_)r` ra Nr^ )rI r r` ra rH r r r � _domain_event_tray_change_cb} s ��rq c C � t || ||d ddi� dS )z& Domain wakeup events handler r6 ra r) NrU �rI r ra rH r r r �_domain_event_pmwakeup_cb� r\ rt c C rr )z' Domain suspend events handler r6 ra r) NrU rs r r r �_domain_event_pmsuspend_cb� r\ ru c C rY )z. Domain balloon change events handler r6 �actualNrU )rI r rv rH r r r � _domain_event_balloon_change_cb� � rw c C rr )z, Domain disk suspend events handler r6 ra r) NrU rs r r r � _domain_event_pmsuspend_disk_cb� r\ ry c C s, t || ||d |td|�td|�d�� dS )z) Domain block job events handler r6 ZVIR_DOMAIN_BLOCK_JOB_TYPE_ZVIR_DOMAIN_BLOCK_JOB_)�diskrh �statusNr^ )rI r rz Zjob_typer{ rH r r r �_domain_event_block_job_cb� s ��r| c C rY )z. Domain device removal events handler r6 r` NrU �rI r r` rH r r r � _domain_event_device_removed_cb� rx r~ c C rY )z' Domain tunable events handler r6 �paramsNrU �rI r r rH r r r �_domain_event_tunable_cb� rx r� c C s* t || ||d td|�td|�d�� dS )z/ Domain agent lifecycle events handler r6 Z/VIR_CONNECT_DOMAIN_EVENT_AGENT_LIFECYCLE_STATE_Z0VIR_CONNECT_DOMAIN_EVENT_AGENT_LIFECYCLE_REASON_)�statera Nr^ )rI r r� ra rH r r r � _domain_event_agent_lifecycle_cb� s ����r� c C rY )z/ Domain device addition events handler r6 r` NrU r} r r r � _domain_event_device_added_cb� rx r� c C rY )z3 Domain migration iteration events handler r6 � iterationNrU )rI r r� rH r r r �$_domain_event_migration_iteration_cb� r\ r� c C rY )z. Domain job completion events handler r6 r NrU r� r r r � _domain_event_job_completed_cb� rx r� c C rY )z6 Domain device removal failure events handler r6 r` NrU r} r r r �&_domain_event_device_removal_failed_cb� rx r� c C s$ t || ||d td|�|d�� dS )z/ Domain metadata change events handler r6 ZVIR_DOMAIN_METADATA_)rh �nsuriNr^ )rI r Zmtyper� rH r r r � _domain_event_metadata_change_cb s ��r� c C s" t || ||d ||||d�� dS )z/ Domain block threshold events handler r6 )r` rC � threshold�excessNrU )rI r r` rC r� r� rH r r r � _domain_event_block_threshold_cb s �r� c C �, t || |�� |�� d�td|�dd�� dS )z* Network lifecycle events handler �r3 rO ZVIR_NETWORK_EVENT_r) )r r6 r7 N�rM r3 rQ r4 )rI �netr6 r7 rH r r r �_network_event_lifecycle_cb! s ��r� c C r� )z/ Storage pool lifecycle events handler r� ZVIR_STORAGE_POOL_EVENT_r) )r r6 r7 Nr� )rI r r6 r7 rH r r r �_pool_event_lifecycle_cb1 s ��r� c C s( t || |�� |�� d�|d d�� dS )z- Storage pool refresh events handler r� r6 )r r6 N)rM r3 rQ )rI r rH r r r �_pool_event_refresh_cb@ s ��r� c C �& t || d|�� itd|�dd�� dS )z. Node device lifecycle events handler r3 ZVIR_NODE_DEVICE_EVENT_r) )r r6 r7 N)rM r3 r4 )rI r` r6 r7 rH r r r �_nodedev_event_lifecycle_cbN � ��r� c C �" t || d|�� i|d d�� dS )z+ Node device update events handler r3 r6 )r r6 N)rM r3 )rI r` rH r r r �_nodedev_event_update_cb] s �r� c C r� )z) Secret lifecycle events handler rO ZVIR_SECRET_EVENT_r) )r r6 r7 N)rM rQ r4 )rI r r6 r7 rH r r r �_secret_event_lifecycle_cbf r� r� c C r� )z, Secret value change events handler rO r6 )r r6 N)rM rQ )rI r rH r r r � _secret_event_value_changed_cbu s �r� c C s t �d| �� � | �� dS )zJ Close the libvirt connection :param cnx: libvirt connection z Closing libvirt connection: %sN)�log�debugr? �close)�cnxr r r �_cleanup� s r� c C sF |� � D ] \}}t| }|�dd�}t| |�}|D ]}||� qqdS )z� Unregister all the registered callbacks :param cnx: libvirt connection :param callback_ids: dictionary mapping a libvirt object type to an ID list of callbacks to deregister ZRegZDeregN)r+ �REGISTER_FUNCTIONSr. r, )r� � callback_ids�obj�idsZ register_nameZderegister_nameZ deregister� callback_idr r r �_callbacks_cleanup� s ��r� c C s� |}|du rd|� d|� �� � }tt|�s t�d||� dS tt|�}d|� d|� d�}t� �|d�}|du r?t�d|� dS t| t | �} | d|||||d ��S ) a� Helper function registering a callback :param cnx: libvirt connection :param tag_prefix: salt event tag prefix to use :param obj: the libvirt object name for the event. Needs to be one of the REGISTER_FUNCTIONS keys. :param event: the event type name. :param real_id: the libvirt name of an alternative event id to use or None :rtype integer value needed to deregister the callback NZVIR_Z _EVENT_ID_z(Skipping "%s/%s" events: libvirt too oldr Z_event_�_cbz Missing function %s in engine)r r9 r6 ) r5 �hasattrr r� �warningr, �globalsrE �errorr� ) r� rK r� r6 �real_idZ libvirt_nameZ libvirt_idZ callback_name�callback�registerr r r �_register_callback� s& �r� c C s" || vrg | |< | | � |� dS )a Helper function adding a callback ID to the IDs dict. The callback ids dict maps an object to event callback ids. :param ids: dict of callback IDs to update :param obj: one of the keys of REGISTER_FUNCTIONS :param callback_id: the result of _register_callback N)rB )r� r� r� r r r �_append_callback_id� s r� �salt/engines/libvirt_eventsc C s2 |du rdg}z�zWt �� t �| �}t�d|�� � i }d|v }t�� D ]-\}}|D ]&\}} d�||f�} | |vr@||vr@|s@q*t ||||| �} | rPt ||| � q*q$d} | s^t � � dk } | rVW n t yv } z t� | � W Y d} ~ nd} ~ ww W t||� t|� dS W t||� t|� dS t||� t|� w )a Listen to libvirt events and forward them to salt. :param uri: libvirt URI to listen on. Defaults to None to pick the first available local hypervisor :param tag_prefix: the beginning of the salt event tag to use. Defaults to 'salt/engines/libvirt_events' :param filters: the list of event of listen on. Defaults to 'all' N�allzOpened libvirt uri: %sr: Fr )r ZvirEventRegisterDefaultImplZ openReadOnlyr� r� r? � CALLBACK_DEFSr+ r r� r� ZvirEventRunDefaultImpl� Exception� exceptionr� r� )r; rK �filtersr� r� Z all_filtersr� Z event_defsr6 r� Z event_filterZ registered_idZ exit_loop�errr r r �start� sL � �� ����� � � r� )Nr� N)8�__doc__�logging� urllib.parser< Zsalt.utils.eventrF � getLogger�__name__r� r � ImportErrorr r� r� Z BLOCK_JOB_IDr� r r4 r8 rM rR rS rW r[ r_ rb rn ro rp rq rt ru rw ry r| r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r �<module> s� A �� ��' ( ! %
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings