✏️ 正在编辑: dbus_exporter.cpython-36.pyc
路径:
/lib/python3.6/site-packages/tuned/exports/__pycache__/dbus_exporter.cpython-36.pyc
提示:
您可以编辑任何文件（包括二进制文件），但请注意不当修改可能导致文件损坏。
3 �<�eO � @ s d dl mZ ddlZddlZddlZddlZddlZddlZ ddl j Z ddl Z ddl Z ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ dd lmZ ydd lmZ d d � ZW n ek r� dd lmZ Y nX e j j � Z dd� Z G dd� dej �Z!dS )� )� interfaces� N)�ismethod)�polkit)�GLib)� FunctionType)� DBusException)� ErrorMessage)�getfullargspecc C s t | �S )N)r )�func� r �#/usr/lib/python3.6/dbus_exporter.py� getargspec s r )r c C s� t |dd �}|d k rn0t |dd�dkr4d|jj }nd|j|jjf }t|t�rZ|j� }ndjtj |j|��}t |||�}|j � s�| j |� d S )NZ_dbus_error_name� __module__� �__main__z org.freedesktop.DBus.Python.%sz!org.freedesktop.DBus.Python.%s.%s)r r ) �getattr� __class__�__name__r � isinstancer Zget_dbus_message�join� traceback�format_exception_onlyr Z get_no_replyZ send_message)Z connection�messageZ 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 j� tjkrttj_tjjj dd� d | _ d | _ i | _ t � | _|| _|| _|| _|| _d | _d | _t� | _tjtj�}tj� | _ tjtj|� 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 )N)r' )r2 r r r r3 ` s zDBusExporter.bus_namec C s | j S )N)r( )r2 r r r r4 d s zDBusExporter.interface_namec C s | j S )N)r) )r2 r r r r5 h s zDBusExporter.object_namec C s | j d k S )N)r+ )r2 r r r �runningl s zDBusExporter.runningc C sN dj |jdjt|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__r9 �compile�lenr$ r � co_consts�locals)r2 �method�wrapper�source�coder r r r �_prepare_for_dbuso s z DBusExporter._prepare_for_dbusc sj t � �std��� j}|�jkr(td��� �fdd�}�j� |�}tjj�j||dd�|�}|�j|< d S )Nz#Only bound methods can be exported.z*Method with this name is already exported.c s �j d � j }|d }tjd||f � �jj||�}|}|dkrXtjd||f � n�|dkrttjd||f � n�|dkr�tjd||f � t|d d � �d g }nZ|dkr�tjd ||f � t|d d� �d g }n(tj d ||f � t|d d� �d g }� ||�S )N�.r z?checking authorization for action '%s' requested by caller '%s'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���rH rH rH rH ) r* r r �debugr- Zcheck_authorization�warn�info�list�error)�ownerr9 �kwargsZ action_id�caller�retZ args_copy)rA r2 r r rB � s$ z$DBusExporter.export.<locals>.wrapperrP )Zsender_keyword) r � Exceptionr r$ rE r! r" rA r( )r2 rA Z in_signature� out_signature� method_namerB r )rA r2 r �export} s zDBusExporter.exportc sn t � �std��� j}|| jkr(td��� fdd�}| j� |�}tjj| j|�|�}|| j|< | j j |� d S )Nz#Only bound methods can be exported.z*Method with this name is already exported.c s � ||�S )Nr )rN r9 rO )rA r r rB � s z$DBusExporter.signal.<locals>.wrapper) r rR r r$ rE r! r" r. r( r& �add)r2 rA rS rT rB r )rA r r. � s zDBusExporter.signalc O sf d}|| j ks| jd kr d}yt| j|�}W n tk rD d}Y nX |rXtd| ��n |||� d S )NFTzSignal '%s' doesn't exist.)r& r, r �AttributeErrorrR )r2 r. r9 rO �errrA r r r � send_signal� s zDBusExporter.send_signalc C s< | j d k rtd��dt| � }t|tjjf| j�}|| _ d S )Nz%The exporter class was already build.zDBusExporter_%d)r# rR �id�typer! r" ZObjectr$ )r2 Z unique_name�clsr r r � _construct_dbus_object_class� s z)DBusExporter._construct_dbus_object_classc C sn | j � r d S | jd kr | j� | j� tj� }tjj| j|�}| j|| j |�| _ t j | j d�| _| jj� d S )N)�target)r8 r# r] �stopr! Z SystemBusr" ZBusNamer' r) r, � threadingZThread� _thread_coder+ �start)r2 Zbusr3 r r r rb � s zDBusExporter.startc C s2 | j d k r.| j j� r.| jj� | j j� d | _ d S )N)r+ Zis_aliver1 �quitr )r2 r r r r_ � s zDBusExporter.stopc C s | j j� | `d | _d S )N)r1 Zrunr, )r2 r r r ra � s zDBusExporter._thread_codeN)r r � __qualname__�__doc__r7 �propertyr3 r4 r5 r8 rE rU r. rY r] rb r_ ra r r r r r 8 s " r )"r r Z dbus.servicer! Zdbus.mainloop.glibZdbus.exceptionsr` r. 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.
💾 保存文件
← 返回文件管理器