�
��\c@s�dd
lj
Z
ddlmZ
ddlTddlmZmZ
dd
lZ	ddl
mZ
dd
lZe	j
j�Ze�Zdejf
d��YZd
S(	i����Ni
(
tbase(
t
*(tPopentPIPE(
tcommandstMountsPlugincBs�eZ
dZed
��
Zd�Zed��
Zd�Zd�Zd�Z	d�Z
d�Zd	�Ze
d
de�

d��
ZRS(
s.
	Plugin for tuning options of mount-points.
	c

Cs�
i}
d}t
d
ddgdtdtdtdt�
j�\}}x-
g|j�D]}|j�^qUD]
}t|�
dkr�qkn|d \}}}	t|�
dkr�|dnd}
t|�
d	kr�|d	nd}|d
kr�|	}qkn|dksk|dkr
qkn|dksk|dkr4
qkn|
j|it	�d6|	d6|
d6�
|
|dj
|�

qkW|
|_dS(s�
		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.
		tlsblks-rnosTYPE,RM,KNAME,FSTYPE,MOUNTPOINTtstdouttstderrt	close_fdstuniversal_newlinesiitdiskt
1tparttlvms[SWAP]tdiskstdevice_namet
filesystemN(R
R(tNoneRRtTruetcommunicatet
splitlinestsplittlent
setdefaulttsettaddt_mountpoint_topology(tclstmountpoint_topologytcurrent_diskRRtlinetcolumnstdevice_typetdevice_removableRRt
mountpoint((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_generate_mountpoint_topologys,
	
	


,



"
"



(
c

Cs;|j�
t
|_t|jj��
|_t�|_dS(
N(R$Rt_devices_supportedRRtkeyst
_free_devicest_assigned_devices(
tself((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt
_init_devices5s


	

c

Csi
dd
6S(Ntdisable_barriers(
R(
R)((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_get_config_options;s
cCst|
_
t|
_dS(
N(tFalset_has_dynamic_tuningRt_has_static_tuning(R)tinstance((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_instance_initAs
	
c
CsdS(
N((R)R0((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_instance_cleanupEs
cCs8tjd
|
�
}x|D]}t
j|�
j�SWdS(sV
		Get device cache type. This will work only for devices on SCSI kernel subsystem.
		s+/sys/block/%s/device/scsi_disk/*/cache_typeN(tglobtcmdt	read_filetstripR(R)tdevicetsource_filenamestsource_filename((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_get_device_cache_typeHs



cCs9x2|j|
d
D]}|j
|�
dkrtSqWtS(sr
		Checks if the device has 'write back' cache. If the cache type cannot be determined, asume some other cache.
		Rs
write back(RR:RR-(R)R#R7((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_mountpoint_has_writeback_cacheQs


cCs�td
�
�`}xV|D]J}|j
�}|dddkrBqn|d|
kr|d}PqqWdSWdQX|j
d�
}xb|D]V}|jd�
\}}	}
|d	ks�|d
kr�|
dkr�tS|d
kr�tSq�WtSdS(sP
		Checks if a given mountpoint is mounted with barriers enabled or disabled.
		s/proc/mountsit
/i
iNt
,t
=t	nobarriertbarriert
0(topenRRt	partitionR-R(R)R#tmounts_fileRR toption_listtoptionstoptiontnametseptvalue((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_mountpoint_has_barriersZs"











$

cCs'd
|
dd|g}tj
|�

dS(s
		Remounts partition.
		s/usr/bin/mounts-os
remount,%sN(R4texecute(R)RCRFtremount_command((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_remount_partitionws
R+t
per_devicec
Cs�
|jd
dd|�}t
|�
j�dk}|pB|j|�
}|
rp
|sUdSd}|j|djd�
s~d}n�|r�|j|�
r�d}nu|j|�
}	|	dkr�d	}nQ|	t	kr�|r�t
jtj
|�

tSd
}n|r
t
jtj|�

t	S|dk	r9
t
jd||f�

dS|jj||	�
t
jd|�

|j|d
�
n]|rz
dS|jj|�
}	|	dkr�
dSt
jd|�

|j|d�
|jj|�

dS(Ntcommand_nameR+RtforceRtextsfilesystem not supportedsdevice uses write back cachesunknown current settingsbarriers already disableds#not disabling barriers on '%s' (%s)sdisabling barriers on '%s's	barrier=0senabling barriers on '%s's	barrier=1(t_storage_keytstrtlowert_option_boolRRt
startswithR;RKR-tlogtinfotconststSTR_VERIFY_PROFILE_OKRterrortSTR_VERIFY_PROFILE_FAILt_storageRRNtgettunset(
R)tstartRJR#tverifytignore_missingtstorage_keyRQt
reject_reasontoriginal_value((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt_disable_barriers~sN	

	




	

	

	



	













(t__name__t
__module__t__doc__tclassmethodR$R*R,R1R2R:R;RKRNtcommand_customRRg(((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyRs$									(ttuned.constsRZtRt
decoratorst
subprocessRRt
tuned.logsttunedttuned.utils.commandsRR3tlogsR_RXR4tPluginR(((s?/usr/lib/python2.7/site-packages/tuned/plugins/plugin_mounts.pyt<module>
s