a
Á]›iøJ ã @ sž d dl mZ d dlZ d dlZ d dlmZ d dlZd dlmZ d dlm Z d dl
m Z d dl Z d dl
Z
dgZe j ¡ ZG dd„ deƒZG d d„ de jjjƒZdS )
é )ÚexportsN)ÚTunedException)Úcommands)ÚhotplugÚ
Controllerc @ s, e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd S )
Ú
TimerStorec C s t ƒ | _t ¡ | _d S ©N)ÚdictÚ_timersÚ threadingÚLockÚ _timers_lock©Úself© r ú;/usr/lib/python3.9/site-packages/tuned/daemon/controller.pyÚ__init__ s zTimerStore.__init__c C s4 | j || j|< W d ƒ n1 s&0 Y d S r )r
r
©r ÚtokenÚtimerr r r Ú store_timer s zTimerStore.store_timerc C sV | j < z | j| }| ¡ | j|= W n Y n0 W d ƒ n1 sH0 Y d S r )r
r
Úcancelr r r r Ú
drop_timer s
zTimerStore.drop_timerc C sL | j 2 | j ¡ D ] }| ¡ q| j ¡ W d ƒ n1 s>0 Y d S r )r
r
Úvaluesr Úclear)r r r r r Ú
cancel_all" s
zTimerStore.cancel_allN)Ú__name__Ú
__module__Ú __qualname__r r r r r r r r r s r c s¶ e Zd ZdZ‡ fdd„Zdd„ Zdd„ Zdd „ Ze d
¡d d „ ƒZ
d
d„ Z e dd¡dZdd„ƒZ
e dd¡d[dd„ƒZe dd¡d\dd„ƒZd]dd „Ze dd¡d^d d „ƒZe dd¡d_d d „ƒZd!d"„ Ze dd#¡d`d$d%„ƒZe dd#¡dad&d'„ƒZe dd¡dbd(d)„ƒZe dd*¡dcd+d,„ƒZe dd¡ddd-d.„ƒZe dd¡ded/d0„ƒZe dd¡dfd1d2„ƒZe dd3¡dgd4d5„ƒZe dd6¡dhd7d8„ƒZ e dd9¡did:d;„ƒZ e dd¡djdd?„ƒZ e dd¡dld@dA„ƒZ e ddB¡dmdCdD„ƒZ!e dd¡dndEdF„ƒZ"e ddG¡dodHdI„ƒZ#e dd¡dpdJdK„ƒZ$e dLd#¡dqdMdN„ƒZ%e ddO¡drdPdQ„ƒZ&e ddR¡dsdSdT„ƒZ'e dUd#¡dtdVdW„ƒZ(e dd#¡dudXdY„ƒZ)‡ Z*S )vr z‘
Controller's purpose is to keep the program running, start/stop the tuning,
and export the controller interface (currently only over D-Bus).
c s8 t t| ƒ ¡ || _|| _t ¡ | _tƒ | _ t
ƒ | _ d S r ) Úsuperr r Ú_daemonÚ_global_configr ÚEventÚ
_terminater Ú_cmdr Ú _timer_store)r ÚdaemonZ
global_config©Ú __class__r r r . s
zController.__init__c
C sŠ t d¡ | j ¡ | j tjtj¡}|dkr"t d¡ t j
t ¡ ¡}| j
dtj¡}z| |¡ W n ty„ t d¡ Y n0 d}t ¡ }zTt ¡ || k rÀ| j ¡ sÀ|rÀ|jdd}q”| j ¡ sä|rÚt d ¡ n
t d
¡ W n8 ttfy } zt d | ¡ W Y d }~n
d }~0 0 ~| ¡ }| j tjtj¡}|sP|rPt ¡ |rt| j | jd¡stt ¡ qVt d
¡ | ¡ d S )z1
Controller main loop. The call is blocking.
zstarting controllerr zwaiting for udev to settleÚudev_buffer_sizez•cannot set udev monitor receive buffer size, we are probably running inside container or with limited capabilites, TuneD functionality may be limitedTé )Útimeoutzudev settle timed outz udev settledzudev settle failed, '%s'Nzterminating controller) ÚlogÚinfor# r r! Zget_intÚconstsZ CFG_STARTUP_UDEV_SETTLE_WAITZ CFG_DEF_STARTUP_UDEV_SETTLE_WAITÚpyudevZMonitorZ from_netlinkZContextZget_sizeZCFG_DEF_UDEV_BUFFER_SIZEZset_receive_buffer_sizeÚEnvironmentErrorÚwarningÚtimeÚis_setZpollÚOSErrorÚIOErrorÚstartÚget_boolÚ
CFG_DAEMONÚCFG_DEF_DAEMONr r$ ÚwaitZ period_checkÚstop) r Z wait_settleZmonitorr) ÚpÚtÚeÚresr& r r r Úrun6 sD
ÿ
$
zController.runc C s | j ¡ d S r )r# Úsetr r r r Ú terminatec s zController.terminatec C s` | j j ¡ r| j j ¡ nBd}|r\| j j ¡ | j j ¡ | ¡ sN| j j ¡ | j j ¡ }q d S )NT)r Z_sighup_processingr3 Z_sighup_pendingrA r Úreload)r Z do_reloadr r r Úsighupf s zController.sighupZsbsc C s d S r r )r Ú profile_nameÚresultZerrstrr r r Úprofile_changedr s zController.profile_changedc C s t j |¡ | j |¡ d S r ©ÚtunedÚlogsÚlog_capture_finishr% r )r r r r r Ú_log_capture_abort{ s z Controller._log_capture_abortÚiiÚsNc C sf |dkr dS t j |¡}|d u r$dS |dkrVtj|| j|gd}| j ||¡ | ¡ |d u rbdS |S )NÚ r )Úargs) rI rJ Úlog_capture_startr ÚTimerrL r% r r6 )r Z log_levelr+ Úcallerr r r r r rQ s ÿz Controller.log_capture_startc C s4 |dkr dS t j |¡}| j |¡ |d u r0dS |S ©NrO rH )r r rS r? r r r rK s
z Controller.log_capture_finishrO Úbc C sD |dkr dS | j tjtj¡r:| j ¡ r,dS | j ¡ s:dS | j ¡ S )NrO FT) r! r7 r. r8 r9 r Ú
is_runningÚ
is_enabledr6 ©r rS r r r r6 • s
zController.startFc C s, | j ¡ sd}n| j j|d}| j ¡ |S )NT©Úprofile_switch)r rV r; r% r )r rZ r? r r r Ú_stop s
zController._stopc C s |dkr dS | j ddS )NrO FrY )r[ rX r r r r; ¨ s zController.stopc
C sv |dkr dS | j ¡ r*| jdd}|s*dS z| j ¡ W n4 tyl } z t d| ¡ W Y d }~dS d }~0 0 | ¡ S )NrO FTrY zFailed to reload TuneD: %s)r rV r[ Zreload_profile_configr r, Úerrorr6 )r rS Zstop_okr> r r r rC ® s
zController.reloadc
C s | j ¡ }d}d}d}zÂz$|r,| j jdd | j ||¡ W nh tjjy¤ } zLd}t|ƒ}|r‚| j jj |kr‚t
d| ¡ d}nt
d| ¡ W Y d }~n
d }~0 0 W |rØ|rÀt
d| ¡ n|sÎt
d¡ | j ¡ n6|r|rôt
d| ¡ n|st
d¡ | j ¡ 0 ||fS ) NÚOKTFrY z@Failed to reapply profile '%s'. Did it change on disk and break?z Failed to apply profile '%s'z>Applying previously applied (possibly out-dated) profile '%s'.z$Applying previously applied profile.)r rV r; Z set_profilerI Ú
exceptionsr ÚstrÚprofileÚnamer, r\ r1 r- r6 )r rE ÚmanualZ was_runningÚmsgÚsuccessZreapplyr> r r r Ú_switch_profile½ s8
&
û
zController._switch_profilez(bs)c C s( |dkr dS | j |¡s dS | |d¡S )NrO ©FÚ Unauthorized)FzInvalid profile_nameT)r$ Ú
is_valid_namere ©r rE rS r r r Úswitch_profileØ s
zController.switch_profilec C s |dkr dS | ¡ }| |d¡S )NrO rf F)Úrecommend_profilere )r rS rE r r r Ú auto_profileà s zController.auto_profilec C s* |dkr dS | j jd ur"| j jjS dS d S rT )r r` ra rX r r r Úactive_profileç s
zController.active_profilez(ss)c
C s |dkr dS | j j}|d u rxz"| j ¡ \}}|d u r<|d u}W n8 tyv } z d}t|ƒ}||fW Y d }~S d }~0 0 |r‚tjntj}|dfS )NrO )Úunknownrg rn ) r rb r$ Zget_active_profiler r_ r. ZACTIVE_PROFILE_MANUALZACTIVE_PROFILE_AUTO)r rS rb r` r> Úmoder\ r r r Ú profile_modeð s zController.profile_modec C s |dkr dS | j jpdS rT )r Úpost_loaded_profilerX r r r rq s z Controller.post_loaded_profilec C sB |dkr dS | j ¡ r | j ¡ | j ¡ r>| j jd dd dd dS )NrO FT)Zsave_instantly)r rV r; rW Zset_all_profilesrX r r r Údisable s
ÿzController.disablec C s |dkr dS | j ¡ S )NrO F)r rV rX r r r rV s zController.is_runningÚasc C s |dkr g S | j jj ¡ S rT )r Úprofile_loaderÚprofile_locatorZget_known_namesrX r r r Úprofiles s zController.profilesza(ss)c C s |dkr g S | j jj ¡ S rT )r rt ru Zget_known_names_summaryrX r r r Ú profiles2 s zController.profiles2z(bsss)c C sR |dks| j |¡sdS |d u s(|dkr0| ¡ }t| jjj |tj tj
gdg¡ƒS )NrO )FrO rO rO ) r$ rh rm Útupler rt ru Zget_profile_attrsr. ZPROFILE_ATTR_SUMMARYZPROFILE_ATTR_DESCRIPTIONri r r r Ú profile_info% s
zController.profile_infoc C s |dkr dS | j j ¡ S rT )r Zprofile_recommenderZ recommendrX r r r rk - s z Controller.recommend_profilec C s |dkr dS | j jddS )NrO F©Zignore_missing©r Úverify_profilerX r r r r| 3 s zController.verify_profilec C s |dkr dS | j jddS )NrO FTrz r{ rX r r r Ú verify_profile_ignore_missing9 s z(Controller.verify_profile_ignore_missingz a{sa{ss}}c C sr |dkr i S i }| j ¡ D ]R}|j d¡d dd¡d }| ¡ }i ||< | ¡ D ]\}}t|ƒ|| |< qRq|S )zuReturn dictionary with accesible plugins
Return:
dictionary -- {plugin_name: {parameter_name: default_value}}
rO Ú.éÿÿÿÿÚ_r* )r Úget_all_pluginsr ÚsplitZ_get_config_optionsÚitemsr_ )r rS ÚpluginsZ plugin_classÚ plugin_nameZ conf_optionsÚkeyÚvalr r r r ? s zController.get_all_pluginsc C s( |dks| j |¡sdS | j t|ƒ¡S )z"Return docstring of plugin's classrO )r$ rh r Úget_plugin_documentationr_ ©r r… rS r r r rˆ Q s z#Controller.get_plugin_documentationza{ss}c C s( |dks| j |¡si S | j t|ƒ¡S )zžReturn dictionary with plugin's parameters and their hints
Parameters:
plugin_name -- name of plugin
Return:
dictionary -- {parameter_name: hint}
rO )r$ rh r Úget_plugin_hintsr_ r‰ r r r rŠ X s
zController.get_plugin_hintsc C sB |dks| j |¡sdS | jjr>| jjjr>| jjj |¡ dS dS )z¤Allows to dynamically add sockets to send signals to
Parameters:
path -- path to socket to register for sending signals
Return:
bool -- True on success
rO FT)r$ rh r Z _applicationZ_unix_socket_exporterZregister_signal_path)r ÚpathrS r r r Úregister_socket_signal_pathf s
z&Controller.register_socket_signal_pathÚssc
C s¬ |dkr dS | j |¡s dS | j |¡s,dS d}| jjjD ]&}|j|kr:t d|j ¡ d} qbq:|s€d| }t |¡ d|fS t |j
t j ƒs¬d |j
j }t |¡ d|fS t
| j |¡ƒ}t d
|jt|ƒf ¡ | jjjD ] }|j|@ } t| ƒrÞ|| 8 }t d t| ƒ|j|jf ¡ |j
j|j
jkrbd |j|j
jt| ƒ|j|j
jf }t |¡ d|f S |j
|| ¡ |j
|| ¡ qÞt|ƒr¨d
t|ƒ }t |¡ d|fS dS )NrO rf )FzInvalid devices©FúInvalid instance_nameFzFound instance '%s'.TúInstance '%s' not foundú>Plugin '%s' does not support hotplugging or dynamic instances.z-Instance '%s' trying to acquire devices '%s'.ú8Moving devices '%s' from instance '%s' to instance '%s'.ztTarget instance '%s' is of type '%s', but devices '%s' are currently handled by instance '%s' which is of type '%s'.z2Ignoring devices not handled by any instance '%s'.©Tr] )r$ rh r Ú
_unit_managerÚ instancesra r, Údebugr\ Ú
isinstanceÚpluginr ÚPluginrA Z devstr2devsr_ Úprocessed_devicesÚlenr- Ú_remove_devices_nocheckÚ_add_devices_nocheck)
r ÚdevicesÚ
instance_namerS ÚfoundZinstance_targetÚretsZdevsÚinstanceÚ devs_movingr r r Úinstance_acquire_devicesz sX
ÿÿÿ
z#Controller.instance_acquire_devicesz (bsa(ss))c s¢ |dkrddg fS | j ˆ ¡s(ddg fS ˆ dkr\ˆ | ¡ ¡ vr\dˆ }t |¡ d|g fS tdd„ | jjj ƒ}ˆ dkrŠt‡ fdd„|ƒ}d d
t
t d d„ |ƒƒfS ) a Return a list of active instances of a plugin or all active instances
Parameters:
plugin_name -- name of the plugin or an empty string
Return:
bool -- True on success
string -- error message or "OK"
list of string pairs -- [(instance_name, plugin_name)]
rO Frg úInvalid plugin_namezPlugin '%s' does not existc S s | j S r )Zactive©r¢ r r r Úº ó z*Controller.get_instances..c s | j jˆ kS r )r˜ ra r¦ ©r… r r r§ ¼ r¨ Tr] c S s | j | jj fS r )ra r˜ r¦ r r r r§ ½ r¨ ) r$ rh r Úkeysr, r\ Úfilterr r” r• ÚlistÚmap)r r… rS r¡ r• r r© r Ú
get_instances¦ s
zController.get_instancesz(bsas)c C sv |dkrddg fS | j |¡s(ddg fS | jjjD ]&}|j|kr2ddtt|jƒƒf S q2d| }t
|¡ d|g fS )zÓReturn a list of devices assigned to an instance
Parameters:
instance_name -- name of the instance
Return:
bool -- True on success
string -- error message or "OK"
list of strings -- device names
rO Frg r Tr] r ) r$ rh r r” r• ra Úsortedr¬ rš r, r\ )r rŸ rS r¢ r¡ r r r Úinstance_get_devices¿ s
z Controller.instance_get_deviceszssa{ss}c
C s: |dkr dS | j |¡s dS | j |¡s,dS | ¡ D ]&\}}| j |¡rT| j |¡s4 dS q4dd„ | jjjD ƒ}|| ¡ vr–d| }t |¡ d |fS || } t | t
j ƒsÆd
| j }t |¡ d |fS |
d d ¡}
|
d
d ¡} |
dd ¡} |
dd ¡}
t|
d| jjj¡ƒ}z4| |||
| | |
|¡}| |¡ | jjj |¡ W nH tyˆ } z.d|t|ƒf }t |¡ d |fW Y d }~S d }~0 0 t d||f ¡ | |¡ | |¡ | jjjD ]z}||ksº|j| ksº|j|jkræqº| ||j ¡}t |ƒrºt dt|ƒ|j |j f ¡ | ||¡ | ||¡ qºdS )a Dynamically create a plugin instance
Parameters:
plugin_name -- name of the plugin
instance_name -- name of the new instance
dict of string-string -- options for the new instance
Return:
bool -- True on success
string -- error message or "OK"
rO rf )Fr¥ rŽ )FzInvalid optionsc S s i | ] }|j |“qS r ©ra )Ú.0r< r r r Ú
ì r¨ z.Controller.instance_create..zPlugin '%s' not foundFr‘ rž NÚdevices_udev_regexÚ
script_preÚ script_postÚpriorityz Error creating instance '%s': %sz,Created dynamic instance '%s' of plugin '%s'r’ r“ ) r$ rh rƒ r r” r„ rª r, r\ r— r r™ ra ÚpopÚintZ_def_instance_priorityZcreate_instanceZinitialize_instancer• ÚappendÚ Exceptionr_ r- Zassign_free_devicesZinstance_apply_tuningr˜ r· Z_get_matching_devicesrš r› rœ r )r r… rŸ ÚoptionsrS r† Úvaluer„ r¡ r˜ rž r´ rµ r¶ r· r¢ r> Zother_instancer£ r r r Úinstance_createÖ sd
ÿ
þ
ÿ zController.instance_createc
sH |dkr dS | j ˆ ¡s dS z ‡ fdd„| jjjD ƒd }W n, tyh dˆ }t |¡ d|f Y S 0 |j}t |t
j ƒs˜d |j }t |¡ d|fS |j
¡ }z4| ||¡ | jjj |¡ | |¡ | |¡ W nH ty } z.d
ˆ t|ƒf }t |¡ d|fW Y d }~S d }~0 0 t d ˆ ¡ |D ]}| |¡ q2d
S )z²Destroy a dynamically created plugin instance
Parameters:
instance_name -- name of the new instance
Return:
bool -- True on success
string -- error message or "OK"
rO rf rŽ c s g | ]}|j ˆ kr|‘qS r r± )r² Úi©rŸ r r Ú
& r¨ z/Controller.instance_destroy..r r Fr‘ z Error deleting instance '%s': %sNzDeleted instance '%s'r“ )r$ rh r r” r• Ú
IndexErrorr, r\ r˜ r— r r™ ra rš Úcopyrœ ÚremoveZinstance_unapply_tuningZdestroy_instancer» r_ r- Z _add_device) r rŸ rS r¢ r¡ r˜ rž r> Zdevicer rÀ r Úinstance_destroy s:
zController.instance_destroy)N)N)N)F)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)N)+r r r Ú__doc__r r@ rB rD r ÚsignalrG rL ZexportrQ rK r6 r[ r; rC re rj rl rm rp rq rr rV rv rw ry rk r| r} r rˆ rŠ rŒ r¤ r® r° r¾ rÅ Ú
__classcell__r r r' r r ( s€ -
+
?
)rI r Z
tuned.logsZtuned.exceptionsr r Z tuned.constsr. Ztuned.utils.commandsr Z
tuned.pluginsr r/ r2 Ú__all__rJ Úgetr, Úobjectr Z
interfacesZExportableInterfacer r r r r Ú s