File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/zfs.cpython-310.pyc
Back
o ;j�� � @ s d Z ddlZddlmZ ddlmZ e�e�ZdZddiZ ddd�Z dddd �Z ddddd �Z d d � Z d/dd�Zd/dd�Zd/dd�Zd/dd�Zd/dd�Zd0dd�Zd0dd�Z d1d d �Zd2d d �Z d3d d!�Zd"d#� Zd4d$d%�Zd&d'� Zd(d)� Zd*d+� Z d5d-d.�Z dS )6a� States for managing zfs datasets :maintainer: Jorge Schrauwen <sjorge@blackdot.be> :maturity: new :depends: salt.utils.zfs, salt.modules.zfs :platform: smartos, illumos, solaris, freebsd, linux .. versionadded:: 2016.3.0 .. versionchanged:: 2018.3.1 Big refactor to remove duplicate code, better type conversions and improved consistency in output. .. code-block:: yaml test/shares/yuki: zfs.filesystem_present: - create_parent: true - properties: quota: 16G test/iscsi/haruhi: zfs.volume_present: - create_parent: true - volume_size: 16M - sparse: true - properties: readonly: on test/shares/yuki@frozen: zfs.snapshot_present moka_origin: zfs.hold_present: - snapshot: test/shares/yuki@frozen test/shares/moka: zfs.filesystem_present: - cloned_from: test/shares/yuki@frozen test/shares/moka@tsukune: zfs.snapshot_absent � N)� OrderedDict)�datetimeZzfs�minute)r �hour� )r r �day)r r r �monthc C s t �d�sdS tS )z Provides zfs state Z zfs_support)Fz1The zfs state cannot be loaded: zfs not supported)Z __grains__�get�__virtualname__� r r �C/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/zfs.py� __virtual__> s r Fc C s� | i ddd�}|� � }t�d|| |� t�d|| |� td | fi d|i��rltd s9td | fi ||d ���}ntd g�}|d |d < |d rXd |d | < d�|| �|d< |S d�|| �|d< d|v rj|d |d< |S |� d| � d�|d< |S )aE internal shared function for *_absent name : string name of dataset dataset_type : string [filesystem, volume, snapshot, or bookmark] type of dataset to remove force : boolean try harder to destroy the dataset recursive : boolean also destroy all the child datasets T� ��name�changes�result�commentz%zfs.%s_absent::%s::config::force = %sz)zfs.%s_absent::%s::config::recursive = %s� zfs.exists�type�test� zfs.destroy)�force� recursive�� destroyedTr r r z{} {} was destroyedr zfailed to destroy {} {}�error� z is absent)�lower�log�debug�__salt__�__opts__r �format)r � dataset_typer r �ret�mod_resr r r �_absentG s> ��� ��� �r' c C �6 t d | �s| i dd| � �d�}|S t| d||�}|S )a� ensure filesystem is absent on the system name : string name of filesystem force : boolean try harder to destroy the dataset (zfs destroy -f) recursive : boolean also destroy all the child datasets (zfs destroy -r) .. warning:: If a volume with ``name`` exists, this state will succeed without destroying the volume specified by ``name``. This module is dataset type sensitive. �zfs.is_datasetF�invalid dataset name: r � filesystem�� __utils__r' �r r r r% r r r �filesystem_absent} � ��r/ c C r( )a� ensure volume is absent on the system name : string name of volume force : boolean try harder to destroy the dataset (zfs destroy -f) recursive : boolean also destroy all the child datasets (zfs destroy -r) .. warning:: If a filesystem with ``name`` exists, this state will succeed without destroying the filesystem specified by ``name``. This module is dataset type sensitive. r) Fr* r �volumer, r. r r r � volume_absent� r0 r2 c C r( )a ensure snapshot is absent on the system name : string name of snapshot force : boolean try harder to destroy the dataset (zfs destroy -f) recursive : boolean also destroy all the child datasets (zfs destroy -r) �zfs.is_snapshotF�invalid snapshot name: r �snapshotr, r. r r r �snapshot_absent� � ��r6 c C r( )a ensure bookmark is absent on the system name : string name of snapshot force : boolean try harder to destroy the dataset (zfs destroy -f) recursive : boolean also destroy all the child datasets (zfs destroy -r) �zfs.is_bookmarkF�invalid bookmark name: r �bookmarkr, r. r r r �bookmark_absent� r7 r; c C sZ | i ddd�}t �d| |� t �d| |� td |�s(d|d< d |� �|d < |S td | �s8td | �s8| d krEd|d< d | � �|d < |S td |�}| |v r�td satd | |fi d|i��}ntdg�}|d |d< |d r�|| dii|d< d�| �|d < |S d�| �|d < d |v r�|d |d < |S d |v r�d|d< |d |d < |S d�| �|d < |S )a ensure hold is absent on the system name : string name of hold snapshot : string name of snapshot recursive : boolean recursively releases a hold with the given tag on the snapshots of all descendent file systems. Tr r z*zfs.hold_absent::%s::config::snapshot = %sz+zfs.hold_absent::%s::config::recursive = %sr3 Fr r4 r r8 r �invalid tag name: � zfs.holdsr � zfs.releaser ��releasedTr@ r zhold {} releasedzfailed to release hold {}zhold {} is absent)r r r- r! r" r r# �r r5 r r% Zholdsr& r r r � hold_absent� sZ � � �� ��� � ��rB c C sT | i ddd�}t �d| |� t �d| |� td |�s(d|d< d |� �|d < |S td | �s8td | �s8| d krEd|d< d | � �|d < |S td |�}| |v rYd�| |�|d < |S td sktd | |fi d|i��}ntdg�}|d |d< |d r�t|t| dfg�fg�|d< d| � d|� �|d < |S d| � d|� �|d < d |v r�|d |d < |S )a ensure hold is present on the system name : string name of holdt snapshot : string name of snapshot recursive : boolean recursively add hold with the given tag on the snapshots of all descendent file systems. Tr r z+zfs.hold_present::%s::config::snapshot = %sz,zfs.hold_present::%s::config::recursive = %sr3 Fr r4 r r8 r r< r= zhold {} is present for {}r �zfs.holdr ��heldTrE r zhold z added to zfailed to add hold z to )r r r- r! r# r" r rA r r r � hold_present, sD � � �� � rF c C s� |i ddd�}| dvr d} |du ri }t d |�}|r(t d |�}|�d |i� d �t|�� ��}t�d | ||� t�d | ||� t�d | ||� t�d| ||� t�d| ||� t d |�sld|d< d|� �|d< |S |r�t d |�s�d|d< |� d�|d< |S td |fi d| i��} | r�t|�dkr�| � d|� d�|d< |S | �rgt|�dk�rgtd ||| d ddd �� |t � �} g } |D ] } | | vr�t� d | || � q�| | d || kr�| � | � q�| D ]P} t d s�td! |fi | || i��} nt d"g�} | d# �r||d$ v�r i |d$ |< || |d$ | | < q�d|d< |d dk�r'd%|d< d&�|d | �|d< q�|d �rJ||d$ v �rJ| � d|� d'�|d< |S |d �r[| � d|� d�|d< |S | � d|� d(�|d< |S | �s�|�rod)nd*}t d �r~t |dfg�} n(|�r�|�r�||d < td+ ||fi ||d,���} ntd- |fi ||||d.���} | | |d< |d �r�||d$ |< |�r�||d$ |< d/�| ||�|d< |S d0�|dd1� | |�|d< d2| v �r�| d2 |d< |S )3aT internal handler for filesystem_present/volume_present dataset_type : string volume or filesystem name : string name of volume volume_size : string size of volume sparse : boolean create sparse volume create_parent : boolean creates all the non-existing parent datasets. any property specified on the command line using the -o option is ignored. cloned_from : string name of snapshot to clone properties : dict additional zfs properties (-o) .. note:: ``cloned_from`` is only use if the volume does not exist yet, when ``cloned_from`` is set after the volume exists it will be ignored. .. note:: Properties do not get cloned, if you specify the properties in the state file they will be applied on a subsequent run. ``volume_size`` is considered a property, so the volume's size will be corrected when the properties get updated if it differs from the original volume. The sparse parameter is ignored when using ``cloned_from``. Tr r )r+ r1 r+ N�zfs.from_auto_dictz zfs.from_sizeZvolsize�,z,zfs.%s_present::%s::config::volume_size = %sz'zfs.%s_present::%s::config::sparse = %sz.zfs.%s_present::%s::config::create_parent = %sz,zfs.%s_present::%s::config::cloned_from = %sz+zfs.%s_present::%s::config::properties = %sr) Fr r* r r3 z is not a snapshotr r r r z is uptodate�zfs.get�value)� propertiesr �fields�depth�parsablez1zfs.%s_present::%s::update - unknown property: %sr zzfs.set)�setTrO r z*The following properties were not updated:z{} {}z was updatedz failed to be updatedZcloned�createdz zfs.clone)� create_parentrK z zfs.create)rQ rK � volume_size�sparsez {} {} was {}zfailed to {} {} {}���r )r- �update�join�sorted�keysr r r! �lenr r �warning�appendr" r# )r$ r rK rR rS rQ � cloned_fromr% Z propnames�existsZproperties_currentZproperties_updateZpropr& Zmod_res_actionr r r �_dataset_presenth s� + ���� f�� � � � 6 �4�2� ����� �� � r^ c C s t d| |||d�S )a� ensure filesystem exists and has properties set name : string name of filesystem create_parent : boolean creates all the non-existing parent datasets. any property specified on the command line using the -o option is ignored. cloned_from : string name of snapshot to clone properties : dict additional zfs properties (-o) .. note:: ``cloned_from`` is only use if the filesystem does not exist yet, when ``cloned_from`` is set after the filesystem exists it will be ignored. .. note:: Properties do not get cloned, if you specify the properties in the state file they will be applied on a subsequent run. r+ )rQ r\ �r^ )r rQ rK r\ r r r �filesystem_present/ s �r` c C s t d| |||||d�S )a ensure volume exists and has properties set name : string name of volume volume_size : string size of volume sparse : boolean create sparse volume create_parent : boolean creates all the non-existing parent datasets. any property specified on the command line using the -o option is ignored. cloned_from : string name of snapshot to clone properties : dict additional zfs properties (-o) .. note:: ``cloned_from`` is only use if the volume does not exist yet, when ``cloned_from`` is set after the volume exists it will be ignored. .. note:: Properties do not get cloned, if you specify the properties in the state file they will be applied on a subsequent run. ``volume_size`` is considered a property, so the volume's size will be corrected when the properties get updated if it differs from the original volume. The sparse parameter is ignored when using ``cloned_from``. r1 )rS rQ r\ r_ )r rR rS rQ rK r\ r r r �volume_presentO s (�ra c C s< | i ddd�}t �d| |� td |�s!d|d< d| � �|d < |S d | vr:d | vr:d �|d |�d�� | �} | |d< td | �sMd|d< d| � �|d < |S td | fi ddi��s�td setd || �}ntdg�}|d |d< |d r�||d | < |� d| � �|d < |S d|� �|d < d |v r�|d |d < |S d |d < |S ) z| ensure bookmark exists name : string name of bookmark snapshot : string name of snapshot Tr r z/zfs.bookmark_present::%s::config::snapshot = %sr3 Fr r4 r �#�/z{}#{}N�@r r8 r9 r r r: r z zfs.bookmark)� bookmarkedTre r z bookmarked as zfailed to bookmark r zbookmark is present)r r r- r# �indexr! r" r )r r5 r% r& r r r �bookmark_present� s8 � �rg c C s | i ddd�}t �d| |� t �d| |� |r td |�}td | �s0d|d < d | � �|d < |S td | fi d di��s�td sNtd | fi ||d���}ntdg�}|d |d < |d rud|d | < |rk||d | < d| � d�|d < |S d| � �|d < d|v r�|d |d < |S d|d < |S )a8 ensure snapshot exists and has properties set name : string name of snapshot recursive : boolean recursively create snapshots of all descendent datasets properties : dict additional zfs properties (-o) .. note: Properties are only set at creation time Tr r z0zfs.snapshot_present::%s::config::recursive = %sz1zfs.snapshot_present::%s::config::properties = %srG r3 Fr r4 r r r r5 r � zfs.snapshot)r rK �� snapshottedTrj r z snapshot z was createdzfailed to create snapshot r zsnapshot is present)r r r- r! r" r )r r rK r% r& r r r �snapshot_present� s< �� � �rk c C s | i ddd�}t d | �sd|d< d| � �|d< |S td | fi d d i��s4d|d< d | � d �|d< |S td | fi dddd���| d d dkrS| � d�|d< |S td s^td | �}ntdg�}|d |d< |d r|d|d | < | � d�|d< |S d| � �|d< d|v r�|d |d< |S ) z� ensure a dataset is not a clone name : string name of fileset or volume .. warning:: only one dataset can be the origin, if you promote a clone the original will now point to the promoted dataset Tr r r) Fr r* r r r �filesystem,volume�dataset � does not existrI �originrJ )rK rL rN �-z already promotedr z zfs.promote)�promotedTrq r z promotedzfailed to promote r )r- r! r" r )r r% r& r r r rq � sH �� ������ � rq c C s� t td | fi dddd����� �D ]9}||�d�d d� }|�|� d��s(qtd |�}|s7|d �|� |D ]}||d �� v rJ|| �|� q9q|S ) aA Update snapshots dict with current snapshots dataset: string name of filesystem or volume prefix : string prefix for the snapshots e.g. 'test' will result in snapshots being named 'test-yyyymmdd_hhmm' snapshots : OrderedDict preseeded OrderedDict with configuration zzfs.listTr r5 )r rM r rd Nrp r= � _prunable� _schedule)rW r! rX rf � startswithr[ )�dataset�prefix� snapshotsZsnapZ snap_nameZ snap_holds�holdr r r �_schedule_snapshot_retrieve+ s( � �� ��ry c C sZ dj | |t�� �d�d�}t�� jddd�}g |d |< |d �� D ]�\}}|dkr+q"|| r�t�|| d | � d |� d ��jddd�}|d krM||krMq"|d krb|jdi t��|jdi t��krbq"|d krw|jdi t��|jdi t��krwq"|dkr�|jdi t ��|jdi t ��kr�q"|dkr�|jdi t ��|jdi t ��kr�q"|d | � |� q"|S )aG Update snapshots dict with info for a new snapshot dataset: string name of filesystem or volume prefix : string prefix for the snapshots e.g. 'test' will result in snapshots being named 'test-yyyymmdd_hhmm' snapshots : OrderedDict preseeded OrderedDict with configuration z {dataset}@{prefix}-{timestamp}z %Y%m%d_%H%M%S)ru rv � timestampr )�second� microsecond�_creaters rT rd z-%Y%m%d_%H%M%Sr r r r �yearNr ) r# r �now�strftime�replace�items�strptime� comp_hour�comp_day� comp_month� comp_yearr[ )ru rv rw Zsnapshot_create_nameZ timestamp_nowrx � hold_countrz r r r �_schedule_snapshot_prepareW sZ � ����������r� Tc C s" | i ddd�}g d�}t dt � fdg fdt � fg�}td | �s+d |d < d | � �|d < td | fi ddi��sCd| � d�|d < d |d < |rKt|�dk rWd|� d�|d < d |d < d}|D ]6}g ||< ||vrld|d |< n t|| t�r||| |d |< n d |d < d�|�|d < n ||d | 7 }q[|d r�|dkr�d |d < d|d < |d s�|S t| ||�}t| ||�}t � d| |� t � d| |� t � d| |� |d � � D ]�\} } | s�q�t d s�td | fi d |i��} nt d g�} | d s�d |d < d | � d!�|d < n7| D ]4}t d �std" || fi d |i��} nt d#g�} | d$ �s,d |d < d%�|| �|d < n|| � | � q�|d �rSd&|d < d'|d( v�rJg |d( d'< |d( d' � | � q�|d � � D ]_\}} |d �r�t|| �| k�r�|| �d�} t d �s�td) || fi d |i��} nt d*g�} | d+ �s�d |d < d%�|| �|d < td, | ��s�|d � | � |d �r�t|| �| k�sl�qZ|d D ],} t d �s�td- | fi d |i��} nt d.g�} | d/ �s�d |d < d0�| �|d < n�q�|d �r|d �rd&|d < |d |d( d1< |d �r|d( �sd2|d < |S )3a� maintain a set of snapshots based on a schedule name : string name of filesystem or volume prefix : string prefix for the snapshots e.g. 'test' will result in snapshots being named 'test-yyyymmdd_hhmm' recursive : boolean create snapshots for all children also schedule : dict dict holding the schedule, the following keys are available (minute, hour, day, month, and year) by default all are set to 0 the value indicated the number of snapshots of that type to keep around. .. warning:: snapshots will only be created and pruned every time the state runs. a schedule must be setup to automatically run the state. this means that if you run the state daily the hourly snapshot will only be made once per day! .. versionchanged:: 2018.3.0 switched to localtime from gmtime so times now take into account timezones. Tr r )r r r r r~ r} rr rs r) Fr r* r r r rl rm rn � zprefix (z) must be at least 4 longr z'schedule value for {} is not an integerz:schedule is not valid, you need to keep atleast 1 snapshotz2zfs.scheduled_snapshot::%s::config::recursive = %sz/zfs.scheduled_snapshot::%s::config::prefix = %sz*zfs.scheduled_snapshot::%s::snapshots = %sr rh r ri rj zerror creating snapshot (�)rC rD rE z'error adding hold ({}) to snapshot ({})zscheduled snapshots updatedrP r r> r? r@ r= r r r z error prunding snapshot ({1})Zprunedz"scheduled snapshots are up to date)r r- r! rY � isinstance�intr# ry r� r r r� r" r[ �pop) r rv r Zscheduler% Zschedule_holdsrw Z total_countrx Z snapshot_nameZsnapshot_holdsr& r� r r r �scheduled_snapshot� s� � � �� �� � � �� � �� ��r� )FF)F)NFFN)FNN)FFNN)FN)TN) �__doc__�logging� collectionsr r � getLogger�__name__r r r� r� r� r� r r' r/ r2 r6 r; rB rF r^ r` ra rg rk rq ry r� r� r r r r �<module> sH - 6 E@ � H# �3 8:7,>
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings