3
�<�e� � @ sp d dl jZddlmZ ddlT d dlmZmZ d dlZ d dl
m Z d dl Z e j
j� Ze � ZG dd� dej�ZdS ) � N� )�base)�*)�Popen�PIPE)�commandsc @ st e Zd ZdZedd� �Zdd� Zedd� �Zdd � Zd
d � Z d d
� Z
dd� Z dd� Z dd� Z
eddd�dd� �ZdS )� MountsPluginaP
`mounts`::
Enables or disables barriers for mounts according to the value of the
[option]`disable_barriers` option. The [option]`disable_barriers`
option has an optional value `force` which disables barriers even
on mountpoints with write back caches. Note that only extended file
systems (ext) are supported by this plug-in.
c C s� i }d}t dddgttddd�j� \}}x�dd� |j� D �D ]�}t|�d k rNq<|dd � \}}}t|�d krt|d nd} t|�d
kr�|d
nd}
|d kr�|}q<|d ks<|dkr�q<|
dks<|
dkr�q<|j|
t� || d�� ||
d j|� q<W || _dS )z�
Gets the information about disks, partitions and mountpoints. Stores information about used filesystem and
creates a list of all underlying devices (in case of LVM) for each mountpoint.
NZlsblkz-rnoz TYPE,RM,KNAME,FSTYPE,MOUNTPOINTT)�stdout�stderrZ close_fdsZuniversal_newlinesc S s g | ] }|j � �qS � )�split)�.0�liner r �#/usr/lib/python3.6/plugin_mounts.py�
<listcomp>$ s z>MountsPlugin._generate_mountpoint_topology.<locals>.<listcomp>� � Zdisk�1�part�lvmz[SWAP])�disks� device_name�
filesystemr )r r ) r r Z communicate�
splitlines�len�
setdefault�set�add�_mountpoint_topology) �clsZmountpoint_topologyZ current_diskr r
�columnsZ device_typeZdevice_removabler r �
mountpointr r r � _generate_mountpoint_topology s, z*MountsPlugin._generate_mountpoint_topologyc C s* | j � d| _t| jj� �| _t� | _d S )NT)r" Z_devices_supportedr r �keysZ
_free_devicesZ_assigned_devices)�selfr r r �
_init_devices; s zMountsPlugin._init_devicesc C s dd iS )N�disable_barriersr )r$ r r r �_get_config_optionsA s z MountsPlugin._get_config_optionsc C s d|_ d|_d S )NFT)Z_has_dynamic_tuningZ_has_static_tuning)r$ �instancer r r �_instance_initG s zMountsPlugin._instance_initc C s d S )Nr )r$ r( r r r �_instance_cleanupK s z MountsPlugin._instance_cleanupc C s, t j d| �}x|D ]}tj|�j� S W dS )zV
Get device cache type. This will work only for devices on SCSI kernel subsystem.
z+/sys/block/%s/device/scsi_disk/*/cache_typeN)�glob�cmdZ read_file�strip)r$ �deviceZsource_filenamesZsource_filenamer r r �_get_device_cache_typeN s
z#MountsPlugin._get_device_cache_typec C s. x(| j | d D ]}| j|�dkrdS qW dS )zr
Checks if the device has 'write back' cache. If the cache type cannot be determined, asume some other cache.
r z
write backTF)r r/ )r$ r! r. r r r � _mountpoint_has_writeback_cacheW s z,MountsPlugin._mountpoint_has_writeback_cachec C s� t d��H}x@|D ]4}|j� }|d d dkr.q|d |kr|d }P qW dS W dQ R X |jd�}xH|D ]<}|jd�\}} }
|d ks�|d
kr�|
d kr�d S |d
krfd
S qfW d
S dS )zP
Checks if a given mountpoint is mounted with barriers enabled or disabled.
z /proc/mountsr �/r r N�,�=Z nobarrierZbarrier�0FT)�openr � partition) r$ r! Z mounts_filer r Z option_list�optionsZoption�name�sep�valuer r r �_mountpoint_has_barriers` s"
z%MountsPlugin._mountpoint_has_barriersc C s d|dd| g}t j|� dS )z
Remounts partition.
z/usr/bin/mountz-oz
remount,%sN)r, Zexecute)r$ r6 r7 Zremount_commandr r r �_remount_partition} s z MountsPlugin._remount_partitionr& T)Z
per_devicec
C sZ | j d|d�}t|�j� dk}|p*| j|�}|�r |s:d S d }| j| d jd�sXd}nl| rn| j|�rnd}nV| j|�} | d kr�d}n>| d kr�|r�tj t
j | � d
S d }n|r�tj t
j
| � d S |d k r�tj d ||f � d S | jj|| � tj d
| � | j|d� nJ|�rd S | jj|�} | d k�r0d S tj d| � | j|d� | jj|� d S )Nr& )Z command_namer �forcer Zextzfilesystem not supportedz device uses write back cachezunknown current settingFTzbarriers already disabledz#not disabling barriers on '%s' (%s)zdisabling barriers on '%s'z barrier=0zenabling barriers on '%s'z barrier=1)Z _storage_key�str�lowerZ _option_boolr �
startswithr0 r; �log�info�constsZSTR_VERIFY_PROFILE_OK�errorZSTR_VERIFY_PROFILE_FAILZ_storager r< �getZunset)
r$ �startr: r! ZverifyZignore_missingZ storage_keyr= Z
reject_reason�original_valuer r r �_disable_barriers� sN
z MountsPlugin._disable_barriersN)�__name__�
__module__� __qualname__�__doc__� classmethodr" r% r' r) r* r/ r0 r; r< Zcommand_customrH r r r r r s $ r )Z tuned.constsrC � r Z
decorators�
subprocessr r Z
tuned.logsZtunedZtuned.utils.commandsr r+ ZlogsrE rA r, ZPluginr r r r r �<module> s