PK ��\q�Z/� � $ __pycache__/variables.cpython-36.pycnu �[��� 3
�<�e$ � @ sf d dl Z d dlZd dlZddlmZ d dljZd dlmZ d dl m
Z
m Z ej j
� ZG dd� d�ZdS )� N� )� functions)�commands)� ConfigParser�Errorc @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dS )� Variablesz8
Storage and processing of variables used in profiles
c C s" t � | _i | _i | _tj� | _d S )N)r �_cmd�
_lookup_re� _lookup_envr Z Functions�
_functions)�self� r
� /usr/lib/python3.6/variables.py�__init__ s zVariables.__init__c C s |j |�dkr|S || S )Nr )�find)r �s�prefixr
r
r �_add_env_prefix s zVariables._add_env_prefixc C s t jd|�S )Nz\w+$)�re�match)r �variabler
r
r �
_check_var s zVariables._check_varc C sj |d kr d S t |�}| j|�s0tjd| � d S | j|�}|| jdtj|� d < || j| j |t
j �< d S )Nz6variable definition '%s' contains unallowed charactersz
(?<!\\)\${�}) �strr �log�error�expandr r �escaper
r �constsZ
ENV_PREFIX)r r �valuer �vr
r
r � add_variable s
zVariables.add_variablec C s� t jj|�s tjd| � d S yLtddddd�}t|_t|��$}|j dt
j d |j � |� W d Q R X W n" t
k
r� tjd | � d S X x<|j� D ]0}x*|j|�D ] }| j||j||dd
�� q�W q�W d S ) Nz#unable to find variables_file: '%s'�=�#TF)Z
delimitersZinline_comment_prefixesZallow_no_value�strict�[z]
z"error parsing variables_file: '%s')�raw)�os�path�existsr r r r Z optionxform�openZ read_stringr ZMAGIC_HEADER_NAME�readr ZsectionsZoptionsr! �get)r �filename�config�fr �or
r
r �
add_from_file+ s
,zVariables.add_from_filec C sF x@|D ]8}t |�dkr.| jtjj|| �� q| j||| � qW d S )N�include)r r1 r' r( �normpathr! )r Zcfg�itemr
r
r � add_from_cfg; s
zVariables.add_from_cfgc C s t jdd| jj| j|��S )Nz \\(\${\w+})z\1)r �subr Zmultiple_re_replacer )r r r
r
r �
expand_staticC s zVariables.expand_staticc C s& |d kr d S | j t|��}| jj|�S )N)r7 r r r )r r r r
r
r r F s zVariables.expandc C s | j S )N)r
)r r
r
r �get_envN s zVariables.get_envN)
�__name__�
__module__� __qualname__�__doc__r r r r! r1 r5 r7 r r8 r
r
r
r r s
r )r' r Z
tuned.logsZtunedr Z tuned.constsr Ztuned.utils.commandsr Ztuned.utils.config_parserr r Zlogsr, r r r
r
r
r �<module> s
PK ��\W��qx x " __pycache__/locator.cpython-36.pycnu �[��� 3
�<�e� � @ s6 d dl Z d dljZd dlmZmZ G dd� de�ZdS )� N)� ConfigParser�Errorc @ sn e Zd ZdZdgZdd� Zedd� �Zdd� Zdd
d �Z d d
� Z
dd� Z ddd�Z dd� Z
dd� Zdd� Zd S )�Locatorz$
Profiles locator and enumerator.
�_load_directoriesc C s t |�tk rtd��|| _d S )Nz(load_directories parameter is not a list)�type�list� TypeErrorr )�self�load_directories� r � /usr/lib/python3.6/locator.py�__init__ s zLocator.__init__c C s | j S )N)r )r r r r r
s zLocator.load_directoriesc G s& t |�dg }tjj|� }tjj|�S )Nz
tuned.conf)r �os�path�join�normpath)r �
path_partsZ config_namer r r �_get_config_filename s z Locator._get_config_filenameNc C s� d }|dd� dk}|r$|dd � }xLt | j�D ]>}| j|tjj|��}|d k r^||kr^d}q0tjj|�r0|S q0W |r�|d kr�d}|S )Nr � �-� )�reversedr r r r �basename�isfile)r � profile_nameZ
skip_files�retZconditional_load�dir_name� config_filer r r �
get_config s zLocator.get_configc C s |d k o|dkod|kS )Nr �/r )r r r r r �check_profile_name_format0 s z!Locator.check_profile_name_formatc C s� | j |�sd S | j|�}|d kr$d S yJtddddd�}t|_t|��"}|jdtj d |j � � W d Q R X |S t
t t fk
r� } zd S d }~X nX d S )N�=�#TF)Z
delimitersZinline_comment_prefixesZallow_no_value�strict�[z]
)
r r r �strZ optionxform�openZ read_string�constsZMAGIC_HEADER_NAME�read�IOError�OSErrorr )r r r �config�f�er r r � parse_config3 s
&zLocator.parse_configc C s$ y t |�}W n tk
r* |g}d}Y nX y t |�}W n tk
rV |g}d}Y nX ||k rv||d g|| }| j|�}|d kr�ddddgS tj|j� k}d|g}xtt||�D ]f\} }
| dks�| d kr�d|d< |dg }q�|o�| |jtj�k�r||jtj| dd�g }q�||
g }q�W |S )Nr Fr Tr )�raw���) �lenr r. r' ZPLUGIN_MAIN_UNIT_NAMEZsections�zipZoptions�get) r r ZattrsZdefvalsZ attrs_lenZ defvals_lenr+ Zmain_unit_in_config�vals�attrZdefvalr r r �get_profile_attrsG s2
zLocator.get_profile_attrsc C sj t � }x^| jD ]T}y:x4tj|�D ]&}| j||�}tjj|�r |j|� q W W q tk
r` Y qX qW |S )N) �setr r �listdirr r r �addr* )r Zprofilesr r r r r r �
list_profilese s
zLocator.list_profilesc C s t | j� �S )N)�sortedr: )r r r r �get_known_namesq s zLocator.get_known_namesc s � fdd�t � j� �D �S )Nc s( g | ] }|� j |tjgd g�d f�qS )r � )r6 r' ZPROFILE_ATTR_SUMMARY)�.0Zprofile)r r r �
<listcomp>u s z3Locator.get_known_names_summary.<locals>.<listcomp>)r; r: )r r )r r �get_known_names_summaryt s z Locator.get_known_names_summary)N)N)�__name__�
__module__� __qualname__�__doc__� __slots__r
�propertyr
r r r r. r6 r: r< r@ r r r r r s
r )r Z tuned.constsr' Ztuned.utils.config_parserr r �objectr r r r r �<module> s
PK ��\pm�5T T ' __pycache__/merger.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s( d dl Z d dlmZ G dd� de�ZdS )� N)�reducec @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �Mergerz0
Tool for merging multiple profiles into one.
c C s d S )N� )�selfr r � /usr/lib/python3.6/merger.py�__init__ s zMerger.__init__c C s t | j|�}|S )z�
Merge multiple configurations into one. If there are multiple units of the same type, option 'devices'
is set for each unit with respect to eliminating any duplicate devices.
)r �
_merge_two)r ZconfigsZ
merged_configr r r �merge s z Merger.mergec C s� |j j|j � �x�t|jj� �D �]~\}}|js:||jkrF||j|< q |j|j| _|j|j| _|j|j| _|j dk r�|j |j| _ |j
dk r�|j
|j| _
|j dk r�|j |j| _ |j dk r�|j |j| _ |j
dk r�|j
|j| _
|jdk �r x"|jD ]}|j| j j|d� q�W d|_|dk�r�|j| j jdd�dk �r�|j| j jdd�}|j| j j|j � ||j| j d |j| j d< q |j| j j|j � q W |S )z�
Merge two profiles. The configuration of units with matching names are updated with options
from the newer profile. If the 'replace' options of the newer unit is 'True', all options from the
older unit are dropped.
N�script)Zoptions�update�listZunits�items�replace�typeZenabledZdevicesZdevices_udev_regexZ
cpuinfo_regexZ uname_regexZ
script_preZ script_postZdrop�pop�get)r Z profile_aZ profile_bZ unit_nameZunitZoptionr
r r r r s6
$"zMerger._merge_twoN)�__name__�
__module__� __qualname__�__doc__r r r r r r r r s r )� collections� functoolsr �objectr r r r r �<module> s PK ��\?��4^ ^ % __pycache__/exceptions.cpython-36.pycnu �[��� 3
�<�e_ � @ s d dl ZG dd� dejj�ZdS )� Nc @ s e Zd ZdS )�InvalidProfileExceptionN)�__name__�
__module__� __qualname__� r r � /usr/lib/python3.6/exceptions.pyr s r )Ztuned.exceptionsZtuned�
exceptionsZTunedExceptionr r r r r �<module> s PK ��\Y��l l ' __pycache__/loader.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ st d dl Zd dlZd dlmZmZ d dljZd dlZ d dl
Z
d dl Zd dl Z d dl
mZ ejj� ZG dd� de�ZdS )� N)� ConfigParser�Error)�InvalidProfileExceptionc @ sv e Zd ZdZdddddgZdd� Zd d
� Zed d � �Ze d
d� �Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� ZdS ) �Loaderz
Profiles loader.
�_profile_locator�_profile_merger�_profile_factory�_global_config�
_variablesc C s" || _ || _|| _|| _|| _d S )N)r r r r r
)�self�profile_locatorZprofile_factoryZprofile_mergerZ
global_config� variables� r � /usr/lib/python3.6/loader.py�__init__ s
zLoader.__init__c C s t jjj||�S )N)�tuned�profiles�profileZProfile)r � profile_name�configr r r �_create_profile s zLoader._create_profilec C s t jd|�S )Nz^[a-zA-Z0-9_.-]+$)�re�match)�clsr r r r � safe_name s zLoader.safe_namec C s | j S )N)r )r r r r r " s zLoader.profile_locatorc C s� t |�tk r|j� }tt| j|��}t|�dkr8td��t|�dkrZtjddj |� � ntjd|d � g }g }| j
|||� t|�dkr�| j j |�}n|d }dj |�|_
d|jkr�| jj|jd j� |jd= | j|� | j|� |S ) Nr z.No profile or invalid profiles were specified.� zloading profiles: %sz, zloading profile: %s� r
)�type�list�split�filterr �lenr �log�info�join�
_load_profiler �merge�name�unitsr
Z add_from_cfg�options�_expand_vars_in_devices�_expand_vars_in_regexes)r �
profile_namesr �processed_filesZ
final_profiler r r �load& s*
z Loader.loadc C s0 x*|j D ] }| jj|j | j�|j | _qW d S )N)r( r
�expandZdevices)r r �unitr r r r* D s z Loader._expand_vars_in_devicesc C sL xF|j D ]<}| jj|j | j�|j | _| jj|j | j�|j | _qW d S )N)r( r
r/ Z
cpuinfo_regexZ uname_regex)r r r0 r r r r+ H s z Loader._expand_vars_in_regexesc C s� x�|D ]�}| j j||�}|dkr"q|d krFtd|tt| j j��f ��|j|� | j|�}| jj ||�}d|j
kr�t j d| j
j|j
jd���}| j|||� |j|� qW d S )N� z!Cannot find profile '%s' in '%s'.�includez
\s*[,;]\s*)r Z
get_configr r �reversedZ_load_directories�append�_load_config_datar Zcreater) r r r
r/ �popr% ) r r, r r- r' �filenamer r Z
include_namesr r r r% M s
zLoader._load_profilec C s t jd||�S )Nz(?<!\\)\$\{i:PROFILE_DIR\})r �sub)r Z profile_dir�stringr r r �_expand_profile_dir^ s zLoader._expand_profile_dirc
C s, y8t dddd�}t|_t|��}|j||� W d Q R X W n2 tjk
rj } ztd| |��W Y d d }~X nX tj � }t
j j |�}x�t
|j� �D ]�}tj � ||< xF|j|�D ]8}|j||dd�|| |< | j||| | �|| |< q�W || jd�d k r�t
j j||| d �} t
j j| �g|| d< q�W |S ) N�=�#F)Z
delimitersZinline_comment_prefixes�strictzCannot parse '%s'.T)�rawZscript)r �strZ optionxform�openZ read_filer � __bases__r � collections� OrderedDict�os�path�dirnamer Zsectionsr) �getr: r$ �normpath)
r � file_nameZ
config_obj�f�er Zdir_nameZsectionZoptionZ script_pathr r r r5 a s$
zLoader._load_config_dataN)�__name__�
__module__� __qualname__�__doc__� __slots__r r � classmethodr �propertyr r. r* r+ r% r: r5 r r r r r
s r )Ztuned.profiles.profiler Ztuned.profiles.variablesZtuned.utils.config_parserr r Z tuned.constsZconstsZos.pathrD rB Z
tuned.logsr Ztuned.profiles.exceptionsr ZlogsrG r" �objectr r r r r �<module> s
PK ��\@
�� � " __pycache__/factory.cpython-36.pycnu �[��� 3
�<�e� � @ s d dl ZG dd� de�ZdS )� Nc @ s e Zd Zdd� ZdS )�Factoryc C s t jjj||�S )N)�tunedZprofilesZprofileZProfile)�self�name�config� r � /usr/lib/python3.6/factory.py�create s zFactory.createN)�__name__�
__module__� __qualname__r r r r r r s r )Ztuned.profiles.profiler �objectr r r r r �<module> s PK ��\
_� " __pycache__/profile.cpython-36.pycnu �[��� 3
�<�en � @ s. d dl Zd dljZd dlZG dd� de�ZdS )� Nc @ sl e Zd ZdZdddgZdd� Zdd� Zd d
� Zd d � Ze d
d� �Z
e
j dd� �Z
e dd� �Z e dd� �Z
dS )�Profilez'
Representation of a tuning profile.
�_name�_options�_unitsc C s || _ | j|� | j|� d S )N)r �
_init_options� _init_units)�self�name�config� r � /usr/lib/python3.6/profile.py�__init__ s
zProfile.__init__c C s$ i | _ tj|kr t|tj �| _ d S )N)r �consts�PLUGIN_MAIN_UNIT_NAME�dict)r r
r r r r s
zProfile._init_optionsc C s@ t j� | _x0|D ](}|tjkr| j||| �}|| j|< qW d S )N)� collections� OrderedDictr r r � _create_unit)r r
Z unit_nameZnew_unitr r r r s
zProfile._init_unitsc C s t jjj||�S )N)�tunedZprofilesZunitZUnit)r r r
r r r r s zProfile._create_unitc C s | j S )z
Profile name.
)r )r r r r r s z Profile.namec C s
|| _ d S )N)r )r �valuer r r r ' s c C s | j S )z$
Units included in the profile.
)r )r r r r �units+ s z
Profile.unitsc C s | j S )z
Profile global options.
)r )r r r r �options2 s zProfile.optionsN)�__name__�
__module__� __qualname__�__doc__� __slots__r
r r r �propertyr �setterr r r r r r r s
r )Ztuned.profiles.unitr Z tuned.constsr r �objectr r r r r �<module> s
PK ��\�\�� � # __pycache__/__init__.cpython-36.pycnu �[��� 3
�<�e � @ sH d dl T d dlT d dlT d dlT d dlT d dlT d dlT ddlmZ dS )� )�*� )� functionsN) Ztuned.profiles.locatorZtuned.profiles.loaderZtuned.profiles.profileZtuned.profiles.unitZtuned.profiles.exceptionsZtuned.profiles.factoryZtuned.profiles.merger� r � r r � /usr/lib/python3.6/__init__.py�<module> s PK ��\Y��l l ! __pycache__/loader.cpython-36.pycnu �[��� 3
�<�e� � @ st d dl Zd dlZd dlmZmZ d dljZd dlZ d dl
Z
d dl Zd dl Z d dl
mZ ejj� ZG dd� de�ZdS )� N)� ConfigParser�Error)�InvalidProfileExceptionc @ sv e Zd ZdZdddddgZdd� Zd d
� Zed d � �Ze d
d� �Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� ZdS ) �Loaderz
Profiles loader.
�_profile_locator�_profile_merger�_profile_factory�_global_config�
_variablesc C s" || _ || _|| _|| _|| _d S )N)r r r r r
)�self�profile_locatorZprofile_factoryZprofile_mergerZ
global_config� variables� r � /usr/lib/python3.6/loader.py�__init__ s
zLoader.__init__c C s t jjj||�S )N)�tuned�profiles�profileZProfile)r � profile_name�configr r r �_create_profile s zLoader._create_profilec C s t jd|�S )Nz^[a-zA-Z0-9_.-]+$)�re�match)�clsr r r r � safe_name s zLoader.safe_namec C s | j S )N)r )r r r r r " s zLoader.profile_locatorc C s� t |�tk r|j� }tt| j|��}t|�dkr8td��t|�dkrZtjddj |� � ntjd|d � g }g }| j
|||� t|�dkr�| j j |�}n|d }dj |�|_
d|jkr�| jj|jd j� |jd= | j|� | j|� |S ) Nr z.No profile or invalid profiles were specified.� zloading profiles: %sz, zloading profile: %s� r
)�type�list�split�filterr �lenr �log�info�join�
_load_profiler �merge�name�unitsr
Z add_from_cfg�options�_expand_vars_in_devices�_expand_vars_in_regexes)r �
profile_namesr �processed_filesZ
final_profiler r r �load& s*
z Loader.loadc C s0 x*|j D ] }| jj|j | j�|j | _qW d S )N)r( r
�expandZdevices)r r �unitr r r r* D s z Loader._expand_vars_in_devicesc C sL xF|j D ]<}| jj|j | j�|j | _| jj|j | j�|j | _qW d S )N)r( r
r/ Z
cpuinfo_regexZ uname_regex)r r r0 r r r r+ H s z Loader._expand_vars_in_regexesc C s� x�|D ]�}| j j||�}|dkr"q|d krFtd|tt| j j��f ��|j|� | j|�}| jj ||�}d|j
kr�t j d| j
j|j
jd���}| j|||� |j|� qW d S )N� z!Cannot find profile '%s' in '%s'.�includez
\s*[,;]\s*)r Z
get_configr r �reversedZ_load_directories�append�_load_config_datar Zcreater) r r r
r/ �popr% ) r r, r r- r' �filenamer r Z
include_namesr r r r% M s
zLoader._load_profilec C s t jd||�S )Nz(?<!\\)\$\{i:PROFILE_DIR\})r �sub)r Z profile_dir�stringr r r �_expand_profile_dir^ s zLoader._expand_profile_dirc
C s, y8t dddd�}t|_t|��}|j||� W d Q R X W n2 tjk
rj } ztd| |��W Y d d }~X nX tj � }t
j j |�}x�t
|j� �D ]�}tj � ||< xF|j|�D ]8}|j||dd�|| |< | j||| | �|| |< q�W || jd�d k r�t
j j||| d �} t
j j| �g|| d< q�W |S ) N�=�#F)Z
delimitersZinline_comment_prefixes�strictzCannot parse '%s'.T)�rawZscript)r �strZ optionxform�openZ read_filer � __bases__r � collections� OrderedDict�os�path�dirnamer Zsectionsr) �getr: r$ �normpath)
r � file_nameZ
config_obj�f�er Zdir_nameZsectionZoptionZ script_pathr r r r5 a s$
zLoader._load_config_dataN)�__name__�
__module__� __qualname__�__doc__� __slots__r r � classmethodr �propertyr r. r* r+ r% r: r5 r r r r r
s r )Ztuned.profiles.profiler Ztuned.profiles.variablesZtuned.utils.config_parserr r Z tuned.constsZconstsZos.pathrD rB Z
tuned.logsr Ztuned.profiles.exceptionsr ZlogsrG r" �objectr r r r r �<module> s
PK ��\$�0 __pycache__/unit.cpython-36.pycnu �[��� 3
�<�e� � @ s$ d dl Z d dlZG dd� de�ZdS )� Nc @ sP e Zd ZdZdddddddd d
d d d
g Zdd� Zedd� �Zedd� �Zej dd� �Zedd� �Z
e
j dd� �Z
edd� �Z edd� �Z e j d d� �Z ed d � �Z
e
j d d � �Z
ed d!� �Zej d"d!� �Zed#d$� �Zej d%d$� �Zed&d'� �Zej d(d'� �Zed)d*� �Zej d+d*� �Zed,d-� �Zej d.d-� �Zed/d0� �Zej d1d0� �Zd2S )3�Unitz
Unit description.
�_name�_type�_enabled�_replace�_drop�_devices�_devices_udev_regex�_cpuinfo_regex� _uname_regex� _script_pre� _script_post�_optionsc C s� || _ |jd| j �| _|jdd�dk| _|jdd �dk| _|jd
d �| _| jd k rftjd t| j��| _|jd d
�| _ |jdd �| _
|jdd �| _ |jdd �| _ |jdd �| _
|jdd �| _tj|�| _d S )N�type�enabledT�True�true� �1�replaceF�dropz \b\s*[,;]\s*�devices�*�devices_udev_regex�
cpuinfo_regex� uname_regex�
script_pre� script_post)Tr r r r )Tr r r r )r �popr r r r �re�split�strr r r
r r r
� collections� OrderedDictr )�self�name�config� r' �/usr/lib/python3.6/unit.py�__init__ s
z
Unit.__init__c C s | j S )N)r )r$ r' r' r( r% s z Unit.namec C s | j S )N)r )r$ r' r' r( r s z Unit.typec C s
|| _ d S )N)r )r$ �valuer' r' r( r $ s c C s | j S )N)r )r$ r' r' r( r ( s z Unit.enabledc C s
|| _ d S )N)r )r$ r* r' r' r( r , s c C s | j S )N)r )r$ r' r' r( r 0 s z Unit.replacec C s | j S )N)r )r$ r' r' r( r 4 s z Unit.dropc C s
|| _ d S )N)r )r$ r* r' r' r( r 8 s c C s | j S )N)r )r$ r' r' r( r < s z Unit.devicesc C s
|| _ d S )N)r )r$ r* r' r' r( r @ s c C s | j S )N)r )r$ r' r' r( r D s zUnit.devices_udev_regexc C s
|| _ d S )N)r )r$ r* r' r' r( r H s c C s | j S )N)r
)r$ r' r' r( r L s zUnit.cpuinfo_regexc C s
|| _ d S )N)r
)r$ r* r' r' r( r P s c C s | j S )N)r )r$ r' r' r( r T s zUnit.uname_regexc C s
|| _ d S )N)r )r$ r* r' r' r( r X s c C s | j S )N)r )r$ r' r' r( r \ s zUnit.script_prec C s
|| _ d S )N)r )r$ r* r' r' r( r ` s c C s | j S )N)r
)r$ r' r' r( r d s zUnit.script_postc C s
|| _ d S )N)r
)r$ r* r' r' r( r h s c C s | j S )N)r )r$ r' r' r( �optionsl s z Unit.optionsc C s
|| _ d S )N)r )r$ r* r' r' r( r+ p s N)�__name__�
__module__� __qualname__�__doc__� __slots__r) �propertyr% r �setterr r r r r r r r r r+ r' r' r' r( r s4 r )r" r �objectr r' r' r' r( �<module> s PK ��\q�Z/� � * __pycache__/variables.cpython-36.opt-1.pycnu �[��� 3
�<�e$ � @ sf d dl Z d dlZd dlZddlmZ d dljZd dlmZ d dl m
Z
m Z ej j
� ZG dd� d�ZdS )� N� )� functions)�commands)� ConfigParser�Errorc @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dS )� Variablesz8
Storage and processing of variables used in profiles
c C s" t � | _i | _i | _tj� | _d S )N)r �_cmd�
_lookup_re� _lookup_envr Z Functions�
_functions)�self� r
� /usr/lib/python3.6/variables.py�__init__ s zVariables.__init__c C s |j |�dkr|S || S )Nr )�find)r �s�prefixr
r
r �_add_env_prefix s zVariables._add_env_prefixc C s t jd|�S )Nz\w+$)�re�match)r �variabler
r
r �
_check_var s zVariables._check_varc C sj |d kr d S t |�}| j|�s0tjd| � d S | j|�}|| jdtj|� d < || j| j |t
j �< d S )Nz6variable definition '%s' contains unallowed charactersz
(?<!\\)\${�}) �strr �log�error�expandr r �escaper
r �constsZ
ENV_PREFIX)r r �valuer �vr
r
r � add_variable s
zVariables.add_variablec C s� t jj|�s tjd| � d S yLtddddd�}t|_t|��$}|j dt
j d |j � |� W d Q R X W n" t
k
r� tjd | � d S X x<|j� D ]0}x*|j|�D ] }| j||j||dd
�� q�W q�W d S ) Nz#unable to find variables_file: '%s'�=�#TF)Z
delimitersZinline_comment_prefixesZallow_no_value�strict�[z]
z"error parsing variables_file: '%s')�raw)�os�path�existsr r r r Z optionxform�openZ read_stringr ZMAGIC_HEADER_NAME�readr ZsectionsZoptionsr! �get)r �filename�config�fr �or
r
r �
add_from_file+ s
,zVariables.add_from_filec C sF x@|D ]8}t |�dkr.| jtjj|| �� q| j||| � qW d S )N�include)r r1 r' r( �normpathr! )r Zcfg�itemr
r
r � add_from_cfg; s
zVariables.add_from_cfgc C s t jdd| jj| j|��S )Nz \\(\${\w+})z\1)r �subr Zmultiple_re_replacer )r r r
r
r �
expand_staticC s zVariables.expand_staticc C s& |d kr d S | j t|��}| jj|�S )N)r7 r r r )r r r r
r
r r F s zVariables.expandc C s | j S )N)r
)r r
r
r �get_envN s zVariables.get_envN)
�__name__�
__module__� __qualname__�__doc__r r r r! r1 r5 r7 r r8 r
r
r
r r s
r )r' r Z
tuned.logsZtunedr Z tuned.constsr Ztuned.utils.commandsr Ztuned.utils.config_parserr r Zlogsr, r r r
r
r
r �<module> s
PK ��\W��qx x ( __pycache__/locator.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s6 d dl Z d dljZd dlmZmZ G dd� de�ZdS )� N)� ConfigParser�Errorc @ sn e Zd ZdZdgZdd� Zedd� �Zdd� Zdd
d �Z d d
� Z
dd� Z ddd�Z dd� Z
dd� Zdd� Zd S )�Locatorz$
Profiles locator and enumerator.
�_load_directoriesc C s t |�tk rtd��|| _d S )Nz(load_directories parameter is not a list)�type�list� TypeErrorr )�self�load_directories� r � /usr/lib/python3.6/locator.py�__init__ s zLocator.__init__c C s | j S )N)r )r r r r r
s zLocator.load_directoriesc G s& t |�dg }tjj|� }tjj|�S )Nz
tuned.conf)r �os�path�join�normpath)r �
path_partsZ config_namer r r �_get_config_filename s z Locator._get_config_filenameNc C s� d }|dd� dk}|r$|dd � }xLt | j�D ]>}| j|tjj|��}|d k r^||kr^d}q0tjj|�r0|S q0W |r�|d kr�d}|S )Nr � �-� )�reversedr r r r �basename�isfile)r � profile_nameZ
skip_files�retZconditional_load�dir_name� config_filer r r �
get_config s zLocator.get_configc C s |d k o|dkod|kS )Nr �/r )r r r r r �check_profile_name_format0 s z!Locator.check_profile_name_formatc C s� | j |�sd S | j|�}|d kr$d S yJtddddd�}t|_t|��"}|jdtj d |j � � W d Q R X |S t
t t fk
r� } zd S d }~X nX d S )N�=�#TF)Z
delimitersZinline_comment_prefixesZallow_no_value�strict�[z]
)
r r r �strZ optionxform�openZ read_string�constsZMAGIC_HEADER_NAME�read�IOError�OSErrorr )r r r �config�f�er r r � parse_config3 s
&zLocator.parse_configc C s$ y t |�}W n tk
r* |g}d}Y nX y t |�}W n tk
rV |g}d}Y nX ||k rv||d g|| }| j|�}|d kr�ddddgS tj|j� k}d|g}xtt||�D ]f\} }
| dks�| d kr�d|d< |dg }q�|o�| |jtj�k�r||jtj| dd�g }q�||
g }q�W |S )Nr Fr Tr )�raw���) �lenr r. r' ZPLUGIN_MAIN_UNIT_NAMEZsections�zipZoptions�get) r r ZattrsZdefvalsZ attrs_lenZ defvals_lenr+ Zmain_unit_in_config�vals�attrZdefvalr r r �get_profile_attrsG s2
zLocator.get_profile_attrsc C sj t � }x^| jD ]T}y:x4tj|�D ]&}| j||�}tjj|�r |j|� q W W q tk
r` Y qX qW |S )N) �setr r �listdirr r r �addr* )r Zprofilesr r r r r r �
list_profilese s
zLocator.list_profilesc C s t | j� �S )N)�sortedr: )r r r r �get_known_namesq s zLocator.get_known_namesc s � fdd�t � j� �D �S )Nc s( g | ] }|� j |tjgd g�d f�qS )r � )r6 r' ZPROFILE_ATTR_SUMMARY)�.0Zprofile)r r r �
<listcomp>u s z3Locator.get_known_names_summary.<locals>.<listcomp>)r; r: )r r )r r �get_known_names_summaryt s z Locator.get_known_names_summary)N)N)�__name__�
__module__� __qualname__�__doc__� __slots__r
�propertyr
r r r r. r6 r: r< r@ r r r r r s
r )r Z tuned.constsr' Ztuned.utils.config_parserr r �objectr r r r r �<module> s
PK ��\pm�5T T ! __pycache__/merger.cpython-36.pycnu �[��� 3
�<�e� � @ s( d dl Z d dlmZ G dd� de�ZdS )� N)�reducec @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �Mergerz0
Tool for merging multiple profiles into one.
c C s d S )N� )�selfr r � /usr/lib/python3.6/merger.py�__init__ s zMerger.__init__c C s t | j|�}|S )z�
Merge multiple configurations into one. If there are multiple units of the same type, option 'devices'
is set for each unit with respect to eliminating any duplicate devices.
)r �
_merge_two)r ZconfigsZ
merged_configr r r �merge s z Merger.mergec C s� |j j|j � �x�t|jj� �D �]~\}}|js:||jkrF||j|< q |j|j| _|j|j| _|j|j| _|j dk r�|j |j| _ |j
dk r�|j
|j| _
|j dk r�|j |j| _ |j dk r�|j |j| _ |j
dk r�|j
|j| _
|jdk �r x"|jD ]}|j| j j|d� q�W d|_|dk�r�|j| j jdd�dk �r�|j| j jdd�}|j| j j|j � ||j| j d |j| j d< q |j| j j|j � q W |S )z�
Merge two profiles. The configuration of units with matching names are updated with options
from the newer profile. If the 'replace' options of the newer unit is 'True', all options from the
older unit are dropped.
N�script)Zoptions�update�listZunits�items�replace�typeZenabledZdevicesZdevices_udev_regexZ
cpuinfo_regexZ uname_regexZ
script_preZ script_postZdrop�pop�get)r Z profile_aZ profile_bZ unit_nameZunitZoptionr
r r r r s6
$"zMerger._merge_twoN)�__name__�
__module__� __qualname__�__doc__r r r r r r r r s r )� collections� functoolsr �objectr r r r r �<module> s PK ��\?��4^ ^ + __pycache__/exceptions.cpython-36.opt-1.pycnu �[��� 3
�<�e_ � @ s d dl ZG dd� dejj�ZdS )� Nc @ s e Zd ZdS )�InvalidProfileExceptionN)�__name__�
__module__� __qualname__� r r � /usr/lib/python3.6/exceptions.pyr s r )Ztuned.exceptionsZtuned�
exceptionsZTunedExceptionr r r r r �<module> s PK ��\$�0 % __pycache__/unit.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s$ d dl Z d dlZG dd� de�ZdS )� Nc @ sP e Zd ZdZdddddddd d
d d d
g Zdd� Zedd� �Zedd� �Zej dd� �Zedd� �Z
e
j dd� �Z
edd� �Z edd� �Z e j d d� �Z ed d � �Z
e
j d d � �Z
ed d!� �Zej d"d!� �Zed#d$� �Zej d%d$� �Zed&d'� �Zej d(d'� �Zed)d*� �Zej d+d*� �Zed,d-� �Zej d.d-� �Zed/d0� �Zej d1d0� �Zd2S )3�Unitz
Unit description.
�_name�_type�_enabled�_replace�_drop�_devices�_devices_udev_regex�_cpuinfo_regex� _uname_regex� _script_pre� _script_post�_optionsc C s� || _ |jd| j �| _|jdd�dk| _|jdd �dk| _|jd
d �| _| jd k rftjd t| j��| _|jd d
�| _ |jdd �| _
|jdd �| _ |jdd �| _ |jdd �| _
|jdd �| _tj|�| _d S )N�type�enabledT�True�true� �1�replaceF�dropz \b\s*[,;]\s*�devices�*�devices_udev_regex�
cpuinfo_regex� uname_regex�
script_pre� script_post)Tr r r r )Tr r r r )r �popr r r r �re�split�strr r r
r r r
� collections� OrderedDictr )�self�name�config� r' �/usr/lib/python3.6/unit.py�__init__ s
z
Unit.__init__c C s | j S )N)r )r$ r' r' r( r% s z Unit.namec C s | j S )N)r )r$ r' r' r( r s z Unit.typec C s
|| _ d S )N)r )r$ �valuer' r' r( r $ s c C s | j S )N)r )r$ r' r' r( r ( s z Unit.enabledc C s
|| _ d S )N)r )r$ r* r' r' r( r , s c C s | j S )N)r )r$ r' r' r( r 0 s z Unit.replacec C s | j S )N)r )r$ r' r' r( r 4 s z Unit.dropc C s
|| _ d S )N)r )r$ r* r' r' r( r 8 s c C s | j S )N)r )r$ r' r' r( r < s z Unit.devicesc C s
|| _ d S )N)r )r$ r* r' r' r( r @ s c C s | j S )N)r )r$ r' r' r( r D s zUnit.devices_udev_regexc C s
|| _ d S )N)r )r$ r* r' r' r( r H s c C s | j S )N)r
)r$ r' r' r( r L s zUnit.cpuinfo_regexc C s
|| _ d S )N)r
)r$ r* r' r' r( r P s c C s | j S )N)r )r$ r' r' r( r T s zUnit.uname_regexc C s
|| _ d S )N)r )r$ r* r' r' r( r X s c C s | j S )N)r )r$ r' r' r( r \ s zUnit.script_prec C s
|| _ d S )N)r )r$ r* r' r' r( r ` s c C s | j S )N)r
)r$ r' r' r( r d s zUnit.script_postc C s
|| _ d S )N)r
)r$ r* r' r' r( r h s c C s | j S )N)r )r$ r' r' r( �optionsl s z Unit.optionsc C s
|| _ d S )N)r )r$ r* r' r' r( r+ p s N)�__name__�
__module__� __qualname__�__doc__� __slots__r) �propertyr% r �setterr r r r r r r r r r+ r' r' r' r( r s4 r )r" r �objectr r' r' r' r( �<module> s PK ��\
_� ( __pycache__/profile.cpython-36.opt-1.pycnu �[��� 3
�<�en � @ s. d dl Zd dljZd dlZG dd� de�ZdS )� Nc @ sl e Zd ZdZdddgZdd� Zdd� Zd d
� Zd d � Ze d
d� �Z
e
j dd� �Z
e dd� �Z e dd� �Z
dS )�Profilez'
Representation of a tuning profile.
�_name�_options�_unitsc C s || _ | j|� | j|� d S )N)r �
_init_options� _init_units)�self�name�config� r � /usr/lib/python3.6/profile.py�__init__ s
zProfile.__init__c C s$ i | _ tj|kr t|tj �| _ d S )N)r �consts�PLUGIN_MAIN_UNIT_NAME�dict)r r
r r r r s
zProfile._init_optionsc C s@ t j� | _x0|D ](}|tjkr| j||| �}|| j|< qW d S )N)� collections� OrderedDictr r r � _create_unit)r r
Z unit_nameZnew_unitr r r r s
zProfile._init_unitsc C s t jjj||�S )N)�tunedZprofilesZunitZUnit)r r r
r r r r s zProfile._create_unitc C s | j S )z
Profile name.
)r )r r r r r s z Profile.namec C s
|| _ d S )N)r )r �valuer r r r ' s c C s | j S )z$
Units included in the profile.
)r )r r r r �units+ s z
Profile.unitsc C s | j S )z
Profile global options.
)r )r r r r �options2 s zProfile.optionsN)�__name__�
__module__� __qualname__�__doc__� __slots__r
r r r �propertyr �setterr r r r r r r s
r )Ztuned.profiles.unitr Z tuned.constsr r �objectr r r r r �<module> s
PK ��\�\�� � ) __pycache__/__init__.cpython-36.opt-1.pycnu �[��� 3
�<�e � @ sH d dl T d dlT d dlT d dlT d dlT d dlT d dlT ddlmZ dS )� )�*� )� functionsN) Ztuned.profiles.locatorZtuned.profiles.loaderZtuned.profiles.profileZtuned.profiles.unitZtuned.profiles.exceptionsZtuned.profiles.factoryZtuned.profiles.merger� r � r r � /usr/lib/python3.6/__init__.py�<module> s PK ��\@
�� � ( __pycache__/factory.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s d dl ZG dd� de�ZdS )� Nc @ s e Zd Zdd� ZdS )�Factoryc C s t jjj||�S )N)�tunedZprofilesZprofileZProfile)�self�name�config� r � /usr/lib/python3.6/factory.py�create s zFactory.createN)�__name__�
__module__� __qualname__r r r r r r s r )Ztuned.profiles.profiler �objectr r r r r �<module> s PK ��\��Sn n
profile.pynu �[��� import tuned.profiles.unit
import tuned.consts as consts
import collections
class Profile(object):
"""
Representation of a tuning profile.
"""
__slots__ = ["_name", "_options", "_units"]
def __init__(self, name, config):
self._name = name
self._init_options(config)
self._init_units(config)
def _init_options(self, config):
self._options = {}
if consts.PLUGIN_MAIN_UNIT_NAME in config:
self._options = dict(config[consts.PLUGIN_MAIN_UNIT_NAME])
def _init_units(self, config):
self._units = collections.OrderedDict()
for unit_name in config:
if unit_name != consts.PLUGIN_MAIN_UNIT_NAME:
new_unit = self._create_unit(unit_name, config[unit_name])
self._units[unit_name] = new_unit
def _create_unit(self, name, config):
return tuned.profiles.unit.Unit(name, config)
@property
def name(self):
"""
Profile name.
"""
return self._name
@name.setter
def name(self, value):
self._name = value
@property
def units(self):
"""
Units included in the profile.
"""
return self._units
@property
def options(self):
"""
Profile global options.
"""
return self._options
PK ��\o� __init__.pynu �[��� from tuned.profiles.locator import *
from tuned.profiles.loader import *
from tuned.profiles.profile import *
from tuned.profiles.unit import *
from tuned.profiles.exceptions import *
from tuned.profiles.factory import *
from tuned.profiles.merger import *
from . import functions
PK ��\�]��� � unit.pynu �[��� import collections
import re
class Unit(object):
"""
Unit description.
"""
__slots__ = [ "_name", "_type", "_enabled", "_replace", "_drop", "_devices", "_devices_udev_regex", \
"_cpuinfo_regex", "_uname_regex", "_script_pre", "_script_post", "_options" ]
def __init__(self, name, config):
self._name = name
self._type = config.pop("type", self._name)
self._enabled = config.pop("enabled", True) in [True, "True", "true", 1, "1"]
self._replace = config.pop("replace", False) in [True, "True", "true", 1, "1"]
self._drop = config.pop("drop", None)
if self._drop is not None:
self._drop = re.split(r"\b\s*[,;]\s*", str(self._drop))
self._devices = config.pop("devices", "*")
self._devices_udev_regex = config.pop("devices_udev_regex", None)
self._cpuinfo_regex = config.pop("cpuinfo_regex", None)
self._uname_regex = config.pop("uname_regex", None)
self._script_pre = config.pop("script_pre", None)
self._script_post = config.pop("script_post", None)
self._options = collections.OrderedDict(config)
@property
def name(self):
return self._name
@property
def type(self):
return self._type
@type.setter
def type(self, value):
self._type = value
@property
def enabled(self):
return self._enabled
@enabled.setter
def enabled(self, value):
self._enabled = value
@property
def replace(self):
return self._replace
@property
def drop(self):
return self._drop
@drop.setter
def drop(self, value):
self._drop = value
@property
def devices(self):
return self._devices
@devices.setter
def devices(self, value):
self._devices = value
@property
def devices_udev_regex(self):
return self._devices_udev_regex
@devices_udev_regex.setter
def devices_udev_regex(self, value):
self._devices_udev_regex = value
@property
def cpuinfo_regex(self):
return self._cpuinfo_regex
@cpuinfo_regex.setter
def cpuinfo_regex(self, value):
self._cpuinfo_regex = value
@property
def uname_regex(self):
return self._uname_regex
@uname_regex.setter
def uname_regex(self, value):
self._uname_regex = value
@property
def script_pre(self):
return self._script_pre
@script_pre.setter
def script_pre(self, value):
self._script_pre = value
@property
def script_post(self):
return self._script_post
@script_post.setter
def script_post(self, value):
self._script_post = value
@property
def options(self):
return self._options
@options.setter
def options(self, value):
self._options = value
PK ��\R�5>� � merger.pynu �[��� import collections
from functools import reduce
class Merger(object):
"""
Tool for merging multiple profiles into one.
"""
def __init__(self):
pass
def merge(self, configs):
"""
Merge multiple configurations into one. If there are multiple units of the same type, option 'devices'
is set for each unit with respect to eliminating any duplicate devices.
"""
merged_config = reduce(self._merge_two, configs)
return merged_config
def _merge_two(self, profile_a, profile_b):
"""
Merge two profiles. The configuration of units with matching names are updated with options
from the newer profile. If the 'replace' options of the newer unit is 'True', all options from the
older unit are dropped.
"""
profile_a.options.update(profile_b.options)
for unit_name, unit in list(profile_b.units.items()):
if unit.replace or unit_name not in profile_a.units:
profile_a.units[unit_name] = unit
else:
profile_a.units[unit_name].type = unit.type
profile_a.units[unit_name].enabled = unit.enabled
profile_a.units[unit_name].devices = unit.devices
if unit.devices_udev_regex is not None:
profile_a.units[unit_name].devices_udev_regex = unit.devices_udev_regex
if unit.cpuinfo_regex is not None:
profile_a.units[unit_name].cpuinfo_regex = unit.cpuinfo_regex
if unit.uname_regex is not None:
profile_a.units[unit_name].uname_regex = unit.uname_regex
if unit.script_pre is not None:
profile_a.units[unit_name].script_pre = unit.script_pre
if unit.script_post is not None:
profile_a.units[unit_name].script_post = unit.script_post
if unit.drop is not None:
for option in unit.drop:
profile_a.units[unit_name].options.pop(option, None)
unit.drop = None
if unit_name == "script" and profile_a.units[unit_name].options.get("script", None) is not None:
script = profile_a.units[unit_name].options.get("script", None)
profile_a.units[unit_name].options.update(unit.options)
profile_a.units[unit_name].options["script"] = script + profile_a.units[unit_name].options["script"]
else:
profile_a.units[unit_name].options.update(unit.options)
return profile_a
PK ��\��|� � loader.pynu �[��� import tuned.profiles.profile
import tuned.profiles.variables
from tuned.utils.config_parser import ConfigParser, Error
import tuned.consts as consts
import os.path
import collections
import tuned.logs
import re
from tuned.profiles.exceptions import InvalidProfileException
log = tuned.logs.get()
class Loader(object):
"""
Profiles loader.
"""
__slots__ = ["_profile_locator", "_profile_merger", "_profile_factory", "_global_config", "_variables"]
def __init__(self, profile_locator, profile_factory, profile_merger, global_config, variables):
self._profile_locator = profile_locator
self._profile_factory = profile_factory
self._profile_merger = profile_merger
self._global_config = global_config
self._variables = variables
def _create_profile(self, profile_name, config):
return tuned.profiles.profile.Profile(profile_name, config)
@classmethod
def safe_name(cls, profile_name):
return re.match(r'^[a-zA-Z0-9_.-]+$', profile_name)
@property
def profile_locator(self):
return self._profile_locator
def load(self, profile_names):
if type(profile_names) is not list:
profile_names = profile_names.split()
profile_names = list(filter(self.safe_name, profile_names))
if len(profile_names) == 0:
raise InvalidProfileException("No profile or invalid profiles were specified.")
if len(profile_names) > 1:
log.info("loading profiles: %s" % ", ".join(profile_names))
else:
log.info("loading profile: %s" % profile_names[0])
profiles = []
processed_files = []
self._load_profile(profile_names, profiles, processed_files)
if len(profiles) > 1:
final_profile = self._profile_merger.merge(profiles)
else:
final_profile = profiles[0]
final_profile.name = " ".join(profile_names)
if "variables" in final_profile.units:
self._variables.add_from_cfg(final_profile.units["variables"].options)
del(final_profile.units["variables"])
# FIXME hack, do all variable expansions in one place
self._expand_vars_in_devices(final_profile)
self._expand_vars_in_regexes(final_profile)
return final_profile
def _expand_vars_in_devices(self, profile):
for unit in profile.units:
profile.units[unit].devices = self._variables.expand(profile.units[unit].devices)
def _expand_vars_in_regexes(self, profile):
for unit in profile.units:
profile.units[unit].cpuinfo_regex = self._variables.expand(profile.units[unit].cpuinfo_regex)
profile.units[unit].uname_regex = self._variables.expand(profile.units[unit].uname_regex)
def _load_profile(self, profile_names, profiles, processed_files):
for name in profile_names:
filename = self._profile_locator.get_config(name, processed_files)
if filename == "":
continue
if filename is None:
raise InvalidProfileException("Cannot find profile '%s' in '%s'." % (name, list(reversed(self._profile_locator._load_directories))))
processed_files.append(filename)
config = self._load_config_data(filename)
profile = self._profile_factory.create(name, config)
if "include" in profile.options:
include_names = re.split(r"\s*[,;]\s*", self._variables.expand(profile.options.pop("include")))
self._load_profile(include_names, profiles, processed_files)
profiles.append(profile)
def _expand_profile_dir(self, profile_dir, string):
return re.sub(r'(?<!\\)\$\{i:PROFILE_DIR\}', profile_dir, string)
def _load_config_data(self, file_name):
try:
config_obj = ConfigParser(delimiters=('='), inline_comment_prefixes=('#'), strict=False)
config_obj.optionxform=str
with open(file_name) as f:
config_obj.read_file(f, file_name)
except Error.__bases__ as e:
raise InvalidProfileException("Cannot parse '%s'." % file_name, e)
config = collections.OrderedDict()
dir_name = os.path.dirname(file_name)
for section in list(config_obj.sections()):
config[section] = collections.OrderedDict()
for option in config_obj.options(section):
config[section][option] = config_obj.get(section, option, raw=True)
config[section][option] = self._expand_profile_dir(dir_name, config[section][option])
if config[section].get("script") is not None:
script_path = os.path.join(dir_name, config[section]["script"])
config[section]["script"] = [os.path.normpath(script_path)]
return config
PK ��\�Ԇ�� � functions/function_s2kb.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
class s2kb(base.Function):
"""
Conversion function: sectors to kbytes
"""
def __init__(self):
# 1 argument
super(s2kb, self).__init__("s2kb", 1, 1)
def execute(self, args):
if not super(s2kb, self).execute(args):
return None
try:
return str(int(round(int(args[0]) / 2)))
except ValueError:
return None
PK ��\{I� � G functions/__pycache__/function_assertion_non_equal.cpython-36.opt-1.pycnu �[��� 3
�<�e+ � @ sT d dl Z d dlZddlmZ d dlmZ d dlmZ ej j
� Z G dd� dej �Z
dS )� N� )�base)�commands)�InvalidProfileExceptionc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�assertion_non_equalz�
Assertion non equal: compares argument 2 with argument 3. If they match
it logs text from argument 1 and throws InvalidProfileException. This
exception will abort profile loading.
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �2/usr/lib/python3.6/function_assertion_non_equal.pyr s z assertion_non_equal.__init__c sX t t| �j|�sd S |d |d krTtjd|d |d |d f � td|d ��d S )Nr � z#assertion '%s' failed: '%s' == '%s'r zAssertion '%s' failed.)r r �execute�log�errorr )r
�args)r r r
r s zassertion_non_equal.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r )�osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Ztuned.profiles.exceptionsr Zlogs�getr ZFunctionr r r r r
�<module> s
PK ��\��z0O O 3 functions/__pycache__/function_strip.cpython-36.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�stripz0
Makes string from all arguments and strip it
c s t t| �jddd� d S )Nr r r )�superr �__init__)�self)� __class__� �$/usr/lib/python3.6/function_strip.pyr
s zstrip.__init__c s" t t| �j|�sd S dj|�j� S )N� )r r �execute�join)r �args)r r
r r
s z
strip.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtunedr r Ztuned.utils.commandsr ZFunctionr r
r
r
r �<module> s PK ��\E�. C functions/__pycache__/function_cpulist_present.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_presentzY
Checks whether CPUs from list are present, returns list containing
only present CPUs
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �./usr/lib/python3.6/function_cpulist_present.pyr
s zcpulist_present.__init__c sd t t| �j|�sd S | jjdj|��}| jj| jjd��}djdd� ttt |�j
t |����D ��S )Nz,,z /sys/devices/system/cpu/present�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z*cpulist_present.execute.<locals>.<genexpr>) r r �executeZ_cmdZcpulist_unpack�joinZ read_file�sorted�list�set� intersection)r �argsZcpusZpresent)r r
r r s
zcpulist_present.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\Jb�o" " > functions/__pycache__/function_virt_check.cpython-36.opt-1.pycnu �[��� 3
�<�eS � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�
virt_checkz�
Checks whether running inside virtual machine (VM) or on bare metal.
If running inside VM expands to argument 1, otherwise expands to
argument 2 (even on error).
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �)/usr/lib/python3.6/function_virt_check.pyr s zvirt_check.__init__c sJ t t| �j|�sd S | jjdg�\}}|dkrBt|�dkrB|d S |d S )Nz virt-whatr r )r r �executeZ_cmd�len)r �args�ret�out)r
r r r
s zvirt_check.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r r )r
r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r r r r �<module> s PK ��\��_ 5 functions/__pycache__/repository.cpython-36.opt-1.pycnu �[��� 3
�<�e � @ sT d dl mZ ddlmZ d dlZd dljZd dlm Z ej
j � Z G dd� de�Z
dS )� )� PluginLoader� )�baseN)�commandsc sH e Zd Z� fdd�Zedd� �Zdd� Zdd� Zd d
� Zd d � Z � Z
S )
�
Repositoryc s t t| �j� i | _d S )N)�superr �__init__�
_functions)�self)� __class__� � /usr/lib/python3.6/repository.pyr s zRepository.__init__c C s | j S )N)r )r
r r r
� functions s zRepository.functionsc C s d| _ tj| _tjjjj| _ d S )Nztuned.profiles.functions)
Z
_namespace�constsZFUNCTION_PREFIX�_prefix�tunedZprofilesr r ZFunctionZ
_interface)r
r r r
�_set_loader_parameters s z!Repository._set_loader_parametersc C s, t jd| � | j|�}|� }|| j|< |S )Nzcreating function %s)�log�debugZ load_pluginr )r
�
function_nameZ function_clsZfunction_instancer r r
�create s
zRepository.createc C s || j kr| j|�S | j | S )N)r r )r
r r r r
� load_func! s
zRepository.load_funcc C s> t jd| � x*t| jj� �D ]\}}||kr | j|= q W d S )Nzremoving function %s)r r �listr �items)r
Zfunction�k�vr r r
�delete& s zRepository.delete) �__name__�
__module__� __qualname__r �propertyr r r r r �
__classcell__r r )r r
r s r )Ztuned.utils.plugin_loaderr � r Z
tuned.logsr Z tuned.constsr Ztuned.utils.commandsr Zlogs�getr r r r r r
�<module> s
PK ��\�n��I I < functions/__pycache__/function_cpulist_unpack.cpython-36.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_unpackzB
Conversion function: unpacks CPU list in form 1-3,4 to 1,2,3,4
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �-/usr/lib/python3.6/function_cpulist_unpack.pyr s zcpulist_unpack.__init__c s6 t t| �j|�sd S djdd� | jjdj|��D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z)cpulist_unpack.execute.<locals>.<genexpr>z,,)r r �execute�joinZ_cmd)r �args)r r
r r s zcpulist_unpack.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\���jT T C functions/__pycache__/function_check_net_queue_count.cpython-36.pycnu �[��� 3
�<�e� � @ s4 d dl ZddlmZ ejj� ZG dd� dej�ZdS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�check_net_queue_countz�
Checks whether the user has specified a queue count for net devices. If
not, return the number of housekeeping CPUs.
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �4/usr/lib/python3.6/function_check_net_queue_count.pyr s z check_net_queue_count.__init__c sL t t| �j|�sd S |d j� r(|d S | jjdg�\}}tjd| � |S )Nr ZnproczHnet-dev queue count is not correctly specified, setting it to HK CPUs %s)r r �execute�isdigitZ_cmd�log�warn)r �args�ret�out)r r r
r s z check_net_queue_count.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r ) Z
tuned.logsZtuned� r Zlogs�getr
ZFunctionr r r r r
�<module> s
PK ��\ށ��| | @ functions/__pycache__/function_cpulist2hex_invert.cpython-36.pycnu �[��� 3
�<�ep � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist2hex_invertz<
Converts CPU list to hexadecimal CPU mask and inverts it
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �1/usr/lib/python3.6/function_cpulist2hex_invert.pyr s zcpulist2hex_invert.__init__c s> t t| �j|�sd S | jjdjdd� | jjdj|��D ���S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z-cpulist2hex_invert.execute.<locals>.<genexpr>z,,)r r �executeZ_cmdZ cpulist2hex�joinZcpulist_invert)r �args)r r
r r s zcpulist2hex_invert.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\q{n n 2 functions/__pycache__/function_exec.cpython-36.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�executez0
Executes process and substitutes its output.
c s t t| �jddd� d S )N�execr r )�superr �__init__)�self)� __class__� �#/usr/lib/python3.6/function_exec.pyr
s zexecute.__init__c s4 t t| �j|�sd S | jj|�\}}|dkr0|S d S )Nr )r r Z_cmd)r �args�ret�out)r
r r r s zexecute.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r
r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r r r r �<module> s PK ��\1?��� � < functions/__pycache__/function_cpulist_invert.cpython-36.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_invertz�
Inverts list of CPUs (makes its complement). For the complement it
gets number of online CPUs from the /sys/devices/system/cpu/online,
e.g. system with 4 CPUs (0-3), the inversion of list "0,2,3" will be
"1"
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �-/usr/lib/python3.6/function_cpulist_invert.pyr s zcpulist_invert.__init__c s6 t t| �j|�sd S djdd� | jjdj|��D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z)cpulist_invert.execute.<locals>.<genexpr>z,,)r r �execute�joinZ_cmd)r �args)r r
r r s zcpulist_invert.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\k1 �� � : functions/__pycache__/function_cpulist_pack.cpython-36.pycnu �[��� 3
�<�e} � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� cpulist_packz�
Conversion function: packs CPU list in form 1,2,3,5 to 1-3,5.
The cpulist_unpack is used as a preprocessor, so it always returns
optimal results. For details about input syntax see cpulist_unpack.
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �+/usr/lib/python3.6/function_cpulist_pack.pyr s zcpulist_pack.__init__c s6 t t| �j|�sd S djdd� | jjdj|��D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z'cpulist_pack.execute.<locals>.<genexpr>z,,)r r �execute�joinZ_cmd)r �args)r r
r r s zcpulist_pack.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\ށ��| | F functions/__pycache__/function_cpulist2hex_invert.cpython-36.opt-1.pycnu �[��� 3
�<�ep � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist2hex_invertz<
Converts CPU list to hexadecimal CPU mask and inverts it
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �1/usr/lib/python3.6/function_cpulist2hex_invert.pyr s zcpulist2hex_invert.__init__c s> t t| �j|�sd S | jjdjdd� | jjdj|��D ���S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z-cpulist2hex_invert.execute.<locals>.<genexpr>z,,)r r �executeZ_cmdZ cpulist2hex�joinZcpulist_invert)r �args)r r
r r s zcpulist2hex_invert.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\�n��I I B functions/__pycache__/function_cpulist_unpack.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_unpackzB
Conversion function: unpacks CPU list in form 1-3,4 to 1,2,3,4
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �-/usr/lib/python3.6/function_cpulist_unpack.pyr s zcpulist_unpack.__init__c s6 t t| �j|�sd S djdd� | jjdj|��D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z)cpulist_unpack.execute.<locals>.<genexpr>z,,)r r �execute�joinZ_cmd)r �args)r r
r r s zcpulist_unpack.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\A�f�; ; ? functions/__pycache__/function_hex2cpulist.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� hex2cpulistzB
Conversion function: converts hexadecimal CPU mask to CPU list
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �*/usr/lib/python3.6/function_hex2cpulist.pyr s zhex2cpulist.__init__c s4 t t| �j|�sd S djdd� | jj|d �D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z&hex2cpulist.execute.<locals>.<genexpr>r )r r �execute�joinZ_cmd)r �args)r r
r r s zhex2cpulist.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\�
��{ { 2 functions/__pycache__/function_kb2s.cpython-36.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�kb2sz*
Conversion function: kbytes to sectors
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �#/usr/lib/python3.6/function_kb2s.pyr
s z
kb2s.__init__c sB t t| �j|�sd S ytt|d �d �S tk
r< d S X d S )Nr � )r r �execute�str�int�
ValueError)r �args)r r
r r
s z kb2s.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r
r
r
r �<module> s PK ��\{I� � A functions/__pycache__/function_assertion_non_equal.cpython-36.pycnu �[��� 3
�<�e+ � @ sT d dl Z d dlZddlmZ d dlmZ d dlmZ ej j
� Z G dd� dej �Z
dS )� N� )�base)�commands)�InvalidProfileExceptionc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�assertion_non_equalz�
Assertion non equal: compares argument 2 with argument 3. If they match
it logs text from argument 1 and throws InvalidProfileException. This
exception will abort profile loading.
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �2/usr/lib/python3.6/function_assertion_non_equal.pyr s z assertion_non_equal.__init__c sX t t| �j|�sd S |d |d krTtjd|d |d |d f � td|d ��d S )Nr � z#assertion '%s' failed: '%s' == '%s'r zAssertion '%s' failed.)r r �execute�log�errorr )r
�args)r r r
r s zassertion_non_equal.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r )�osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Ztuned.profiles.exceptionsr Zlogs�getr ZFunctionr r r r r
�<module> s
PK ��\AL��� � B functions/__pycache__/function_regex_search_ternary.cpython-36.pycnu �[��� 3
�<�e* � @ s* d dl Z ddlmZ G dd� dej�ZdS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�regex_search_ternaryz�
Ternary regex operator, it takes arguments in the following form
STR1, REGEX, STR2, STR3
If REGEX matches STR1 (re.search is used), STR2 is returned,
otherwise STR3 is returned
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �3/usr/lib/python3.6/function_regex_search_ternary.pyr s z regex_search_ternary.__init__c s< t t| �j|�sd S tj|d |d �r0|d S |d S d S )Nr r � � )r r �execute�re�search)r �args)r r
r r s
z regex_search_ternary.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r )r � r ZFunctionr r
r
r
r �<module> s PK ��\3�wB B . functions/__pycache__/functions.cpython-36.pycnu �[��� 3
�<�eb � @ sd d dl Z d dlZd dlZddlmZ d dlZd dljZd dl m
Z
ej j � Z
e
� ZG dd� d�ZdS )� N� )�
repository)�commandsc @ sZ e Zd ZdZdd� Zddd�Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )� Functionsz
Built-in functions
c C s t j� | _| j� d S )N)r Z
Repository� _repository� _parse_init)�self� r � /usr/lib/python3.6/functions.py�__init__ s
zFunctions.__init__� c C s& d| _ || _t|�| _g | _d| _d S )Nr F)�_cnt�_str�len�_len�_stack�_esc)r �sr r r
r s
zFunctions._parse_initc C s | j | jk r| j| j S dS )Nr )r
r r )r r r r
�
_curr_char s zFunctions._curr_charc C s | j | j| j| � S )N)r r
)r r r r r
� _curr_substr s zFunctions._curr_substrc C s | j j|| jf� d S )N)r �appendr
)r �escr r r
� _push_pos# s zFunctions._push_posc C sd | j d |� | | j |d d � | _ t| j �| _| jt|�|| d 7 _| jdk r`d| _d S )Nr r )r r r r
)r �a�br r r r
�_sub& s
&
zFunctions._subc C s� t jd| j|| j� �}|d dkr(d S dd� |D �}t jd|d �s\tjd|d � d S y| jj|d �}W n& t k
r� tjd |d � d S X |j
|d
d � �}|d kr�d S | j || j|� d S ) Nz(?<!\\):r z${fc S s g | ]}t |�jd d��qS )z\:�:)�str�replace)�.0�vr r r
�
<listcomp>1 s z+Functions._process_func.<locals>.<listcomp>z\w+$r zinvalid function name '%s'z function '%s' not implemented� ) �re�splitr r
�match�log�errorr Z load_func� ImportErrorZexecuter )r Z_fromZsl�fr r r r
�
_process_func- s zFunctions._process_funcc C s� | j |� x�| j| jk r�| j� dkrpy| jj� }W n$ tk
rV tjd| � | j S X |d s�| j
|d � n| j d�dkr�| j | j
� | j� dkr�d| _
nd | _
| jd7 _q W t| j�r�tjd
| � | j S ) N�}z.invalid variable syntax, non pair '}' in: '%s'r r r" z${�\TFz.invalid variable syntax, non pair '{' in: '%s')r r
r r r �pop�
IndexErrorr& r' r r* r r r r )r r Zsir r r
�_process? s&
zFunctions._processc C s( |d ks|dkr|S t jdd| j|��S )Nr z \\(\${f:.*})z\1)r# �subr/ )r r r r r
�expandV s zFunctions.expandN)r )
�__name__�
__module__� __qualname__�__doc__r r r r r r r* r/ r1 r r r r
r
s
r )�osr# Zglobr r Z
tuned.logsZtunedZ tuned.constsZconstsZtuned.utils.commandsr Zlogs�getr& �cmdr r r r r
�<module> s
PK ��\��� � < functions/__pycache__/function_cpulist_online.cpython-36.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_onlinezW
Checks whether CPUs from list are online, returns list containing
only online CPUs
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �-/usr/lib/python3.6/function_cpulist_online.pyr
s zcpulist_online.__init__c sR t t| �j|�sd S | jjdj|��}| jj| jjd��� dj� fdd�|D ��S )N�,z /sys/devices/system/cpu/onlinec 3 s | ]}|� krt |�V qd S )N)�str)�.0�v)�onliner
r � <genexpr> s z)cpulist_online.execute.<locals>.<genexpr>)r r �executeZ_cmdZcpulist_unpack�joinZ read_file)r �argsZcpus)r )r r r s
zcpulist_online.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\��!B� � 8 functions/__pycache__/function_s2kb.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�s2kbz*
Conversion function: sectors to kbytes
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �#/usr/lib/python3.6/function_s2kb.pyr
s z
s2kb.__init__c sJ t t| �j|�sd S y tttt|d �d ���S tk
rD d S X d S )Nr � )r r �execute�str�int�round�
ValueError)r �args)r r
r r
s z s2kb.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r
r
r
r �<module> s PK ��\��!B� � 2 functions/__pycache__/function_s2kb.cpython-36.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�s2kbz*
Conversion function: sectors to kbytes
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �#/usr/lib/python3.6/function_s2kb.pyr
s z
s2kb.__init__c sJ t t| �j|�sd S y tttt|d �d ���S tk
rD d S X d S )Nr � )r r �execute�str�int�round�
ValueError)r �args)r r
r r
s z s2kb.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r
r
r
r �<module> s PK ��\�
��{ { 8 functions/__pycache__/function_kb2s.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�kb2sz*
Conversion function: kbytes to sectors
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �#/usr/lib/python3.6/function_kb2s.pyr
s z
kb2s.__init__c sB t t| �j|�sd S ytt|d �d �S tk
r< d S X d S )Nr � )r r �execute�str�int�
ValueError)r �args)r r
r r
s z kb2s.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r
r
r
r �<module> s PK ��\AL��� � H functions/__pycache__/function_regex_search_ternary.cpython-36.opt-1.pycnu �[��� 3
�<�e* � @ s* d dl Z ddlmZ G dd� dej�ZdS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�regex_search_ternaryz�
Ternary regex operator, it takes arguments in the following form
STR1, REGEX, STR2, STR3
If REGEX matches STR1 (re.search is used), STR2 is returned,
otherwise STR3 is returned
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �3/usr/lib/python3.6/function_regex_search_ternary.pyr s z regex_search_ternary.__init__c s< t t| �j|�sd S tj|d |d �r0|d S |d S d S )Nr r � � )r r �execute�re�search)r �args)r r
r r s
z regex_search_ternary.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r )r � r ZFunctionr r
r
r
r �<module> s PK ��\E�. = functions/__pycache__/function_cpulist_present.cpython-36.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_presentzY
Checks whether CPUs from list are present, returns list containing
only present CPUs
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �./usr/lib/python3.6/function_cpulist_present.pyr
s zcpulist_present.__init__c sd t t| �j|�sd S | jjdj|��}| jj| jjd��}djdd� ttt |�j
t |����D ��S )Nz,,z /sys/devices/system/cpu/present�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z*cpulist_present.execute.<locals>.<genexpr>) r r �executeZ_cmdZcpulist_unpack�joinZ read_file�sorted�list�set� intersection)r �argsZcpusZpresent)r r
r r s
zcpulist_present.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\��� � B functions/__pycache__/function_cpulist_online.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_onlinezW
Checks whether CPUs from list are online, returns list containing
only online CPUs
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �-/usr/lib/python3.6/function_cpulist_online.pyr
s zcpulist_online.__init__c sR t t| �j|�sd S | jjdj|��}| jj| jjd��� dj� fdd�|D ��S )N�,z /sys/devices/system/cpu/onlinec 3 s | ]}|� krt |�V qd S )N)�str)�.0�v)�onliner
r � <genexpr> s z)cpulist_online.execute.<locals>.<genexpr>)r r �executeZ_cmdZcpulist_unpack�joinZ read_file)r �argsZcpus)r )r r r s
zcpulist_online.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\�m�� � - functions/__pycache__/__init__.cpython-36.pycnu �[��� 3
�<�e# � @ s d dl mZ dS )� )�
RepositoryN)Z
repositoryr � r r � /usr/lib/python3.6/__init__.py�<module> s PK ��\1?��� � B functions/__pycache__/function_cpulist_invert.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�cpulist_invertz�
Inverts list of CPUs (makes its complement). For the complement it
gets number of online CPUs from the /sys/devices/system/cpu/online,
e.g. system with 4 CPUs (0-3), the inversion of list "0,2,3" will be
"1"
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �-/usr/lib/python3.6/function_cpulist_invert.pyr s zcpulist_invert.__init__c s6 t t| �j|�sd S djdd� | jjdj|��D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z)cpulist_invert.execute.<locals>.<genexpr>z,,)r r �execute�joinZ_cmd)r �args)r r
r r s zcpulist_invert.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\� �D� � = functions/__pycache__/function_assertion.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ sT d dl Z d dlZddlmZ d dlmZ d dlmZ ej j
� Z G dd� dej �Z
dS )� N� )�base)�commands)�InvalidProfileExceptionc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� assertionz�
Assertion: compares argument 2 with argument 3. If they don't match
it logs text from argument 1 and throws InvalidProfileException. This
exception will abort profile loading.
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �(/usr/lib/python3.6/function_assertion.pyr s zassertion.__init__c sX t t| �j|�sd S |d |d krTtjd|d |d |d f � td|d ��d S )Nr � z#assertion '%s' failed: '%s' != '%s'r zAssertion '%s' failed.)r r �execute�log�errorr )r
�args)r r r
r s zassertion.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r )�osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Ztuned.profiles.exceptionsr Zlogs�getr ZFunctionr r r r r
�<module> s
PK ��\q{n n 8 functions/__pycache__/function_exec.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�executez0
Executes process and substitutes its output.
c s t t| �jddd� d S )N�execr r )�superr �__init__)�self)� __class__� �#/usr/lib/python3.6/function_exec.pyr
s zexecute.__init__c s4 t t| �j|�sd S | jj|�\}}|dkr0|S d S )Nr )r r Z_cmd)r �args�ret�out)r
r r r s zexecute.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r
r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r r r r �<module> s PK ��\Jb�o" " 8 functions/__pycache__/function_virt_check.cpython-36.pycnu �[��� 3
�<�eS � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�
virt_checkz�
Checks whether running inside virtual machine (VM) or on bare metal.
If running inside VM expands to argument 1, otherwise expands to
argument 2 (even on error).
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �)/usr/lib/python3.6/function_virt_check.pyr s zvirt_check.__init__c sJ t t| �j|�sd S | jjdg�\}}|dkrBt|�dkrB|d S |d S )Nz virt-whatr r )r r �executeZ_cmd�len)r �args�ret�out)r
r r r
s zvirt_check.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r r )r
r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr ZFunctionr r r r r �<module> s PK ��\�m�� � 3 functions/__pycache__/__init__.cpython-36.opt-1.pycnu �[��� 3
�<�e# � @ s d dl mZ dS )� )�
RepositoryN)Z
repositoryr � r r � /usr/lib/python3.6/__init__.py�<module> s PK ��\[5��� � A functions/__pycache__/function_cpuinfo_check.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s< d dl Z d dlZddlmZ ejj� ZG dd� dej�Z dS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�
cpuinfo_checka�
Checks regexes against /proc/cpuinfo. Accepts arguments in the
following form: REGEX1, STR1, REGEX2, STR2, ...[, STR_FALLBACK]
If REGEX1 matches something in /proc/cpuinfo it expands to STR1,
if REGEX2 matches it expands to STR2. It stops on the first match,
i.e. if REGEX1 matches, no more regexes are processed. If none
regex matches it expands to STR_FALLBACK. If there is no fallback,
it expands to empty string.
c s t t| �jddd� d S )Nr r � )�superr �__init__)�self)� __class__� �,/usr/lib/python3.6/function_cpuinfo_check.pyr s zcpuinfo_check.__init__c s� t t| �j|�sd S | jjd�}xHtdt|�d�D ]4}|d t|�k r2tj|| |tj �r2||d S q2W t|�d r~|d S dS d S )Nz
/proc/cpuinfor r r � ���)
r r �executeZ_cmdZ read_file�range�len�re�search� MULTILINE)r �argsZcpuinfo�i)r r
r r s zcpuinfo_check.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r )
r Z
tuned.logsZtunedr r Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\�}�2 2 G functions/__pycache__/function_calc_isolated_cores.cpython-36.opt-1.pycnu �[��� 3
�<�ek � @ sN d dl Z d dlZd dlZddlmZ d dljZejj � Z
G dd� dej �Z dS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�calc_isolated_coresz�
Calculates and returns isolated cores. The argument specifies how many
cores per socket reserve for housekeeping. If not specified, 1 core
per socket is reserved for housekeeping and the rest is isolated.
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �2/usr/lib/python3.6/function_calc_isolated_cores.pyr s z calc_isolated_cores.__init__c
sP t t| �j|�sd S d}t|�dkrj|d j� sBt|d �dk r^tjd|d | jf � d S t|d �}i }x�t j
t j j
tjd��D ]|}t j j|�dd � }|j� r�t j j
|d�}t j j|�s�tjd||f � q�| jj|�j� }|j� r�|j|g �|g ||< q�W g }x.|j� D ]"} | jtd� || |d � }�qW |jtd� d j
|�S )
Nr r zPinvalid argument '%s' for builtin function '%s', it must be non-negative integerzcpu*� z topology/physical_package_idz(file '%s' does not exist, cpu%s offline?)�key�,)r r �execute�len� isdecimal�int�log�error�_name�globZiglob�os�path�join�constsZSYSFS_CPUS_PATH�basename�exists�debugZ_cmdZ read_file�strip�get�values�sort)
r �argsZ cpus_reserveZtopoZcpuZcpuidZphysical_package_idZsocketZ isol_cpusZcpus)r r r
r s4 zcalc_isolated_cores.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r )
r r Z
tuned.logsZtuned� r Z tuned.constsr Zlogsr r ZFunctionr r r r r
�<module> s
PK ��\�A��� � @ functions/__pycache__/function_cpulist2devs.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s4 d dl ZddlmZ ejj� ZG dd� dej�ZdS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� cpulist2devsz<
Conversion function: converts CPU list to device strings
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �+/usr/lib/python3.6/function_cpulist2devs.pyr
s zcpulist2devs.__init__c s2 t t| �j|�sd S | jj| jjdj|��dd�S )N�,Zcpu)�prefix)r r �executeZ_cmdZcpulist2stringZcpulist_unpack�join)r �args)r r r
r
s zcpulist2devs.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r r )r r
r s r ) Z
tuned.logsZtuned� r Zlogs�get�logZFunctionr r r r r
�<module> s
PK ��\��z0O O 9 functions/__pycache__/function_strip.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s> d dl Z d dlZddlmZ d dlmZ G dd� dej�ZdS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�stripz0
Makes string from all arguments and strip it
c s t t| �jddd� d S )Nr r r )�superr �__init__)�self)� __class__� �$/usr/lib/python3.6/function_strip.pyr
s zstrip.__init__c s" t t| �j|�sd S dj|�j� S )N� )r r �execute�join)r �args)r r
r r
s z
strip.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtunedr r Ztuned.utils.commandsr ZFunctionr r
r
r
r �<module> s PK ��\3�wB B 4 functions/__pycache__/functions.cpython-36.opt-1.pycnu �[��� 3
�<�eb � @ sd d dl Z d dlZd dlZddlmZ d dlZd dljZd dl m
Z
ej j � Z
e
� ZG dd� d�ZdS )� N� )�
repository)�commandsc @ sZ e Zd ZdZdd� Zddd�Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )� Functionsz
Built-in functions
c C s t j� | _| j� d S )N)r Z
Repository� _repository� _parse_init)�self� r � /usr/lib/python3.6/functions.py�__init__ s
zFunctions.__init__� c C s& d| _ || _t|�| _g | _d| _d S )Nr F)�_cnt�_str�len�_len�_stack�_esc)r �sr r r
r s
zFunctions._parse_initc C s | j | jk r| j| j S dS )Nr )r
r r )r r r r
�
_curr_char s zFunctions._curr_charc C s | j | j| j| � S )N)r r
)r r r r r
� _curr_substr s zFunctions._curr_substrc C s | j j|| jf� d S )N)r �appendr
)r �escr r r
� _push_pos# s zFunctions._push_posc C sd | j d |� | | j |d d � | _ t| j �| _| jt|�|| d 7 _| jdk r`d| _d S )Nr r )r r r r
)r �a�br r r r
�_sub& s
&
zFunctions._subc C s� t jd| j|| j� �}|d dkr(d S dd� |D �}t jd|d �s\tjd|d � d S y| jj|d �}W n& t k
r� tjd |d � d S X |j
|d
d � �}|d kr�d S | j || j|� d S ) Nz(?<!\\):r z${fc S s g | ]}t |�jd d��qS )z\:�:)�str�replace)�.0�vr r r
�
<listcomp>1 s z+Functions._process_func.<locals>.<listcomp>z\w+$r zinvalid function name '%s'z function '%s' not implemented� ) �re�splitr r
�match�log�errorr Z load_func� ImportErrorZexecuter )r Z_fromZsl�fr r r r
�
_process_func- s zFunctions._process_funcc C s� | j |� x�| j| jk r�| j� dkrpy| jj� }W n$ tk
rV tjd| � | j S X |d s�| j
|d � n| j d�dkr�| j | j
� | j� dkr�d| _
nd | _
| jd7 _q W t| j�r�tjd
| � | j S ) N�}z.invalid variable syntax, non pair '}' in: '%s'r r r" z${�\TFz.invalid variable syntax, non pair '{' in: '%s')r r
r r r �pop�
IndexErrorr& r' r r* r r r r )r r Zsir r r
�_process? s&
zFunctions._processc C s( |d ks|dkr|S t jdd| j|��S )Nr z \\(\${f:.*})z\1)r# �subr/ )r r r r r
�expandV s zFunctions.expandN)r )
�__name__�
__module__� __qualname__�__doc__r r r r r r r* r/ r1 r r r r
r
s
r )�osr# Zglobr r Z
tuned.logsZtunedZ tuned.constsZconstsZtuned.utils.commandsr Zlogs�getr& �cmdr r r r r
�<module> s
PK ��\5�� � � 9 functions/__pycache__/function_cpulist2hex.cpython-36.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� cpulist2hexzB
Conversion function: converts CPU list to hexadecimal CPU mask
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �*/usr/lib/python3.6/function_cpulist2hex.pyr s zcpulist2hex.__init__c s& t t| �j|�sd S | jjdj|��S )Nz,,)r r �executeZ_cmd�join)r �args)r r
r r s zcpulist2hex.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\���3 3 / functions/__pycache__/repository.cpython-36.pycnu �[��� 3
�<�e � @ sT d dl mZ ddlmZ d dlZd dljZd dlm Z ej
j � Z G dd� de�Z
dS )� )� PluginLoader� )�baseN)�commandsc sH e Zd Z� fdd�Zedd� �Zdd� Zdd� Zd d
� Zd d � Z � Z
S )
�
Repositoryc s t t| �j� i | _d S )N)�superr �__init__�
_functions)�self)� __class__� � /usr/lib/python3.6/repository.pyr s zRepository.__init__c C s | j S )N)r )r
r r r
� functions s zRepository.functionsc C s d| _ tj| _tjjjj| _ d S )Nztuned.profiles.functions)
Z
_namespace�constsZFUNCTION_PREFIX�_prefix�tunedZprofilesr r ZFunction�
_interface)r
r r r
�_set_loader_parameters s z!Repository._set_loader_parametersc C s, t jd| � | j|�}|� }|| j|< |S )Nzcreating function %s)�log�debugZ load_pluginr )r
�
function_nameZ function_clsZfunction_instancer r r
�create s
zRepository.createc C s || j kr| j|�S | j | S )N)r r )r
r r r r
� load_func! s
zRepository.load_funcc C sN t || j�st�tjd| � x*t| jj� �D ]\}}||kr.| j|= q.W d S )Nzremoving function %s)�
isinstancer �AssertionErrorr r �listr �items)r
Zfunction�k�vr r r
�delete& s
zRepository.delete) �__name__�
__module__� __qualname__r �propertyr r r r r �
__classcell__r r )r r
r s r )Ztuned.utils.plugin_loaderr � r Z
tuned.logsr Z tuned.constsr Ztuned.utils.commandsr Zlogs�getr r r r r r
�<module> s
PK ��\���jT T I functions/__pycache__/function_check_net_queue_count.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ s4 d dl ZddlmZ ejj� ZG dd� dej�ZdS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�check_net_queue_countz�
Checks whether the user has specified a queue count for net devices. If
not, return the number of housekeeping CPUs.
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �4/usr/lib/python3.6/function_check_net_queue_count.pyr s z check_net_queue_count.__init__c sL t t| �j|�sd S |d j� r(|d S | jjdg�\}}tjd| � |S )Nr ZnproczHnet-dev queue count is not correctly specified, setting it to HK CPUs %s)r r �execute�isdigitZ_cmd�log�warn)r �args�ret�out)r r r
r s z check_net_queue_count.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r ) Z
tuned.logsZtuned� r Zlogs�getr
ZFunctionr r r r r
�<module> s
PK ��\�A��� � : functions/__pycache__/function_cpulist2devs.cpython-36.pycnu �[��� 3
�<�e� � @ s4 d dl ZddlmZ ejj� ZG dd� dej�ZdS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� cpulist2devsz<
Conversion function: converts CPU list to device strings
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �+/usr/lib/python3.6/function_cpulist2devs.pyr
s zcpulist2devs.__init__c s2 t t| �j|�sd S | jj| jjdj|��dd�S )N�,Zcpu)�prefix)r r �executeZ_cmdZcpulist2stringZcpulist_unpack�join)r �args)r r r
r
s zcpulist2devs.execute)�__name__�
__module__� __qualname__�__doc__r r
�
__classcell__r r )r r
r s r ) Z
tuned.logsZtuned� r Zlogs�get�logZFunctionr r r r r
�<module> s
PK ��\[5��� � ; functions/__pycache__/function_cpuinfo_check.cpython-36.pycnu �[��� 3
�<�e� � @ s< d dl Z d dlZddlmZ ejj� ZG dd� dej�Z dS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�
cpuinfo_checka�
Checks regexes against /proc/cpuinfo. Accepts arguments in the
following form: REGEX1, STR1, REGEX2, STR2, ...[, STR_FALLBACK]
If REGEX1 matches something in /proc/cpuinfo it expands to STR1,
if REGEX2 matches it expands to STR2. It stops on the first match,
i.e. if REGEX1 matches, no more regexes are processed. If none
regex matches it expands to STR_FALLBACK. If there is no fallback,
it expands to empty string.
c s t t| �jddd� d S )Nr r � )�superr �__init__)�self)� __class__� �,/usr/lib/python3.6/function_cpuinfo_check.pyr s zcpuinfo_check.__init__c s� t t| �j|�sd S | jjd�}xHtdt|�d�D ]4}|d t|�k r2tj|| |tj �r2||d S q2W t|�d r~|d S dS d S )Nz
/proc/cpuinfor r r � ���)
r r �executeZ_cmdZ read_file�range�len�re�search� MULTILINE)r �argsZcpuinfo�i)r r
r r s zcpuinfo_check.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r )
r Z
tuned.logsZtunedr r Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\� �D� � 7 functions/__pycache__/function_assertion.cpython-36.pycnu �[��� 3
�<�e� � @ sT d dl Z d dlZddlmZ d dlmZ d dlmZ ej j
� Z G dd� dej �Z
dS )� N� )�base)�commands)�InvalidProfileExceptionc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� assertionz�
Assertion: compares argument 2 with argument 3. If they don't match
it logs text from argument 1 and throws InvalidProfileException. This
exception will abort profile loading.
c s t t| �jddd� d S )Nr � )�superr �__init__)�self)� __class__� �(/usr/lib/python3.6/function_assertion.pyr s zassertion.__init__c sX t t| �j|�sd S |d |d krTtjd|d |d |d f � td|d ��d S )Nr � z#assertion '%s' failed: '%s' != '%s'r zAssertion '%s' failed.)r r �execute�log�errorr )r
�args)r r r
r s zassertion.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r )�osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Ztuned.profiles.exceptionsr Zlogs�getr ZFunctionr r r r r
�<module> s
PK ��\c.��m m ) functions/__pycache__/base.cpython-36.pycnu �[��� 3
�<�e � @ s: d dl Z d dlZd dlmZ ejj� ZG dd� de�Z dS )� N)�commandsc @ s0 e Zd ZdZd dd�Zed
dd��Zdd� ZdS ) �Functionz
Built-in function
Nc C s || _ || _|| _t� | _d S )N)�_name�
_nargs_max�
_nargs_minr Z_cmd)�self�name� nargs_max� nargs_min� r �/usr/lib/python3.6/base.py�__init__ s zFunction.__init__c C s< |d ks|d krdS t |�}|dks,||ko:|d kp:||kS )NFr )�len)�cls�argsr r
Zlar r r � _check_args s zFunction._check_argsc C s* | j || j| j�rdS tjd| j � dS )NTz5invalid number of arguments for builtin function '%s'F)r r r �log�errorr )r r r r r �execute s zFunction.execute)N)N)�__name__�
__module__� __qualname__�__doc__r
� classmethodr r r r r r r s
r )
�osZ
tuned.logsZtunedZtuned.utils.commandsr Zlogs�getr �objectr r r r r �<module> s
PK ��\c.��m m / functions/__pycache__/base.cpython-36.opt-1.pycnu �[��� 3
�<�e � @ s: d dl Z d dlZd dlmZ ejj� ZG dd� de�Z dS )� N)�commandsc @ s0 e Zd ZdZd dd�Zed
dd��Zdd� ZdS ) �Functionz
Built-in function
Nc C s || _ || _|| _t� | _d S )N)�_name�
_nargs_max�
_nargs_minr Z_cmd)�self�name� nargs_max� nargs_min� r �/usr/lib/python3.6/base.py�__init__ s zFunction.__init__c C s< |d ks|d krdS t |�}|dks,||ko:|d kp:||kS )NFr )�len)�cls�argsr r
Zlar r r � _check_args s zFunction._check_argsc C s* | j || j| j�rdS tjd| j � dS )NTz5invalid number of arguments for builtin function '%s'F)r r r �log�errorr )r r r r r �execute s zFunction.execute)N)N)�__name__�
__module__� __qualname__�__doc__r
� classmethodr r r r r r r s
r )
�osZ
tuned.logsZtunedZtuned.utils.commandsr Zlogs�getr �objectr r r r r �<module> s
PK ��\k1 �� � @ functions/__pycache__/function_cpulist_pack.cpython-36.opt-1.pycnu �[��� 3
�<�e} � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� cpulist_packz�
Conversion function: packs CPU list in form 1,2,3,5 to 1-3,5.
The cpulist_unpack is used as a preprocessor, so it always returns
optimal results. For details about input syntax see cpulist_unpack.
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �+/usr/lib/python3.6/function_cpulist_pack.pyr s zcpulist_pack.__init__c s6 t t| �j|�sd S djdd� | jjdj|��D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z'cpulist_pack.execute.<locals>.<genexpr>z,,)r r �execute�joinZ_cmd)r �args)r r
r r s zcpulist_pack.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\A�f�; ; 9 functions/__pycache__/function_hex2cpulist.cpython-36.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� hex2cpulistzB
Conversion function: converts hexadecimal CPU mask to CPU list
c s t t| �jddd� d S )Nr r )�superr �__init__)�self)� __class__� �*/usr/lib/python3.6/function_hex2cpulist.pyr s zhex2cpulist.__init__c s4 t t| �j|�sd S djdd� | jj|d �D ��S )N�,c s s | ]}t |�V qd S )N)�str)�.0�vr
r
r � <genexpr> s z&hex2cpulist.execute.<locals>.<genexpr>r )r r �execute�joinZ_cmd)r �args)r r
r r s zhex2cpulist.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\�}�2 2 A functions/__pycache__/function_calc_isolated_cores.cpython-36.pycnu �[��� 3
�<�ek � @ sN d dl Z d dlZd dlZddlmZ d dljZejj � Z
G dd� dej �Z dS )� N� )�basec s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )�calc_isolated_coresz�
Calculates and returns isolated cores. The argument specifies how many
cores per socket reserve for housekeeping. If not specified, 1 core
per socket is reserved for housekeeping and the rest is isolated.
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �2/usr/lib/python3.6/function_calc_isolated_cores.pyr s z calc_isolated_cores.__init__c
sP t t| �j|�sd S d}t|�dkrj|d j� sBt|d �dk r^tjd|d | jf � d S t|d �}i }x�t j
t j j
tjd��D ]|}t j j|�dd � }|j� r�t j j
|d�}t j j|�s�tjd||f � q�| jj|�j� }|j� r�|j|g �|g ||< q�W g }x.|j� D ]"} | jtd� || |d � }�qW |jtd� d j
|�S )
Nr r zPinvalid argument '%s' for builtin function '%s', it must be non-negative integerzcpu*� z topology/physical_package_idz(file '%s' does not exist, cpu%s offline?)�key�,)r r �execute�len� isdecimal�int�log�error�_name�globZiglob�os�path�join�constsZSYSFS_CPUS_PATH�basename�exists�debugZ_cmdZ read_file�strip�get�values�sort)
r �argsZ cpus_reserveZtopoZcpuZcpuidZphysical_package_idZsocketZ isol_cpusZcpus)r r r
r s4 zcalc_isolated_cores.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r r )r r
r s r )
r r Z
tuned.logsZtuned� r Z tuned.constsr Zlogsr r ZFunctionr r r r r
�<module> s
PK ��\5�� � � ? functions/__pycache__/function_cpulist2hex.cpython-36.opt-1.pycnu �[��� 3
�<�e� � @ sH d dl Z d dlZddlmZ d dlmZ ejj� Z G dd� dej
�Z dS )� N� )�base)�commandsc s, e Zd ZdZ� fdd�Z� fdd�Z� ZS )� cpulist2hexzB
Conversion function: converts CPU list to hexadecimal CPU mask
c s t t| �jdd� d S )Nr r )�superr �__init__)�self)� __class__� �*/usr/lib/python3.6/function_cpulist2hex.pyr s zcpulist2hex.__init__c s& t t| �j|�sd S | jjdj|��S )Nz,,)r r �executeZ_cmd�join)r �args)r r
r r s zcpulist2hex.execute)�__name__�
__module__� __qualname__�__doc__r r �
__classcell__r
r
)r r r s r ) �osZ
tuned.logsZtuned� r Ztuned.utils.commandsr Zlogs�get�logZFunctionr r
r
r
r �<module> s
PK ��\R�U� � % functions/function_cpulist_present.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class cpulist_present(base.Function):
"""
Checks whether CPUs from list are present, returns list containing
only present CPUs
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist_present, self).__init__("cpulist_present", 0)
def execute(self, args):
if not super(cpulist_present, self).execute(args):
return None
cpus = self._cmd.cpulist_unpack(",,".join(args))
present = self._cmd.cpulist_unpack(self._cmd.read_file("/sys/devices/system/cpu/present"))
return ",".join(str(v) for v in sorted(list(set(cpus).intersection(set(present)))))
PK ��\�� � functions/function_exec.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
class execute(base.Function):
"""
Executes process and substitutes its output.
"""
def __init__(self):
# unlimited number of arguments, min 1 argument (the name of executable)
super(execute, self).__init__("exec", 0, 1)
def execute(self, args):
if not super(execute, self).execute(args):
return None
(ret, out) = self._cmd.execute(args)
if ret == 0:
return out
return None
PK ��\n��� � # functions/function_cpuinfo_check.pynu �[��� import re
import tuned.logs
from . import base
log = tuned.logs.get()
class cpuinfo_check(base.Function):
"""
Checks regexes against /proc/cpuinfo. Accepts arguments in the
following form: REGEX1, STR1, REGEX2, STR2, ...[, STR_FALLBACK]
If REGEX1 matches something in /proc/cpuinfo it expands to STR1,
if REGEX2 matches it expands to STR2. It stops on the first match,
i.e. if REGEX1 matches, no more regexes are processed. If none
regex matches it expands to STR_FALLBACK. If there is no fallback,
it expands to empty string.
"""
def __init__(self):
# unlimited number of arguments, min 2 arguments
super(cpuinfo_check, self).__init__("cpuinfo_check", 0, 2)
def execute(self, args):
if not super(cpuinfo_check, self).execute(args):
return None
cpuinfo = self._cmd.read_file("/proc/cpuinfo")
for i in range(0, len(args), 2):
if i + 1 < len(args):
if re.search(args[i], cpuinfo, re.MULTILINE):
return args[i + 1]
if len(args) % 2:
return args[-1]
else:
return ""
PK ��\� (o� � functions/function_kb2s.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
class kb2s(base.Function):
"""
Conversion function: kbytes to sectors
"""
def __init__(self):
# 1 argument
super(kb2s, self).__init__("kb2s", 1, 1)
def execute(self, args):
if not super(kb2s, self).execute(args):
return None
try:
return str(int(args[0]) * 2)
except ValueError:
return None
PK ��\��� � $ functions/function_cpulist_unpack.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class cpulist_unpack(base.Function):
"""
Conversion function: unpacks CPU list in form 1-3,4 to 1,2,3,4
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist_unpack, self).__init__("cpulist_unpack", 0)
def execute(self, args):
if not super(cpulist_unpack, self).execute(args):
return None
return ",".join(str(v) for v in self._cmd.cpulist_unpack(",,".join(args)))
PK ��\��QW# # functions/__init__.pynu �[��� from .repository import Repository
PK ��\�Q�� � + functions/function_check_net_queue_count.pynu �[��� import tuned.logs
from . import base
log = tuned.logs.get()
class check_net_queue_count(base.Function):
"""
Checks whether the user has specified a queue count for net devices. If
not, return the number of housekeeping CPUs.
"""
def __init__(self):
# 1 argument
super(check_net_queue_count, self).__init__("check_net_queue_count", 1, 1)
def execute(self, args):
if not super(check_net_queue_count, self).execute(args):
return None
if args[0].isdigit():
return args[0]
(ret, out) = self._cmd.execute(["nproc"])
log.warn("net-dev queue count is not correctly specified, setting it to HK CPUs %s" % (out))
return out
PK ��\����+ + ) functions/function_assertion_non_equal.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
from tuned.profiles.exceptions import InvalidProfileException
log = tuned.logs.get()
class assertion_non_equal(base.Function):
"""
Assertion non equal: compares argument 2 with argument 3. If they match
it logs text from argument 1 and throws InvalidProfileException. This
exception will abort profile loading.
"""
def __init__(self):
# 3 arguments
super(assertion_non_equal, self).__init__("assertion_non_equal", 3, 3)
def execute(self, args):
if not super(assertion_non_equal, self).execute(args):
return None
if args[1] == args[2]:
log.error("assertion '%s' failed: '%s' == '%s'" % (args[0], args[1], args[2]))
raise InvalidProfileException("Assertion '%s' failed." % args[0])
return None
PK ��\E"��S S functions/function_virt_check.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
class virt_check(base.Function):
"""
Checks whether running inside virtual machine (VM) or on bare metal.
If running inside VM expands to argument 1, otherwise expands to
argument 2 (even on error).
"""
def __init__(self):
# 2 arguments
super(virt_check, self).__init__("virt_check", 2, 2)
def execute(self, args):
if not super(virt_check, self).execute(args):
return None
(ret, out) = self._cmd.execute(["virt-what"])
if ret == 0 and len(out) > 0:
return args[0]
return args[1]
PK ��\�G5� � " functions/function_cpulist2devs.pynu �[��� import tuned.logs
from . import base
log = tuned.logs.get()
class cpulist2devs(base.Function):
"""
Conversion function: converts CPU list to device strings
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist2devs, self).__init__("cpulist2devs", 0)
def execute(self, args):
if not super(cpulist2devs, self).execute(args):
return None
return self._cmd.cpulist2string(self._cmd.cpulist_unpack(",".join(args)), prefix = "cpu")
PK ��\f��} } " functions/function_cpulist_pack.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class cpulist_pack(base.Function):
"""
Conversion function: packs CPU list in form 1,2,3,5 to 1-3,5.
The cpulist_unpack is used as a preprocessor, so it always returns
optimal results. For details about input syntax see cpulist_unpack.
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist_pack, self).__init__("cpulist_pack", 0)
def execute(self, args):
if not super(cpulist_pack, self).execute(args):
return None
return ",".join(str(v) for v in self._cmd.cpulist_pack(",,".join(args)))
PK ��\�w+b b functions/functions.pynu �[��� import os
import re
import glob
from . import repository
import tuned.logs
import tuned.consts as consts
from tuned.utils.commands import commands
log = tuned.logs.get()
cmd = commands()
class Functions():
"""
Built-in functions
"""
def __init__(self):
self._repository = repository.Repository()
self._parse_init()
def _parse_init(self, s = ""):
self._cnt = 0
self._str = s
self._len = len(s)
self._stack = []
self._esc = False
def _curr_char(self):
return self._str[self._cnt] if self._cnt < self._len else ""
def _curr_substr(self, _len):
return self._str[self._cnt:self._cnt + _len]
def _push_pos(self, esc):
self._stack.append((esc, self._cnt))
def _sub(self, a, b, s):
self._str = self._str[:a] + s + self._str[b + 1:]
self._len = len(self._str)
self._cnt += len(s) - (b - a + 1)
if self._cnt < 0:
self._cnt = 0
def _process_func(self, _from):
sl = re.split(r'(?<!\\):', self._str[_from:self._cnt])
if sl[0] != "${f":
return
sl = [str(v).replace(r"\:", ":") for v in sl]
if not re.match(r'\w+$', sl[1]):
log.error("invalid function name '%s'" % sl[1])
return
try:
f = self._repository.load_func(sl[1])
except ImportError:
log.error("function '%s' not implemented" % sl[1])
return
s = f.execute(sl[2:])
if s is None:
return
self._sub(_from, self._cnt, s)
def _process(self, s):
self._parse_init(s)
while self._cnt < self._len:
if self._curr_char() == "}":
try:
si = self._stack.pop()
except IndexError:
log.error("invalid variable syntax, non pair '}' in: '%s'" % s)
return self._str
# if not escaped
if not si[0]:
self._process_func(si[1])
elif self._curr_substr(2) == "${":
self._push_pos(self._esc)
if self._curr_char() == "\\":
self._esc = True
else:
self._esc = False
self._cnt += 1
if len(self._stack):
log.error("invalid variable syntax, non pair '{' in: '%s'" % s)
return self._str
def expand(self, s):
if s is None or s == "":
return s
# expand functions and convert all \${f:*} to ${f:*} (unescape)
return re.sub(r'\\(\${f:.*})', r'\1', self._process(s))
PK ��\��� functions/base.pynu �[��� import os
import tuned.logs
from tuned.utils.commands import commands
log = tuned.logs.get()
class Function(object):
"""
Built-in function
"""
def __init__(self, name, nargs_max, nargs_min = None):
self._name = name
self._nargs_max = nargs_max
self._nargs_min = nargs_min
self._cmd = commands()
# checks arguments
# nargs_max - maximal number of arguments, there mustn't be more arguments,
# if nargs_max is 0, number of arguments is unlimited
# nargs_min - minimal number of arguments, if not None there must
# be the same number of arguments or more
@classmethod
def _check_args(cls, args, nargs_max, nargs_min = None):
if args is None or nargs_max is None:
return False
la = len(args)
return (nargs_max == 0 or nargs_max >= la) and (nargs_min is None or nargs_min <= la)
def execute(self, args):
if self._check_args(args, self._nargs_max, self._nargs_min):
return True
else:
log.error("invalid number of arguments for builtin function '%s'" % self._name)
return False
PK ��\�,��� � ! functions/function_hex2cpulist.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class hex2cpulist(base.Function):
"""
Conversion function: converts hexadecimal CPU mask to CPU list
"""
def __init__(self):
# 1 argument
super(hex2cpulist, self).__init__("hex2cpulist", 1, 1)
def execute(self, args):
if not super(hex2cpulist, self).execute(args):
return None
return ",".join(str(v) for v in self._cmd.hex2cpulist(args[0]))
PK ��\��0Nk k ) functions/function_calc_isolated_cores.pynu �[��� import os
import glob
import tuned.logs
from . import base
import tuned.consts as consts
log = tuned.logs.get()
class calc_isolated_cores(base.Function):
"""
Calculates and returns isolated cores. The argument specifies how many
cores per socket reserve for housekeeping. If not specified, 1 core
per socket is reserved for housekeeping and the rest is isolated.
"""
def __init__(self):
# max 1 argument
super(calc_isolated_cores, self).__init__("calc_isolated_cores", 1)
def execute(self, args):
if not super(calc_isolated_cores, self).execute(args):
return None
cpus_reserve = 1
if len(args) > 0:
if not args[0].isdecimal() or int(args[0]) < 0:
log.error("invalid argument '%s' for builtin function '%s', it must be non-negative integer" %
(args[0], self._name))
return None
else:
cpus_reserve = int(args[0])
topo = {}
for cpu in glob.iglob(os.path.join(consts.SYSFS_CPUS_PATH, "cpu*")):
cpuid = os.path.basename(cpu)[3:]
if cpuid.isdecimal():
physical_package_id = os.path.join(cpu, "topology/physical_package_id")
# Show no errors when the physical_package_id file does not exist -- the CPU may be offline.
if not os.path.exists(physical_package_id):
log.debug("file '%s' does not exist, cpu%s offline?" % (physical_package_id, cpuid))
continue
socket = self._cmd.read_file(physical_package_id).strip()
if socket.isdecimal():
topo[socket] = topo.get(socket, []) + [cpuid]
isol_cpus = []
for cpus in topo.values():
cpus.sort(key = int)
isol_cpus = isol_cpus + cpus[cpus_reserve:]
isol_cpus.sort(key = int)
return ",".join(isol_cpus)
PK ��\�Ud�� � ! functions/function_cpulist2hex.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class cpulist2hex(base.Function):
"""
Conversion function: converts CPU list to hexadecimal CPU mask
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist2hex, self).__init__("cpulist2hex", 0)
def execute(self, args):
if not super(cpulist2hex, self).execute(args):
return None
return self._cmd.cpulist2hex(",,".join(args))
PK ��\�mg� � functions/function_strip.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
class strip(base.Function):
"""
Makes string from all arguments and strip it
"""
def __init__(self):
# unlimited number of arguments, min 1 argument
super(strip, self).__init__("strip", 0, 1)
def execute(self, args):
if not super(strip, self).execute(args):
return None
return "".join(args).strip()
PK ��\�{k�* * * functions/function_regex_search_ternary.pynu �[��� import re
from . import base
class regex_search_ternary(base.Function):
"""
Ternary regex operator, it takes arguments in the following form
STR1, REGEX, STR2, STR3
If REGEX matches STR1 (re.search is used), STR2 is returned,
otherwise STR3 is returned
"""
def __init__(self):
# 4 arguments
super(regex_search_ternary, self).__init__("regex_search_ternary", 4, 4)
def execute(self, args):
if not super(regex_search_ternary, self).execute(args):
return None
if re.search(args[1], args[0]):
return args[2]
else:
return args[3]
PK ��\�<F�p p ( functions/function_cpulist2hex_invert.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class cpulist2hex_invert(base.Function):
"""
Converts CPU list to hexadecimal CPU mask and inverts it
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist2hex_invert, self).__init__("cpulist2hex_invert", 0)
def execute(self, args):
if not super(cpulist2hex_invert, self).execute(args):
return None
# current implementation inverts the CPU list and then converts it to hexmask
return self._cmd.cpulist2hex(",".join(str(v) for v in self._cmd.cpulist_invert(",,".join(args))))
PK ��\$�X� functions/repository.pynu �[��� from tuned.utils.plugin_loader import PluginLoader
from . import base
import tuned.logs
import tuned.consts as consts
from tuned.utils.commands import commands
log = tuned.logs.get()
class Repository(PluginLoader):
def __init__(self):
super(Repository, self).__init__()
self._functions = {}
@property
def functions(self):
return self._functions
def _set_loader_parameters(self):
self._namespace = "tuned.profiles.functions"
self._prefix = consts.FUNCTION_PREFIX
self._interface = tuned.profiles.functions.base.Function
def create(self, function_name):
log.debug("creating function %s" % function_name)
function_cls = self.load_plugin(function_name)
function_instance = function_cls()
self._functions[function_name] = function_instance
return function_instance
# loads function from plugin file and return it
# if it is already loaded, just return it, it is not loaded again
def load_func(self, function_name):
if not function_name in self._functions:
return self.create(function_name)
return self._functions[function_name]
def delete(self, function):
assert isinstance(function, self._interface)
log.debug("removing function %s" % function)
for k, v in list(self._functions.items()):
if v == function:
del self._functions[k]
PK ��\�j��� � $ functions/function_cpulist_online.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class cpulist_online(base.Function):
"""
Checks whether CPUs from list are online, returns list containing
only online CPUs
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist_online, self).__init__("cpulist_online", 0)
def execute(self, args):
if not super(cpulist_online, self).execute(args):
return None
cpus = self._cmd.cpulist_unpack(",".join(args))
online = self._cmd.cpulist_unpack(self._cmd.read_file("/sys/devices/system/cpu/online"))
return ",".join(str(v) for v in cpus if v in online)
PK ��\���F� � functions/function_assertion.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
from tuned.profiles.exceptions import InvalidProfileException
log = tuned.logs.get()
class assertion(base.Function):
"""
Assertion: compares argument 2 with argument 3. If they don't match
it logs text from argument 1 and throws InvalidProfileException. This
exception will abort profile loading.
"""
def __init__(self):
# 3 arguments
super(assertion, self).__init__("assertion", 3, 3)
def execute(self, args):
if not super(assertion, self).execute(args):
return None
if args[1] != args[2]:
log.error("assertion '%s' failed: '%s' != '%s'" % (args[0], args[1], args[2]))
raise InvalidProfileException("Assertion '%s' failed." % args[0])
return None
PK ��\�@�z� � $ functions/function_cpulist_invert.pynu �[��� import os
import tuned.logs
from . import base
from tuned.utils.commands import commands
log = tuned.logs.get()
class cpulist_invert(base.Function):
"""
Inverts list of CPUs (makes its complement). For the complement it
gets number of online CPUs from the /sys/devices/system/cpu/online,
e.g. system with 4 CPUs (0-3), the inversion of list "0,2,3" will be
"1"
"""
def __init__(self):
# arbitrary number of arguments
super(cpulist_invert, self).__init__("cpulist_invert", 0)
def execute(self, args):
if not super(cpulist_invert, self).execute(args):
return None
return ",".join(str(v) for v in self._cmd.cpulist_invert(",,".join(args)))
PK ��\0�t&� �
factory.pynu �[��� import tuned.profiles.profile
class Factory(object):
def create(self, name, config):
return tuned.profiles.profile.Profile(name, config)
PK ��\A�o�$ $ variables.pynu �[��� import os
import re
import tuned.logs
from .functions import functions as functions
import tuned.consts as consts
from tuned.utils.commands import commands
from tuned.utils.config_parser import ConfigParser, Error
log = tuned.logs.get()
class Variables():
"""
Storage and processing of variables used in profiles
"""
def __init__(self):
self._cmd = commands()
self._lookup_re = {}
self._lookup_env = {}
self._functions = functions.Functions()
def _add_env_prefix(self, s, prefix):
if s.find(prefix) == 0:
return s
return prefix + s
def _check_var(self, variable):
return re.match(r'\w+$',variable)
def add_variable(self, variable, value):
if value is None:
return
s = str(variable)
if not self._check_var(variable):
log.error("variable definition '%s' contains unallowed characters" % variable)
return
v = self.expand(value)
# variables referenced by ${VAR}, $ can be escaped by two $,
# i.e. the following will not expand: $${VAR}
self._lookup_re[r'(?<!\\)\${' + re.escape(s) + r'}'] = v
self._lookup_env[self._add_env_prefix(s, consts.ENV_PREFIX)] = v
def add_from_file(self, filename):
if not os.path.exists(filename):
log.error("unable to find variables_file: '%s'" % filename)
return
try:
config = ConfigParser(delimiters=('='), inline_comment_prefixes=('#'), allow_no_value=True, strict=False)
config.optionxform = str
with open(filename) as f:
config.read_string("[" + consts.MAGIC_HEADER_NAME + "]\n" + f.read(), filename)
except Error:
log.error("error parsing variables_file: '%s'" % filename)
return
for s in config.sections():
for o in config.options(s):
self.add_variable(o, config.get(s, o, raw=True))
def add_from_cfg(self, cfg):
for item in cfg:
if str(item) == "include":
self.add_from_file(os.path.normpath(cfg[item]))
else:
self.add_variable(item, cfg[item])
# expand static variables (no functions)
def expand_static(self, value):
return re.sub(r'\\(\${\w+})', r'\1', self._cmd.multiple_re_replace(self._lookup_re, value))
def expand(self, value):
if value is None:
return None
# expand variables and convert all \${VAR} to ${VAR} (unescape)
s = self.expand_static(str(value))
# expand built-in functions
return self._functions.expand(s)
def get_env(self):
return self._lookup_env
PK ��\��F� �
locator.pynu �[��� import os
import tuned.consts as consts
from tuned.utils.config_parser import ConfigParser, Error
class Locator(object):
"""
Profiles locator and enumerator.
"""
__slots__ = ["_load_directories"]
def __init__(self, load_directories):
if type(load_directories) is not list:
raise TypeError("load_directories parameter is not a list")
self._load_directories = load_directories
@property
def load_directories(self):
return self._load_directories
def _get_config_filename(self, *path_parts):
path_parts = list(path_parts) + ["tuned.conf"]
config_name = os.path.join(*path_parts)
return os.path.normpath(config_name)
def get_config(self, profile_name, skip_files=None):
ret = None
conditional_load = profile_name[0:1] == "-"
if conditional_load:
profile_name = profile_name[1:]
for dir_name in reversed(self._load_directories):
# basename is protection not to get out of the path
config_file = self._get_config_filename(dir_name, os.path.basename(profile_name))
if skip_files is not None and config_file in skip_files:
ret = ""
continue
if os.path.isfile(config_file):
return config_file
if conditional_load and ret is None:
ret = ""
return ret
def check_profile_name_format(self, profile_name):
return profile_name is not None and profile_name != "" and "/" not in profile_name
def parse_config(self, profile_name):
if not self.check_profile_name_format(profile_name):
return None
config_file = self.get_config(profile_name)
if config_file is None:
return None
try:
config = ConfigParser(delimiters=('='), inline_comment_prefixes=('#'), allow_no_value=True, strict=False)
config.optionxform = str
with open(config_file) as f:
config.read_string("[" + consts.MAGIC_HEADER_NAME + "]\n" + f.read())
return config
except (IOError, OSError, Error) as e:
return None
# Get profile attributes (e.g. summary, description), attrs is list of requested attributes,
# if it is not list it is converted to list, defvals is list of default values to return if
# attribute is not found, it is also converted to list if it is not list.
# Returns list of the following format [status, profile_name, attr1_val, attr2_val, ...],
# status is boolean.
def get_profile_attrs(self, profile_name, attrs, defvals = None):
# check types
try:
attrs_len = len(attrs)
except TypeError:
attrs = [attrs]
attrs_len = 1
try:
defvals_len = len(defvals)
except TypeError:
defvals = [defvals]
defvals_len = 1
# Extend defvals if needed, last value is used for extension
if defvals_len < attrs_len:
defvals = defvals + ([defvals[-1]] * (attrs_len - defvals_len))
config = self.parse_config(profile_name)
if config is None:
return [False, "", "", ""]
main_unit_in_config = consts.PLUGIN_MAIN_UNIT_NAME in config.sections()
vals = [True, profile_name]
for (attr, defval) in zip(attrs, defvals):
if attr == "" or attr is None:
vals[0] = False
vals = vals + [""]
elif main_unit_in_config and attr in config.options(consts.PLUGIN_MAIN_UNIT_NAME):
vals = vals + [config.get(consts.PLUGIN_MAIN_UNIT_NAME, attr, raw=True)]
else:
vals = vals + [defval]
return vals
def list_profiles(self):
profiles = set()
for dir_name in self._load_directories:
try:
for profile_name in os.listdir(dir_name):
config_file = self._get_config_filename(dir_name, profile_name)
if os.path.isfile(config_file):
profiles.add(profile_name)
except OSError:
pass
return profiles
def get_known_names(self):
return sorted(self.list_profiles())
def get_known_names_summary(self):
return [(profile, self.get_profile_attrs(profile, [consts.PROFILE_ATTR_SUMMARY], [""])[2]) for profile in sorted(self.list_profiles())]
PK ��\����_ _
exceptions.pynu �[��� import tuned.exceptions
class InvalidProfileException(tuned.exceptions.TunedException):
pass
PK ��\q�Z/� � $ __pycache__/variables.cpython-36.pycnu �[��� PK ��\W��qx x " __pycache__/locator.cpython-36.pycnu �[��� PK ��\pm�5T T ' � __pycache__/merger.cpython-36.opt-1.pycnu �[��� PK ��\?��4^ ^ % }" __pycache__/exceptions.cpython-36.pycnu �[��� PK ��\Y��l l ' 0$ __pycache__/loader.cpython-36.opt-1.pycnu �[��� PK ��\@
�� � " �4 __pycache__/factory.cpython-36.pycnu �[��� PK ��\
_� " #7 __pycache__/profile.cpython-36.pycnu �[��� PK ��\�\�� � # �> __pycache__/__init__.cpython-36.pycnu �[��� PK ��\Y��l l ! l@ __pycache__/loader.cpython-36.pycnu �[��� PK ��\$�0 )Q __pycache__/unit.cpython-36.pycnu �[��� PK ��\q�Z/� � * �_ __pycache__/variables.cpython-36.opt-1.pycnu �[��� PK ��\W��qx x ( �k __pycache__/locator.cpython-36.opt-1.pycnu �[��� PK ��\pm�5T T ! tz __pycache__/merger.cpython-36.pycnu �[��� PK ��\?��4^ ^ + � __pycache__/exceptions.cpython-36.opt-1.pycnu �[��� PK ��\$�0 % ҃ __pycache__/unit.cpython-36.opt-1.pycnu �[��� PK ��\
_� ( E� __pycache__/profile.cpython-36.opt-1.pycnu �[��� PK ��\�\�� � ) �� __pycache__/__init__.cpython-36.opt-1.pycnu �[��� PK ��\@
�� � ( �� __pycache__/factory.cpython-36.opt-1.pycnu �[��� PK ��\��Sn n
Н profile.pynu �[��� PK ��\o� x� __init__.pynu �[��� PK ��\�]��� � ̣ unit.pynu �[��� PK ��\R�5>� � �� merger.pynu �[��� PK ��\��|� � }� loader.pynu �[��� PK ��\�Ԇ�� � d� functions/function_s2kb.pynu �[��� PK ��\{I� � G O� functions/__pycache__/function_assertion_non_equal.cpython-36.opt-1.pycnu �[��� PK ��\��z0O O 3 �� functions/__pycache__/function_strip.cpython-36.pycnu �[��� PK ��\E�. C w� functions/__pycache__/function_cpulist_present.cpython-36.opt-1.pycnu �[��� PK ��\Jb�o" " > �� functions/__pycache__/function_virt_check.cpython-36.opt-1.pycnu �[��� PK ��\��_ 5 }� functions/__pycache__/repository.cpython-36.opt-1.pycnu �[��� PK ��\�n��I I < �� functions/__pycache__/function_cpulist_unpack.cpython-36.pycnu �[��� PK ��\���jT T C �� functions/__pycache__/function_check_net_queue_count.cpython-36.pycnu �[��� PK ��\ށ��| | @ ^� functions/__pycache__/function_cpulist2hex_invert.cpython-36.pycnu �[��� PK ��\q{n n 2 J� functions/__pycache__/function_exec.cpython-36.pycnu �[��� PK ��\1?��� � < � functions/__pycache__/function_cpulist_invert.cpython-36.pycnu �[��� PK ��\k1 �� � : c� functions/__pycache__/function_cpulist_pack.cpython-36.pycnu �[��� PK ��\ށ��| | F � functions/__pycache__/function_cpulist2hex_invert.cpython-36.opt-1.pycnu �[��� PK ��\�n��I I B � functions/__pycache__/function_cpulist_unpack.cpython-36.opt-1.pycnu �[��� PK ��\A�f�; ; ? A
functions/__pycache__/function_hex2cpulist.cpython-36.opt-1.pycnu �[��� PK ��\�
��{ { 2 � functions/__pycache__/function_kb2s.cpython-36.pycnu �[��� PK ��\{I� � A � functions/__pycache__/function_assertion_non_equal.cpython-36.pycnu �[��� PK ��\AL��� � B 8 functions/__pycache__/function_regex_search_ternary.cpython-36.pycnu �[��� PK ��\3�wB B . � functions/__pycache__/functions.cpython-36.pycnu �[��� PK ��\��� � < 9) functions/__pycache__/function_cpulist_online.cpython-36.pycnu �[��� PK ��\��!B� � 8 o. functions/__pycache__/function_s2kb.cpython-36.opt-1.pycnu �[��� PK ��\��!B� � 2 a2 functions/__pycache__/function_s2kb.cpython-36.pycnu �[��� PK ��\�
��{ { 8 M6 functions/__pycache__/function_kb2s.cpython-36.opt-1.pycnu �[��� PK ��\AL��� � H 0: functions/__pycache__/function_regex_search_ternary.cpython-36.opt-1.pycnu �[��� PK ��\E�. = �> functions/__pycache__/function_cpulist_present.cpython-36.pycnu �[��� PK ��\��� � B D functions/__pycache__/function_cpulist_online.cpython-36.opt-1.pycnu �[��� PK ��\�m�� � - CI functions/__pycache__/__init__.cpython-36.pycnu �[��� PK ��\1?��� � B >J functions/__pycache__/function_cpulist_invert.cpython-36.opt-1.pycnu �[��� PK ��\� �D� � = �O functions/__pycache__/function_assertion.cpython-36.opt-1.pycnu �[��� PK ��\q{n n 8 �T functions/__pycache__/function_exec.cpython-36.opt-1.pycnu �[��� PK ��\Jb�o" " 8 �X functions/__pycache__/function_virt_check.cpython-36.pycnu �[��� PK ��\�m�� � 3 -] functions/__pycache__/__init__.cpython-36.opt-1.pycnu �[��� PK ��\[5��� � A .^ functions/__pycache__/function_cpuinfo_check.cpython-36.opt-1.pycnu �[��� PK ��\�}�2 2 G Bd functions/__pycache__/function_calc_isolated_cores.cpython-36.opt-1.pycnu �[��� PK ��\�A��� � @ �k functions/__pycache__/function_cpulist2devs.cpython-36.opt-1.pycnu �[��� PK ��\��z0O O 9 �o functions/__pycache__/function_strip.cpython-36.opt-1.pycnu �[��� PK ��\3�wB B 4 �s functions/__pycache__/functions.cpython-36.opt-1.pycnu �[��� PK ��\5�� � � 9 E� functions/__pycache__/function_cpulist2hex.cpython-36.pycnu �[��� PK ��\���3 3 / E� functions/__pycache__/repository.cpython-36.pycnu �[��� PK ��\���jT T I functions/__pycache__/function_check_net_queue_count.cpython-36.opt-1.pycnu �[��� PK ��\�A��� � : �� functions/__pycache__/function_cpulist2devs.cpython-36.pycnu �[��� PK ��\[5��� � ; �� functions/__pycache__/function_cpuinfo_check.cpython-36.pycnu �[��� PK ��\� �D� � 7 �� functions/__pycache__/function_assertion.cpython-36.pycnu �[��� PK ��\c.��m m ) � functions/__pycache__/base.cpython-36.pycnu �[��� PK ��\c.��m m / �� functions/__pycache__/base.cpython-36.opt-1.pycnu �[��� PK ��\k1 �� � @ t� functions/__pycache__/function_cpulist_pack.cpython-36.opt-1.pycnu �[��� PK ��\A�f�; ; 9 �� functions/__pycache__/function_hex2cpulist.cpython-36.pycnu �[��� PK ��\�}�2 2 A O� functions/__pycache__/function_calc_isolated_cores.cpython-36.pycnu �[��� PK ��\5�� � � ? � functions/__pycache__/function_cpulist2hex.cpython-36.opt-1.pycnu �[��� PK ��\R�U� � % �� functions/function_cpulist_present.pynu �[��� PK ��\�� � � functions/function_exec.pynu �[��� PK ��\n��� � # 1� functions/function_cpuinfo_check.pynu �[��� PK ��\� (o� � w� functions/function_kb2s.pynu �[��� PK ��\��� � $ V� functions/function_cpulist_unpack.pynu �[��� PK ��\��QW# # �� functions/__init__.pynu �[��� PK ��\�Q�� � + � functions/function_check_net_queue_count.pynu �[��� PK ��\����+ + ) �� functions/function_assertion_non_equal.pynu �[��� PK ��\E"��S S z� functions/function_virt_check.pynu �[��� PK ��\�G5� � " � functions/function_cpulist2devs.pynu �[��� PK ��\f��} } " ;� functions/function_cpulist_pack.pynu �[��� PK ��\�w+b b
� functions/functions.pynu �[��� PK ��\��� �� functions/base.pynu �[��� PK ��\�,��� � ! � functions/function_hex2cpulist.pynu �[��� PK ��\��0Nk k ) ,� functions/function_calc_isolated_cores.pynu �[��� PK ��\�Ud�� � ! �� functions/function_cpulist2hex.pynu �[��� PK ��\�mg� � � functions/function_strip.pynu �[��� PK ��\�{k�* * * �� functions/function_regex_search_ternary.pynu �[��� PK ��\�<F�p p ( |� functions/function_cpulist2hex_invert.pynu �[��� PK ��\$�X� D� functions/repository.pynu �[��� PK ��\�j��� � $ �� functions/function_cpulist_online.pynu �[��� PK ��\���F� � n functions/function_assertion.pynu �[��� PK ��\�@�z� � $ � functions/function_cpulist_invert.pynu �[��� PK ��\0�t&� �
� factory.pynu �[��� PK ��\A�o�$ $ j variables.pynu �[��� PK ��\��F� �
� locator.pynu �[��� PK ��\����_ _
�! exceptions.pynu �[��� PK c c �) h"
