o _@srddlmZddlmZddlTddlmZmZddlZ ddl m Z ddl Z e j Ze ZGdddejZdS) N)base)*)PopenPIPE)commandsc@steZdZdZeddZddZeddZdd Zd d Z d d Z ddZ ddZ ddZ edddddZdS) MountsPluginz. Plugin for tuning options of mount-points. c Csi}d}tgdttddd\}}dd|DD]W}t|dkr%q|dd\}}}t|dkr8|dnd} t|dkrD|dnd} |d krM|}q|d ksU|d vrVq| dus^| d kr_q|| t|| d || d|q||_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. N)lsblkz-rnozTYPE,RM,KNAME,FSTYPE,MOUNTPOINTT)stdoutstderr close_fdsuniversal_newlinescSsg|]}|qS)split).0linerr=/usr/lib/python3/dist-packages/tuned/plugins/plugin_mounts.py sz>MountsPlugin._generate_mountpoint_topology..disk1)partlvmz[SWAP])disks device_name filesystemr) rr communicate splitlineslen setdefaultsetadd_mountpoint_topology) clsmountpoint_topology current_diskr r columns device_typedevice_removablerr mountpointrrr_generate_mountpoint_topologys0  z*MountsPlugin._generate_mountpoint_topologycCs*|d|_t|j|_t|_dS)NT)r+_devices_supportedr!r#keys _free_devices_assigned_devicesselfrrr _init_devices5s zMountsPlugin._init_devicescCsddiS)Ndisable_barriersrr0rrr_get_config_options;sz MountsPlugin._get_config_optionscCsd|_d|_dS)NFT)_has_dynamic_tuning_has_static_tuningr1instancerrr_instance_initAs zMountsPlugin._instance_initcCsdS)Nrr7rrr_instance_cleanupEszMountsPlugin._instance_cleanupcCs,td|}|D] }t|SdS)zV Get device cache type. This will work only for devices on SCSI kernel subsystem. z+/sys/block/%s/device/scsi_disk/*/cache_typeN)globcmd read_filestrip)r1devicesource_filenamessource_filenamerrr_get_device_cache_typeHsz#MountsPlugin._get_device_cache_typecCs,|j|dD] }||dkrdSqdS)zr Checks if the device has 'write back' cache. If the cache type cannot be determined, asume some other cache. rz write backTF)r#rB)r1r*r?rrr_mountpoint_has_writeback_cacheQs z,MountsPlugin._mountpoint_has_writeback_cachec Cstd/}|D]}|}|dddkrq|d|kr"|d}n q WddSWdn1s6wY|d}|D] }|d\}} } |d ksX|d kr[| d kr[d S|d krbd SqBd S)zP Checks if a given mountpoint is mounted with barriers enabled or disabled. z /proc/mountsr/rrN,= nobarrierbarrier0FT)openr partition) r1r* mounts_filerr' option_listoptionsoptionnamesepvaluerrr_mountpoint_has_barriersZs,   z%MountsPlugin._mountpoint_has_barrierscCsd|dd|g}t|dS)z Remounts partition. z/usr/bin/mountz-oz remount,%sN)r<execute)r1rKrNremount_commandrrr_remount_partitionwszMountsPlugin._remount_partitionr3T) per_devicec CsT|jd|d}t|dk}|p||}|r|sdSd}|j|dds+d}n5|s5||r5d}n+||} | durAd}n| d krT|rQt t j |d Sd }n |r`t t j |d S|durot d ||fdS|j|| t d |||ddS|rdS|j|} | durdSt d|||d|j|dS)Nr3) command_namerforcerextzfilesystem not supportedzdevice 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) _storage_keystrlower _option_boolr# startswithrCrSloginfoconstsSTR_VERIFY_PROFILE_OKerrorSTR_VERIFY_PROFILE_FAIL_storager!rVgetunset) r1startrRr*verifyignore_missing storage_keyrY reject_reasonoriginal_valuerrr_disable_barriers~sR      zMountsPlugin._disable_barriersN)__name__ __module__ __qualname____doc__ classmethodr+r2r4r9r:rBrCrSrVcommand_customrorrrrr s #    r) tuned.constsrbr decorators subprocessrr tuned.logstunedtuned.utils.commandsrr;logsrgr`r<Pluginrrrrrs