File: //lib/python3.9/site-packages/tuned/daemon/__pycache__/controller.cpython-39.opt-1.pyc
a
Y��du, � @ s� d dl mZ d dlZ d dlZ d dlmZ d dlZd dlmZ d dlm Z dgZ
e 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 � | _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�dOdd��Z
e� dd�dPdd��Ze� dd�dQdd��ZdRdd �Ze� dd�dSd d ��Ze� dd�dTd d ��Zd!d"� Ze� dd#�dUd$d%��Ze� dd#�dVd&d'��Ze� dd�dWd(d)��Ze� dd*�dXd+d,��Ze� dd�dYd-d.��Ze� dd�dZd/d0��Ze� dd�d[d1d2��Ze� dd3�d\d4d5��Ze� dd6�d]d7d8��Z e� dd9�d^d:d;��Z e� dd�d_d<d=��Z e� dd�d`d>d?��Z e� dd�dad@dA��Z e� ddB�dbdCdD��Z!e� dd�dcdEdF��Z"e� ddG�dddHdI��Z#e� dd�dedJdK��Z$e� dLd#�dfdMdN��Z%� Z&S )gr 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 sr t �d� | �� }| j�tjtj�}|s4|r4t�� |r\| j �
� | j � | j d�s\t�
� qBt �d� | �� 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# �waitZ period_check�stop)r �resr% r r r �run3 s
zController.runc C s | j �� d S r )r" �setr
r r r � terminateF s zController.terminatec C s0 | j j�� s,| j j�� | �� s,| j j�� d S r )r Z_sighup_processing�is_setr4 �reloadr r
r r r �sighupI s zController.sighupZsbsc C s d S r r )r � profile_name�resultZerrstrr r r �profile_changedO 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_abortX 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) r= r> �log_capture_startr
�Timerr@ r$ r r+ )r Z log_level�timeout�callerr r r r r rE \ s �z Controller.log_capture_startc C s4 |dkr dS t j�|�}| j�|� |d u r0dS |S �NrC r< )r r rH r2 r r r r? j s
z Controller.log_capture_finishrC �bc C sD |dkr dS | j �tjtj�r:| j�� r,dS | j�� s:dS | j�� S )NrC FT) r r, r- r. r/ r �
is_running�
is_enabledr+ �r rH r r r r+ r s
zController.startFc C s, | j �� sd}n| j j|d�}| j�� |S )NT��profile_switch)r rK r1 r$ r )r rO r2 r r r �_stop} s
zController._stopc C s |dkr dS | j dd�S )NrC FrN )rP rM r r r r1 � 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 )NrC FTrN zFailed to reload TuneD: %s)r rK rP Zreload_profile_configr r) �errorr+ )r rH Zstop_ok�er r r r7 � 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�OKTFrN 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 rK r1 Z set_profiler= �
exceptionsr �str�profile�namer) rQ �warnr* r+ )r r9 �manualZ was_running�msg�successZreapplyrR r r r �_switch_profile� s8
&
�
zController._switch_profilez(bs)c C s |dkr dS | � |d�S )NrC �F� UnauthorizedT)r\ �r r9 rH r r r �switch_profile� s zController.switch_profilec C s |dkr dS | � � }| �|d�S )NrC r] F)�recommend_profiler\ )r rH r9 r r r � auto_profile� s zController.auto_profilec C s* |dkr dS | j jd ur"| j jjS dS d S rI )r rV rW rM 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 )NrC )�unknownr^ rd ) r rY r# Zget_active_profiler rU r- ZACTIVE_PROFILE_MANUALZACTIVE_PROFILE_AUTO)r rH rY rV rR �moderQ r r r � profile_mode� s zController.profile_modec C s |dkr dS | j jpdS rI )r �post_loaded_profilerM r r r rg � s z Controller.post_loaded_profilec C sB |dkr dS | j �� r | j �� | j �� r>| j jd dd dd� dS )NrC FT)Zsave_instantly)r rK r1 rL Zset_all_profilesrM r r r �disable� s
�zController.disablec C s |dkr dS | j �� S �NrC F)r rK rM r r r rK � s zController.is_running�asc C s |dkr g S | j jj�� S rI )r �profile_loader�profile_locatorZget_known_namesrM r r r �profiles� s zController.profilesza(ss)c C s |dkr g S | j jj�� S rI )r rk rl Zget_known_names_summaryrM r r r � profiles2� s zController.profiles2z(bsss)c C sP |dkrt dddd�S |d u s&|dkr.| �� }t | jjj�|tjtjgdg��S ri ) �tuplerc r rk rl Zget_profile_attrsr- ZPROFILE_ATTR_SUMMARYZPROFILE_ATTR_DESCRIPTIONr_ r r r � profile_info s
zController.profile_infoc C s |dkr dS | j j�� S rI )r Zprofile_recommenderZ recommendrM r r r ra s z Controller.recommend_profilec C s |dkr dS | j jdd�S )NrC F�Zignore_missing�r �verify_profilerM r r r rs s zController.verify_profilec C s |dkr dS | j jdd�S )NrC FTrq rr rM r r r � verify_profile_ignore_missing s z(Controller.verify_profile_ignore_missingz a{sa{ss}}c C sr |dkr dS 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}}
rC F�.����_r( )r �get_all_pluginsr �splitZ_get_config_options�itemsrU )r rH ZpluginsZ plugin_class� plugin_nameZ conf_options�key�valr r r rx s zController.get_all_pluginsc C s |dkr dS | j �t|��S )z"Return docstring of plugin's classrC F)r �get_plugin_documentationrU �r r{ rH r r r r~ , s z#Controller.get_plugin_documentationza{ss}c C s |dkr dS | j �t|��S )z�Return dictionary with plugin's parameters and their hints
Parameters:
plugin_name -- name of plugin
Return:
dictionary -- {parameter_name: hint}
rC F)r �get_plugin_hintsrU r r r r r� 3 s
zController.get_plugin_hintsc C s6 |dkr dS | j jr2| j jjr2| j jj�|� 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
rC FT)r Z _applicationZ_unix_socket_exporterZregister_signal_path)r �pathrH r r r �register_socket_signal_pathA s
z&Controller.register_socket_signal_path�ssc
C s` |dkr dS d}| j jjD ]&}|j|krt�d|j � d} qBq|s`d| }t�|� d|fS t| j� |��}t�d|jt
|�f � | j jjD ]�}|j |@ } t | �r�|| 8 }t�
dt
| �|j|jf � |jj|jjk�rd |j|jjt
| �|j|jjf }t�|� d|f S |j�|| � |j�|| � q�t |��r\d
t
|� }t�
|� d|fS d S ) NrC r] FzFound instance '%s'.TzInstance '%s' not foundz-Instance '%s' trying to acquire devices '%s'.z8Moving 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'.)TrS )r Z
_unit_managerZ instancesrW r) �debugrQ r4 r# Z devstr2devsrU Zprocessed_devices�lenr* ZpluginZ_remove_devices_nocheckZ_add_devices_nocheck)
r ZdevicesZ
instance_namerH �foundZinstance_targetZretsZdevs�instanceZ devs_movingr r r �instance_acquire_devicesU sH
���
z#Controller.instance_acquire_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)'r r r �__doc__r r3 r5 r8 r �signalr; r@ ZexportrE r? r+ rP r1 r7 r\ r` rb rc rf rg rh rK rm rn rp ra rs rt rx r~ r� r� r� �
__classcell__r r r& r r % sp
)r= r Z
tuned.logsZtuned.exceptionsr r
Z tuned.constsr- Ztuned.utils.commandsr �__all__r> �getr) �objectr Z
interfacesZExportableInterfacer r r r r �<module> s