File: //lib/python3.6/site-packages/tuned/daemon/__pycache__/controller.cpython-36.opt-1.pyc
3
]�b?" � @ s� d dl mZ d dlZ d dlZ d dlmZ d dlZd dljZd dlm Z dgZ
e j j � Z
G dd� de�ZG dd� de jjj�ZdS ) � )�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 �token�timerr 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� fdd�Zdd� Zdd� Zejd�d d
� �Z d d � Z
ej d
d�dEdd��Z ej dd�dFdd��Z
ej dd�dGdd��Zej dd�dHdd��Zej dd�dIdd��Zd d � Zej dd �dJd d ��Zej dd �dKd!d"��Zej dd�dLd#d$��Zej dd%�dMd&d'��Zej dd�dNd(d)��Zej dd�dOd*d+��Zej dd�dPd,d-��Zej dd.�dQd/d0��Zej dd1�dRd2d3��Zej dd4�dSd5d6��Zej dd�dTd7d8��Z ej dd�dUd9d:��Z ej dd�dVd;d<��Z ej dd=�dWd>d?��Z ej dd�dXd@dA��Z ej ddB�dYdCdD��Z!� Z"S )Zr 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 sp t jd� | j� }| jjtjtj�}| r6|r6tj� |rZ| j j
� x| j j | j d�sXqFW t jd� | j
� dS )z1
Controller main loop. The call is blocking.
zstarting controller�
zterminating controllerN)�log�info�startr �get_bool�consts�
CFG_DAEMON�CFG_DEF_DAEMONr r r r �wait�stop)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.terminateZsbsc C s d S )Nr )r � profile_name�resultZerrstrr r r
�profile_changedI s zController.profile_changedc C s t jj|� | jj|� d S )N)�tuned�logs�log_capture_finishr r )r r r r r
�_log_capture_abortR s z Controller._log_capture_abortZii�sNc C sf |dkr dS t jj|�}|d kr$dS |dkrVtj|| j|gd�}| jj||� |j� |d krbdS |S )N� r )�args) r3 r4 �log_capture_startr ZTimerr6 r r r% )r Z log_levelZtimeout�callerr r r r r
r: V s z Controller.log_capture_startc C s4 |dkr dS t jj|�}| jj|� |d kr0dS |S )Nr8 )r3 r4 r5 r r )r r r; r, r r r
r5 d s
z Controller.log_capture_finishr8 �bc C sD |dkr dS | j jtjtj�r:| jj� r,dS | jj� s:dS | jj� S )Nr8 FT) r r& r' r( r) r �
is_running�
is_enabledr% )r r; r r r
r% l s
zController.startc C s4 |dkr dS | j j� s d}n
| j j� }| jj� |S )Nr8 FT)r r= r+ r r )r r; r, r r r
r+ w s
zController.stopc C sl |dkr dS | j j� r&| j� }|s&dS y| j j� W n. tk
rb } ztjd| � dS d }~X nX | j� S )Nr8 FzFailed to reload TuneD: %s)r r= r+ Zreload_profile_configr r# �errorr% )r r; Zstop_ok�er r r
�reload� s
zController.reloadc C s� | j j� }d}d}d}z�y$|r,| j jdd� | j j||� W nf tjjk
r� } zFd}t|�}|r�| j jj |kr�t
j d| � d}nt
j d| � W Y d d }~X nX W d |r�|r�t
j d| � n|s�t
j
d� | j j� X ||fS ) NZOKTF)Zprofile_switchz@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_profiler3 �
exceptionsr �str�profile�namer# r? �warnr$ r% )r r0 �manualZ was_running�msg�successZreapplyr@ r r r
�_switch_profile� s,
$
zController._switch_profilez(bs)c C s |dkr dS | j |d�S )Nr8 F� UnauthorizedT)FrK )rJ )r r0 r; r r r
�switch_profile� s zController.switch_profilec C s |dkr dS | j � }| j|d�S )Nr8 FrK )FrK )�recommend_profilerJ )r r; r0 r r r
� auto_profile� s zController.auto_profilec C s* |dkr dS | j jd k r"| j jjS dS d S )Nr8 )r rD rE )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 )Nr8 �unknownrK )rP rK ) r rG r Zget_active_profiler rC r' ZACTIVE_PROFILE_MANUALZACTIVE_PROFILE_AUTO)r r; rG rD r@ �moder? r r r
� profile_mode� s zController.profile_modec C s |dkr dS | j jpdS )Nr8 )r �post_loaded_profile)r r; r r r
rS � s z Controller.post_loaded_profilec C sB |dkr dS | j j� r | j j� | j j� r>| j jd dd dd� dS )Nr8 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 )Nr8 F)r r= )r r; r r r
r= � s zController.is_running�asc C s |dkr g S | j jjj� S )Nr8 )r �profile_loader�profile_locatorZget_known_names)r r; r r r
�profiles� s zController.profilesza(ss)c C s |dkr g S | j jjj� S )Nr8 )r rV rW Zget_known_names_summary)r r; r r r
� profiles2� s zController.profiles2z(bsss)c C sP |dkrt dddd�S |d ks&|dkr.| j� }t | jjjj|tjtjgdg��S )Nr8 F) �tuplerO r rV rW Zget_profile_attrsr' ZPROFILE_ATTR_SUMMARYZPROFILE_ATTR_DESCRIPTION)r r0 r; r r r
� profile_info� s
zController.profile_infoc C s |dkr dS | j jj� S )Nr8 )r Zprofile_recommenderZ recommend)r r; r r r
rM � s z Controller.recommend_profilec C s |dkr dS | j jdd�S )Nr8 F)�ignore_missing)r �verify_profile)r r; r r r
r] s zController.verify_profilec C s |dkr dS | j jdd�S )Nr8 FT)r\ )r r] )r r; r r r
� verify_profile_ignore_missing s z(Controller.verify_profile_ignore_missingz a{sa{ss}}c C sz |dkr dS i }xd| j j� D ]V}|jjd�d jdd�d }|j� }i ||< x$|j� D ]\}}t|�|| |< qVW q W |S )zuReturn dictionary with accesible plugins
Return:
dictionary -- {plugin_name: {parameter_name: default_value}}
r8 F�.� �_���)r �get_all_pluginsr �splitZ_get_config_options�itemsrC )r r; ZpluginsZ plugin_class� plugin_nameZ conf_options�key�valr r r
rc s zController.get_all_pluginsc C s |dkr dS | j jt|��S )z"Return docstring of plugin's classr8 F)r �get_plugin_documentationrC )r rf r; r r r
ri # s z#Controller.get_plugin_documentationza{ss}c C s |dkr dS | j jt|��S )z�Return dictionary with plugin's parameters and their hints
Parameters:
plugin_name -- name of plugin
Return:
dictionary -- {parameter_name: hint}
r8 F)r �get_plugin_hintsrC )r rf r; r r r
rj * s
zController.get_plugin_hints)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/ r �signalr2 r6 Zexportr: r5 r% r+ rA rJ rL rN rO rR rS rT r= rX rY r[ rM r] r^ rc ri rj �
__classcell__r r )r! r
r % sb
)r3 r Z
tuned.logsZtuned.exceptionsr r Z tuned.constsr' Ztuned.utils.commandsr �__all__r4 �getr# �objectr Z
interfacesZExportableInterfacer r r r r
�<module> s