File: //usr/lib/python3.9/site-packages/dasbus/client/__pycache__/observer.cpython-39.pyc
a
װ_[ � @ s� d dl Z d dlmZ d dlmZ d dlmZ d dlZe�dd� d dl m
Z
e � e �Z
g d�ZG d d
� d
e�ZG d d � d e�ZG d
d� de�ZdS )� N)�partial)�DBUS_FLAG_NONE)�Signal�Gioz2.0)r )�DBusObserverError� DBusObserver�GLibMonitoringc @ s e Zd ZdZdS )r z'Exception class for the DBus observers.N)�__name__�
__module__� __qualname__�__doc__� r
r
�:/usr/lib/python3.9/site-packages/dasbus/client/observer.pyr ( s r c @ sH e Zd ZdZeeddfdd��Zedd� �Zedd� �Zed d
� �Z dS ) r z4The low-level DBus monitoring library based on GLib.Nc C sT d}d}|r t | j|dfd�}|r4t | j|dfd�}t�|||||�}t | j||�S )z,Watch a service name on the DBus connection.Nr
)� user_data)r �_name_appeared_callback�_name_vanished_callbackr Z bus_watch_name_on_connection�
_unwatch_name) �cls�
connection�name�flagsZ
name_appearedZ
name_vanishedZname_appeared_closureZname_vanished_closure�registration_idr
r
r �
watch_name0 s0 ����zGLibMonitoring.watch_namec C s |\}}||g|�R � dS )zCallback for watch_name..Nr
)r r r Z
name_ownerr �callback�
callback_argsr
r
r r Q s z&GLibMonitoring._name_appeared_callbackc C s |\}}||� dS )zCallback for watch_name.Nr
)r r r r r r r
r
r r Z s z&GLibMonitoring._name_vanished_callbackc C s t �|� dS )z5Stops watching a service name on the DBus connection.N)r Zbus_unwatch_name)r r r r
r
r r c s z GLibMonitoring._unwatch_name)
r r
r r � classmethodr r r r r r
r
r
r r - s �
r c @ s� e Zd ZdZefdd�Zedd� �Zedd� �Zedd � �Z ed
d � �Z
d d
� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )!r a4 Base class for DBus observers.
This class is recommended to use only to watch the availability
of a service on DBus. It doesn't provide any support for accessing
objects provided by the service.
Usage:
.. code-block:: python
# Create the observer and connect to its signals.
observer = DBusObserver(SystemBus, "org.freedesktop.NetworkManager")
def callback1(observer):
print("Service is available!")
def callback2(observer):
print("Service is unavailable!")
observer.service_available.connect(callback1)
observer.service_unavailable.connect(callback2)
# Connect to the service once it is available.
observer.connect_once_available()
# Disconnect the observer.
observer.disconnect()
c C s2 || _ || _d| _t� | _t� | _|| _g | _dS )z�Creates a DBus service observer.
:param message_bus: a message bus
:param service_name: a DBus name of a service
FN)� _message_bus�
_service_name�_is_service_availabler �_service_available�_service_unavailable� _monitoring�_subscriptions)�selfZ message_bus� service_nameZ
monitoringr
r
r �__init__� s zDBusObserver.__init__c C s | j S )zReturns a DBus name.�r �r# r
r
r r$ � s zDBusObserver.service_namec C s | j S )zThe proxy can be accessed.)r r' r
r
r �is_service_available� s z!DBusObserver.is_service_availablec C s | j S )z�Signal that emits when the service is available.
Signal emits this class as an argument. You have to
call the watch method to activate the signals.
)r r' r
r
r �service_available� s z DBusObserver.service_availablec C s | j S )z�Signal that emits when the service is unavailable.
Signal emits this class as an argument. You have to
call the watch method to activate the signals.
)r r' r
r
r �service_unavailable� s z DBusObserver.service_unavailablec C s | � � dS )z�Connect to the service once it is available.
The observer is not connected to the service until it
emits the service_available signal.
N)�_watchr' r
r
r �connect_once_available� s z#DBusObserver.connect_once_availablec C s | � � | jr| �� dS )z�Disconnect from the service.
Disconnect from the service if it is connected and stop
watching its availability.
N)�_unwatchr( �_disable_servicer' r
r
r �
disconnect� s zDBusObserver.disconnectc C s. | j �| jj| jt| j| j�}| j� |� dS )z Watch the service name on DBus.N)
r! r r r r$ r � _service_name_appeared_callback� _service_name_vanished_callbackr" �append)r# Z subscriptionr
r
r r+ � s �zDBusObserver._watchc C s | j r| j �� }|� q dS )z'Stop to watch the service name on DBus.N)r" �pop)r# r r
r
r r- � s
zDBusObserver._unwatchc C s d| _ | j�| � dS )zEnable the service.TN)r r �emitr' r
r
r �_enable_service� s z DBusObserver._enable_servicec C s d| _ | j�| � dS )zDisable the service.FN)r r r4 r' r
r
r r. � s z DBusObserver._disable_servicec G s | j s| �� dS �z Callback for the watch method.N)r( r5 �r# �argsr
r
r r0 � s z,DBusObserver._service_name_appeared_callbackc G s | j r| �� dS r6 )r( r. r7 r
r
r r1 � s z,DBusObserver._service_name_vanished_callbackc C s | j S )z(Returns a string version of this object.r& r' r
r
r �__str__� s zDBusObserver.__str__c C s d� | jj| j�S )z Returns a string representation.z{}({}))�format� __class__r r r' r
r
r �__repr__� s �zDBusObserver.__repr__N)r r
r r r r% �propertyr$ r( r) r* r, r/ r+ r- r5 r. r0 r1 r9 r< r
r
r
r r i s(
r )Zlogging� functoolsr Zdasbus.constantsr Z
dasbus.signalr ZgiZrequire_versionZ
gi.repositoryr Z getLoggerr �log�__all__� Exceptionr �objectr r r
r
r
r �<module> s
<