File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/bcache.cpython-310.pyc
Back
o ;j�r � @ sz d Z ddlZddlZddlZddlZddlZe�e�Z ej ej ej ej ejejd�Zdddd�Zejj�d�duZd d � ZdEd d �ZdEd d�ZdEdd�Zdd� ZdEdd�ZdFdd�Z dGdd�Z dEd d �Z dHd d �Z dId d!�Z d"d#� Z!d$d%� Z"d&d'� Z#d(d)� Z$dEd*d+�Z%d,d-� Z&d.d/� Z'dJd0d1�Z(dJd2d3�Z)dJd4d5�Z* dKd6d7�Z+d8d9� Z,d:d;� Z-d<d=� Z.dLd?d@�Z/dMdAdB�Z0dCdD� Z1dS )Na� Module for managing BCache sets BCache is a block-level caching mechanism similar to ZFS L2ARC/ZIL, dm-cache and fscache. It works by formatting one block device as a cache set, then adding backend devices (which need to be formatted as such) to the set and activating them. It's available in Linux mainline kernel since 3.10 https://www.kernel.org/doc/Documentation/bcache.txt This module needs the bcache userspace tools to function. .. versionadded:: 2016.3.0 � N)Ztrace�debug�info�warn�errorZcrit�attach�config�super)�attach_�config_�super_� blkdiscardc C s t jj�d�duS )z1 Only work when make-bcache is installed z make-bcacheN)�salt�utils�path�which� r r �G/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/bcache.py� __virtual__- � r c C sR z | du rt tjj�d��d d d W S tj�t| d��W S ty( Y dS w )a Return the bcache UUID of a block device. If no device is given, the Cache UUID is returned. CLI Example: .. code-block:: bash salt '*' bcache.uuid salt '*' bcache.uuid /dev/sda salt '*' bcache.uuid bcache0 N�/sys/fs/bcache/r � �cacheF) �listr r r �os_walk�os�basename�_bcsys� Exception��devr r r �uuid4 s �r c s� t � � � s t�d�� dS �du r/i }tdd��� D ]\�}d|v r(t��|�< q|r-|S dS t ��}|rH|� krBt�d�� � dS t��sHdS t�d�� � t �d � d d �� d � � ��s_dS t � �fd d�d �� d� � d��S )a Attach a backing devices to a cache set If no dev is given, all backing devices will be attached. CLI Example: .. code-block:: bash salt '*' bcache.attach sdc salt '*' bcache.attach /dev/bcache1 :return: bool or None if nuttin' happened zNo cache to attach %s toFNT��alldevsr z2%s is already attached to bcache %s, doing nothingzAttaching %s to bcache %sr r zError attaching z to bcache c s t ��� kS �N�r r �r r r r �<lambda>} � zattach_.<locals>.<lambda>z received attach to bcache z, but did not comply) r �logr �status�itemsr r �detachr r �_wait)r �res�data�bcacher r% r r M s@ � � �r c s� � du r"i }t dd��� D ]\� }d|v rt� �|� < q |r |S dS t�d� � t� dddd � � ��s5d S t� fd d �d� � d �d�S )a� Detach a backing device(s) from a cache set If no dev is given, all backing devices will be attached. Detaching a backing device will flush its write cache. This should leave the underlying device in a consistent state, but might take a while. CLI Example: .. code-block:: bash salt '*' bcache.detach sdc salt '*' bcache.detach bcache1 NTr! r z Detaching %sr+ �goawayr zError detaching Fc s t � �du S �NFr$ r r r r r& � r' zdetach.<locals>.<lambda>z$ received detach, but did not comply�, )r) r* r+ r( r r r, )r r- r. r r r r+ � s � �r+ c C s( t ddd�sdS tdd� dd�sdS d S ) z� Trigger a start of the full bcache system through udev. CLI Example: .. code-block:: bash salt '*' bcache.start zudevadm triggerr zError starting bcache: %sFc S � t � duS r1 r$ r r r r r& � � zstart.<locals>.<lambda>r z5Bcache system started, but no active cache set found.T)�_run_allr, r r r r �start� s �r6 c s� � dur&t �d� � t� dddd� � ��sdS t� fdd �dd � � d �d �S t� }|s2t �d � dS tt� �s9dS tdddd�sBdS tdd � ddd �S )a� Stop a bcache device If no device is given, all backing devices will be detached from the cache, which will subsequently be stopped. .. warning:: 'Stop' on an individual backing device means hard-stop; no attempt at flushing will be done and the bcache device will seemingly 'disappear' from the device lists CLI Example: .. code-block:: bash salt '*' bcache.stop Nz;Stopping %s, device will only reappear after reregistering!�stopr0 r zError stopping Fc s t t� ��du S r1 �� _sysfs_attr�_bcpathr r r r r& � � zstop.<locals>.<lambda>zDevice z did not stopr2 zbcache already stopped?zError stopping cachec S s t � du S r1 r$ r r r r r& � r4 zCache did not stop)r( �warningr r, r �_alltruer+ �_fssys)r r r r r r7 � s& � r7 � writebackFTc s t � }|s t�d� dS tt� ��r,|s t�d� � dS t � �r&t� �s&dS t� �s,dS t� �� tt d��}|du r@tt d��}d� |||� �}|rN|d7 }t |d d � � d ��sZdS td t� �d d � � ��shdS t � fdd�d d� � d��sxdS |r~t � �S dS )a� Create a backing device for attachment to a set. Because the block size must be the same, a cache set already needs to exist. CLI Example: .. code-block:: bash salt '*' bcache.back_make sdc cache_mode=writeback attach=True :param cache_mode: writethrough, writeback, writearound or none. :param force: Overwrite existing bcaches :param attach: Immediately attach the backing device to the set :param bucket_size: Size of a bucket (see kernel doc) zNo bcache set foundFz;%s already contains a bcache. Wipe it manually or use force� block_sizeN� bucket_sizez1make-bcache --block {} --bucket {} --{} --bdev {}� --wipe-bcacher z Error creating backing device �: %szfs/bcache/registerz!Error registering backing device c s t t� ��duS r1 r8 r r r r r& r; zback_make.<locals>.<lambda>zBacking device z did not registerT)r r( r r9 r: r+ r7 �_devpath� _size_mapr> �formatr5 r, r )r � cache_mode�forcer rA r r@ �cmdr r r � back_make� sR � �� �rJ c C s~ t � }|r|st�d|� dS t� }t| �} td | �}d|v s,|�dd�dkr6d|v r6|s6t�d | � dS |durI|�dd�d krIt�d � dS t| �\}} } |du rX| }d}|du r^| }|rkt� sedS t |�skdS t | �sqdS |r�d � | |�} t | d d| � d��s�dS | � d�} d| � d|� d�} |r�| d|� �7 } t | d d| � d��s�dS t dd� d d| � d��s�dS |r�t t� �S dS )a� Create BCache cache on a block device. If blkdiscard is available the entire device will be properly cleared in advance. CLI Example: .. code-block:: bash salt '*' bcache.cache_make sdb reserved=10% block_size=4096 :param reserved: if dev is a full device, create a partition table with this size empty. .. note:: this increases the amount of reserved space available to SSD garbage collectors, potentially (vastly) increasing performance :param block_size: Block size of the cache; defaults to devices' logical block size :param force: Overwrite existing BCache sets :param attach: Attach all existing backend devices immediately z(BCache cache %s is already on the systemFzudev.envZ ID_FS_TYPEZDEVTYPEN� partitionZID_PART_TABLE_TYPEz-%s already contains data, wipe first or forceZdiskz2Need a partitionable blockdev for reserved to workzdparted -m -s -a optimal -- /dev/{0} mklabel gpt mkpart bcache-reserved 1M {1} mkpart bcache {1} 100%r z$Error creating bcache partitions on rC �2zmake-bcache --cache /dev/z --block rB z --bucket zError creating cache c S r3 r1 r$ r r r r r& � r4 z cache_make.<locals>.<lambda>zCache z. seemingly created OK, but FS did not activateT)r r( r �_bdev�_devbase�__salt__�get�_sizesr7 �_wiperF r5 r, r= r ) r ZreservedrH r@ rA r r Zudev�_�blockZbucketrI r r r � cache_make' sj � �� � rU c K s� | du rt � }nt| �}dd� |�� D �}|r<d}|�� D ]\}}|t||g|ddtj�||�� d|� ��7 }q |dkS i }t|dddd �}d D ] }||v rQ||= qH|D ] }|�|| � qT|S ) a� Show or update config of a bcache device. If no device is given, operate on the cache set itself. CLI Example: .. code-block:: bash salt '*' bcache.config salt '*' bcache.config bcache1 salt '*' bcache.config errors=panic journal_delay_ms=150 salt '*' bcache.config bcache1 cache_mode=writeback writeback_percent=15 :return: config or True/False Nc S s i | ] \}}|� d �s||�qS )�__)� startswith)�.0�key�valr r r � <dictcomp>� s zconfig_.<locals>.<dictcomp>r r zFailed to update z with T)r � internals�options)Zother_ro�inter_ro) �_fspathr: r* r9 r r �join� _sysfs_parse�update) r �kwargs�spathZupdates�endresrY rZ �resultr. r r r r � s. ��r c C s� g }t jj�d�D ].\}}}|D ]&}d|v rqt jjjd|� �dd�D ]\} } }d| v r5|�tj�| �� q#qq i } |D ] } t| | |||�| | < q<t� } t � }|rtd}| D ]}||krg| | d | krg|d7 }qU|| | d< |st| | } | S ) a� Show the full status of the BCache system and optionally all its involved devices CLI Example: .. code-block:: bash salt '*' bcache.status salt '*' bcache.status stats=True salt '*' bcache.status internals=True alldevs=True :param stats: include statistics :param config: include settings :param internals: include internals :param superblock: include superblock � /sys/block/r/ F)� followlinksr r r Zattached_backing_devices) r r r r �appendr r �devicer rM )�statsr r\ � superblockr" ZbdevsrS ZlinksrT rd ZsdirsZstatiir/ �cuuidZcdev�countr r r r r) � s: ���� � r) c C s, i }t t| �dd| � d��sdS t| d�r@t� |d< g d�}|�tt| �||||�� |�tt� ||||�� |�|�d�� nqt| �}|durL||d < z tj � t| d ��|d < W n t yb Y nw t | �|d < g d �}t| �}|�t|||||�� |�|�d�� |d g} |�d�r�| � d� n| � d� d|v r�|�d�r�| � d� n| � d� | |d < d|v �rd} |d } |d D ]<} d| vr�t�| d| �} | �| �| | < q�| �dd�\}} t�| d|�}t�| d| �} || vr�i | |< | �| �| | | < q�| |d< |�rX|�di �}|�|�di �� |�rX|D ];} | �d��r0t�dd| �}|�| �||< |} | �d��rRtjd | dd �\}}||v�rIi ||< |�| �|| |< �q||d < |�r�|d }|D ]%} | �d ��r�tjd | dd �\}}||v�r|i ||< |�| �|| |< �qa||d < |�r�t| �|d!< |S )"ae Check the state of a single bcache device CLI Example: .. code-block:: bash salt '*' bcache.device bcache0 salt '*' bcache.device /dev/sdc stats=True :param stats: include statistics :param settings: include all settings :param internals: include all internals :param superblock: include superblock info Nr z is not a bcache fo any kindF�setr )r@ rA Zcache_available_percent�cache_replacement_policy� congested�baser r Zbdev)rG �running�state�writeback_runningrt rs �stoppedru Zwriteback_stoppedrk z(stats|cache)_�/� r r^ �inter_rw�internalz internal[s/]*)Zbtreer? rS ��maxsplitr\ r r? rl )r9 r: r r rb ra r_ �popr r r r rM ri �re�sub�splitrW r )r rk r r\ rl rf � base_attrZ back_uuid� base_pathrt Zreplre�statres�attrrY �statZinterresZnkeyZmkeyZskeyZ configresr r r rj � s� � � � � rj c C sV t | �} i }td| � �dd| � d��}|sdS |�� D ]�}|�� }|s$qdd� tjd|d d �D �\}}|r7|s8qd }d |v rTd d� tjd|d d �D �\}}|d d� }n|}zt|�}W n& ty� zt|�}W n ty |dkrwd}n|dkr}d}Y nw Y nw tjd|d d �\}}||vr�i ||< |d ur�||f|| |< q||| |< q|S )z� Read out BCache SuperBlock CLI Example: .. code-block:: bash salt '*' bcache.device bcache0 salt '*' bcache.device /dev/sdc zbcache-super-show r z Error reading superblock on rC Fc s � � | ]}|� � V qd S r# ��strip�rX rZ r r r � <genexpr>� � � zsuper_.<locals>.<genexpr>z[\s]+r r{ N� c s r� r# r� r� r r r r� � r� ���ZyesT�noz\.) rD r5 � splitlinesr� r~ r� �intr �float) r �retr- �linerY rZ ZmvalZrvalZpkeyr r r r i sT � ���� r c C s$ t j�t j�| ��} t j�| �} | S )z( Basename of just about any dev )r r �realpath� expandvarsr r r r r rN � s rN c C s t j�dt| ��S )zM Return /dev name of just about any dev :return: /dev/devicename z/dev)r r r` rN r r r r rD � s rD c C s$ t | �} t�dd| �} tj�d| �S )z% Full SysFS path of a device z^([vhs][a-z]+)([0-9]+)z\1/\1\2rg )rN r~ r r r r` r r r r �_syspath� s r� c C s2 | du r t d�} nt| �} | sdS ttj�| ��S )zV Resolve a bcacheX or cache to a real dev :return: basename of bcache dev NZcache0F)r> r: rN r r �dirnamer r r r rM � s rM c C s t j�t| �d�S )z, Full SysFS path of a bcache device r/ )r r r` r� r r r r r: � r r: c C s t � } | sdS tj�d| �S )z( :return: path of active bcache Fr )r r r r` )rm r r r r_ � s r_ c C s t � }|sdS t|| g|||�S )z7 Simple wrapper to interface with bcache SysFS F)r_ r9 )�name�value�log_lvl�log_msg�fspathr r r r> � s r> c C s t t| �|g|||�S )z= Simple wrapper to interface with backing devs SysFS r8 )r r� r� r� r� r r r r � s r c C sN t | t�r| g} td tjj| � |�}|s%|dur%|dur%t�t| |� |S )z7 Simple wrapper with logging around sysfs.attr z sysfs.attrN)� isinstance�strrO r r r` r( �LOG)r� r� r� r� r- r r r r9 � s r9 c s� i }t d | �}|d= g }|r|�ddg� |r |�d� |r$|�d� i } |D ]} g | | < q(|d D ] } | �d�r=d} n d| v rDd} nd} | | v rQ| | �| � q3|d D ]} | �d�r`d} nd} | | v rm| | �| � qV� d ur�| D ]} � fd d �| | D �| | < qt� | d < dg d�i} | �� D ]-\} }g }| | vr�q�|D ]}| �� D ]}||v r�|�|� |�|� q�q�| | |7 < q�dd � | �� D �}|�t d || �� dD ]K}||v �r i }|| �d�D ]6}|�dd�\} }|� � }zt |�}W n t �y zt |�}W n t �y Y nw Y nw ||| � � < q�|||< q�|�s=dD ]}||v �r;t �d|| ��� d ||< �q&dD ]}||v �rNt|| �||< �q?i }| �� D ] \}}i }|D ]} | |v �rl|�| �|| < �q^|�ru|||< �qV|S )z> Helper function for parsing BCache's SysFS interface zsysfs.interfaces�wr^ ry r rk �rrz �rwNc s g | ]}|� vr|�qS r r )rX Zsintf�r� r r � <listcomp>9 s z _sysfs_parse.<locals>.<listcomp>rr )�internal/bset_tree_stats�writeback_rate_debugZmetadata_writtenZnbucketsZwrittenZaverage_key_sizeZbtree_cache_sizec S s g | ] }|D ]}|�qqS r r )rX Ziflist�intfr r r r� T s � sysfs.read)r� r� Zpriority_stats� �:r )rG rp �errorsz\[(.+)\]r )rs ru rq )rO �extendri rW r* �values�removerb r� r� r� r r� r~ �search�groups�boolr} ) r r� rk r r\ r] rf ZintfsZbinkeysZbintfrY r� �modsZmodtZmodlist�found�modZintflistZ bintflistZstrlistZlistresr� rZ ZsellistZboolkeyZbresultZiftypeZifresr r� r ra s� � � � �� ���� � � ��ra c C st z/t | t�s-t�d| �rdtt�dd| �� } nt�d| �r)dtt�dd| �� } t| �} | W S ty9 Y dS w )z1 Map Bcache's size strings to real bytes z[Kk]i rx z[Mm]� N)r� r� r~ r� r� r r )�sizer r r rE � s �rE c C s^ t | �} d}d}td dt| �d�}|�d|�dd��}|�d |�d d��}d |d ||fS ) z� Return neigh useless sizing info about a blockdev :return: (total size in blocks, blocksize, maximum discard size in bytes) )Zhw_sector_sizeZminimum_io_sizeZphysical_block_sizeZlogical_block_size)Zdiscard_max_bytesZdiscard_max_hw_bytesr� )r� �queue/hw_sector_size�../queue/hw_sector_size�queue/discard_max_bytes�../queue/discard_max_bytes)�rootr� r� Nr� r� i r� )rN rO r� rP )r Z block_sizesZ discard_sizesZsysfs�discardrT r r r rQ � s � � �rQ c C s� d}t | �} t| �\}}}|du rt�d| � dS |s$t�d| � d}n ts.t�d� d}nd}d| � d �}|dkrcd }d | � d |� �}|t|d |�7 }|d|d | � �7 }|t|d |�7 }|dkS |dkrvd| � �}|t|d |�7 }d}|dkS )z. REALLY DESTRUCTIVE STUFF RIGHT AHEAD r Nz!Unable to read SysFS props for %sz%s seems unable to discard�ddzSblkdiscard binary not available, properly wipe the dev manually for optimal resultsr z Error wiping rC � zdd if=/dev/zero of=/dev/z bs=1M count=r z seek=r� zblkdiscard /dev/r )rN rQ r( r r< �HAS_BLKDISCARDr5 ) r re r� rT r� ZwiperZ wipe_failmsg�blocksrI r r r rR � s8 � � rR � c C sL d}||k rt �d� | � rdS |d7 }||k s|dur$t�t| |� dS )zi Wait for lfunc to be True :return: True if lfunc succeeded within tries, False if it didn't r r TNF)�time�sleepr( r� )Zlfuncr� r� Ztries�ir r r r, � s �r, c C sN t d | �}|d |kr|d r|d S dS |dur%t�t| ||d � dS )z� Simple wrapper around cmd.run_all log_msg can contain {0} for stderr :return: True or stdout, False if retcode wasn't exitcode z cmd.run_all�retcode�stdoutTN�stderrF)rO r( r� )rI r� r� �exitcoder- r r r r5 s r5 c C s& | d u rdS t dd� | �� D ��dkS )NTc S s g | ]}|r|�qS r r r� r r r r� s z _alltrue.<locals>.<listcomp>r )�lenr� )Zresdictr r r r= s r= r# )r? FTN)NFNNT)FFFFF)FFFF)NNN)NFFFF)NNr� )NNr )2�__doc__�loggingr r~ r� Zsalt.utils.pathr � getLogger�__name__r( ZTRACE�DEBUG�INFO�WARNING�ERROR�CRITICALr� Z__func_alias__r r r r� r r r r+ r6 r7 rJ rU r r) rj r rN rD r� rM r: r_ r> r r9 ra rE rQ rR r, r5 r= r r r r �<module> sb � � 6# (D � h 0 1yA �~3 +
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings