3
iRV` @ 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 jdZd dlmZmZmZmZmZ d dlmZ G d d
d
ZG d d d ZG d
d deZG dd deZdS ) N)RLock)process_introspection_data)
DBusException IntrospectionParserException MissingErrorHandlerException MissingReplyHandlerExceptionZrestructuredtextz dbus.proxies)BUS_DAEMON_IFACEBUS_DAEMON_NAMEBUS_DAEMON_PATHINTROSPECTABLE_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_methodappendblock r /usr/lib64/python3.6/proxies.py__init__6 s z_DeferredMethod.__init__c O s@ d|ks|j ddr(| j| j|| d S | j | j||S d S )N
reply_handler ignore_replyF)getr r r )r argskeywordsr 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 ) _ProxyMethodzA 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
connectionbus_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 togetherdbus_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 dddZe dd dddZd&ddZdd Zdd Zdd Zdd Zdd Zd d Zd d Zd'd!d"Zd#d$ ZeZdS )( ProxyObjectzA 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 |rtd d
j|j |r|j || _|dk rt j
| | | _ | _ t j
| || _|s|j|| _ d| _g | _i | _t | _| s | jtkr&| 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; DeprecationWarningjoinkeysZ_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_changeskwargsr: r; r= r r r r sJ
zProxyObject.__init__c C s | j S )N)r( )r r r r s zProxyObject.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 dataer 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_loggererrorr( 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 dr |jdr t|n
| j|S d S )N__)
startswithendswithAttributeErrorget_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&)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 dddZeZedd ddd Zed
d ddd Z ed d ddd
Z
edd dddZ dddZ dd Z
dddZdd ZeZdS ) InterfacezAn 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 |tr|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.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 dr |jdr t|n| jj|| jS 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%)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 s"
` B