File manager - Edit - /home/u478019808/domains/bestandroidphones.store/public_html/static/img/logo/exports.zip
Back
PK ��ZJq�SB B + __pycache__/interfaces.cpython-39.opt-1.pycnu �[��� a �ԳfL � @ s$ G d d� de �ZG dd� de �ZdS )c @ s e Zd ZdS )�ExportableInterfaceN)�__name__� __module__� __qualname__� r r �</usr/lib/python3.9/site-packages/tuned/exports/interfaces.pyr s r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�ExporterInterfacec C s t � �d S �N��NotImplementedError)�self�methodZ in_signature� out_signaturer r r �export s zExporterInterface.exportc C s t � �d S r r )r r r r r r �signal s zExporterInterface.signalc O s t � �d S r r )r r �args�kwargsr r r � send_signal s z ExporterInterface.send_signalc C s t � �d S r r �r r r r �start s zExporterInterface.startc C s t � �d S r r r r r r �stop s zExporterInterface.stopc C s d S r r r r r r � period_check s z ExporterInterface.period_checkN) r r r r r r r r r r r r r r s r N)�objectr r r r r r �<module> s PK ��Z��OE E + __pycache__/controller.cpython-39.opt-1.pycnu �[��� a �Գf� � @ s4 d dl mZ ddlZddlZG dd� dejj�ZdS )� )� interfaces� Nc s� e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Z� ZS )$�ExportsControllerz4 Controls and manages object interface exporting. c s$ t t| ��� g | _g | _d| _d S )NF)�superr �__init__� _exporters�_objects�_exports_initialized)�self�� __class__� �</usr/lib/python3.9/site-packages/tuned/exports/controller.pyr s zExportsController.__init__c C s | j �|� dS )zRegister objects exporter.N)r �append�r �instancer r r �register_exporter s z#ExportsController.register_exporterc C s | j �|� dS )z Register object to be exported.N)r r r r r r �register_object s z!ExportsController.register_objectc C s t �|�ot|d�S )z8Check if method was marked with @exports.export wrapper.� export_params��inspectZismethod�hasattr�r �methodr r r �_is_exportable_method s z'ExportsController._is_exportable_methodc C s t �|�ot|d�S )z8Check if method was marked with @exports.signal wrapper.� signal_paramsr r r r r �_is_exportable_signal s z'ExportsController._is_exportable_signalc C s t �|�ot|d�S )z>Check if method was marked with @exports.get_property wrapper.�property_get_paramsr r r r r �_is_exportable_getter s z'ExportsController._is_exportable_getterc C s t �|�ot|d�S )z>Check if method was marked with @exports.set_property wrapper.�property_set_paramsr r r r r �_is_exportable_setter$ s z'ExportsController._is_exportable_setterc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )z!Register method to all exporters.r r N)r r Zexport�r r �exporter�args�kwargsr r r �_export_method( s z ExportsController._export_methodc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )�!Register signal to all exporters.r r N)r r �signalr! r r r �_export_signal/ s z ExportsController._export_signalc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )z*Register property getter to all exporters.r r N)r r Zproperty_getterr! r r r �_export_getter6 s z ExportsController._export_getterc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )z*Register property setter to all exporters.r r N)r r Zproperty_setterr! r r r �_export_setter= s z ExportsController._export_setterc O s( | j D ] }|j|g|�R i |�� qdS )r& N)r � send_signal)r r' r# r$ r" r r r r+ D s z ExportsController.send_signalc O s | j D ]}|j|i |�� qd S )N)r �property_changed)r r# r$ r" r r r r, I s z"ExportsController.property_changedc C s | j D ] }|�� qdS )z=Allows to perform checks on exporters without special thread.N)r � period_check�r r" r r r r- M s z ExportsController.period_checkc C s� | j r d S | jD ]�}t�|| j�D ]\}}| �|� q"t�|| j�D ]\}}| �|� qDt�|| j�D ]\}}| � |� qft�|| j �D ]\}}| � |� q�qd| _ d S )NT) r r r Z getmembersr r% r r( r r) r r* )r r �namer r r r �_initialize_exportsR s z%ExportsController._initialize_exportsc C s | � � | jD ] }|�� qdS )zStart the exports.N)r0 r �startr. r r r r1 b s zExportsController.startc C s | j D ] }|�� qdS )zStop the exports.N)r �stopr. r r r r2 h s zExportsController.stop)�__name__� __module__� __qualname__�__doc__r r r r r r r r% r( r) r* r+ r, r- r0 r1 r2 � __classcell__r r r r r s$ r )� r r Ztuned.patternsZtuned�patternsZ Singletonr r r r r �<module> s PK ��Z��OE E % __pycache__/controller.cpython-39.pycnu �[��� a �Գf� � @ s4 d dl mZ ddlZddlZG dd� dejj�ZdS )� )� interfaces� Nc s� e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Z� ZS )$�ExportsControllerz4 Controls and manages object interface exporting. c s$ t t| ��� g | _g | _d| _d S )NF)�superr �__init__� _exporters�_objects�_exports_initialized)�self�� __class__� �</usr/lib/python3.9/site-packages/tuned/exports/controller.pyr s zExportsController.__init__c C s | j �|� dS )zRegister objects exporter.N)r �append�r �instancer r r �register_exporter s z#ExportsController.register_exporterc C s | j �|� dS )z Register object to be exported.N)r r r r r r �register_object s z!ExportsController.register_objectc C s t �|�ot|d�S )z8Check if method was marked with @exports.export wrapper.� export_params��inspectZismethod�hasattr�r �methodr r r �_is_exportable_method s z'ExportsController._is_exportable_methodc C s t �|�ot|d�S )z8Check if method was marked with @exports.signal wrapper.� signal_paramsr r r r r �_is_exportable_signal s z'ExportsController._is_exportable_signalc C s t �|�ot|d�S )z>Check if method was marked with @exports.get_property wrapper.�property_get_paramsr r r r r �_is_exportable_getter s z'ExportsController._is_exportable_getterc C s t �|�ot|d�S )z>Check if method was marked with @exports.set_property wrapper.�property_set_paramsr r r r r �_is_exportable_setter$ s z'ExportsController._is_exportable_setterc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )z!Register method to all exporters.r r N)r r Zexport�r r �exporter�args�kwargsr r r �_export_method( s z ExportsController._export_methodc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )�!Register signal to all exporters.r r N)r r �signalr! r r r �_export_signal/ s z ExportsController._export_signalc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )z*Register property getter to all exporters.r r N)r r Zproperty_getterr! r r r �_export_getter6 s z ExportsController._export_getterc C s< | j D ]0}|jd }|jd }|j|g|�R i |�� qdS )z*Register property setter to all exporters.r r N)r r Zproperty_setterr! r r r �_export_setter= s z ExportsController._export_setterc O s( | j D ] }|j|g|�R i |�� qdS )r& N)r � send_signal)r r' r# r$ r" r r r r+ D s z ExportsController.send_signalc O s | j D ]}|j|i |�� qd S )N)r �property_changed)r r# r$ r" r r r r, I s z"ExportsController.property_changedc C s | j D ] }|�� qdS )z=Allows to perform checks on exporters without special thread.N)r � period_check�r r" r r r r- M s z ExportsController.period_checkc C s� | j r d S | jD ]�}t�|| j�D ]\}}| �|� q"t�|| j�D ]\}}| �|� qDt�|| j�D ]\}}| � |� qft�|| j �D ]\}}| � |� q�qd| _ d S )NT) r r r Z getmembersr r% r r( r r) r r* )r r �namer r r r �_initialize_exportsR s z%ExportsController._initialize_exportsc C s | � � | jD ] }|�� qdS )zStart the exports.N)r0 r �startr. r r r r1 b s zExportsController.startc C s | j D ] }|�� qdS )zStop the exports.N)r �stopr. r r r r2 h s zExportsController.stop)�__name__� __module__� __qualname__�__doc__r r r r r r r r% r( r) r* r+ r, r- r0 r1 r2 � __classcell__r r r r r s$ r )� r r Ztuned.patternsZtuned�patternsZ Singletonr r r r r �<module> s PK ��Z�.� � > __pycache__/dbus_exporter_with_properties.cpython-39.opt-1.pycnu �[��� a �Գf* � @ sT d dl mZ d dlmZmZ d dlmZ d dlmZ d dl m Z G dd� de �Z dS ) � )�ismethod)�method�signal)�PROPERTIES_IFACE)� DBusException)� DBusExporterc s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �DBusExporterWithPropertiesc s� t t� ��||||� i � _i � _� fdd�}� fdd�}� fdd�}� fdd�}ttd d d �|�� jd < ttd d�|�� jd< ttddd �|�� jd< ttdd�|�� jd< � j � d� d S )Nc s< |� j krtd| ��|� jvr,td| ��� j| }|� S �N�Unknown interface: %szNo such property: %s)�_interface_namer �_property_getters)�_�interface_name� property_name�getter��self� �O/usr/lib/python3.9/site-packages/tuned/exports/dbus_exporter_with_properties.py�Get s z0DBusExporterWithProperties.__init__.<locals>.Getc sB |� j krtd| ��|� jvr,td| ��� j| }||� d S r )r r �_property_setters)r r r �value�setterr r r �Set s z0DBusExporterWithProperties.__init__.<locals>.Setc s* |� j krtd| ��dd� � j�� D �S )Nr c S s i | ]\}}||� �qS r r )�.0�namer r r r � <dictcomp>! � zGDBusExporterWithProperties.__init__.<locals>.GetAll.<locals>.<dictcomp>)r r r �items)r r r r r �GetAll s z3DBusExporterWithProperties.__init__.<locals>.GetAllc s |� j krtd| ��d S )Nr )r r )r r Zchanged_propertiesZinvalidated_propertiesr r r �PropertiesChanged# s z>DBusExporterWithProperties.__init__.<locals>.PropertiesChanged�ss�v)� in_signatureZ out_signaturer Zssv)r# r �sza{sv}r zsa{sv}as)Z signaturer ) �superr �__init__r r r r Z _dbus_methodsr Z_signals�add) r Zbus_namer Z object_name� namespacer r r r �� __class__r r r& s z#DBusExporterWithProperties.__init__c C s | � d| j||ii � d S )Nr )Z send_signalr )r r r r r r �property_changed- s z+DBusExporterWithProperties.property_changedc C s0 t |�std��|| jv r"td��|| j|< d S )N�#Only bound methods can be exported.z1A getter for this property is already registered.)r � Exceptionr �r r r r r r �property_getter0 s z*DBusExporterWithProperties.property_getterc C s0 t |�std��|| jv r"td��|| j|< d S )Nr, z1A setter for this property is already registered.)r r- r r. r r r �property_setter7 s z*DBusExporterWithProperties.property_setter)�__name__� __module__� __qualname__r& r+ r/ r0 � __classcell__r r r) r r s $r N) �inspectr Z dbus.servicer r Zdbusr Zdbus.exceptionsr Ztuned.exports.dbus_exporterr r r r r r �<module> s PK ��Z���:� � ( __pycache__/dbus_exporter.cpython-39.pycnu �[��� a �ԳfU � @ s d dl mZ ddlZddlZddlZddlZddlZddlZ ddl m Z ddl Z ddl Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ zdd lmZ d d � ZW n ey� dd lmZ Y n0 e j � � Z dd� Z G dd� dej �Z!dS )� )� interfaces� N)�ismethod)�polkit)�GLib)� FunctionType)� DBusException)� ErrorMessage��getfullargspecc C s t | �S �Nr )�func� r �?/usr/lib/python3.9/site-packages/tuned/exports/dbus_exporter.py� getargspec s r )r c C s� t |dd �}|d urn0t |dd�dv r4d|jj }nd|j|jjf }t|t�rZ|�� }nd�t� |j|��}t |||�}|� � s�| � |� d S )NZ_dbus_error_name� __module__� )r �__main__z org.freedesktop.DBus.Python.%sz!org.freedesktop.DBus.Python.%s.%s) �getattr� __class__�__name__r � isinstancer Zget_dbus_message�join� traceback�format_exception_onlyr Z get_no_replyZ send_message)Z connection�message� exception�name�contentsZreplyr r r �_method_reply_error$ s � r c @ s� e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd S ) � DBusExportera+ Export method calls through DBus Interface. We take a method to be exported and create a simple wrapper function to call it. This is required as we need the original function to be bound to the original object instance. While the wrapper will be bound to an object we dynamically construct. c C s� t �� tjkrttj_tjjj dd� d | _ d | _ i | _ t � | _|| _|| _|| _|| _d | _d | _t� | _t�tj�}t�� | _ t�tj|� d S )NT)Zset_as_default) �logZgetEffectiveLevel�logging�DEBUGr �dbus�serviceZmainloopZglibZ DBusGMainLoop�_dbus_object_clsZ _dbus_object� _dbus_methods�set�_signals� _bus_name�_interface_name� _object_name� _namespace�_thread� _bus_objectr �_polkit�signal� getsignal�SIGINTr ZMainLoop� _main_loop)�self�bus_name�interface_name� object_name� namespaceZsignal_handlerr r r �__init__B s" zDBusExporter.__init__c C s | j S r )r* �r5 r r r r6 ` s zDBusExporter.bus_namec C s | j S r )r+ r; r r r r7 d s zDBusExporter.interface_namec C s | j S r )r, r; r r r r8 h s zDBusExporter.object_namec C s | j d uS r )r. r; r r r �runningl s zDBusExporter.runningc C sN dj |jd�t|j�j�d�}t|dt| j� d�}t |j d t � |j�}|S )Nz2def {name}({args}): return wrapper({args}) z, )r �argsz<decorator-gen-%d>�execr ) �formatr r r �__func__r= �compile�lenr' r � co_consts�locals)r5 �method�wrapper�source�coder r r r �_prepare_for_dbuso s �z DBusExporter._prepare_for_dbusc sj t � �std��� j}|�jv r(td��� �fdd�}��� |�}tjj�j||dd�|�}|�j|< d S )N�#Only bound methods can be exported.�*Method with this name is already exported.c s �j d � j }|d }t�d||f � �j�||�}|}|dkrXt�d||f � n�|dkrtt�d||f � n�|dkr�t�d ||f � t|d d� �d g }nZ|dkr�t�d ||f � t|d d� �d g }n(t� d ||f � t|d d� �d g }� |i |��S ) N�.���z?checking authorization for action '%s' requested by caller '%s'r zJaction '%s' requested by caller '%s' was successfully authorized by polkit� zepolkit error, but action '%s' requested by caller '%s' was successfully authorized by fallback methodr zLaction '%s' requested by caller '%s' wasn't authorized, ignoring the requestr zppolkit error and action '%s' requested by caller '%s' wasn't authorized by fallback method, ignoring the requestzvpolkit error and unable to use fallback method to authorize action '%s' requested by caller '%s', ignoring the request) r- r r! �debugr0 Zcheck_authorizationZwarning�info�list�error)�ownerr= �kwargsZ action_id�caller�retZ args_copy�rE r5 r r rF � s$ z$DBusExporter.export.<locals>.wrapperrU )Zsender_keyword) r � Exceptionr r' rI r$ r% rE r+ )r5 rE Z in_signature� out_signature� method_namerF r rW r �export} s zDBusExporter.exportc sn t � �std��� j}|| jv r(td��� fdd�}| �� |�}tj�| j|�|�}|| j|< | j � |� d S )NrJ rK c s � |i |��S r r )rS r= rT �rE r r rF � s z$DBusExporter.signal.<locals>.wrapper) r rX r r' rI r$ r% r1 r+ r) �add)r5 rE rY rZ rF r r\ r r1 � s zDBusExporter.signalc O sh d}|| j vs| jd u r d}zt| j|�}W n tyB d}Y n0 |rVtd| ��n||i |�� d S )NFTzSignal '%s' doesn't exist.)r) r/ r �AttributeErrorrX )r5 r1 r= rT �errrE r r r � send_signal� s zDBusExporter.send_signalc C s< | j d urtd��dt| � }t|tjjf| j�}|| _ d S )Nz%The exporter class was already build.zDBusExporter_%d)r& rX �id�typer$ r% ZObjectr' )r5 Z unique_name�clsr r r � _construct_dbus_object_class� s z)DBusExporter._construct_dbus_object_classc C sn | � � r d S | jd u r | �� | �� t�� }tj�| j|�}| �|| j |�| _ t j | j d�| _| j�� d S )N)�target)r< r& rd �stopr$ Z SystemBusr% ZBusNamer* r, r/ � threading�Thread� _thread_coder. �start)r5 Zbusr6 r r r rj � s zDBusExporter.startc C s2 | j d ur.| j �� r.| j�� | j �� d | _ d S r )r. �is_aliver4 �quitr r; r r r rf � s zDBusExporter.stopc C s | j �� | `d | _d S r )r4 �runr/ r; r r r ri � s zDBusExporter._thread_codeN)r r � __qualname__�__doc__r: �propertyr6 r7 r8 r< rI r[ r1 r` rd rj rf ri r r r r r 8 s" " r )"r r Z dbus.servicer$ Zdbus.mainloop.glibZdbus.exceptionsrg r1 Z tuned.logsZtunedZ tuned.constsZconstsr r" �inspectr Ztuned.utils.polkitr Z gi.repositoryr �typesr r Z dbus.lowlevelr r r � ImportErrorZlogs�getr! r ZExporterInterfacer r r r r �<module> s. PK ��Z{7�[C" C" / __pycache__/unix_socket_exporter.cpython-39.pycnu �[��� a �Գf� � @ s� d dl Z d dlZd dlZd dlZddlmZ d dlZd dlm Z d dl m Z d dl Z d dl Z d dlZej�� ZG dd� dej�ZdS )� N� )� interfaces)�ismethodc @ s� e Zd ZdZejejejejej fdd�Z dd� Z dd� Z dd � Z d d � Zd d � Zdd� Zdd� Zdd� Zdd� Zd$dd�Zd%dd�Zd d � Zd d � Zd d!� Zd"d#� ZdS )&�UnixSocketExportera9 Export method calls through Unix Domain Socket Interface. We take a method to be exported and create a simple wrapper function to call it. This is required as we need the original function to be bound to the original object instance. While the wrapper will be bound to an object we dynamically construct. c C s� || _ d | _|| _g | _ddg| _|r�|�� }t|d d� �D ]�\}}zt|�| j|< W q> ty� z2|dkr�t � |�j | j|< nt � |�j| j|< W n0 ty� t�d|dkr�dnd|f � Y n0 Y q>0 q>|| _|| _i | _t� | _d | _d | _d S )N���� r z(%s '%s' does not exists, leaving defaultZUserZGroup)� _socket_path�_socket_object�_socket_signal_pathsZ_socket_signal_objects� _ownership�split� enumerate�int� ValueError�pwd�getpwnam�pw_uid�grp�getgrnam�gr_gid�KeyError�log�error� _permissions�_connections_backlog�_unix_socket_methods�set�_signalsZ_connZ_channel)�selfZ socket_pathZ signal_pathsZ ownershipZ permissionsZconnections_backlog�i�o� r! �F/usr/lib/python3.9/site-packages/tuned/exports/unix_socket_exporter.py�__init__ s. ,zUnixSocketExporter.__init__c C s | j d uS �N)r �r r! r! r" �running; s zUnixSocketExporter.runningc sT t � �std��� j}|| jv r,td| ��G � fdd�dt�}|||�| j|< d S )N�#Only bound methods can be exported.�/Method with this name (%s) is already exported.c s e Zd Zdd� Z� fdd�ZdS )z*UnixSocketExporter.export.<locals>.wrapperc S s || _ || _d S r$ )Z _in_signature�_out_signature)r � in_signature� out_signaturer! r! r" r# G s z3UnixSocketExporter.export.<locals>.wrapper.__init__c s � |i |��S r$ r! �r �args�kwargs��methodr! r" �__call__K s z3UnixSocketExporter.export.<locals>.wrapper.__call__N��__name__� __module__� __qualname__r# r1 r! r/ r! r" �wrapperF s r6 )r � Exceptionr3 r �object)r r0 r* r+ � method_namer6 r! r/ r" �export> s zUnixSocketExporter.exportc s^ t � �std��� j}|| jv r,td| ��G � fdd�dt�}||�| j|< | j�|� d S )Nr' r( c s e Zd Zdd� Z� fdd�ZdS )z*UnixSocketExporter.signal.<locals>.wrapperc S s || _ d S r$ )r) )r r+ r! r! r" r# Y s z3UnixSocketExporter.signal.<locals>.wrapper.__init__c s � |i |��S r$ r! r, r/ r! r" r1 \ s z3UnixSocketExporter.signal.<locals>.wrapper.__call__Nr2 r! r/ r! r" r6 X s r6 )r r7 r3 r r8 r �add)r r0 r+ r9 r6 r! r/ r" �signalP s zUnixSocketExporter.signalc O s� || j vrtd| ��| jD ]�}t�d| � zDt�tjtj�}|�d� |� |� | � |d||d�� |� � W q t y� } z t� d|||f � W Y d }~q d }~0 0 q d S )NzSignal '%s' doesn't exist.zSending signal on socket %sF�2.0)�jsonrpcr0 �paramsz2Error while sending signal '%s' to socket '%s': %s)r r7 r r �debug�socket�AF_UNIX� SOCK_STREAMZ setblockingZconnect� _send_data�close�OSError�warning)r r< r- r. �p�s�er! r! r" � send_signalb s z UnixSocketExporter.send_signalc C s | j �|� d S r$ )r �append)r �pathr! r! r" �register_signal_pathp s z'UnixSocketExporter.register_signal_pathc C s� | j r�tj�| j �r t�| j � t�tjtj�| _| j� | j � | j� | j � t� | j | j d | j d � | jr�t�| j | j� d S )Nr r )r �osrM �exists�unlinkrA rB rC r ZbindZlistenr �chownr r �chmodr% r! r! r" �_construct_socket_objects s z+UnixSocketExporter._construct_socket_objectc C s | � � r d S | �� | �� d S r$ )r& �stoprT r% r! r! r" �start~ s zUnixSocketExporter.startc C s | j r| j �� d S r$ )r rE r% r! r! r" rU � s zUnixSocketExporter.stopc C sd t �d| � z|�t�|��d�� W n6 ty^ } z t �d||f � W Y d }~n d }~0 0 d S )NzSending socket data: %s)zutf-8z Failed to send data '%s': %s)r r@ �send�json�dumps�encoder7 rG )r rI �datarJ r! r! r" rD � s z UnixSocketExporter._send_dataFc C s$ d|d�}|r||d< n||d< |S )Nr= )r> �idr �resultr! )r r[ r\ r �resr! r! r" �_create_response� s � z#UnixSocketExporter._create_responseNc C s | j |||d�d|d�S )N)�code�messager[ T)r r\ �r_ )r r` ra r\ r[ r! r! r" �_create_error_responce� s ��z)UnixSocketExporter._create_error_responcec C s | � ||�S r$ rb )r r] r\ r! r! r" �_create_result_response� s z*UnixSocketExporter._create_result_responsec C s |� d�r|S d S )Nr\ )�get)r r[ r! r! r" � _check_id� s z UnixSocketExporter._check_idc C s� t |�tks$|�d�dks$|�d�s0| �dd�S |�d�}d }|d | jvr`| �| �dd|��S z�|�d �s~| j|d � }npt |d �ttfv r�| j|d |d � }nDt |d �tkr�| j|d f i |d ��}n| �| �dd|��W S W n~ t�y0 } z&| �| �d d |t |���W Y d }~S d }~0 t �yn } z&| �| �d d |t |���W Y d }~S d }~0 0 | �| � ||��S )Nr> r= r0 騀���Invalid Requestr\ i����zMethod not foundr? i����zInvalid paramsr �Error) �type�dictre rc r rf �list�tuple� TypeError�strr7 rd )r �reqr\ �retrJ r! r! r" �_process_request� s& $ .0z#UnixSocketExporter._process_requestc C s� | � � s dS t�| jgddd�\}}}|�r�| j�� \}}z&d}|�d��� }|sTq^||7 }q@W n> ty� } z&t�d| � W Y d}~q W Y d}~n d}~0 0 |�r�zt � |�}W n^ t�y } zDt�d||f � | � || � dd t |��� W Y d}~q W Y d}~n d}~0 0 t|�tttfv�rNt�d � | � || � dd t |��� q t|�ttfv �r�t|�dk�r�| � || � d d t |��� q g }|D ] }| �|�}|�r�|�|� �q�|�r�| � ||� n | �|�}|�r�| � ||� q dS q dS ) a� Periodically checks socket object for new calls. This allows to function without special thread. Interface is according JSON-RPC 2.0 Specification (see https://www.jsonrpc.org/specification) Example calls: printf '[{"jsonrpc": "2.0", "method": "active_profile", "id": 1}, {"jsonrpc": "2.0", "method": "profiles", "id": 2}]' | nc -U /run/tuned/tuned.sock printf '{"jsonrpc": "2.0", "method": "switch_profile", "params": {"profile_name": "balanced"}, "id": 1}' | nc -U /run/tuned/tuned.sock Nr! r � i z"Failed to load data of message: %sz!Failed to load json data '%s': %siD���z Parse errorzWrong format of callrg rh )r& �selectr ZacceptZrecv�decoder7 r r rX �loadsrD rc ro rj rm rl rk �lenrr rL ) r �r�_Zconnr[ Zrec_datarJ r^ rp r! r! r" � period_check� sP "" z UnixSocketExporter.period_check)F)NN)r3 r4 r5 �__doc__�constsZCFG_DEF_UNIX_SOCKET_PATHZ CFG_DEF_UNIX_SOCKET_SIGNAL_PATHSZ CFG_DEF_UNIX_SOCKET_OWNERSHIPZ CFG_DEF_UNIX_SOCKET_PERMISIONSZ'CFG_DEF_UNIX_SOCKET_CONNECTIONS_BACKLOGr# r& r: r< rK rN rT rV rU rD r_ rc rd rf rr rz r! r! r! r" r s, � " r )rO �rer r rs r Z tuned.logsZtunedZ tuned.constsr| �inspectr rA rX rt Zlogsre r ZExporterInterfacer r! r! r! r" �<module> s PK ��ZJq�SB B % __pycache__/interfaces.cpython-39.pycnu �[��� a �ԳfL � @ s$ G d d� de �ZG dd� de �ZdS )c @ s e Zd ZdS )�ExportableInterfaceN)�__name__� __module__� __qualname__� r r �</usr/lib/python3.9/site-packages/tuned/exports/interfaces.pyr s r c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�ExporterInterfacec C s t � �d S �N��NotImplementedError)�self�methodZ in_signature� out_signaturer r r �export s zExporterInterface.exportc C s t � �d S r r )r r r r r r �signal s zExporterInterface.signalc O s t � �d S r r )r r �args�kwargsr r r � send_signal s z ExporterInterface.send_signalc C s t � �d S r r �r r r r �start s zExporterInterface.startc C s t � �d S r r r r r r �stop s zExporterInterface.stopc C s d S r r r r r r � period_check s z ExporterInterface.period_checkN) r r r r r r r r r r r r r r s r N)�objectr r r r r r �<module> s PK ��Z�#� # __pycache__/__init__.cpython-39.pycnu �[��� a �Գfq � @ s� d dl mZ d dl mZ d dl mZ d dl mZ d dl mZ dd� Z dd � Z d d � Z d d � Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd S ) � )� interfaces)� controller)� dbus_exporter)� dbus_exporter_with_properties)�unix_socket_exporterc s � �fdd�}|S )z*Decorator, use to mark exportable methods.c s � �g| _ | S �N)Z export_params��method��args�kwargs� �:/usr/lib/python3.9/site-packages/tuned/exports/__init__.py�wrapper s zexport.<locals>.wrapperr �r r r r r r �export s r c s � �fdd�}|S )z*Decorator, use to mark exportable signals.c s � �g| _ | S r )Z signal_paramsr r r r r s zsignal.<locals>.wrapperr r r r r �signal s r c s � �fdd�}|S )z8Decorator, use to mark setters of exportable properties.c s � �g| _ | S r )Zproperty_set_paramsr r r r r s z property_setter.<locals>.wrapperr r r r r �property_setter s r c s � �fdd�}|S )z8Decorator, use to mark getters of exportable properties.c s � �g| _ | S r )Zproperty_get_paramsr r r r r s z property_getter.<locals>.wrapperr r r r r �property_getter s r c O s t j�� }|j| i |��S r )r �ExportsController� get_instance�property_changed�r r �ctlr r r r # s r c C s& t | tj�st� �tj�� }|�| �S r )� isinstancer ZExporterInterface� Exceptionr r r �register_exporter��instancer r r r r ' s r c C s& t | tj�st� �tj�� }|�| �S r )r r ZExportableInterfacer r r r �register_objectr r r r r - s r c O s t j�� }|j| i |��S r )r r r � send_signalr r r r r 3 s r c C s t j�� } | �� S r )r r r �start�r r r r r! 7 s r! c C s t j�� } | �� S r )r r r �stopr" r r r r# ; s r# c C s t j�� } | �� S r )r r r � period_checkr" r r r r$ ? s r$ N)� r r r Zdbusr Zdbus_with_propertiesr Z unix_socketr r r r r r r r r! r# r$ r r r r �<module> s PK ��Z{7�[C" C" 5 __pycache__/unix_socket_exporter.cpython-39.opt-1.pycnu �[��� a �Գf� � @ s� d dl Z d dlZd dlZd dlZddlmZ d dlZd dlm Z d dl m Z d dl Z d dl Z d dlZej�� ZG dd� dej�ZdS )� N� )� interfaces)�ismethodc @ s� e Zd ZdZejejejejej fdd�Z dd� Z dd� Z dd � Z d d � Zd d � Zdd� Zdd� Zdd� Zdd� Zd$dd�Zd%dd�Zd d � Zd d � Zd d!� Zd"d#� ZdS )&�UnixSocketExportera9 Export method calls through Unix Domain Socket Interface. We take a method to be exported and create a simple wrapper function to call it. This is required as we need the original function to be bound to the original object instance. While the wrapper will be bound to an object we dynamically construct. c C s� || _ d | _|| _g | _ddg| _|r�|�� }t|d d� �D ]�\}}zt|�| j|< W q> ty� z2|dkr�t � |�j | j|< nt � |�j| j|< W n0 ty� t�d|dkr�dnd|f � Y n0 Y q>0 q>|| _|| _i | _t� | _d | _d | _d S )N���� r z(%s '%s' does not exists, leaving defaultZUserZGroup)� _socket_path�_socket_object�_socket_signal_pathsZ_socket_signal_objects� _ownership�split� enumerate�int� ValueError�pwd�getpwnam�pw_uid�grp�getgrnam�gr_gid�KeyError�log�error� _permissions�_connections_backlog�_unix_socket_methods�set�_signalsZ_connZ_channel)�selfZ socket_pathZ signal_pathsZ ownershipZ permissionsZconnections_backlog�i�o� r! �F/usr/lib/python3.9/site-packages/tuned/exports/unix_socket_exporter.py�__init__ s. ,zUnixSocketExporter.__init__c C s | j d uS �N)r �r r! r! r" �running; s zUnixSocketExporter.runningc sT t � �std��� j}|| jv r,td| ��G � fdd�dt�}|||�| j|< d S )N�#Only bound methods can be exported.�/Method with this name (%s) is already exported.c s e Zd Zdd� Z� fdd�ZdS )z*UnixSocketExporter.export.<locals>.wrapperc S s || _ || _d S r$ )Z _in_signature�_out_signature)r � in_signature� out_signaturer! r! r" r# G s z3UnixSocketExporter.export.<locals>.wrapper.__init__c s � |i |��S r$ r! �r �args�kwargs��methodr! r" �__call__K s z3UnixSocketExporter.export.<locals>.wrapper.__call__N��__name__� __module__� __qualname__r# r1 r! r/ r! r" �wrapperF s r6 )r � Exceptionr3 r �object)r r0 r* r+ � method_namer6 r! r/ r" �export> s zUnixSocketExporter.exportc s^ t � �std��� j}|| jv r,td| ��G � fdd�dt�}||�| j|< | j�|� d S )Nr' r( c s e Zd Zdd� Z� fdd�ZdS )z*UnixSocketExporter.signal.<locals>.wrapperc S s || _ d S r$ )r) )r r+ r! r! r" r# Y s z3UnixSocketExporter.signal.<locals>.wrapper.__init__c s � |i |��S r$ r! r, r/ r! r" r1 \ s z3UnixSocketExporter.signal.<locals>.wrapper.__call__Nr2 r! r/ r! r" r6 X s r6 )r r7 r3 r r8 r �add)r r0 r+ r9 r6 r! r/ r" �signalP s zUnixSocketExporter.signalc O s� || j vrtd| ��| jD ]�}t�d| � zDt�tjtj�}|�d� |� |� | � |d||d�� |� � W q t y� } z t� d|||f � W Y d }~q d }~0 0 q d S )NzSignal '%s' doesn't exist.zSending signal on socket %sF�2.0)�jsonrpcr0 �paramsz2Error while sending signal '%s' to socket '%s': %s)r r7 r r �debug�socket�AF_UNIX� SOCK_STREAMZ setblockingZconnect� _send_data�close�OSError�warning)r r< r- r. �p�s�er! r! r" � send_signalb s z UnixSocketExporter.send_signalc C s | j �|� d S r$ )r �append)r �pathr! r! r" �register_signal_pathp s z'UnixSocketExporter.register_signal_pathc C s� | j r�tj�| j �r t�| j � t�tjtj�| _| j� | j � | j� | j � t� | j | j d | j d � | jr�t�| j | j� d S )Nr r )r �osrM �exists�unlinkrA rB rC r ZbindZlistenr �chownr r �chmodr% r! r! r" �_construct_socket_objects s z+UnixSocketExporter._construct_socket_objectc C s | � � r d S | �� | �� d S r$ )r& �stoprT r% r! r! r" �start~ s zUnixSocketExporter.startc C s | j r| j �� d S r$ )r rE r% r! r! r" rU � s zUnixSocketExporter.stopc C sd t �d| � z|�t�|��d�� W n6 ty^ } z t �d||f � W Y d }~n d }~0 0 d S )NzSending socket data: %s)zutf-8z Failed to send data '%s': %s)r r@ �send�json�dumps�encoder7 rG )r rI �datarJ r! r! r" rD � s z UnixSocketExporter._send_dataFc C s$ d|d�}|r||d< n||d< |S )Nr= )r> �idr �resultr! )r r[ r\ r �resr! r! r" �_create_response� s � z#UnixSocketExporter._create_responseNc C s | j |||d�d|d�S )N)�code�messager[ T)r r\ �r_ )r r` ra r\ r[ r! r! r" �_create_error_responce� s ��z)UnixSocketExporter._create_error_responcec C s | � ||�S r$ rb )r r] r\ r! r! r" �_create_result_response� s z*UnixSocketExporter._create_result_responsec C s |� d�r|S d S )Nr\ )�get)r r[ r! r! r" � _check_id� s z UnixSocketExporter._check_idc C s� t |�tks$|�d�dks$|�d�s0| �dd�S |�d�}d }|d | jvr`| �| �dd|��S z�|�d �s~| j|d � }npt |d �ttfv r�| j|d |d � }nDt |d �tkr�| j|d f i |d ��}n| �| �dd|��W S W n~ t�y0 } z&| �| �d d |t |���W Y d }~S d }~0 t �yn } z&| �| �d d |t |���W Y d }~S d }~0 0 | �| � ||��S )Nr> r= r0 騀���Invalid Requestr\ i����zMethod not foundr? i����zInvalid paramsr �Error) �type�dictre rc r rf �list�tuple� TypeError�strr7 rd )r �reqr\ �retrJ r! r! r" �_process_request� s& $ .0z#UnixSocketExporter._process_requestc C s� | � � s dS t�| jgddd�\}}}|�r�| j�� \}}z&d}|�d��� }|sTq^||7 }q@W n> ty� } z&t�d| � W Y d}~q W Y d}~n d}~0 0 |�r�zt � |�}W n^ t�y } zDt�d||f � | � || � dd t |��� W Y d}~q W Y d}~n d}~0 0 t|�tttfv�rNt�d � | � || � dd t |��� q t|�ttfv �r�t|�dk�r�| � || � d d t |��� q g }|D ] }| �|�}|�r�|�|� �q�|�r�| � ||� n | �|�}|�r�| � ||� q dS q dS ) a� Periodically checks socket object for new calls. This allows to function without special thread. Interface is according JSON-RPC 2.0 Specification (see https://www.jsonrpc.org/specification) Example calls: printf '[{"jsonrpc": "2.0", "method": "active_profile", "id": 1}, {"jsonrpc": "2.0", "method": "profiles", "id": 2}]' | nc -U /run/tuned/tuned.sock printf '{"jsonrpc": "2.0", "method": "switch_profile", "params": {"profile_name": "balanced"}, "id": 1}' | nc -U /run/tuned/tuned.sock Nr! r � i z"Failed to load data of message: %sz!Failed to load json data '%s': %siD���z Parse errorzWrong format of callrg rh )r& �selectr ZacceptZrecv�decoder7 r r rX �loadsrD rc ro rj rm rl rk �lenrr rL ) r �r�_Zconnr[ Zrec_datarJ r^ rp r! r! r" � period_check� sP "" z UnixSocketExporter.period_check)F)NN)r3 r4 r5 �__doc__�constsZCFG_DEF_UNIX_SOCKET_PATHZ CFG_DEF_UNIX_SOCKET_SIGNAL_PATHSZ CFG_DEF_UNIX_SOCKET_OWNERSHIPZ CFG_DEF_UNIX_SOCKET_PERMISIONSZ'CFG_DEF_UNIX_SOCKET_CONNECTIONS_BACKLOGr# r& r: r< rK rN rT rV rU rD r_ rc rd rf rr rz r! r! r! r" r s, � " r )rO �rer r rs r Z tuned.logsZtunedZ tuned.constsr| �inspectr rA rX rt Zlogsre r ZExporterInterfacer r! r! r! r" �<module> s PK ��Z�#� ) __pycache__/__init__.cpython-39.opt-1.pycnu �[��� a �Գfq � @ s� d dl mZ d dl mZ d dl mZ d dl mZ d dl mZ dd� Z dd � Z d d � Z d d � Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd S ) � )� interfaces)� controller)� dbus_exporter)� dbus_exporter_with_properties)�unix_socket_exporterc s � �fdd�}|S )z*Decorator, use to mark exportable methods.c s � �g| _ | S �N)Z export_params��method��args�kwargs� �:/usr/lib/python3.9/site-packages/tuned/exports/__init__.py�wrapper s zexport.<locals>.wrapperr �r r r r r r �export s r c s � �fdd�}|S )z*Decorator, use to mark exportable signals.c s � �g| _ | S r )Z signal_paramsr r r r r s zsignal.<locals>.wrapperr r r r r �signal s r c s � �fdd�}|S )z8Decorator, use to mark setters of exportable properties.c s � �g| _ | S r )Zproperty_set_paramsr r r r r s z property_setter.<locals>.wrapperr r r r r �property_setter s r c s � �fdd�}|S )z8Decorator, use to mark getters of exportable properties.c s � �g| _ | S r )Zproperty_get_paramsr r r r r s z property_getter.<locals>.wrapperr r r r r �property_getter s r c O s t j�� }|j| i |��S r )r �ExportsController� get_instance�property_changed�r r �ctlr r r r # s r c C s& t | tj�st� �tj�� }|�| �S r )� isinstancer ZExporterInterface� Exceptionr r r �register_exporter��instancer r r r r ' s r c C s& t | tj�st� �tj�� }|�| �S r )r r ZExportableInterfacer r r r �register_objectr r r r r - s r c O s t j�� }|j| i |��S r )r r r � send_signalr r r r r 3 s r c C s t j�� } | �� S r )r r r �start�r r r r r! 7 s r! c C s t j�� } | �� S r )r r r �stopr" r r r r# ; s r# c C s t j�� } | �� S r )r r r � period_checkr" r r r r$ ? s r$ N)� r r r Zdbusr Zdbus_with_propertiesr Z unix_socketr r r r r r r r r! r# r$ r r r r �<module> s PK ��Z���:� � . __pycache__/dbus_exporter.cpython-39.opt-1.pycnu �[��� a �ԳfU � @ s d dl mZ ddlZddlZddlZddlZddlZddlZ ddl m Z ddl Z ddl Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ zdd lmZ d d � ZW n ey� dd lmZ Y n0 e j � � Z dd� Z G dd� dej �Z!dS )� )� interfaces� N)�ismethod)�polkit)�GLib)� FunctionType)� DBusException)� ErrorMessage��getfullargspecc C s t | �S �Nr )�func� r �?/usr/lib/python3.9/site-packages/tuned/exports/dbus_exporter.py� getargspec s r )r c C s� t |dd �}|d urn0t |dd�dv r4d|jj }nd|j|jjf }t|t�rZ|�� }nd�t� |j|��}t |||�}|� � s�| � |� d S )NZ_dbus_error_name� __module__� )r �__main__z org.freedesktop.DBus.Python.%sz!org.freedesktop.DBus.Python.%s.%s) �getattr� __class__�__name__r � isinstancer Zget_dbus_message�join� traceback�format_exception_onlyr Z get_no_replyZ send_message)Z connection�message� exception�name�contentsZreplyr r r �_method_reply_error$ s � r c @ s� e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd S ) � DBusExportera+ Export method calls through DBus Interface. We take a method to be exported and create a simple wrapper function to call it. This is required as we need the original function to be bound to the original object instance. While the wrapper will be bound to an object we dynamically construct. c C s� t �� tjkrttj_tjjj dd� d | _ d | _ i | _ t � | _|| _|| _|| _|| _d | _d | _t� | _t�tj�}t�� | _ t�tj|� d S )NT)Zset_as_default) �logZgetEffectiveLevel�logging�DEBUGr �dbus�serviceZmainloopZglibZ DBusGMainLoop�_dbus_object_clsZ _dbus_object� _dbus_methods�set�_signals� _bus_name�_interface_name� _object_name� _namespace�_thread� _bus_objectr �_polkit�signal� getsignal�SIGINTr ZMainLoop� _main_loop)�self�bus_name�interface_name� object_name� namespaceZsignal_handlerr r r �__init__B s" zDBusExporter.__init__c C s | j S r )r* �r5 r r r r6 ` s zDBusExporter.bus_namec C s | j S r )r+ r; r r r r7 d s zDBusExporter.interface_namec C s | j S r )r, r; r r r r8 h s zDBusExporter.object_namec C s | j d uS r )r. r; r r r �runningl s zDBusExporter.runningc C sN dj |jd�t|j�j�d�}t|dt| j� d�}t |j d t � |j�}|S )Nz2def {name}({args}): return wrapper({args}) z, )r �argsz<decorator-gen-%d>�execr ) �formatr r r �__func__r= �compile�lenr' r � co_consts�locals)r5 �method�wrapper�source�coder r r r �_prepare_for_dbuso s �z DBusExporter._prepare_for_dbusc sj t � �std��� j}|�jv r(td��� �fdd�}��� |�}tjj�j||dd�|�}|�j|< d S )N�#Only bound methods can be exported.�*Method with this name is already exported.c s �j d � j }|d }t�d||f � �j�||�}|}|dkrXt�d||f � n�|dkrtt�d||f � n�|dkr�t�d ||f � t|d d� �d g }nZ|dkr�t�d ||f � t|d d� �d g }n(t� d ||f � t|d d� �d g }� |i |��S ) N�.���z?checking authorization for action '%s' requested by caller '%s'r zJaction '%s' requested by caller '%s' was successfully authorized by polkit� zepolkit error, but action '%s' requested by caller '%s' was successfully authorized by fallback methodr zLaction '%s' requested by caller '%s' wasn't authorized, ignoring the requestr zppolkit error and action '%s' requested by caller '%s' wasn't authorized by fallback method, ignoring the requestzvpolkit error and unable to use fallback method to authorize action '%s' requested by caller '%s', ignoring the request) r- r r! �debugr0 Zcheck_authorizationZwarning�info�list�error)�ownerr= �kwargsZ action_id�caller�retZ args_copy�rE r5 r r rF � s$ z$DBusExporter.export.<locals>.wrapperrU )Zsender_keyword) r � Exceptionr r' rI r$ r% rE r+ )r5 rE Z in_signature� out_signature� method_namerF r rW r �export} s zDBusExporter.exportc sn t � �std��� j}|| jv r(td��� fdd�}| �� |�}tj�| j|�|�}|| j|< | j � |� d S )NrJ rK c s � |i |��S r r )rS r= rT �rE r r rF � s z$DBusExporter.signal.<locals>.wrapper) r rX r r' rI r$ r% r1 r+ r) �add)r5 rE rY rZ rF r r\ r r1 � s zDBusExporter.signalc O sh d}|| j vs| jd u r d}zt| j|�}W n tyB d}Y n0 |rVtd| ��n||i |�� d S )NFTzSignal '%s' doesn't exist.)r) r/ r �AttributeErrorrX )r5 r1 r= rT �errrE r r r � send_signal� s zDBusExporter.send_signalc C s< | j d urtd��dt| � }t|tjjf| j�}|| _ d S )Nz%The exporter class was already build.zDBusExporter_%d)r& rX �id�typer$ r% ZObjectr' )r5 Z unique_name�clsr r r � _construct_dbus_object_class� s z)DBusExporter._construct_dbus_object_classc C sn | � � r d S | jd u r | �� | �� t�� }tj�| j|�}| �|| j |�| _ t j | j d�| _| j�� d S )N)�target)r< r& rd �stopr$ Z SystemBusr% ZBusNamer* r, r/ � threading�Thread� _thread_coder. �start)r5 Zbusr6 r r r rj � s zDBusExporter.startc C s2 | j d ur.| j �� r.| j�� | j �� d | _ d S r )r. �is_aliver4 �quitr r; r r r rf � s zDBusExporter.stopc C s | j �� | `d | _d S r )r4 �runr/ r; r r r ri � s zDBusExporter._thread_codeN)r r � __qualname__�__doc__r: �propertyr6 r7 r8 r< rI r[ r1 r` rd rj rf ri r r r r r 8 s" " r )"r r Z dbus.servicer$ Zdbus.mainloop.glibZdbus.exceptionsrg r1 Z tuned.logsZtunedZ tuned.constsZconstsr r" �inspectr Ztuned.utils.polkitr Z gi.repositoryr �typesr r Z dbus.lowlevelr r r � ImportErrorZlogs�getr! r ZExporterInterfacer r r r r �<module> s. PK ��Z�.� � 8 __pycache__/dbus_exporter_with_properties.cpython-39.pycnu �[��� a �Գf* � @ sT d dl mZ d dlmZmZ d dlmZ d dlmZ d dl m Z G dd� de �Z dS ) � )�ismethod)�method�signal)�PROPERTIES_IFACE)� DBusException)� DBusExporterc s4 e Zd Z� fdd�Zdd� Zdd� Zdd� Z� ZS ) �DBusExporterWithPropertiesc s� t t� ��||||� i � _i � _� fdd�}� fdd�}� fdd�}� fdd�}ttd d d �|�� jd < ttd d�|�� jd< ttddd �|�� jd< ttdd�|�� jd< � j � d� d S )Nc s< |� j krtd| ��|� jvr,td| ��� j| }|� S �N�Unknown interface: %szNo such property: %s)�_interface_namer �_property_getters)�_�interface_name� property_name�getter��self� �O/usr/lib/python3.9/site-packages/tuned/exports/dbus_exporter_with_properties.py�Get s z0DBusExporterWithProperties.__init__.<locals>.Getc sB |� j krtd| ��|� jvr,td| ��� j| }||� d S r )r r �_property_setters)r r r �value�setterr r r �Set s z0DBusExporterWithProperties.__init__.<locals>.Setc s* |� j krtd| ��dd� � j�� D �S )Nr c S s i | ]\}}||� �qS r r )�.0�namer r r r � <dictcomp>! � zGDBusExporterWithProperties.__init__.<locals>.GetAll.<locals>.<dictcomp>)r r r �items)r r r r r �GetAll s z3DBusExporterWithProperties.__init__.<locals>.GetAllc s |� j krtd| ��d S )Nr )r r )r r Zchanged_propertiesZinvalidated_propertiesr r r �PropertiesChanged# s z>DBusExporterWithProperties.__init__.<locals>.PropertiesChanged�ss�v)� in_signatureZ out_signaturer Zssv)r# r �sza{sv}r zsa{sv}as)Z signaturer ) �superr �__init__r r r r Z _dbus_methodsr Z_signals�add) r Zbus_namer Z object_name� namespacer r r r �� __class__r r r& s z#DBusExporterWithProperties.__init__c C s | � d| j||ii � d S )Nr )Z send_signalr )r r r r r r �property_changed- s z+DBusExporterWithProperties.property_changedc C s0 t |�std��|| jv r"td��|| j|< d S )N�#Only bound methods can be exported.z1A getter for this property is already registered.)r � Exceptionr �r r r r r r �property_getter0 s z*DBusExporterWithProperties.property_getterc C s0 t |�std��|| jv r"td��|| j|< d S )Nr, z1A setter for this property is already registered.)r r- r r. r r r �property_setter7 s z*DBusExporterWithProperties.property_setter)�__name__� __module__� __qualname__r& r+ r/ r0 � __classcell__r r r) r r s $r N) �inspectr Z dbus.servicer r Zdbusr Zdbus.exceptionsr Ztuned.exports.dbus_exporterr r r r r r �<module> s PK ��Z���U U dbus_exporter.pynu �[��� from . import interfaces import dbus.service import dbus.mainloop.glib import dbus.exceptions import threading import signal import tuned.logs import tuned.consts as consts import traceback import logging from inspect import ismethod from tuned.utils.polkit import polkit from gi.repository import GLib from types import FunctionType from dbus.exceptions import DBusException from dbus.lowlevel import ErrorMessage try: # Python3 version # getfullargspec is not present in Python2, so when we drop P2 support # replace "getargspec(func)" in code with "getfullargspec(func).args" from inspect import getfullargspec def getargspec(func): return getfullargspec(func) except ImportError: # Python2 version, drop after support stops from inspect import getargspec log = tuned.logs.get() # This is mostly copy of the code from the dbus.service module without the # code that sends tracebacks through the D-Bus (i.e. no library tracebacks # are exposed on the D-Bus now). def _method_reply_error(connection, message, exception): name = getattr(exception, '_dbus_error_name', None) if name is not None: pass elif getattr(exception, '__module__', '') in ('', '__main__'): name = 'org.freedesktop.DBus.Python.%s' % exception.__class__.__name__ else: name = 'org.freedesktop.DBus.Python.%s.%s' % (exception.__module__, exception.__class__.__name__) if isinstance(exception, DBusException): contents = exception.get_dbus_message() else: contents = ''.join(traceback.format_exception_only(exception.__class__, exception)) reply = ErrorMessage(message, name, contents) if not message.get_no_reply(): connection.send_message(reply) class DBusExporter(interfaces.ExporterInterface): """ Export method calls through DBus Interface. We take a method to be exported and create a simple wrapper function to call it. This is required as we need the original function to be bound to the original object instance. While the wrapper will be bound to an object we dynamically construct. """ def __init__(self, bus_name, interface_name, object_name, namespace): # Monkey patching of the D-Bus library _method_reply_error() to reply # tracebacks via D-Bus only if in the debug mode. It doesn't seem there is a # more simple way how to cover all possible exceptions that could occur in # the D-Bus library. Just setting the exception.include_traceback to False doesn't # seem to help because there is only a subset of exceptions that support this flag. if log.getEffectiveLevel() != logging.DEBUG: dbus.service._method_reply_error = _method_reply_error dbus.mainloop.glib.DBusGMainLoop(set_as_default=True) self._dbus_object_cls = None self._dbus_object = None self._dbus_methods = {} self._signals = set() self._bus_name = bus_name self._interface_name = interface_name self._object_name = object_name self._namespace = namespace self._thread = None self._bus_object = None self._polkit = polkit() # dirty hack that fixes KeyboardInterrupt handling # the hack is needed because PyGObject / GTK+-3 developers are morons signal_handler = signal.getsignal(signal.SIGINT) self._main_loop = GLib.MainLoop() signal.signal(signal.SIGINT, signal_handler) @property def bus_name(self): return self._bus_name @property def interface_name(self): return self._interface_name @property def object_name(self): return self._object_name def running(self): return self._thread is not None def _prepare_for_dbus(self, method, wrapper): source = """def {name}({args}): return wrapper({args}) """.format(name=method.__name__, args=', '.join(getargspec(method.__func__).args)) code = compile(source, '<decorator-gen-%d>' % len(self._dbus_methods), 'exec') # https://docs.python.org/3.9/library/inspect.html # co_consts - tuple of constants used in the bytecode # example: # compile("e=2\ndef f(x):\n return x*2\n", "X", 'exec').co_consts # (2, <code object f at 0x7f8c60c65330, file "X", line 2>, None) # Because we have only one object in code (our function), we can use code.co_consts[0] func = FunctionType(code.co_consts[0], locals(), method.__name__) return func def export(self, method, in_signature, out_signature): if not ismethod(method): raise Exception("Only bound methods can be exported.") method_name = method.__name__ if method_name in self._dbus_methods: raise Exception("Method with this name is already exported.") def wrapper(owner, *args, **kwargs): action_id = self._namespace + "." + method.__name__ caller = args[-1] log.debug("checking authorization for action '%s' requested by caller '%s'" % (action_id, caller)) ret = self._polkit.check_authorization(caller, action_id) args_copy = args if ret == 1: log.debug("action '%s' requested by caller '%s' was successfully authorized by polkit" % (action_id, caller)) elif ret == 2: log.warning("polkit error, but action '%s' requested by caller '%s' was successfully authorized by fallback method" % (action_id, caller)) elif ret == 0: log.info("action '%s' requested by caller '%s' wasn't authorized, ignoring the request" % (action_id, caller)) args_copy = list(args[:-1]) + [""] elif ret == -1: log.warning("polkit error and action '%s' requested by caller '%s' wasn't authorized by fallback method, ignoring the request" % (action_id, caller)) args_copy = list(args[:-1]) + [""] else: log.error("polkit error and unable to use fallback method to authorize action '%s' requested by caller '%s', ignoring the request" % (action_id, caller)) args_copy = list(args[:-1]) + [""] return method(*args_copy, **kwargs) wrapper = self._prepare_for_dbus(method, wrapper) wrapper = dbus.service.method(self._interface_name, in_signature, out_signature, sender_keyword = "caller")(wrapper) self._dbus_methods[method_name] = wrapper def signal(self, method, out_signature): if not ismethod(method): raise Exception("Only bound methods can be exported.") method_name = method.__name__ if method_name in self._dbus_methods: raise Exception("Method with this name is already exported.") def wrapper(owner, *args, **kwargs): return method(*args, **kwargs) wrapper = self._prepare_for_dbus(method, wrapper) wrapper = dbus.service.signal(self._interface_name, out_signature)(wrapper) self._dbus_methods[method_name] = wrapper self._signals.add(method_name) def send_signal(self, signal, *args, **kwargs): err = False if not signal in self._signals or self._bus_object is None: err = True try: method = getattr(self._bus_object, signal) except AttributeError: err = True if err: raise Exception("Signal '%s' doesn't exist." % signal) else: method(*args, **kwargs) def _construct_dbus_object_class(self): if self._dbus_object_cls is not None: raise Exception("The exporter class was already build.") unique_name = "DBusExporter_%d" % id(self) cls = type(unique_name, (dbus.service.Object,), self._dbus_methods) self._dbus_object_cls = cls def start(self): if self.running(): return if self._dbus_object_cls is None: self._construct_dbus_object_class() self.stop() bus = dbus.SystemBus() bus_name = dbus.service.BusName(self._bus_name, bus) self._bus_object = self._dbus_object_cls(bus, self._object_name, bus_name) self._thread = threading.Thread(target=self._thread_code) self._thread.start() def stop(self): if self._thread is not None and self._thread.is_alive(): self._main_loop.quit() self._thread.join() self._thread = None def _thread_code(self): self._main_loop.run() del self._bus_object self._bus_object = None PK ��ZN2�� � controller.pynu �[��� from . import interfaces import inspect import tuned.patterns class ExportsController(tuned.patterns.Singleton): """ Controls and manages object interface exporting. """ def __init__(self): super(ExportsController, self).__init__() self._exporters = [] self._objects = [] self._exports_initialized = False def register_exporter(self, instance): """Register objects exporter.""" self._exporters.append(instance) def register_object(self, instance): """Register object to be exported.""" self._objects.append(instance) def _is_exportable_method(self, method): """Check if method was marked with @exports.export wrapper.""" return inspect.ismethod(method) and hasattr(method, "export_params") def _is_exportable_signal(self, method): """Check if method was marked with @exports.signal wrapper.""" return inspect.ismethod(method) and hasattr(method, "signal_params") def _is_exportable_getter(self, method): """Check if method was marked with @exports.get_property wrapper.""" return inspect.ismethod(method) and hasattr(method, "property_get_params") def _is_exportable_setter(self, method): """Check if method was marked with @exports.set_property wrapper.""" return inspect.ismethod(method) and hasattr(method, "property_set_params") def _export_method(self, method): """Register method to all exporters.""" for exporter in self._exporters: args = method.export_params[0] kwargs = method.export_params[1] exporter.export(method, *args, **kwargs) def _export_signal(self, method): """Register signal to all exporters.""" for exporter in self._exporters: args = method.signal_params[0] kwargs = method.signal_params[1] exporter.signal(method, *args, **kwargs) def _export_getter(self, method): """Register property getter to all exporters.""" for exporter in self._exporters: args = method.property_get_params[0] kwargs = method.property_get_params[1] exporter.property_getter(method, *args, **kwargs) def _export_setter(self, method): """Register property setter to all exporters.""" for exporter in self._exporters: args = method.property_set_params[0] kwargs = method.property_set_params[1] exporter.property_setter(method, *args, **kwargs) def send_signal(self, signal, *args, **kwargs): """Register signal to all exporters.""" for exporter in self._exporters: exporter.send_signal(signal, *args, **kwargs) def property_changed(self, *args, **kwargs): for exporter in self._exporters: exporter.property_changed(*args, **kwargs) def period_check(self): """Allows to perform checks on exporters without special thread.""" for exporter in self._exporters: exporter.period_check() def _initialize_exports(self): if self._exports_initialized: return for instance in self._objects: for name, method in inspect.getmembers(instance, self._is_exportable_method): self._export_method(method) for name, method in inspect.getmembers(instance, self._is_exportable_signal): self._export_signal(method) for name, method in inspect.getmembers(instance, self._is_exportable_getter): self._export_getter(method) for name, method in inspect.getmembers(instance, self._is_exportable_setter): self._export_setter(method) self._exports_initialized = True def start(self): """Start the exports.""" self._initialize_exports() for exporter in self._exporters: exporter.start() def stop(self): """Stop the exports.""" for exporter in self._exporters: exporter.stop() PK ��Z 'M * * dbus_exporter_with_properties.pynu �[��� from inspect import ismethod from dbus.service import method, signal from dbus import PROPERTIES_IFACE from dbus.exceptions import DBusException from tuned.exports.dbus_exporter import DBusExporter class DBusExporterWithProperties(DBusExporter): def __init__(self, bus_name, interface_name, object_name, namespace): super(DBusExporterWithProperties, self).__init__(bus_name, interface_name, object_name, namespace) self._property_setters = {} self._property_getters = {} def Get(_, interface_name, property_name): if interface_name != self._interface_name: raise DBusException("Unknown interface: %s" % interface_name) if property_name not in self._property_getters: raise DBusException("No such property: %s" % property_name) getter = self._property_getters[property_name] return getter() def Set(_, interface_name, property_name, value): if interface_name != self._interface_name: raise DBusException("Unknown interface: %s" % interface_name) if property_name not in self._property_setters: raise DBusException("No such property: %s" % property_name) setter = self._property_setters[property_name] setter(value) def GetAll(_, interface_name): if interface_name != self._interface_name: raise DBusException("Unknown interface: %s" % interface_name) return {name: getter() for name, getter in self._property_getters.items()} def PropertiesChanged(_, interface_name, changed_properties, invalidated_properties): if interface_name != self._interface_name: raise DBusException("Unknown interface: %s" % interface_name) self._dbus_methods["Get"] = method(PROPERTIES_IFACE, in_signature="ss", out_signature="v")(Get) self._dbus_methods["Set"] = method(PROPERTIES_IFACE, in_signature="ssv")(Set) self._dbus_methods["GetAll"] = method(PROPERTIES_IFACE, in_signature="s", out_signature="a{sv}")(GetAll) self._dbus_methods["PropertiesChanged"] = signal(PROPERTIES_IFACE, signature="sa{sv}as")(PropertiesChanged) self._signals.add("PropertiesChanged") def property_changed(self, property_name, value): self.send_signal("PropertiesChanged", self._interface_name, {property_name: value}, {}) def property_getter(self, method, property_name): if not ismethod(method): raise Exception("Only bound methods can be exported.") if property_name in self._property_getters: raise Exception("A getter for this property is already registered.") self._property_getters[property_name] = method def property_setter(self, method, property_name): if not ismethod(method): raise Exception("Only bound methods can be exported.") if property_name in self._property_setters: raise Exception("A setter for this property is already registered.") self._property_setters[property_name] = method PK ��Z�uj�L L interfaces.pynu �[��� class ExportableInterface(object): pass class ExporterInterface(object): def export(self, method, in_signature, out_signature): # to be overridden by concrete implementation raise NotImplementedError() def signal(self, method, out_signature): # to be overridden by concrete implementation raise NotImplementedError() def send_signal(self, signal, *args, **kwargs): # to be overridden by concrete implementation raise NotImplementedError() def start(self): raise NotImplementedError() def stop(self): raise NotImplementedError() def period_check(self): pass PK ��Zc�� � unix_socket_exporter.pynu �[��� import os import re import pwd, grp from . import interfaces import tuned.logs import tuned.consts as consts from inspect import ismethod import socket import json import select log = tuned.logs.get() class UnixSocketExporter(interfaces.ExporterInterface): """ Export method calls through Unix Domain Socket Interface. We take a method to be exported and create a simple wrapper function to call it. This is required as we need the original function to be bound to the original object instance. While the wrapper will be bound to an object we dynamically construct. """ def __init__(self, socket_path=consts.CFG_DEF_UNIX_SOCKET_PATH, signal_paths=consts.CFG_DEF_UNIX_SOCKET_SIGNAL_PATHS, ownership=consts.CFG_DEF_UNIX_SOCKET_OWNERSHIP, permissions=consts.CFG_DEF_UNIX_SOCKET_PERMISIONS, connections_backlog=consts.CFG_DEF_UNIX_SOCKET_CONNECTIONS_BACKLOG): self._socket_path = socket_path self._socket_object = None self._socket_signal_paths = signal_paths self._socket_signal_objects = [] self._ownership = [-1, -1] if ownership: ownership = ownership.split() for i, o in enumerate(ownership[:2]): try: self._ownership[i] = int(o) except ValueError: try: # user if i == 0: self._ownership[i] = pwd.getpwnam(o).pw_uid # group else: self._ownership[i] = grp.getgrnam(o).gr_gid except KeyError: log.error("%s '%s' does not exists, leaving default" % ("User" if i == 0 else "Group", o)) self._permissions = permissions self._connections_backlog = connections_backlog self._unix_socket_methods = {} self._signals = set() self._conn = None self._channel = None def running(self): return self._socket_object is not None def export(self, method, in_signature, out_signature): if not ismethod(method): raise Exception("Only bound methods can be exported.") method_name = method.__name__ if method_name in self._unix_socket_methods: raise Exception("Method with this name (%s) is already exported." % method_name) class wrapper(object): def __init__(self, in_signature, out_signature): self._in_signature = in_signature self._out_signature = out_signature def __call__(self, *args, **kwargs): return method(*args, **kwargs) self._unix_socket_methods[method_name] = wrapper(in_signature, out_signature) def signal(self, method, out_signature): if not ismethod(method): raise Exception("Only bound methods can be exported.") method_name = method.__name__ if method_name in self._unix_socket_methods: raise Exception("Method with this name (%s) is already exported." % method_name) class wrapper(object): def __init__(self, out_signature): self._out_signature = out_signature def __call__(self, *args, **kwargs): return method(*args, **kwargs) self._unix_socket_methods[method_name] = wrapper(out_signature) self._signals.add(method_name) def send_signal(self, signal, *args, **kwargs): if not signal in self._signals: raise Exception("Signal '%s' doesn't exist." % signal) for p in self._socket_signal_paths: log.debug("Sending signal on socket %s" % p) try: s = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) s.setblocking(False) s.connect(p) self._send_data(s, {"jsonrpc": "2.0", "method": signal, "params": args}) s.close() except OSError as e: log.warning("Error while sending signal '%s' to socket '%s': %s" % (signal, p, e)) def register_signal_path(self, path): self._socket_signal_paths.append(path) def _construct_socket_object(self): if self._socket_path: if os.path.exists(self._socket_path): os.unlink(self._socket_path) self._socket_object = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) self._socket_object.bind(self._socket_path) self._socket_object.listen(self._connections_backlog) os.chown(self._socket_path, self._ownership[0], self._ownership[1]) if self._permissions: os.chmod(self._socket_path, self._permissions) def start(self): if self.running(): return self.stop() self._construct_socket_object() def stop(self): if self._socket_object: self._socket_object.close() def _send_data(self, s, data): log.debug("Sending socket data: %s)" % data) try: s.send(json.dumps(data).encode("utf-8")) except Exception as e: log.warning("Failed to send data '%s': %s" % (data, e)) def _create_response(self, data, id, error=False): res = { "jsonrpc": "2.0", "id": id } if error: res["error"] = data else: res["result"] = data return res def _create_error_responce(self, code, message, id=None, data=None): return self._create_response({ "code": code, "message": message, "data": data, }, error=True, id=id) def _create_result_response(self, result, id): return self._create_response(result, id) def _check_id(self, data): if data.get("id"): return data return None def _process_request(self, req): if type(req) != dict or req.get("jsonrpc") != "2.0" or not req.get("method"): return self._create_error_responce(-32600, "Invalid Request") id = req.get("id") ret = None if req["method"] not in self._unix_socket_methods: return self._check_id(self._create_error_responce(-32601, "Method not found", id)) try: if not req.get("params"): ret = self._unix_socket_methods[req["method"]]() elif type(req["params"]) in (list, tuple): ret = self._unix_socket_methods[req["method"]](*req["params"]) elif type(req["params"]) == dict: ret = self._unix_socket_methods[req["method"]](**req["params"]) else: return self._check_id(self._create_error_responce(-32600, "Invalid Request", id)) except TypeError as e: return self._check_id(self._create_error_responce(-32602, "Invalid params", id, str(e))) except Exception as e: return self._check_id(self._create_error_responce(1, "Error", id, str(e))) return self._check_id(self._create_result_response(ret, id)) def period_check(self): """ Periodically checks socket object for new calls. This allows to function without special thread. Interface is according JSON-RPC 2.0 Specification (see https://www.jsonrpc.org/specification) Example calls: printf '[{"jsonrpc": "2.0", "method": "active_profile", "id": 1}, {"jsonrpc": "2.0", "method": "profiles", "id": 2}]' | nc -U /run/tuned/tuned.sock printf '{"jsonrpc": "2.0", "method": "switch_profile", "params": {"profile_name": "balanced"}, "id": 1}' | nc -U /run/tuned/tuned.sock """ if not self.running(): return while True: r, _, _ = select.select([self._socket_object], (), (), 0) if r: conn, _ = self._socket_object.accept() try: data = "" while True: rec_data = conn.recv(4096).decode() if not rec_data: break data += rec_data except Exception as e: log.error("Failed to load data of message: %s" % e) continue if data: try: data = json.loads(data) except Exception as e: log.error("Failed to load json data '%s': %s" % (data, e)) self._send_data(conn, self._create_error_responce(-32700, "Parse error", str(e))) continue if type(data) not in (tuple, list, dict): log.error("Wrong format of call") self._send_data(conn, self._create_error_responce(-32700, "Parse error", str(e))) continue if type(data) in (tuple, list): if len(data) == 0: self._send_data(conn, self._create_error_responce(-32600, "Invalid Request", str(e))) continue res = [] for req in data: r = self._process_request(req) if r: res.append(r) if res: self._send_data(conn, res) else: res = self._process_request(data) if r: self._send_data(conn, res) else: return PK ��Z룄�q q __init__.pynu �[��� from . import interfaces from . import controller from . import dbus_exporter as dbus from . import dbus_exporter_with_properties as dbus_with_properties from . import unix_socket_exporter as unix_socket def export(*args, **kwargs): """Decorator, use to mark exportable methods.""" def wrapper(method): method.export_params = [ args, kwargs ] return method return wrapper def signal(*args, **kwargs): """Decorator, use to mark exportable signals.""" def wrapper(method): method.signal_params = [ args, kwargs ] return method return wrapper def property_setter(*args, **kwargs): """Decorator, use to mark setters of exportable properties.""" def wrapper(method): method.property_set_params = [ args, kwargs ] return method return wrapper def property_getter(*args, **kwargs): """Decorator, use to mark getters of exportable properties.""" def wrapper(method): method.property_get_params = [ args, kwargs ] return method return wrapper def property_changed(*args, **kwargs): ctl = controller.ExportsController.get_instance() return ctl.property_changed(*args, **kwargs) def register_exporter(instance): if not isinstance(instance, interfaces.ExporterInterface): raise Exception() ctl = controller.ExportsController.get_instance() return ctl.register_exporter(instance) def register_object(instance): if not isinstance(instance, interfaces.ExportableInterface): raise Exception() ctl = controller.ExportsController.get_instance() return ctl.register_object(instance) def send_signal(*args, **kwargs): ctl = controller.ExportsController.get_instance() return ctl.send_signal(*args, **kwargs) def start(): ctl = controller.ExportsController.get_instance() return ctl.start() def stop(): ctl = controller.ExportsController.get_instance() return ctl.stop() def period_check(): ctl = controller.ExportsController.get_instance() return ctl.period_check() PK ��ZJq�SB B + __pycache__/interfaces.cpython-39.opt-1.pycnu �[��� PK ��Z��OE E + � __pycache__/controller.cpython-39.opt-1.pycnu �[��� PK ��Z��OE E % = __pycache__/controller.cpython-39.pycnu �[��� PK ��Z�.� � > �* __pycache__/dbus_exporter_with_properties.cpython-39.opt-1.pycnu �[��� PK ��Z���:� � ( �7 __pycache__/dbus_exporter.cpython-39.pycnu �[��� PK ��Z{7�[C" C" / �S __pycache__/unix_socket_exporter.cpython-39.pycnu �[��� PK ��ZJq�SB B % jv __pycache__/interfaces.cpython-39.pycnu �[��� PK ��Z�#� # | __pycache__/__init__.cpython-39.pycnu �[��� PK ��Z{7�[C" C" 5 i� __pycache__/unix_socket_exporter.cpython-39.opt-1.pycnu �[��� PK ��Z�#� ) � __pycache__/__init__.cpython-39.opt-1.pycnu �[��� PK ��Z���:� � . � __pycache__/dbus_exporter.cpython-39.opt-1.pycnu �[��� PK ��Z�.� � 8 v� __pycache__/dbus_exporter_with_properties.cpython-39.pycnu �[��� PK ��Z���U U p� dbus_exporter.pynu �[��� PK ��ZN2�� � � controller.pynu �[��� PK ��Z 'M * * dbus_exporter_with_properties.pynu �[��� PK ��Z�uj�L L � interfaces.pynu �[��� PK ��Zc�� � unix_socket_exporter.pynu �[��� PK ��Z룄�q q �8 __init__.pynu �[��� PK �@
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings