3
`g4 @ s d dl mZ d dlZ d dlZ d dlmZ d dlZd dljZd dlm Z dgZ
e j j Z
G dd deZG dd de jjjZdS ) )exportsN)TunedException)commands
Controllerc @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
TimerStorec C s t | _tj | _d S )N)dict_timers threadingZLock _timers_lock)self r /usr/lib/python3.6/controller.py__init__ s zTimerStore.__init__c
C s | j || j|< W d Q R X d S )N)r
r )r tokentimerr r r
store_timer s zTimerStore.store_timerc C sB | j 2 y | j| }|j | j|= W n Y nX W d Q R X d S )N)r
r cancel)r r r r r r
drop_timer s
zTimerStore.drop_timerc C s< | j , x| jj D ] }|j qW | jj W d Q R X d S )N)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 fddZdd Zdd Zdd Zej d
d d Z
d
d Z ej dddUddZ
ej dddVddZej dddWddZdXdd Zej dddYd d Zej dddZd d Zd!d" Zej dd#d[d$d%Zej dd#d\d&d'Zej ddd]d(d)Zej dd*d^d+d,Zej ddd_d-d.Zej ddd`d/d0Zej dddad1d2Zej dd3dbd4d5Zej dd6dcd7d8Z ej dd9ddd:d;Z ej dddedd?Z ej dddgd@dAZ ej ddBdhdCdDZ!ej dddidEdFZ"ej ddGdjdHdIZ#ej dddkdJdKZ$ej dLd#dldMdNZ%ej ddOdmdPdQZ&ej ddRdndSdTZ' Z(S )or 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| j || _|| _tj | _t | _ t
| _ d S )N) superr r _daemon_global_configr ZEvent
_terminater _cmdr _timer_store)r daemonZ
global_config) __class__r r
r + s
zController.__init__c C sx t jd | j }| jjtjtj}| r6|r6tj |rb| j j
x | j j | j ds`tj
qFW t jd | j dS )z1
Controller main loop. The call is blocking.
zstarting controller zterminating controllerN)loginfostartr get_boolconsts
CFG_DAEMONCFG_DEF_DAEMONr r r r waitZ period_checkstop)r resr r r r
run3 s
zController.runc C s | j j d S )N)r set)r r r r
terminateF s zController.terminatec C s0 | j jj s,| j jj | j s,| j jj d S )N)r Z_sighup_processingZis_setr. reloadr )r r r r
sighupI s zController.sighupZsbsc C s d S )Nr )r profile_nameresultZerrstrr r r
profile_changedO s zController.profile_changedc C s t jj| | jj| d S )N)tunedlogslog_capture_finishr r )r r r r r
_log_capture_abortX s z Controller._log_capture_abortZiisNc C sf |dkr dS t jj|}|d kr$dS |dkrVtj|| j|gd}| jj|| |j |d krbdS |S )N r )args) r5 r6 log_capture_startr ZTimerr8 r r r% )r Z log_levelZtimeoutcallerr r r r r
r< \ s z Controller.log_capture_startc C s4 |dkr dS t jj|}| jj| |d kr0dS |S )Nr: )r5 r6 r7 r r )r r r= r, r r r
r7 j s
z Controller.log_capture_finishr: bc C sD |dkr dS | j jtjtjr:| jj r,dS | jj s:dS | jj S )Nr: FT) r r& r' r( r) r
is_running
is_enabledr% )r r= r r r
r% r s
zController.startFc C s, | j j sd}n| j j|d}| jj |S )NT)profile_switch)r r? r+ r r )r rA r, r r r
_stop} s
zController._stopc C s |dkr dS | j ddS )Nr: F)rA )rB )r r= r r r
r+ s zController.stopc C sp |dkr dS | j j r*| jdd}|s*dS y| j j W n. tk
rf } ztjd| dS d }~X nX | j S )Nr: FT)rA zFailed to reload TuneD: %s)r r? rB Zreload_profile_configr r# errorr% )r r= Zstop_oker r r
r0 s
zController.reloadc C s | j j }d}d}d}zy$|r,| j jdd | j j|| W nf tjjk
r } zFd}t|}|r| j jj |krt
j d| d}nt
j d| W Y d d }~X nX W d |r|rt
j d| n|st
j
d | j j X ||fS ) NOKTF)rA 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 r? r+ Z set_profiler5
exceptionsr strprofilenamer# rC warnr$ r% )r r2 manualZ was_runningmsgsuccessZreapplyrD r r r
_switch_profile s,
$
zController._switch_profilez(bs)c C s( |dkr dS | j j|s dS | j|dS )Nr: F UnauthorizedInvalid profile_nameT)FrO )FrP )r
is_valid_namerN )r r2 r= r r r
switch_profile s
zController.switch_profilec C s |dkr dS | j }| j|dS )Nr: FrO )FrO )recommend_profilerN )r r= r2 r r r
auto_profile s zController.auto_profilec C s* |dkr dS | j jd k r"| j jjS dS d S )Nr: )r rH rI )r r= r r r
active_profile s
zController.active_profilez(ss)c C s |dkr dS | j j}|d krpy"| jj \}}|d kr<|d k }W n0 tk
rn } zd}t|}||fS d }~X nX |rztjntj}|dfS )Nr: unknownrO )rV rO ) r rK r Zget_active_profiler rG r' ZACTIVE_PROFILE_MANUALZACTIVE_PROFILE_AUTO)r r= rK rH rD moderC r r r
profile_mode s zController.profile_modec C s |dkr dS | j jpdS )Nr: )r post_loaded_profile)r r= r r r
rY s z Controller.post_loaded_profilec C sB |dkr dS | j j r | j j | j j r>| j jd dd dd dS )Nr: FT)Zsave_instantly)r r? r+ r@ Zset_all_profiles)r r= r r r
disable s
zController.disablec C s |dkr dS | j j S )Nr: F)r r? )r r= r r r
r? s zController.is_runningasc C s |dkr g S | j jjj S )Nr: )r profile_loaderprofile_locatorZget_known_names)r r= r r r
profiles s zController.profilesza(ss)c C s |dkr g S | j jjj S )Nr: )r r\ r] Zget_known_names_summary)r r= r r r
profiles2 s zController.profiles2z(bsss)c C sT |dks| j j| rdS |d ks*|dkr2| j }t| jjjj|tj tj
gdgS )Nr: F)Fr: r: r: ) r rQ rU tupler r\ r] Zget_profile_attrsr' ZPROFILE_ATTR_SUMMARYZPROFILE_ATTR_DESCRIPTION)r r2 r= r r r
profile_info s
zController.profile_infoc C s |dkr dS | j jj S )Nr: )r Zprofile_recommenderZ recommend)r r= r r r
rS
s z Controller.recommend_profilec C s |dkr dS | j jddS )Nr: F)ignore_missing)r verify_profile)r r= r r r
rc s zController.verify_profilec C s |dkr dS | j jddS )Nr: FT)rb )r rc )r r= r r r
verify_profile_ignore_missing s z(Controller.verify_profile_ignore_missingz a{sa{ss}}c C sz |dkr i S i }xd| j j D ]V}|jjdd jddd }|j }i ||< x$|j D ]\}}t||| |< qVW q W |S )zuReturn dictionary with accesible plugins
Return:
dictionary -- {plugin_name: {parameter_name: default_value}}
r: .r" _)r get_all_pluginsr splitZ_get_config_optionsitemsrG )r r= ZpluginsZ plugin_class plugin_nameZ conf_optionskeyvalr r r
rh s zController.get_all_pluginsc C s* |dks| j j| rdS | jjt|S )z"Return docstring of plugin's classr: )r rQ r get_plugin_documentationrG )r rk r= r r r
rn . s z#Controller.get_plugin_documentationza{ss}c C s* |dks| j j| ri S | jjt|S )zReturn dictionary with plugin's parameters and their hints
Parameters:
plugin_name -- name of plugin
Return:
dictionary -- {parameter_name: hint}
r: )r rQ r get_plugin_hintsrG )r rk r= r r r
ro 5 s
zController.get_plugin_hintsc C sD |dks| j j| rdS | jjr@| jjjr@| jjjj| dS dS )zAllows to dynamically add sockets to send signals to
Parameters:
path -- path to socket to register for sending signals
Return:
bool -- True on success
r: FT)r rQ r Z _applicationZ_unix_socket_exporterZregister_signal_path)r pathr= r r r
register_socket_signal_pathC s
z&Controller.register_socket_signal_pathZssc
C s |dkr dS | j j|s dS | j j|s,dS d}x2| jjjD ]$}|j|kr s z*Controller.get_instances..c s | j j kS )N)ry rI )r} )rk r r
r s TrE c S s | j | jj fS )N)rI ry )r} r r r
r s ) r rQ rh keysr# rC filterr rt ru listmap)r rk r= r| ru r )rk r
get_instances s
zController.get_instancesz(bsas)c C sv |dkrddg fS | j j|s(ddg fS x0| jjjD ]"}|j|kr4ddtt|jfS q4W d| }t j
| d|g fS )zReturn 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
r: FrO zInvalid instance_nameTrE zInstance '%s' not found) r rQ r rt ru rI sortedr rw r# rC )r rz r= r} r| r r r
instance_get_devices s
z Controller.instance_get_devices)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))r r r __doc__r r- r/ r1 r signalr4 r8 Zexportr< r7 r% rB r+ r0 rN rR rT rU rX rY rZ r? r^ r_ ra rS rc rd rh rn ro rq r~ r r
__classcell__r r )r! r
r % sv
'
)r5 r Z
tuned.logsZtuned.exceptionsr r Z tuned.constsr' Ztuned.utils.commandsr __all__r6 getr# objectr Z
interfacesZExportableInterfacer r r r r
s