Google
Edit File: plugin_disk.cpython-39.pyc
a �]�iC � @ sl d dl Z ddlmZ ddlT d dlZd dlmZ d dlm Z d dl Z d dl Z ej � � ZG dd� dej�ZdS )� N� )�hotplug)�*)�commandsc s� e Zd ZdZ� fdd�Z� fdd�Zdd� Zdd � Zed d � �Z d d � Z dd� Z � fdd�Z � fdd�Z � fdd�Zedd� �Zedd� �Zdd� Zd d � Z� fd d �Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Z� fd.d/�Zd0d1� Z d\d3d4�Z d5d6� Z e d7d8d9�d:d;� �Z e!d7�d]d=d>��Z"e d?d8d9�d@dA� �Z#e!d?�d^dBdC��Z$e dDd8d9�dEdF� �Z%e!dD�d_dGdH��Z&dIdJ� Z'dKdL� Z(e dMd8d9�dNdO� �Z)e!dM�d`dPdQ��Z*e+dRd8d9�dSdT� �Z,dUdV� Z-e dWd8d9�dXdY� �Z.e!dW�dadZd[��Z/� Z0S )b� DiskPlugina. Plug-in for tuning various block device options. This plug-in can also dynamically change the advanced power management and spindown timeout setting for a drive according to the current drive utilization. The dynamic tuning is controlled by the [option]`dynamic` and the global [option]`dynamic_tuning` option in `tuned-main.conf`. The disk plug-in operates on all supported block devices unless a comma separated list of [option]`devices` is passed to it. .Operate only on the `sda` block device ==== ---- [disk] devices=sda ---- ==== The [option]`elevator` option sets the Linux I/O scheduler. .Use the bfq I/O scheduler on the `xvda` block device ==== ---- [disk] device=xvda elevator=bfq ---- ==== The [option]`scheduler_quantum` option only applies to the CFQ I/O scheduler. It defines the number of I/O requests that CFQ sends to one device at one time, essentially limiting queue depth. The default value is 8 requests. The device being used may support greater queue depth, but increasing the value of quantum will also increase latency, especially for large sequential write work loads. The [option]`apm` option sets the Advanced Power Management feature on drives that support it. It corresponds to using the `-B` option of the `hdparm` utility. The [option]`spindown` option puts the drive into idle (low-power) mode, and also sets the standby (spindown) timeout for the drive. It corresponds to using `-S` option of the `hdparm` utility. .Use a medium-agressive power management with spindown ==== ---- [disk] apm=128 spindown=6 ---- ==== The [option]`readahead` option controls how much extra data the operating system reads from disk when performing sequential I/O operations. Increasing the `readahead` value might improve performance in application environments where sequential reading of large files takes place. The default unit for readahead is KiB. This can be adjusted to sectors by specifying the suffix 's'. If the suffix is specified, there must be at least one space between the number and suffix (for example, `readahead=8192 s`). .Set the `readahead` to 4MB unless already set to a higher value ==== ---- [disk] readahead=>4096 ---- ==== The disk readahead value can be multiplied by the constant specified by the [option]`readahead_multiply` option. c sN t t| �j|i |�� g d�| _g d�| _t| j�| _d| _d| _t � | _ d S )N) � �� �� � � �} �i �U �F �7 � � ) r � �� �� � � � � �n �Z r �< � g{�G�z�?) �superr �__init__� _power_levels�_spindown_levels�len�_levels� _level_steps�_load_smallestr �_cmd)�self�args�kwargs�� __class__� �=/usr/lib/python3.9/site-packages/tuned/plugins/plugin_disk.pyr U s zDiskPlugin.__init__c s` t t| ��� d| _d| _t� | _t� | _| j � d�D ] }| � |�r6| j� |j � q6t� | _d S )NT�block)r r � _init_devicesZ_devices_supported� _use_hdparm�setZ _free_devices�dict�_hdparm_apm_device_support�_hardware_inventoryZ get_devices�_device_is_supported�addZsys_nameZ_assigned_devices�r' �devicer* r, r- r/ _ s zDiskPlugin._init_devicesc s � fdd�|D �S )Nc s g | ]}� j �d |��qS )r. )r4 Z get_device)�.0�x�r' r, r- � <listcomp>k � z2DiskPlugin._get_device_objects.<locals>.<listcomp>r, )r' Zdevicesr, r; r- �_get_device_objectsj s z DiskPlugin._get_device_objectsc C s� | j s dS || jv r | j| S | jjddd| gtjgdd�\}}}|tj krdt�d� d| _ dS |r�t�d| � t� d ||f � d| j|< dS d |v r�t�d | � d| j|< dS d| j|< dS ) NF�hdparm�-C�/dev/%sT)� no_errorsZ return_errz4hdparm command not found, ignoring for other devicesz#Device '%s' not supported by hdparmz(rc: %s, msg: '%s')�unknownz3Driver for device '%s' does not support apm command) r0 r3 r& �execute�errno�ENOENT�log�warning�info�debug)r' r8 �rc�out�err_msgr, r, r- �_is_hdparm_apm_supportedm s, � z#DiskPlugin._is_hdparm_apm_supportedc C s2 |j dko0|j�dd �dko0|jd u p0|jjdv S )N�diskZ removable� 0)ZscsiZvirtioZxenZnvmeZmmc)Z device_typeZ attributes�get�parentZ subsystem)�clsr8 r, r, r- r5 � s � �z DiskPlugin._device_is_supportedc C s | j �| d| j� d S )Nr. )r4 Z subscribe�_hardware_events_callbackr; r, r, r- �_hardware_events_init� s z DiskPlugin._hardware_events_initc C s | j �| � d S �N)r4 Z unsubscriber; r, r, r- �_hardware_events_cleanup� s z#DiskPlugin._hardware_events_cleanupc s( | � |�s|dkr$tt| ��||� d S )N�remove)r5 r r rT )r' Zeventr8 r* r, r- rT � s z$DiskPlugin._hardware_events_callbackc s, |j d ur|j �|� tt| ��||� d S rV )� _load_monitorZ add_devicer r �_added_device_apply_tuning�r' �instance� device_namer* r, r- rZ � s z%DiskPlugin._added_device_apply_tuningc s, |j d ur|j �|� tt| ��||� d S rV )rY Z remove_devicer r � _removed_device_unapply_tuningr[ r* r, r- r^ � s z)DiskPlugin._removed_device_unapply_tuningc C s dd d d d d d d�S )NT)�dynamic�elevator�apm�spindown� readahead�readahead_multiply�scheduler_quantumr, �rS r, r, r- �_get_config_options� s �z DiskPlugin._get_config_optionsc C s ddgS )Nra rb r, rf r, r, r- �#_get_config_options_used_by_dynamic� s �z.DiskPlugin._get_config_options_used_by_dynamicc C s. d|_ d| _d| _d |_| �|jd �|_d S )NTr r_ )Z_has_static_tuning� _apm_errcnt�_spindown_errcntrY Z _option_bool�optionsZ_has_dynamic_tuning�r' r\ r, r, r- �_instance_init� s zDiskPlugin._instance_initc C s" |j d ur | j�|j � d |_ d S rV )rY �_monitors_repository�deleterl r, r, r- �_instance_cleanup� s z DiskPlugin._instance_cleanupc s> t t| ��|� i |_i |_i |_i |_| j�d|j �|_ d S )NrO ) r r �_instance_init_dynamicZ _device_idle�_stats�_idle�_spindown_change_delayedrn ZcreateZassigned_devicesrY rl r* r, r- rq � s �z!DiskPlugin._instance_init_dynamicc C s� |rd}| j }n d}| j}|tjkr(d S |dkr6d}nL|tj krbtjd | _ | _t�d� d S |d7 }|tjkr�t�d| � |r�|| _ n|| _d S )Nrb ra r r zIhdparm command not found, ignoring future set_apm / set_spindown commandsz5disabling set_%s command: too many consecutive errors) rj ri �consts�ERROR_THRESHOLDrE rF rG rH rI )r' rK rb �sZcntr, r, r- �_update_errcnt� s& zDiskPlugin._update_errcntc C sN t �d| � | jjdd| d| gtjgd�\}}| �|d� d|j|< d S )Nzchanging spindown to %dr? z-S%drA �rB TF)rG rJ r& rD rE rF rx rt )r' r\ r8 �new_spindown_levelrK rL r, r, r- �_change_spindown� s & zDiskPlugin._change_spindownc C s2 | j jddd| gtjgd�\}}d|vo0d|vS )Nr? r@ rA ry ZstandbyZsleeping)r& rD rE rF )r' r8 rK rL r, r, r- �_drive_spinning� s "zDiskPlugin._drive_spinningc C s& | � |�sd S |j�|�}|d u r&d S ||jvr<| �||� | �|||� | �||� |j| }|j| }|d d | jk r�|d | j kr�|d | j kr�d}n.|d dkr�|d dks�|d dkr�d}nd}|dk�r�|d |7 < | j |d }| j |d }t � d|d � | jtjk �r`| �|��sR|dk�rRt � d| � d |j|< n| �|||� | jtjk �r�t � d | � | jjd d | d | gtjgd�\} } | �| d� n4|j| �r�| �|��r�| j |d }| �|||� t � d||d |d f � t � d||d |d |d f � d S )N�levelr �read�writer ���ztuning level changed to %dz;delaying spindown change to %d, drive has already spun downTzchanging APM_level to %dr? z-B%drA ry Fz %s load: read %0.2f, write %0.2fz$%s idle: read %d, write %d, level %d)rN rY Zget_device_loadrr �_init_stats_and_idle� _update_stats� _update_idlers r# r$ r r! rG rJ rj ru rv r| rt r{ ri r& rD rE rF rx ) r' r\ r8 �loadZstatsZidleZ level_changeZnew_power_levelrz rK rL r, r, r- �_instance_update_dynamic� sF .$ & z#DiskPlugin._instance_update_dynamicc C sD ddg ddg ddg d�|j |< dddd�|j|< d|j|< d S )N� r r )�new�old�max)r} r~ r F)rr rs rt �r' r\ r8 r, r, r- r� s $z DiskPlugin._init_stats_and_idlec C s� |j | d |j | d< }||j | d< dd� t||�D �}||j | d< |j | d }dd� t||�D �}||j | d< t|d �t|d � |j | d < t|d �t|d � |j | d < d S ) Nr� r� c S s g | ]}|d |d �qS )r r r, )r9 Znew_oldr, r, r- r< ( r= z,DiskPlugin._update_stats.<locals>.<listcomp>�diffr� c S s g | ] }t |��qS r, )r� )r9 Zpairr, r, r- r< - r= r r~ � r )rr �zip�float)r' r\ r8 Znew_loadZold_loadr� Z old_max_loadZmax_loadr, r, r- r� # s "zDiskPlugin._update_statsc C sH dD ]>}|j | | | jk r4|j| | d7 < qd|j| |< qd S )N)r~ r r r )rr r% rs )r' r\ r8 Z operationr, r, r- r� 4 s zDiskPlugin._update_idlec s0 | � |�st�d| � ntt| ��||� d S )Nz<There is no dynamic tuning available for device '%s' at time)rN rG rI r r �_instance_apply_dynamicr� r* r, r- r� < s z"DiskPlugin._instance_apply_dynamicc C s d S rV r, r� r, r, r- �_instance_unapply_dynamicE s z$DiskPlugin._instance_unapply_dynamic� /sys/block/c C s@ d|v r0t j�||�dd�|�}t j�|�r0|S t j�|||�S )N�/�!)�os�path�join�replace�exists)r' r8 �suffix�prefix�devr, r, r- � _sysfs_pathH s zDiskPlugin._sysfs_pathc C s | � |d�S )Nzqueue/scheduler�r� r7 r, r, r- �_elevator_fileO s zDiskPlugin._elevator_filer` T)Z per_devicec C s0 | � |�}|s,| jj|||r$tjgndd� |S )NF�Zno_error)r� r& � write_to_filerE rF �r' �valuer8 r\ �simrX �sys_filer, r, r- � _set_elevatorR s �zDiskPlugin._set_elevatorFc C s" | � |�}| j�| jj||d��S )Nr� )r� r& Zget_active_option� read_file)r' r8 r\ �ignore_missingr� r, r, r- � _get_elevatorZ s zDiskPlugin._get_elevatorra c C s| | � |�s(|s t�d| � d S t|�S | jtjk rt|sl| jjddt|�d| gt j gd�\}}| � |d� t|�S d S d S )N�+apm option is not supported for device '%s'r? �-B�/dev/ry F) rN rG rI �strri ru rv r& rD rE rF rx �r' r� r8 r\ r� rX rK rL r, r, r- �_set_apma s ( zDiskPlugin._set_apmc C s� | � |�s |s t�d| � d S d }d}| jjddd| gtjgd�\}}|tj krZd S |dkrhd}n>t�d |tj �}|r�zt |� d ��}W n t y� d}Y n0 |r�t� d | � |S ) Nr� Fr? r� r� ry r Tz .*=\s*(\d+).*r z2could not get current APM settings for device '%s')rN rG rI r& rD rE rF �re�match�S�int�group� ValueError�error) r' r8 r\ r� r� �errrK rL �mr, r, r- �_get_apmq s( " zDiskPlugin._get_apmrb c C s| | � |�s(|s t�d| � d S t|�S | jtjk rt|sl| jjddt|�d| gt j gd�\}}| � |d� t|�S d S d S )N�0spindown option is not supported for device '%s'r? z-Sr� ry T) rN rG rI r� rj ru rv r& rD rE rF rx r� r, r, r- � _set_spindown� s ( zDiskPlugin._set_spindownc C s$ | � |�s |s t�d| � d S dS )Nr� � )rN rG rI )r' r8 r\ r� r, r, r- � _get_spindown� s zDiskPlugin._get_spindownc C s | � |d�S )Nzqueue/read_ahead_kbr� r7 r, r, r- �_readahead_file� s zDiskPlugin._readahead_filec C s^ t |��d d�}zt|d �}W n ty4 Y d S 0 t|�dkrZ|d d dkrZ|d }|S )Nr r rw � )r� �splitr� r� r" )r' r� �val�vr, r, r- � _parse_ra� s zDiskPlugin._parse_rarc c C sZ | � |�}| �|�}|d u r0t�d||f � n&|sV| jj|d| |rNtjgndd� |S )Nz,Invalid readahead value '%s' for device '%s'�%dFr� )r� r� rG r� r& r� rE rF )r' r� r8 r\ r� rX r� r� r, r, r- �_set_readahead� s �zDiskPlugin._set_readaheadc C s6 | � |�}| jj||d��� }t|�dkr.d S t|�S )Nr� r )r� r& r� �stripr" r� �r' r8 r\ r� r� r� r, r, r- �_get_readahead� s zDiskPlugin._get_readaheadrd c C s� |rd S | j d|d�}|rd| �||�}|d u r2d S tt|�| �} | j�||� | �| ||dd� n6| j�|�}|d u r|d S | �|||dd� | j�|� d S )Nrd )Z command_namer] F) Z _storage_keyr� r� r� Z_storager1 r� rQ Zunset) r' ZenablingZ multiplierr8 Zverifyr� r\ Z storage_keyZ old_readaheadZ new_readaheadr, r, r- �_multiply_readahead� s$ � z DiskPlugin._multiply_readaheadc C s | � |d�S )Nzqueue/iosched/quantumr� r7 r, r, r- �_scheduler_quantum_file� s z"DiskPlugin._scheduler_quantum_filere c C s8 | � |�}|s4| jj|dt|� |r,tjgndd� |S )Nr� Fr� )r� r& r� r� rE rF r� r, r, r- �_set_scheduler_quantum� s �z!DiskPlugin._set_scheduler_quantumc C sH | � |�}| jj||d��� }t|�dkr@|s<t�d| � d S t|�S )Nr� r z>disk_scheduler_quantum option is not supported for device '%s')r� r& r� r� r" rG rI r� r� r, r, r- �_get_scheduler_quantum� s z!DiskPlugin._get_scheduler_quantum)r� )F)F)F)F)F)1�__name__� __module__� __qualname__�__doc__r r/ r> rN � classmethodr5 rU rW rT rZ r^ rg rh rm rp rq rx r{ r| r� r� r� r� r� r� r� r� Z command_setr� Z command_getr� r� r� r� r� r� r� r� r� Zcommand_customr� r� r� r� � __classcell__r, r, r* r- r sn H 2 r )rE � r Z decoratorsZ tuned.logsZtunedZ tuned.constsru Ztuned.utils.commandsr r� r� ZlogsrQ rG ZPluginr r, r, r, r- �<module> s