관리-도구
편집 파일: proxies.cpython-36.pyc
3 iR�V�` � @ s� d dl Z yd dlmZ W n ek r8 d dlmZ Y nX d dlZd dlmZ d dlm Z m Z m Z m Z dZ e jd�Zd dlmZmZmZmZmZ d dlmZ G d d � d �ZG d d � d �ZG d d� de�ZG dd� de�ZdS )� N)�RLock)�process_introspection_data)� DBusException� IntrospectionParserException� MissingErrorHandlerException� MissingReplyHandlerExceptionZrestructuredtextz dbus.proxies)�BUS_DAEMON_IFACE�BUS_DAEMON_NAME�BUS_DAEMON_PATH�INTROSPECTABLE_IFACE� LOCAL_PATH)�is_py2c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �_DeferredMethodzXA proxy method which will only get called once we have its introspection reply. c C s || _ |j| _|| _|| _d S )N)� _proxy_method� _method_name�_append�_block)�self� proxy_method�append�block� r � /usr/lib64/python3.6/proxies.py�__init__6 s z_DeferredMethod.__init__c O s@ d|ks|j dd�r(| j| j||� d S | j� | j||�S d S )N� reply_handler� ignore_replyF)�getr r r )r �args�keywordsr r r �__call__= s z_DeferredMethod.__call__c O s | j | j||� d S )N)r r )r r r r r r � call_asyncH s z_DeferredMethod.call_asyncN)�__name__� __module__� __qualname__�__doc__r r r r r r r r 2 s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � _ProxyMethodz�A proxy method. Typically a member of a ProxyObject. Calls to the method produce messages that travel over the Bus and are routed to a specific named Service. c C sX |t krtdt ��|| _|| _|| _|| _tj|� || _|d k rNtj |� || _ d S )Nz1Methods may not be called on the reserved path %s) r r �_proxy� _connection�_named_service� _object_path�_dbus_bindingsZvalidate_member_namer Zvalidate_interface_name�_dbus_interface)r �proxyZ connection�bus_name� object_pathZ method_nameZifacer r r r S s z_ProxyMethod.__init__c O s |j dd �}|j dd �}|j dd�}|j dd �}|d k s@|d k rl|d krPt� �n |d kr`t� �n |rltd��|j d| j�}|d kr�|d kr�| j}n|d | j }| jjj|d �}|s�|d k r�| j j | j | j || j||||f|� n | j j | j | j || j||f|�S d S ) Nr � error_handlerr F� signaturez6ignore_reply and reply_handler cannot be used together�dbus_interface�.)�popr r � TypeErrorr+ r r& �_introspect_method_mapr r' r r( r) Z call_blocking) r r r r r/ r r0 r1 �keyr r r r g sD z_ProxyMethod.__call__c O s� |j dd �}|j dd �}|j dd �}|j d| j�}|d krd|rN|d | j }n| j}| jjj|d �}| jj| j| j || j||||f|� d S )Nr r/ r0 r1 r2 ) r3 r+ r r& r5 r r' r r( r) )r r r r r/ r0 r1 r6 r r r r � s$ z_ProxyMethod.call_asyncN)r! r" r# r$ r r r r r r r r% L s ,r% c @ s� e Zd ZdZeZeZdZdZ dZ d%dd �Z e d d � ddd �Z e d d � ddd�Ze dd � ddd�Zd&dd�Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd'd!d"�Zd#d$� ZeZdS )(� ProxyObjectz�A proxy to the remote Object. A ProxyObject is provided by the Bus. ProxyObjects have member functions, and can be called like normal Python objects. r � � NTFc K s< |j dd�}|dk rB|dk r$td��|}ddlm} |dtdd� |j d d�} | dk r�|dk rftd ��| }ddlm} |d tdd� |r�td d j|j� � ��|r�|j� || _|dk r�t j |� | | _ | _ t j |� || _|s�|j|�| _ d| _g | _i | _t� | _| �s | jtk�r&| j| _n| j| _| j� | _dS )a� Initialize the proxy object. :Parameters: `conn` : `dbus.connection.Connection` The bus or connection on which to find this object. The keyword argument `bus` is a deprecated alias for this. `bus_name` : str A bus name for the application owning the object, to be used as the destination for method calls and the sender for signal matches. The keyword argument ``named_service`` is a deprecated alias for this. `object_path` : str The object path at which the application exports the object `introspect` : bool If true (default), attempt to introspect the remote object to find out supported methods and their signatures `follow_name_owner_changes` : bool If true (default is false) and the `bus_name` is a well-known name, follow ownership changes for that name �busNz%conn and bus cannot both be specifiedr )�warnz`Passing the bus parameter to ProxyObject by name is deprecated: please use positional parametersr9 )� stacklevel� named_servicez3bus_name and named_service cannot both be specifiedzjPassing the named_service parameter to ProxyObject by name is deprecated: please use positional parametersz>ProxyObject.__init__ does not take these keyword arguments: %sz, )r3 r4 �warningsr; �DeprecationWarning�join�keysZ_require_main_loop�_busr* Zvalidate_bus_namer( �_requested_bus_nameZvalidate_object_path�__dbus_object_path__Zactivate_name_owner�_pending_introspect�_pending_introspect_queuer5 r �_introspect_lockr � INTROSPECT_STATE_DONT_INTROSPECT�_introspect_state�'INTROSPECT_STATE_INTROSPECT_IN_PROGRESS� _Introspect) r Zconnr- r. Z introspectZfollow_name_owner_changes�kwargsr: r; r= r r r r � sJ zProxyObject.__init__c C s | j S )N)r( )r r r r �<lambda> s zProxyObject.<lambda>a� The bus name to which this proxy is bound. (Read-only, may change.) If the proxy was instantiated using a unique name, this property is that unique name. If the proxy was instantiated with a well-known name and with ``follow_name_owner_changes`` set false (the default), this property is the unique name of the connection that owned that well-known name when the proxy was instantiated, which might not actually own the requested well-known name any more. If the proxy was instantiated with a well-known name and with ``follow_name_owner_changes`` set true, this property is that well-known name. c C s | j S )N)rC )r r r r rM s z[The bus name which was requested when this proxy was instantiated. c C s | j S )N)rD )r r r r rM $ s z The object-path of this proxy.c K s" | j j|f||| j| jd�|��S )ax Arrange for the given function to be called when the given signal is received. :Parameters: `signal_name` : str The name of the signal `handler_function` : callable A function to be called when the signal is emitted by the remote object. Its positional arguments will be the arguments of the signal; optionally, it may be given keyword arguments as described below. `dbus_interface` : str Optional interface with which to qualify the signal name. If None (the default) the handler will be called whenever a signal of the given member name is received, whatever its interface. :Keywords: `utf8_strings` : bool If True, the handler function will receive any string arguments as dbus.UTF8String objects (a subclass of str guaranteed to be UTF-8). If False (default) it will receive any string arguments as dbus.String objects (a subclass of unicode). `byte_arrays` : bool If True, the handler function will receive any byte-array arguments as dbus.ByteArray objects (a subclass of str). If False (default) it will receive any byte-array arguments as a dbus.Array of dbus.Byte (subclasses of: a list of ints). `sender_keyword` : str If not None (the default), the handler function will receive the unique name of the sending endpoint as a keyword argument with this name `destination_keyword` : str If not None (the default), the handler function will receive the bus name of the destination (or None if the signal is a broadcast, as is usual) as a keyword argument with this name. `interface_keyword` : str If not None (the default), the handler function will receive the signal interface as a keyword argument with this name. `member_keyword` : str If not None (the default), the handler function will receive the signal name as a keyword argument with this name. `path_keyword` : str If not None (the default), the handler function will receive the object-path of the sending object as a keyword argument with this name `message_keyword` : str If not None (the default), the handler function will receive the `dbus.lowlevel.SignalMessage` as a keyword argument with this name. `arg...` : unicode or UTF-8 str If there are additional keyword parameters of the form ``arg``\ *n*, match only signals where the *n*\ th argument is the value given for that keyword parameter. As of this time only string arguments can be matched (in particular, object paths and signatures can't). )� signal_namer1 r- �path)rB Zadd_signal_receiverr( rD )r rN �handler_functionr1 r r r r �connect_to_signal0 s < z ProxyObject.connect_to_signalc C s> i }t rd|d< | jj| j| jtddf | j| jfddi|��S )NTZ utf8_stringsZ Introspect� Zrequire_main_loopF)r rB r r( rD r �_introspect_reply_handler�_introspect_error_handler)r rL r r r rK s s zProxyObject._Introspectc C s* x | j D ]\}}}|||� qW g | _ d S )N)rF )r r r r r r r �_introspect_execute_queue~ s z%ProxyObject._introspect_execute_queuec C sp | j j� zTyt|�| _W n* tk rD } z| j|� d S d }~X nX | j| _d | _| j � W d | j j � X d S )N) rG �acquirer r5 r rT � INTROSPECT_STATE_INTROSPECT_DONErI rE rU �release)r �data�er r r rS � s z%ProxyObject._introspect_reply_handlerc C sh t j� tjd| j| j|jj|jj|� | j j � z$tj d� | j | _ d | _| j� W d | j j� X d S )Nz$Introspect error on %s:%s: %s.%s: %sz'Executing introspect queue due to error)�loggingZ basicConfig�_logger�errorr( rD � __class__r" r! rG rV �debugrH rI rE rU rX )r r] r r r rT � s z%ProxyObject._introspect_error_handlerc C s4 | j j� z| jd k r | jj� W d | j j� X d S )N)rG rV rE r rX )r r r r �_introspect_block� s z ProxyObject._introspect_blockc C sJ | j j� z.| j| jkr,| jj|||f� n |||� W d | j j� X d S )N)rG rV rI rJ rF r rX )r �callbackr rL r r r �_introspect_add_to_queue� s z$ProxyObject._introspect_add_to_queuec C s, |j d�r |jd�r t|��n | j|�S d S )N�__)� startswith�endswith�AttributeError�get_dbus_method)r �memberr r r � __getattr__� s zProxyObject.__getattr__c C s< | j | | j| j| j||�}| j| jkr8| j|| j| j�}|S )a, Return a proxy method representing the given D-Bus method. The returned proxy method can be called in the usual way. For instance, :: proxy.get_dbus_method("Foo", dbus_interface='com.example.Bar')(123) is equivalent to:: proxy.Foo(123, dbus_interface='com.example.Bar') or even:: getattr(proxy, "Foo")(123, dbus_interface='com.example.Bar') However, using `get_dbus_method` is the only way to call D-Bus methods with certain awkward names - if the author of a service implements a method called ``connect_to_signal`` or even ``__getattr__``, you'll need to use `get_dbus_method` to call them. For services which follow the D-Bus convention of CamelCaseMethodNames this won't be a problem. ) �ProxyMethodClassrB r( rD rI rJ �DeferredMethodClassrb r` )r rh r1 �retr r r rg � s zProxyObject.get_dbus_methodc C s d| j | j| jt| �f S )Nz&<ProxyObject wrapping %s %s %s at %#x>)rB r( rD �id)r r r r �__repr__� s zProxyObject.__repr__)NNNTF)N)N)r! r" r# r$ r% rj r rk rH rJ rW r �propertyr- �requested_bus_namer. rQ rK rU rS rT r` rb ri rg rn �__str__r r r r r7 � s6 R C &r7 c @ s� e Zd ZdZdd� Zedd� ddd�ZeZedd� ddd �Zed d� ddd �Z ed d� ddd �Z edd� ddd�Z ddd�Z dd� Z ddd�Zdd� ZeZdS )� Interfacez�An interface into a remote object. An Interface can be used to wrap ProxyObjects so that calls can be routed to their correct D-Bus interface. c C s$ t |t�r|j| _n|| _|| _dS )a: Construct a proxy for the given interface on the given object. :Parameters: `object` : `dbus.proxies.ProxyObject` or `dbus.Interface` The remote object or another of its interfaces `dbus_interface` : str An interface the `object` implements N)� isinstancerr � proxy_object�_objr+ )r �objectr1 r r r r � s zInterface.__init__c C s | j jS )N)ru r. )r r r r rM s zInterface.<lambda>Nz.The D-Bus object path of the underlying objectc C s | j jS )N)ru r- )r r r r rM s z:The bus name to which the underlying proxy object is boundc C s | j jS )N)ru rp )r r r r rM s zGThe bus name which was requested when the underlying object was createdc C s | j S )N)ru )r r r r rM s zThe underlying proxy objectc C s | j S )N)r+ )r r r r rM s z The D-Bus interface representedc K s |s | j }| jj|||f|�S )aa Arrange for a function to be called when the given signal is emitted. The parameters and keyword arguments are the same as for `dbus.proxies.ProxyObject.connect_to_signal`, except that if `dbus_interface` is None (the default), the D-Bus interface that was passed to the `Interface` constructor is used. )r+ ru rQ )r rN rP r1 r r r r rQ s zInterface.connect_to_signalc C s2 |j d�r |jd�r t|��n| jj|| j�S d S )Nrc )rd re rf ru rg r+ )r rh r r r ri " s zInterface.__getattr__c C s |dkr| j }| jj||�S )a& Return a proxy method representing the given D-Bus method. This is the same as `dbus.proxies.ProxyObject.get_dbus_method` except that if `dbus_interface` is None (the default), the D-Bus interface that was passed to the `Interface` constructor is used. N)r+ ru rg )r rh r1 r r r rg ( s zInterface.get_dbus_methodc C s d| j | jt| �f S )Nz%<Interface %r implementing %r at %#x>)ru r+ rm )r r r r rn 4 s zInterface.__repr__)N)N)r! r" r# r$ r ro r. rD r- rp rt r1 rQ ri rg rn rq r r r r rr � s& rr ) r[ Z threadingr � ImportErrorZdummy_threadingr* Z dbus._expat_introspect_parserr Zdbus.exceptionsr r r r Z __docformat__Z getLoggerr\ r r r r r Z dbus._compatr r r% rv r7 rr r r r r �<module> s" ` B