Server IP : 149.255.58.128 / Your IP : 216.73.216.48
System : Linux cloud516.thundercloud.uk 5.14.0-427.26.1.el9_4.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 17 15:51:13 EDT 2024 x86_64
PHP Version : 8.2.28
Disable Function : allow_url_include, apache_child_terminate, apache_setenv, exec, passthru, pcntl_exec, posix_kill, posix_mkfifo, posix_getpwuid, posix_setpgid, posix_setsid, posix_setuid, posix_setgid, posix_seteuid, posix_setegid, posix_uname, proc_close, proc_get_status, proc_open, proc_terminate, shell_exec, show_source, system
cURL : ON | WGET : ON | Sudo : OFF | Pkexec : OFF
Upload Files :
Command :
Current File : /usr/lib/python3.9/site-packages/tuned/exports/__pycache__//dbus_exporter.cpython-39.pyc
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.
