+cc @ s d d l Z d d l m Z d d l Td d l Z d d l j Z d d l m Z d d l
Z
d d l Z e j j
Z d e j f d YZ d S( iNi ( t hotplug( t *( t commandst
DiskPluginc B s9 e Z d Z d Z d Z d Z d Z e d Z d Z d Z
d Z d Z d
Z
e d Z e d Z d
Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d d Z d Z e d d e d Z e d e! d Z" e d d e d Z# e d e! d! Z$ e d" d e d# Z% e d" e! d$ Z& d% Z' d& Z( e d' d e d( Z) e d' e! d) Z* e+ d* d e d+ Z, d, Z- e d- d e d. Z. e d- e! d/ Z/ RS(0 s'
Plugin for tuning options of disks.
c O s t t | j | | d d d d d d d d d d
d d g | _ d
d d d d d d d d d d d g | _ t | j | _ d | _ d | _ t | _
d S( Ni i i i i i} ii iU iF i7 i i i i i i i i i i in iZ i< i g{Gz?( t superR t __init__t
_power_levelst _spindown_levelst lent _levelst _level_stepst _load_smallestR t _cmd( t selft argst kwargs( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyR s -- c C s t t | j t | _ t | _ t | _ t | _ xp | j j
d D]\ } | j | rP | j j | j
| j r | j | j
r | j j | j
q qP qP Wt | _ d S( Nt block( R R t
_init_devicest Truet _devices_supportedt _use_hdparmt sett
_free_devicest _hdparm_apm_devicest _hardware_inventoryt get_devicest _device_is_supportedt addt sys_namet _is_hdparm_apm_supportedt _assigned_devices( R
t device( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyR s c C s& g | D] } | j j d | ^ q S( NR ( R t
get_device( R
t devicest x( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _get_device_objects) s c C s | j j d d d | g d t j g d t \ } } } | t j k rd t j d t | _ t S| r t j d | t j
d | | f t Sd | k r t j d
| t St S( Nt hdparms -Cs /dev/%st no_errorst
return_errs4 hdparm command not found, ignoring for other devicess# Device '%s' not supported by hdparms (rc: %s, msg: '%s')t unknowns3 Driver for device '%s' does not support apm command( R t executet errnot ENOENTR t logt warnt FalseR t infot debug( R
R t rct outt err_msg( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyR , s
c C sI | j d k oH | j j d d d k oH | j d k pH | j j d k S( Nt diskt removablet 0t scsit virtiot xent nvme( R6 R7 R8 R9 ( t device_typet
attributest gett Nonet parentt subsystem( t clsR ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyR < s c C s | j j | d | j d S( NR ( R t subscribet _hardware_events_callback( R
( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _hardware_events_initC s c C s | j j | d S( N( R t unsubscribe( R
( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _hardware_events_cleanupF s c C s; | j | s | d k r7 t t | j | | n d S( Nt remove( R R R RB ( R
t eventR ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyRB I s c C s? | j d k r" | j j | n t t | j | | d S( N( t
_load_monitorR= t
add_deviceR R t _added_device_apply_tuning( R
t instancet device_name( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyRJ M s c C s? | j d k r" | j j | n t t | j | | d S( N( RH R= t
remove_deviceR R t _removed_device_unapply_tuning( R
RK RL ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyRN R s c C s5 i t d 6d d 6d d 6d d 6d d 6d d 6d d 6S( Nt dynamict elevatort apmt spindownt readaheadt readahead_multiplyt scheduler_quantum( R R= ( R@ ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _get_config_optionsW s c C s
d d g S( NRQ RR ( ( R@ ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt# _get_config_options_used_by_dynamicc s c C s t | _ d | _ d | _ | j | j d r| t | _ | j j d | j | _
i | _ i | _ i | _
i | _ n t | _ d | _
d S( Ni RO R3 ( R t _has_static_tuningt _apm_errcntt _spindown_errcntt _option_boolt optionst _has_dynamic_tuningt _monitors_repositoryt createt assigned_devicesRH t _device_idlet _statst _idlet _spindown_change_delayedR- R= ( R
RK ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _instance_initj s c C s2 | j d k r. | j j | j d | _ n d S( N( RH R= R^ t delete( R
RK ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _instance_cleanup} s c C s | r d } | j } n d } | j } | t j k r: d S| d k rO d } ne | t j k r t j d | _ | _ t j d d S| d 7} | t j k r t j d | n | r | | _ n | | _ d S( NRR RQ i i sI hdparm command not found, ignoring future set_apm / set_spindown commandss5 disabling set_%s command: too many consecutive errors( RZ RY t constst ERROR_THRESHOLDR) R* R+ R, R. ( R
R0 RR t st cnt( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _update_errcnt s&
c C sg t j d | | j j d d | d | g d t j g \ } } | j | t t | j | <d S( Ns changing spindown to %dR$ s -S%ds /dev/%sR% (
R+ R/ R R( R) R* Rl R R- Rd ( R
RK R t new_spindown_levelR0 R1 ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _change_spindown s 5c C sG | j j d d d | g d t j g \ } } d | k oF d | k S( NR$ s -Cs /dev/%sR% t standbyt sleeping( R R( R) R* ( R
R R0 R1 ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _drive_spinning s 1c C s | | j k r d S| j j | } | d k r5 d S| | j k rW | j | | n | j | | | | j | | | j | } | j | } | d d | j k r | d | j
k r | d | j
k r d } n? | d d k r| d d k s
| d d k rd } n d } | d k r?| d c | 7<| j | d } | j | d } t
j d | d | j t j k r| j | r| d k rt
j d | t | j | <q| j | | | n | j t j k rt
j d | | j j d
d | d | g d
t j g \ } }
| j | t qnC | j | r| j | r| j | d } | j | | | n t
j d | | d | d f t
j d | | d | d | d f d S( Nt leveli t readt writei is tuning level changed to %ds; delaying spindown change to %d, drive has already spun downs changing APM_level to %dR$ s -B%ds /dev/%sR% s %s load: read %0.2f, write %0.2fs$ %s idle: read %d, write %d, level %d( R RH t get_device_loadR= Rb t _init_stats_and_idlet
_update_statst _update_idleRc R R
R R R+ R/ RZ Rh Ri Rq R Rd Rn RY R R( R) R* Rl R- ( R
RK R t loadt statst idlet level_changet new_power_levelRm R0 R1 ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _instance_update_dynamic sF
= 0 5 "c C sj i d d g d 6d d g d 6d d g d 6| j | <i d d 6d d 6d d 6| j | <t | j | <d S(
Ni i t newt oldi t maxRr Rs Rt ( Rb Rc R- Rd ( R
RK R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyRv s 7"c
C s | j | d | j | d <} | | j | d <g t | | D] } | d | d ^ qA } | | j | d <| j | d } g t | | D] } t | ^ q } | | j | d <t | d t | d | j | d <t | d t | d | j | d <d S(
NR R i i t diffR Rs i Rt ( Rb t zipR t float(
R
RK R t new_loadt old_loadt new_oldR t old_max_loadt pairt max_load( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyRw s .()c C s` xY d d g D]K } | j | | | j k rG | j | | c d 7<q
d | j | | <q
Wd S( NRs Rt i i ( Rb R Rc ( R
RK R t operation( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyRx s c C s@ | | j k r# t j d | n t t | j t t d S( Ns< There is no dynamic tuning available for device '%s' at time( R R+ R. R R t _instance_apply_dynamicR R ( R
RK R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyR s c C s d S( N( ( R
RK R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _instance_unapply_dynamic s s /sys/block/c C s_ d | k rI t j j | | j d d | } t j j | rI | Sn t j j | | | S( Nt /t !( t ost patht joint replacet exists( R
R t suffixt prefixt dev( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _sysfs_path s
$c C s | j | d S( Ns queue/scheduler( R ( R
R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _elevator_file s RP t
per_devicec C s/ | j | } | s+ | j j | | n | S( N( R R t
write_to_file( R
t valueR t simt sys_file( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt
_set_elevator
s c C s1 | j | } | j j | j j | d | S( Nt no_error( R R t get_active_optiont read_file( R
R t ignore_missingR ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt
_get_elevator s RQ c C s | | j k r7 | s* t j d | d St | Sn | j t j k r | s | j j d d t | d | g d t
j g \ } } | j | t
n t | Sd Sd S( Ns+ apm option is not supported for device '%s'R$ s -Bs /dev/R% ( R R+ R. R= t strRY Rh Ri R R( R) R* Rl R- ( R
R R R R0 R1 ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _set_apm s
:
c C s | | j k r- | s) t j d | n d Sd } t } | j j d d d | g d t j g \ } } | t j k r~ d S| d k r t } nT t
j d | t
j } | r y t
| j d } Wq t k
r t } q Xn | rt j d | n | S(
Ns+ apm option is not supported for device '%s'R$ s -Bs /dev/R% i s
.*=\s*(\d+).*i s2 could not get current APM settings for device '%s'( R R+ R. R= R- R R( R) R* R t ret matcht St intt groupt
ValueErrort error( R
R R R t errR0 R1 t m( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _get_apm( s( 1
RR c C s | | j k r7 | s* t j d | d St | Sn | j t j k r | s | j j d d t | d | g d t
j g \ } } | j | t
n t | Sd Sd S( Ns0 spindown option is not supported for device '%s'R$ s -Ss /dev/R% ( R R+ R. R= R RZ Rh Ri R R( R) R* Rl R ( R
R R R R0 R1 ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt
_set_spindown@ s
:
c C s1 | | j k r- | s) t j d | n d Sd S( Ns0 spindown option is not supported for device '%s'i ( R R+ R. R= ( R
R R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt
_get_spindownP s
c C s | j | d S( Ns queue/read_ahead_kb( R ( R
R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _readahead_fileY s c C s_ t | j d d } t | d } t | d k r[ | d d d k r[ | d :} n | S( Ni i Rj i ( R t splitR= R R ( R
R t valt v( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _parse_ra\ s
&
RS c C sB | j | } | j | } | s> | j j | d | n | S( Ns %d( R R R R ( R
R R R R R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _set_readaheadd s
c C sM | j | } | j j | d | j } t | d k rC d St | S( NR i ( R R R t stripR R= R ( R
R R R R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _get_readaheadl s
RT c C s | r
d S| j d d d | } | r | j | } | d k rG d St t | | } | j j | | | j | | t nE | j j | } | d k r d S| j | | t | j j
| d S( Nt command_nameRT RL ( R= t _storage_keyR R R t _storageR R R- R< t unset( R
t enablingt
multiplierR t verifyR t storage_keyt
old_readaheadt
new_readahead( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _multiply_readaheadt s" c C s | j | d S( Ns queue/iosched/quantum( R ( R
R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _scheduler_quantum_file s RU c C s9 | j | } | s5 | j j | d t | n | S( Ns %d( R R R R ( R
R R R R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _set_scheduler_quantum s c C sg | j | } | j j | d | j } t | d k r] | sY t j d | n d St | S( NR i s> disk_scheduler_quantum option is not supported for device '%s'( R R R R R R+ R. R= R ( R
R R R R ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt _get_scheduler_quantum s (0 t __name__t
__module__t __doc__R R R# R t classmethodR RC RE RB RJ RN RV RW Re Rg Rl Rn Rq R~ Rv Rw Rx R R R R t command_setR R t command_getR- R R R R R R R R R t command_customR R R R ( ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyR sZ
2 ( R) t R t
decoratorst
tuned.logst tunedt tuned.constsRh t tuned.utils.commandsR R R t logsR< R+ t PluginR ( ( ( s= /usr/lib/python2.7/site-packages/tuned/plugins/plugin_disk.pyt <module> s