← Back
Editing: connection.cpython-312.pyc
� �ic^- � �H � d dl Z d dlZd dlmZmZ d dlmZmZ d dlm Z m Z d dl m Z d dl mZ d dlZ ej dd� d d lmZ e j& e� Zg d �Z G d � d e� Z G d � de�� Z G d� de� Z G d� de� Z G d� de� Z G d� de� Z y)� N)�ABCMeta�abstractmethod)� DBUS_NAME_FLAG_ALLOW_REPLACEMENT�%DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER)� ObjectProxy�InterfaceProxy)� ErrorMapper)�ServerObjectHandler�Gioz2.0)r )�GLibConnection� MessageBus�SystemMessageBus�SessionMessageBus�AddressedMessageBusc � � e Zd ZdZej j ej j z Ze dd�� Z e dd�� Z e eddfd�� Z y)r z4The low-level DBus connection library based on GLib.Nc � � t j d� t j t j j | � S )z Get a system bus connection.� Connecting to the system bus.)�log�infor � bus_get_sync�BusType�SYSTEM�� cancellables �6/usr/lib/python3.12/site-packages/dasbus/connection.py�get_system_bus_connectionz(GLibConnection.get_system_bus_connection6 s4 � � ���0�1�� � � �K�K� � � � � � c � � t j d� t j t j j | � S )z Get a session bus connection.� Connecting to the session bus.)r r r r r �SESSIONr s r �get_session_bus_connectionz)GLibConnection.get_session_bus_connection? s4 � � ���1�2�� � � �K�K� � � � � r c �F � t j j | |||� S )�3Get a connection to a bus at the specified address.)r �DBusConnection�new_for_address_sync)� bus_address�flags�observerr s r � get_addressed_bus_connectionz+GLibConnection.get_addressed_bus_connectionH s) � � �!�!�6�6� � � � � � r �N) �__name__� __module__� __qualname__�__doc__r �DBusConnectionFlags�AUTHENTICATION_CLIENT�MESSAGE_BUS_CONNECTION� DEFAULT_FLAGS� staticmethodr r! r) � r r r r . ss � �>� � � �5�5� � � �6�6� 7� � � � � � � � � � �8E�.2�� � � r r c �r � e Zd ZdZeed� � � Zd� Zed d�� Zed� � Z ed� � Z ed� � Z y) �AbstractMessageBusa Abstract representation of a message bus. The property connection represents a connection to the bus. You can register a service name with register_service, or publish an object with publish_object and get a proxy of a remote object with get_proxy. c � � y)�The DBus connection.Nr4 ��selfs r � connectionz AbstractMessageBus.connection\ s � � r c �x � | j duS # t $ r }t j d|� Y d}~yd}~ww xY w)znCheck if the connection is set up. :return: True if the connection is set up otherwise False Nz Connection can't be created: %sF)r; � Exceptionr �warning)r: �es r �check_connectionz#AbstractMessageBus.check_connectionb s8 � � ��?�?�$�.� .��� � �K�K�:�A� >��� �s � � 9�4�9Nc � � y)a Returns a proxy of a remote DBus object. :param service_name: a DBus name of a service :param object_path: a DBus path of an object :param interface_name: a DBus name of an interface or None :return: a proxy object Nr4 )r: � service_name� object_path�interface_name�kwargss r � get_proxyz AbstractMessageBus.get_proxym � � � r c � � y)a Register a service on DBus. A service can be registered by requesting its name on DBus. This method should be called only after all of the required objects of the service are published on DBus. :param service_name: a DBus name of a service Nr4 )r: rB rE s r �register_servicez#AbstractMessageBus.register_servicey rG r c � � y)z�Publish an object on DBus. :param object_path: a DBus path of an object :param obj: an instance of @dbus_interface or @dbus_class Nr4 )r: rC �objrE s r �publish_objectz!AbstractMessageBus.publish_object� s � � r c � � y)�Disconnect from DBus.Nr4 r9 s r � disconnectz AbstractMessageBus.disconnect� � � � r r* ) r+ r, r- r. �propertyr r; r@ rF rI rL rO r4 r r r6 r6 T sx � �� ��� � �� � � � � � � � � � � � � � � � � r r6 )� metaclassc � � � e Zd ZdZdef� fd� Zed� � Zed� � Z ed� � Z dd�Z d� Z e fd �Zefd �Zd � Zd � Zd � Zd� Z� xZS )r z/Representation of a message bus based on D-Bus.Nc � �� t �| � � || _ |xs t � | _ d| _ d| _ i | _ t � | _ y)z�Create a new message bus. :param error_mapper: a DBus error mapper :param provider: a provider of DBus connections N) �super�__init__� _providerr � _error_mapper� _connection�_proxy�_registrations�set�_requested_names)r: � error_mapper�provider� __class__s �r rV zMessageBus.__init__� sG �� � ����!��� )� :�[�]��� ����� � ��� #��� r c �\ � | j s| j � | _ | j S )r8 )rY �_get_connectionr9 s r r; zMessageBus.connection� s* � � � � � #� 3� 3� 5�D� �� � � r c � � y)zReturn a DBus connection.Nr4 r9 s r rb zMessageBus._get_connection� rP r c �` � | j s| j dd� | _ | j S )zThe proxy of DBus.zorg.freedesktop.DBusz/org/freedesktop/DBus)rZ rF r9 s r �proxyzMessageBus.proxy� s- � � �{�{� �.�.�&�'��D�K� �{�{�r c � � | j |� |s|rt nt }|r||d< || ||fd| j i|��S )a� Returns a proxy of a remote DBus object. If the proxy factory is not specified, we will use a default one. If the interface name is set, we will choose InterfaceProxy, otherwise ObjectProxy. If the interface name is set, we will add it to the additional arguments for the proxy factory. :param service_name: a DBus name of a service :param object_path: a DBus path of an object :param interface_name: a DBus name of an interface or None :param proxy_factory: a factory of a DBus object proxy :param proxy_arguments: additional arguments for the proxy factory :return: a proxy object rD r^ )�_check_service_accessr r rX )r: rB rC rD � proxy_factory�proxy_argumentss r rF zMessageBus.get_proxy� s\ � �$ �"�"�<�0� �.<�N�+�M� �0>�O� ,� -� � � � � � �+�+� � � � r c � � || j vryt j � t j � uryt dj |� � �)a� Check if we can access a DBus service. FIXME: This is a temporary check that should be later removed. This is useful during the transition of the Anaconda code from UI to DBus modules. This check prevents a deadlock in case that a DBus module tries to access a service, that it provides, from the main thread. :param service_name: a DBus name of a service :raises: RuntimeError if the service cannot be accessed Nz4Can't access DBus service '{}' from the main thread.)r] � threading�current_thread� main_thread� RuntimeError�format�r: rB s r rg z MessageBus._check_service_access� sN � � �t� 4� 4� 4� � � #� #� %�Y�-B�-B�-D� D� �� � %�v�l� 3� � r c � � �� t j d�� � j j �|� }|t k7 rt dj |� � �� j j �� � �fd�� j �< y)z�Register a service on DBus. :param service_name: a DBus name of a service :param flags: the flags argument of the RequestName DBus method z Registering a service name %s.zName request has failed: {}c �: �� � j j �� S r* )re � ReleaseNamerp s ��r �<lambda>z-MessageBus.register_service.<locals>.<lambda> s �� �D�J�J�*�*�<�8r N) r �debugre � RequestNamer �ConnectionErrorro r] �addr[ )r: rB r' �results `` r rI zMessageBus.register_service� sv �� � � � �2�L�A����'�'� �e�<�� �:� :�!�"?�"F�"F�v�"N�O� O� � � �!�!� � � 9� ���L�)r c � � t j d|� || ||fd| j i|��}|j � |j | j |< y)a1 Publish an object on DBus. :param object_path: a DBus path of an object :param obj: an instance of @dbus_interface or @dbus_class :param server_factory: a factory of a DBus server object handler :param server_arguments: additional arguments for the server factory zPublishing an object at %s.r^ N)r ru rX �connect_object�disconnect_objectr[ )r: rC rK �server_factory�server_arguments�object_handlers r rL zMessageBus.publish_object sd � � � � �/��=�'� � � � � �+�+� � � �� �%�%�'�+9�+K�+K����K�(r c �f � || j v r#| j j |� } |� yy)zRemove Object from DBus.N)r[ �pop)r: rC �callbacks r � _unregisterzMessageBus._unregister& s2 � � �$�-�-� -��*�*�.�.�{�;�H� �J� .r c �R � t j d|� | j |� y )Nz Removing object %s from the bus.�r ru r� �r: rC s r �unpublish_objectzMessageBus.unpublish_object- s � � � � �4�k�B� ����%r c �R � t j d|� | j |� y )Nz!Removing service %s from the bus.r� r� s r �unregister_servicez MessageBus.unregister_service1 s � � � � �5�{�C� ����%r c �� � t j d� | j r1| j j � \ }} |� | j r�1d| _ t � | _ y)rN zDisconnecting from the bus.N)r ru r[ �popitemrY r\ r] )r: �_r� s r rO zMessageBus.disconnect5 sT � � � � �/�0��!�!� �-�-�5�5�7�K�A�x� �J� �!�!� ��� #��� r )NN)r+ r, r- r. r rV rQ r; r rb re rF rg r rI r rL r� r� r� rO � __classcell__�r` s @r r r � s� �� �9�$(�>� &� � � � � � � � � �� �� CG� $� �D �8 @� �, ':�L�,�&�&� &r r c � � e Zd ZdZd� Zy)r z*Representation of a system bus connection.c �` � t j d� | j j � S )z Get a system DBus connection.r )r r rW r r9 s r rb z SystemMessageBus._get_connectionD s" � � ���0�1��~�~�7�7�9�9r N�r+ r, r- r. rb r4 r r r r A s � �4�:r r c � � e Zd ZdZd� Zy)r z+Representation of a session bus connection.c �` � t j d� | j j � S )z Get a session DBus connection.r )r r rW r! r9 s r rb z!SessionMessageBus._get_connectionM s" � � ���1�2��~�~�8�8�:�:r Nr� r4 r r r r J s � �5�;r r c �8 � � e Zd ZdZ� fd�Zed� � Zd� Z� xZS )r z9Representation of a connection for the specified address.c �2 �� t �| � |i |�� || _ y)z\Create a new representation of a connection. :param address: a bus address N)rU rV �_address)r: �address�argsrE r` s �r rV z AddressedMessageBus.__init__V s �� � ���$�)�&�)� �� r c � � | j S )zThe bus address.)r� r9 s r r� zAddressedMessageBus.address^ s � � �}�}� r c � � t j d| j � | j j | j � S )r# zConnecting to a bus at %s.)r r r� rW r) r9 s r rb z#AddressedMessageBus._get_connectionc s. � � ���-�t�}�}�=��~�~�:�:�4�=�=�I�Ir ) r+ r, r- r. rV rQ r� rb r� r� s @r r r S s% �� �C� � � � � �Jr r ) �loggingrk �abcr r �dasbus.constantsr r �dasbus.client.proxyr r � dasbus.errorr �dasbus.server.handlerr �gi�require_version� gi.repositoryr � getLoggerr+ r �__all__�objectr r6 r r r r r4 r r �<module>r� s� ��* � � '�*� ;� $� 5� � �� � �5�%� � ��g����!�� ��# �V� # �L= �7� = �@j&�#� j&�Z:�z� :�;� � ;�J�*� Jr
Save File
Cancel