509318396 ÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂ 3 À<×e‘Wã@slddlZddljZddlZddlZddlZddlmZddl Z ddl mZmZej jƒZGdd„deƒZdS)éN)Úcommands)ÚPopenÚPIPEc@s&eZdZdZdd„Zdd„Zdd„Zedd „ƒZe d d„ƒZ e dd „ƒZe dd„ƒZdd„Z dd„Zdd„Zdd„Zdd„Zdd„Zdd„Zdd„Zd d!„Zd"d#„Zd$d%„Zd&d'„Zd(d)„Zd*d+„Zd,d-„Zd.d/„Zd0d1„Zejfd2d3„Z d4d5„Z!d6d7„Z"d8d9„Z#ejfd:d;„Z$dd?„Z&ejfd@dA„Z'dBdC„Z(dDdE„Z)dFdG„Z*dHdI„Z+dJdK„Z,dLdM„Z-d|dOdP„Z.d}dQdR„Z/d~dSdT„Z0ddUdV„Z1dWdX„Z2dYdZ„Z3d[d\„Z4d]d^„Z5d_d`„Z6d€dbdc„Z7dddde„Z8dfdg„Z9dhdi„Z:djdk„Z;d‚dldm„Zdrds„Z?dtdu„Z@d„dvdw„ZAd…dxdy„ZBdzd{„ZCdNS)†ÚPlugina Base class for all plugins. Plugins change various system settings in order to get desired performance or power saving. Plugins use Monitor objects to get information from the running system. Intentionally a lot of logic is included in the plugin to increase plugin flexibility. c Csn|j|jjƒ|_||_||_||_||_||_t j ƒ|_|jƒ||_ ||_d|_d|_|jƒ|_tƒ|_dS)zPlugin constructor.FN)ÚcreateÚ __class__Ú__name__Ú_storageZ_monitors_repositoryZ_hardware_inventoryÚ_device_matcherÚ_device_matcher_udevÚ_instance_factoryÚcollectionsÚOrderedDictÚ _instancesÚ_init_commandsÚ_global_cfgÚ _variablesÚ_has_dynamic_optionsÚ_devices_initedÚ#_get_config_options_used_by_dynamicÚ_options_used_by_dynamicrÚ_cmd) ÚselfZmonitors_repositoryZstorage_factoryZhardware_inventoryZdevice_matcherZdevice_matcher_udevZinstance_factoryZ global_cfgÚ variables©rú/usr/lib/python3.6/base.pyÚ__init__s zPlugin.__init__cCs|jƒdS)N)Údestroy_instances)rrrrÚcleanup,szPlugin.cleanupcCs|js|jƒd|_dS)NT)rÚ _init_devices)rrrrÚinit_devices/szPlugin.init_devicescCs|jjjdƒdjddƒdS)NÚ.éÚ_éÿÿÿÿ)rÚ __module__Úsplit)rrrrÚname4szPlugin.namecCsiS)z-Default configuration options for the plugin.r)rrrrÚ_get_config_options<szPlugin._get_config_optionscCsiS)z*Explanation of each config option functionr)ÚclsrrrÚget_config_options_hintsAszPlugin.get_config_options_hintscCsgS)znList of config options used by dynamic tuning. Their previous values will be automatically saved and restored.r)rrrrrFsz*Plugin._get_config_options_used_by_dynamiccCsP|jƒjƒ}x>|D]6}||ks$|jr2||||<qtjd||jjfƒqW|S)z3Merge provided options with plugin default options.z$Unknown option '%s' for plugin '%s'.)r(ÚcopyrÚlogÚwarnrr)rÚoptionsZ effectiveÚkeyrrrÚ_get_effective_optionsKs zPlugin._get_effective_optionscCs,t|ƒtkr|St|ƒjƒ}|dkp*|dkS)NÚtrueÚ1)ÚtypeÚboolÚstrÚlower)rÚvaluerrrÚ_option_boolVszPlugin._option_boolc CsF||jkrtd|ƒ‚|j|ƒ}|jj|||||||ƒ}||j|<|S)z8Create new instance of the plugin and seize the devices.z.Plugin instance with name '%s' already exists.)rÚ Exceptionr0rr) rr'Údevices_expressionÚdevices_udev_regexÚ script_preÚscript_postr.Zeffective_optionsÚinstancerrrÚcreate_instance`s zPlugin.create_instancecCsV|j|krtd||fƒ‚|j|jkr2td|ƒ‚|j|j}|j|ƒ|j|j=dS)zDestroy existing instance.z9Plugin instance '%s' does not belong to this plugin '%s'.z+Plugin instance '%s' was already destroyed.N)Z_pluginr9r'rÚ_destroy_instance)rr>rrrÚdestroy_instancels zPlugin.destroy_instancecCs$tjd|j|jfƒ|j|ƒdS)zInitialize an instance.zinitializing instance %s (%s)N)r,Údebugr'Ú_instance_init)rr>rrrÚinitialize_instancewszPlugin.initialize_instancecCsFx6t|jjƒƒD]$}tjd|j|jfƒ|j|ƒqW|jjƒdS)zDestroy all instances.zdestroying instance %s (%s)N)ÚlistrÚvaluesr,rBr'r@Úclear)rr>rrrr|szPlugin.destroy_instancescCs|j|ƒ|j|ƒdS)N)Úrelease_devicesÚ_instance_cleanup)rr>rrrr@ƒs zPlugin._destroy_instancecCs tƒ‚dS)N)ÚNotImplementedError)rr>rrrrC‡szPlugin._instance_initcCs tƒ‚dS)N)rJ)rr>rrrrIŠszPlugin._instance_cleanupcCsd|_tƒ|_tƒ|_dS)NF)Ú_devices_supportedÚsetÚ_assigned_devicesÚ _free_devices)rrrrr‘szPlugin._init_devicescCsdS)z’Override this in a subclass to transform a list of device names (e.g. ['sda']) to a list of pyudev.Device objects, if your plugin supports itNr)rÚdevicesrrrÚ_get_device_objects–szPlugin._get_device_objectscCsj|jdkrt|jj|j|ƒƒS|j|ƒ}|dkrDtjd|jƒtƒS|j j|j|ƒ}tdd„|DƒƒSdS)Nz¤sz0Plugin._get_matching_devices..) r;rLr Z match_listr:rPr,Úerrorr'r)rr>rOZudev_devicesrrrÚ_get_matching_devices›s zPlugin._get_matching_devicescCs²|js dStjd|jƒ|j||jƒ}t|ƒdk|_|jsNtjd|jƒn`|j}|j|jkrn|d|j7}tj d|dj |ƒfƒ|jj|ƒ|j |O_ |j|8_dS)Nz assigning devices to instance %srz*instance %s: no matching devices availablez (%s)z!instance %s: assigning devices %sz, )rKr,rBr'rUrNÚlenÚactiver-ÚinfoÚjoinÚassigned_devicesÚupdaterM)rr>Z to_assignr'rrrÚassign_free_devices¦szPlugin.assign_free_devicescCsV|js dS|j|jB|j@}d|_|jjƒ|jjƒ|j|8_|j|O_dS)NF)rKÚprocessed_devicesrZrMrWrGrN)rr>Z to_releaserrrrH¸s zPlugin.release_devicescCs(|jsdg}x|D]}|||ƒqWdS)N)rK)rr>ÚcallbackrOÚdevicerrrÚ_run_for_each_deviceÊs zPlugin._run_for_each_devicecCsdS)Nr)rr>ÚenablingrrrÚ_instance_pre_staticÑszPlugin._instance_pre_staticcCsdS)Nr)rr>rarrrÚ_instance_post_staticÔszPlugin._instance_post_staticcCsn|dkrdSt|ƒdkr0tjd|j|fƒdS|jdƒsHtjdƒdStjj|ƒ}d}x|D]}tj } | j |jjƒƒ|g} |t jkr–| jdƒ| j|ƒtjd |t| ƒfƒtjd tt| jƒƒƒƒyVt|g| ttd| |dd}|jƒ\}} |jr$tjd||j| dd…fƒd}Wq`ttfk rd}ztjd||fƒd}WYdd}~Xq`Xq`W|S)Nrz1Instance '%s': no device to call script '%s' for.ú/zZscriptÚoprOÚrollbackZdir_nameÚretZdevrmZ argumentsÚprocÚoutÚerrÚerrrÚ_call_device_script×sB zPlugin._call_device_scriptcCs |js dS|jrZ|j||jd|jƒ|j|dƒ|j|ƒ|j|dƒ|j||jd|jƒ|j r„|j jtj tjƒr„|j||j|jƒ|jj|jƒ|jjƒdS)zG Apply static and dynamic tuning if the plugin instance is active. NZapplyT)rWÚhas_static_tuningr{r<rZrbÚ_instance_apply_staticrcr=Úhas_dynamic_tuningrÚgetrnÚCFG_DYNAMIC_TUNINGÚCFG_DEF_DYNAMIC_TUNINGr`Ú_instance_apply_dynamicr]r[rG)rr>rrrÚinstance_apply_tuningús zPlugin.instance_apply_tuningcCs”|js dSt|jƒdkr.tjddj|jƒƒ|jjƒ}|jrŒ|j ||j d|ƒdkrXdS|j|||ƒdkrndS|j ||jd|ƒdkrˆdSdSdSdS)z< Verify static tuning if the plugin instance is active. Nrz)BUG: Some devices have not been tuned: %sz, ZverifyFT) rWrVrZr,rTrYr]r+r|r{r<Ú_instance_verify_staticr=)rr>Úignore_missingrOrrrÚinstance_verify_tunings zPlugin.instance_verify_tuningcCs<|js dS|jr8|jjtjtjƒr8|j||j|j j ƒƒdS)z< Apply dynamic tuning if the plugin instance is active. N)rWr~rrrnr€rr`Ú_instance_update_dynamicr]r+)rr>rrrÚinstance_update_tuning$szPlugin.instance_update_tuningcCs–|tjkrdS|jr8|jjtjtjƒr8|j||j|j ƒ|j r’|j||jd|j |d|j |dƒ|j||ƒ|j|dƒ|j||jd|j |ddS)z8 Remove all tunings applied by the plugin instance. NZunapply)ruF)rnZ ROLLBACK_NONEr~rrr€rr`Ú_instance_unapply_dynamicr]r|r{r=rbÚ_instance_unapply_staticrcr<)rr>rurrrÚinstance_unapply_tuning-s zPlugin.instance_unapply_tuningcCs|j|ƒ|j||jƒdS)N)Ú _execute_all_non_device_commandsÚ_execute_all_device_commandsrZ)rr>rrrr}?s zPlugin._instance_apply_staticcCs2d}|j||ƒdkrd}|j|||ƒdkr.d}|S)NTF)Ú_verify_all_non_device_commandsÚ_verify_all_device_commands)rr>r…rOrvrrrr„CszPlugin._instance_verify_staticcCs|j||jƒ|j|ƒdS)N)Ú_cleanup_all_device_commandsr]Ú _cleanup_all_non_device_commands)rr>rurrrrŠKszPlugin._instance_unapply_staticcsFx4‡‡‡fdd„ˆjDƒD]}ˆjˆˆj|ˆƒqWˆjˆˆƒdS)Ncs(g|] }ˆjˆˆj|ˆƒdkr|‘qS)N)Ú_storage_getÚ _commands)rQÚopt)r_r>rrrrSQsz2Plugin._instance_apply_dynamic..)rÚ_check_and_save_valuer“r‡)rr>r_Zoptionr)r_r>rrr‚PszPlugin._instance_apply_dynamiccCs tƒ‚dS)N)rJ)rr>r_rrrr‰Vsz Plugin._instance_unapply_dynamiccCs tƒ‚dS)N)rJ)rr>r_rrrr‡YszPlugin._instance_update_dynamiccCstjƒ|_|jƒ|jƒdS)z Initialize commands. N)r rr“Ú_autoregister_commandsÚ_check_commands)rrrrr`s zPlugin._init_commandscCsúxÒ|jjD]Æ}|jdƒrq t||ƒ}t|dƒs0q |jd}|jj|d|iƒ}d|jkr„d|d<||d<|jd|d<|jd|d<nBd |jkr˜||d <n.d|jkrÆ||d<|jd|d<|jd|d<||j|<q Wtj t t|jjƒƒd d„dƒ|_dS) zd Register all commands marked using @command_set, @command_get, and @command_custom decorators. Ú__Ú_commandr'rLNÚcustomÚ per_deviceÚpriorityrcSs|ddS)Nr"rœr)Z name_inforrrÚ…sz/Plugin._autoregister_commands..)r/) rÚ__dict__riÚgetattrÚhasattrr™r“rr rÚsortedÚiterrp)rÚmember_nameÚmemberÚcommand_namerXrrrr–hs* zPlugin._autoregister_commandscCsJxDt|jjƒƒD]2\}}|jddƒr&qd|ks6d|krtd|ƒ‚qWdS)z2 Check if all commands are defined correctly. ršFrrLz,Plugin command '%s' is not defined correctlyN)rEr“rprÚ TypeError)rr¥Úcommandrrrr—‡s zPlugin._check_commandsNcCsJt|ƒj}|dkrdn|}|dkr&dn|}|dkr6dn|}d||||fS)NÚz%s/%s/%s/%s)r3r)rZ instance_namer¥Údevice_nameÚ class_namerrrÚ_storage_key—s zPlugin._storage_keycCs&|j|j|d|ƒ}|jj||ƒdS)Nr')r«r'r rL)rr>r§r7r©r/rrrÚ_storage_set szPlugin._storage_setcCs |j|j|d|ƒ}|jj|ƒS)Nr')r«r'r r)rr>r§r©r/rrrr’¤szPlugin._storage_getcCs |j|j|d|ƒ}|jj|ƒS)Nr')r«r'r Zunset)rr>r§r©r/rrrÚ_storage_unset¨szPlugin._storage_unsetcCsVxPdd„t|jjƒƒDƒD]4}|jj|jj|ddƒƒ}|dk r|j|||ƒqWdS)NcSsg|]}|ds|‘qS)r›r)rQr§rrrrS±sz;Plugin._execute_all_non_device_commands..r')rEr“rFrÚexpandr.rÚ_execute_non_device_command)rr>r§Ú new_valuerrrrŒ°sz'Plugin._execute_all_non_device_commandscCshxbdd„t|jjƒƒDƒD]F}|jj|jj|ddƒƒ}|dkrBqx|D]}|j||||ƒqHWqWdS)NcSsg|]}|dr|‘qS)r›r)rQr§rrrrS·sz7Plugin._execute_all_device_commands..r')rEr“rFrr®r.rÚ_execute_device_command)rr>rOr§r°r_rrrr¶s z#Plugin._execute_all_device_commandscCsdd}xZdd„t|jjƒƒDƒD]>}|jj|jj|ddƒƒ}|dk r|j||||ƒdkrd}qW|S)NTcSsg|]}|ds|‘qS)r›r)rQr§rrrrSÀsz:Plugin._verify_all_non_device_commands..r'F)rEr“rFrr®r.rÚ_verify_non_device_command)rr>r…rvr§r°rrrrŽ¾sz&Plugin._verify_all_non_device_commandscCsnd}xddd„t|jjƒƒDƒD]H}|jj|ddƒ}|dkr>qx&|D]}|j|||||ƒdkrDd}qDWqW|S)NTcSsg|]}|dr|‘qS)r›r)rQr§rrrrSÉsz6Plugin._verify_all_device_commands..r'F)rEr“rFr.rÚ_verify_device_command)rr>rOr…rvr§r°r_rrrrÇs z"Plugin._verify_all_device_commandscCsÆ|dk rÂt|ƒ}t|ƒdkr |S|dd…}|dd…}|dkrP|dkrL|S|SyF|dkrtt|ƒt|ƒkrn|SdSn |dkr”t|ƒt|ƒkr|SdSWn*tk rÀtjd||||fƒYnX|S)Nr"ú<ú>zhcannot compare new value '%s' with current value '%s' by operator '%s', using '%s' directly as new value)r´rµ)r5rVÚintÚ ValueErrorr,r-)rr°Ú current_valueZnwsrtÚvalrrrÚ_process_assignment_modifiersÒs(z$Plugin._process_assignment_modifiersFcCs&|dk r|d||dS|dƒSdS)Nr)r…r)rr§r_r…rrrÚ_get_current_valueêszPlugin._get_current_valuecCs<|j||ƒ}|j||ƒ}|dk r8|dk r8|j||||ƒ|S)N)r»rºr¬)rr>r§r_r°r¸rrrr•ðs zPlugin._check_and_save_valuecCsR|ddk r"|dd||ddƒn,|j||||ƒ}|dk rN|d||ddddS)NršTFrL)ÚsimÚremove)r•)rr>r§r_r°rrrr±÷s zPlugin._execute_device_commandcCsN|ddk r |dd|ddƒn*|j||d|ƒ}|dk rJ|d|ddddS)NršTFrL)r¼r½)r•)rr>r§r°rrrr¯ÿs z"Plugin._execute_non_device_commandcCs.|jjt|ƒƒ}tjd|ƒr*tjdd|ƒS|S)Nz\s*(0+,?)+([\da-fA-F]*,?)*\s*$z^\s*(0+,?)+r¨)rZunquoter5ÚreÚmatchÚsub)rr7ÚvrrrÚ_norm_valueszPlugin._norm_valuec Cs(|dkrdSd}|dkrN|rN|dkr6tjtj|ƒntjtj||fƒdS|dk r|j|ƒ}|j|ƒ}yt|ƒt|ƒk}WnŽtk ryt|dƒt|dƒk}Wn^tk rt|ƒt|ƒk}|st|ƒj dƒ}x"|D]}|j ƒ}||k}|ræPqæWYnXYnX|j|||||d|S)NFTéú|)r_)r,rXrnZ STR_VERIFY_PROFILE_VALUE_MISSINGZ'STR_VERIFY_PROFILE_DEVICE_VALUE_MISSINGrÂr¶r·r5r&ÚstripÚ_log_verification_result) rr'r°r¸r…r_rvÚvalsr¹rrrÚ _verify_value s8 zPlugin._verify_valuecCs¬|rL|dkr*tjtj|t|ƒjƒfƒntjtj||t|ƒjƒfƒdS|dkr|tjtj|t|ƒjƒt|ƒjƒfƒn(tjtj ||t|ƒjƒt|ƒjƒfƒdSdS)NTF) r,rXrnZSTR_VERIFY_PROFILE_VALUE_OKr5rÅZ"STR_VERIFY_PROFILE_DEVICE_VALUE_OKrTZSTR_VERIFY_PROFILE_VALUE_FAILZ$STR_VERIFY_PROFILE_DEVICE_VALUE_FAIL)rr'Úsuccessr°r¸r_rrrrÆ-s((zPlugin._log_verification_resultcCsp|ddk r |dd||d|ƒS|j|||d}|j||ƒ}|dkrHdS|d||ddƒ}|j|d||||ƒS)NršT)r…rLFr')r»rºrÈ)rr>r§r_r°r…r¸rrrr³<szPlugin._verify_device_commandcCsd|ddk r|dd|d|ƒS|j|ƒ}|j||ƒ}|dkr@dS|d|ddƒ}|j|d|||ƒS)NršTrLFr')r»rºrÈ)rr>r§r°r…r¸rrrr²Fs z!Plugin._verify_non_device_commandcCsZxTtdd„t|jjƒƒDƒƒD]4}|jj|ddƒdk sF|d|jkr|j||ƒqWdS)NcSsg|]}|ds|‘qS)r›r)rQr§rrrrSQsz;Plugin._cleanup_all_non_device_commands..r')ÚreversedrEr“rFr.rrÚ_cleanup_non_device_command)rr>r§rrrr‘Ps"$z'Plugin._cleanup_all_non_device_commandscCslxftdd„t|jjƒƒDƒƒD]F}|jj|ddƒdk sF|d|jkrx|D]}|j||||ƒqLWqWdS)NcSsg|]}|dr|‘qS)r›r)rQr§rrrrSVsz7Plugin._cleanup_all_device_commands..r')rÊrEr“rFr.rrÚ_cleanup_device_command)rr>rOr½r§r_rrrrUs"$ z#Plugin._cleanup_all_device_commandscCs^|ddk r"|ddd|ddƒn8|j|||ƒ}|dk rL|d||d|d|j|||ƒdS)NršFrL)r¼r½)r’r)rr>r§r_r½Ú old_valuerrrrÌ[szPlugin._cleanup_device_commandcCsV|ddk r |dddddƒn2|j||ƒ}|dk rF|d|ddd|j||ƒdS)NršFrL)r¼r½)r’r)rr>r§rÍrrrrËdsz"Plugin._cleanup_non_device_command)NNN)N)N)N)NF)NN)N)N)F)F)Drr%Ú__qualname__Ú__doc__rrr Úpropertyr'Úclassmethodr(r*rr0r8r?rArDrr@rCrIrrPrUr\rHr`rbrcrnZ ROLLBACK_SOFTr{rƒr†rˆr‹r}r„rŠr‚r‰r‡rr–r—r«r¬r’rrŒrrŽrrºr»r•r±r¯rÂrÈrÆr³r²r‘rrÌrËrrrrrs| # ! r)r¾Ztuned.constsrnZtuned.profiles.variablesZtunedZ tuned.logsr Ztuned.utils.commandsrrjÚ subprocessrrZlogsrr,ÚobjectrrrrrÚs