3
iR�VF � @ s� dZ dZddlZddlZddlmZmZmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZmZmZmZmZmZmZ ddl m Z ddl m Z ddl m!Z! ddl"m#Z# d eeef Z$d
Z%ej&d �Z'G d d
� d
e(�Z)G dd � d e �Z*dS )�
BusConnectionZreStructuredText� N)�BUS_DAEMON_IFACE�BUS_DAEMON_NAME�BUS_DAEMON_PATH� BUS_SESSION� BUS_STARTER�
BUS_SYSTEM� DBUS_START_REPLY_ALREADY_RUNNING�DBUS_START_REPLY_SUCCESS�NAME_FLAG_ALLOW_REPLACEMENT�NAME_FLAG_DO_NOT_QUEUE�NAME_FLAG_REPLACE_EXISTING� RELEASE_NAME_REPLY_NON_EXISTENT� RELEASE_NAME_REPLY_NOT_OWNER�RELEASE_NAME_REPLY_RELEASED� REQUEST_NAME_REPLY_ALREADY_OWNER�REQUEST_NAME_REPLY_EXISTS�REQUEST_NAME_REPLY_IN_QUEUE� REQUEST_NAME_REPLY_PRIMARY_OWNER�validate_bus_name�validate_error_name�validate_interface_name�validate_member_name�validate_object_path)�
Connection)�
DBusException)� HANDLER_RESULT_NOT_YET_HANDLED)�is_py2zWtype='signal',sender='%s',interface='%s',member='NameOwnerChanged',path='%s',arg0='%%s'z)org.freedesktop.DBus.Error.NameHasNoOwnerzdbus.busc @ s e Zd ZdZdd� Zdd� ZdS ) �NameOwnerWatch�_match�
_pending_callc sn t � � �fdd�}� �fdd�}|j|dttt� d�| _i }trJd|d< |jtttd d
� f�|f|�| _d S ) Nc s � |� d S )N� )ZownedZ old_owner� new_owner)�callbackr! �/usr/lib64/python3.6/bus.py� signal_cb@ s z*NameOwnerWatch.__init__..signal_cbc s: | j � tkr�d� n tj� tjd� | j| d fd� d S )N� zGetNameOwner(%s) failed:)�exc_info)�
get_dbus_name�_NAME_HAS_NO_OWNER�loggingZ basicConfig�_logger�debug� __class__)�e)�bus_namer# r! r$ �error_cbC s
z)NameOwnerWatch.__init__..error_cbZNameOwnerChanged)Zarg0T� utf8_strings� GetNameOwner�s) r �add_signal_receiverr r r r r �
call_asyncr )�selfZbus_connr/ r# r% r0 �keywordsr! )r/ r# r$ �__init__= s&
zNameOwnerWatch.__init__c C s8 | j d k r| j j� | jd k r(| jj� d | _ d | _d S )N)r �remover �cancel)r6 r! r! r$ r: \ s
zNameOwnerWatch.cancelN)r r )�__name__�
__module__� __qualname__� __slots__r8 r: r! r! r! r$ r : s r c s� e Zd ZdZeZeZeZ e
Z e Z
edfdd�Zd*� fdd� Zdd� Zd d
� Zd+d
d�Zdd� Zd,dd�Zd-dd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Z d$d%� Z d&d'� Z d(d)� Z � Z S ).r zxA connection to a D-Bus daemon that implements the
``org.freedesktop.DBus`` pseudo-service.
:Since: 0.81.0
Nc C s" | j ||d�}tj� |_i |_|S )N)�mainloop)Z _new_for_bus�weakref�WeakValueDictionaryZ
_bus_names�_signal_sender_matches)�clsZaddress_or_typer? Zbusr! r! r$ �__new__y s
zBusConnection.__new__c s� |j dd �}|d k rB|d k r$td��|}ddlm} |dtdd� tt| �j|||||f|�� |d k r�|tkr�|d d� d kr�� fd
d �} n� j } | j
|| �}
|
| j � < | j t
� �� � S ) N�
named_servicez3bus_name and named_service cannot both be specifiedr )�warnzrPassing the named_service parameter to add_signal_receiver by name is deprecated: please use positional parameters� )�
stacklevel� �:c s | dkr� j � d S )Nr& )r9 )r" )�matchr! r$ r# � s z3BusConnection.add_signal_receiver..callback)�pop� TypeError�warningsrF �DeprecationWarning�superr r4 r Zset_sender_name_owner�watch_name_ownerrB �add_match_string�str) r6 Zhandler_functionZ signal_nameZdbus_interfacer/ �pathr7 rE rF r# �watch)r- )rK r$ r4 � s&
z!BusConnection.add_signal_receiverc C s0 | j t|�� | jj|d �}|d k r,|j� d S )N)� remove_match_string_non_blockingrS rB rL r: )r6 rK rU r! r! r$ �_clean_up_signal_match� s z$BusConnection._clean_up_signal_matchc C st |d k rl|d d� dkrl|t krly
| j|�S tk
rh } z"|j� tkrJ� | j|� | j|�S d }~X qpX n|S d S )NrI rJ )r �get_name_ownerr r( r) �start_service_by_name)r6 r/ r. r! r! r$ �activate_name_owner� s
z!BusConnection.activate_name_ownerTFc K s| |r | j � |jdd�}|dk rN|dk r0td��ddlm} |dtdd� |}|rhtd d
j|j� � ��| j| ||||d �S ) aJ Return a local proxy for the given remote object.
Method calls on the proxy are translated into method calls on the
remote object.
:Parameters:
`bus_name` : str
A bus name (either the unique name or a well-known name)
of the application owning the object. The keyword argument
named_service is a deprecated alias for this.
`object_path` : str
The object path of the desired 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 the object path is a well-known name and this parameter
is false (default), resolve the well-known name to the unique
name of its current owner and bind to that instead; if the
ownership of the well-known name changes in future,
keep communicating with the original owner.
This is necessary if the D-Bus API used is stateful.
If the object path is a well-known name and this parameter
is true, whenever the well-known name changes ownership in
future, bind to the new owner, if any.
If the given object path is a unique name, this parameter
has no effect.
:Returns: a `dbus.proxies.ProxyObject`
:Raises `DBusException`: if resolving the well-known name to a
unique name fails
rE Nz3bus_name and named_service cannot both be specifiedr )rF ziPassing the named_service parameter to get_object by name is deprecated: please use positional parametersrG )rH z4get_object does not take these keyword arguments: %sz, )�
introspect�follow_name_owner_changes) Z_require_main_looprL rM rN rF rO �join�keysZProxyObjectClass)r6 r/ Z object_pathr[ r\ �kwargsrE rF r! r! r$ �
get_object� s $
zBusConnection.get_objectc C s t |� | jtttdd|f�S )z�Get the numeric uid of the process owning the given bus name.
:Parameters:
`bus_name` : str
A bus name, either unique or well-known
:Returns: a `dbus.UInt32`
:Since: 0.80.0
ZGetConnectionUnixUserr3 )r �
call_blockingr r r )r6 r/ r! r! r$ �
get_unix_user� s zBusConnection.get_unix_userr c C s$ t |� d| jtttdd||f�fS )a? Start a service which will implement the given bus name on this Bus.
:Parameters:
`bus_name` : str
The well-known bus name to be activated.
`flags` : dbus.UInt32
Flags to pass to StartServiceByName (currently none are
defined)
:Returns: A tuple of 2 elements. The first is always True, the
second is either START_REPLY_SUCCESS or
START_REPLY_ALREADY_RUNNING.
:Raises `DBusException`: if the service could not be started.
:Since: 0.80.0
TZStartServiceByName�su)r ra r r r )r6 r/ �flagsr! r! r$ rY s
z#BusConnection.start_service_by_namec C s$ t |dd� | jtttdd||f�S )a� Request a bus name.
:Parameters:
`name` : str
The well-known name to be requested
`flags` : dbus.UInt32
A bitwise-OR of 0 or more of the flags
`NAME_FLAG_ALLOW_REPLACEMENT`,
`NAME_FLAG_REPLACE_EXISTING`
and `NAME_FLAG_DO_NOT_QUEUE`
:Returns: `REQUEST_NAME_REPLY_PRIMARY_OWNER`,
`REQUEST_NAME_REPLY_IN_QUEUE`,
`REQUEST_NAME_REPLY_EXISTS` or
`REQUEST_NAME_REPLY_ALREADY_OWNER`
:Raises `DBusException`: if the bus daemon cannot be contacted or
returns an error.
F)� allow_uniqueZ RequestNamerc )r ra r r r )r6 �namerd r! r! r$ � request_name s zBusConnection.request_namec C s" t |dd� | jtttdd|f�S )as Release a bus name.
:Parameters:
`name` : str
The well-known name to be released
:Returns: `RELEASE_NAME_REPLY_RELEASED`,
`RELEASE_NAME_REPLY_NON_EXISTENT`
or `RELEASE_NAME_REPLY_NOT_OWNER`
:Raises `DBusException`: if the bus daemon cannot be contacted or
returns an error.
F)re Z ReleaseNamer3 )r ra r r r )r6 rf r! r! r$ � release_name1 s zBusConnection.release_namec C s( i }t rd|d< | jtttddf f|�S )z�Return a list of all currently-owned names on the bus.
:Returns: a dbus.Array of dbus.UTF8String
:Since: 0.81.0
Tr1 Z ListNamesr& )r ra r r r )r6 r7 r! r! r$ �
list_namesB s zBusConnection.list_namesc C s( i }t rd|d< | jtttddf f|�S )z�Return a list of all names that can be activated on the bus.
:Returns: a dbus.Array of dbus.UTF8String
:Since: 0.81.0
Tr1 ZListActivatableNamesr& )r ra r r r )r6 r7 r! r! r$ �list_activatable_namesO s z$BusConnection.list_activatable_namesc C s6 i }t rd|d< t|dd� | jtttdd|ff|�S )z�Return the unique connection name of the primary owner of the
given name.
:Raises `DBusException`: if the `bus_name` has no owner
:Since: 0.81.0
Tr1 F)re r2 r3 )r r ra r r r )r6 r/ r7 r! r! r$ rX \ s z BusConnection.get_name_ownerc C s t | ||�S )a Watch the unique connection name of the primary owner of the
given name.
`callback` will be called with one argument, which is either the
unique connection name, or the empty string (meaning the name is
not owned).
:Since: 0.81.0
)r )r6 r/ r# r! r! r$ rQ k s
z BusConnection.watch_name_ownerc C s t | jtttdd|f��S )z�Return True iff the given bus name has an owner on this bus.
:Parameters:
`bus_name` : str
The bus name to look up
:Returns: a `bool`
Z NameHasOwnerr3 )�boolra r r r )r6 r/ r! r! r$ �name_has_ownerw s
z BusConnection.name_has_ownerc C s | j tttdd|f� dS )a Arrange for this application to receive messages on the bus that
match the given rule. This version will block.
:Parameters:
`rule` : str
The match rule
:Raises `DBusException`: on error.
:Since: 0.80.0
�AddMatchr3 N)ra r r r )r6 �ruler! r! r$ rR � s
z BusConnection.add_match_stringc C s | j tttdd|fdd� dS )a= Arrange for this application to receive messages on the bus that
match the given rule. This version will not block, but any errors
will be ignored.
:Parameters:
`rule` : str
The match rule
:Raises `DBusException`: on error.
:Since: 0.80.0
rm r3 N)r5 r r r )r6 rn r! r! r$ � add_match_string_non_blocking� s
z+BusConnection.add_match_string_non_blockingc C s | j tttdd|f� dS )a Arrange for this application to receive messages on the bus that
match the given rule. This version will block.
:Parameters:
`rule` : str
The match rule
:Raises `DBusException`: on error.
:Since: 0.80.0
� RemoveMatchr3 N)ra r r r )r6 rn r! r! r$ �remove_match_string� s
z!BusConnection.remove_match_stringc C s | j tttdd|fdd� dS )a= Arrange for this application to receive messages on the bus that
match the given rule. This version will not block, but any errors
will be ignored.
:Parameters:
`rule` : str
The match rule
:Raises `DBusException`: on error.
:Since: 0.80.0
rp r3 N)r5 r r r )r6 rn r! r! r$ rV � s
z.BusConnection.remove_match_string_non_blocking)NNNN)TF)r )r )!r; r< r= �__doc__r Z TYPE_SESSIONr Z TYPE_SYSTEMr Z TYPE_STARTERr
ZSTART_REPLY_SUCCESSr ZSTART_REPLY_ALREADY_RUNNINGrD r4 rW rZ r` rb rY rg rh ri rj rX rQ rl rR ro rq rV �
__classcell__r! r! )r- r$ r e s6
8
)r )+�__all__Z
__docformat__r* r@ Z_dbus_bindingsr r r r r r r r
r r r
r r r r r r r r r r r r Zdbus.connectionr Zdbus.exceptionsr Z
dbus.lowlevelr Z dbus._compatr Z_NAME_OWNER_CHANGE_MATCHr) Z getLoggerr+ �objectr r r! r! r! r$ � s d
+