|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/jeepney/integrate/__pycache__/ |
Upload File : |
o
���` � @ s� d Z ddlZddlmZ ddlmZmZ ddlmZm Z m
Z
m Z ddl m
Z
ddlmZ ddlmZ dd lmZ ed
d d � G d
d� dej�ZG dd� de�Zddd�ZdS )z*Deprecated: use jeepney.io.asyncio instead� N)�warn)�Parser� MessageType)�AuthenticationError�BEGIN�make_auth_external�
SASLParser)�get_bus)� message_bus)�Router)� ProxyBasezOjeepney.integrate.asyncio is deprecated: please use jeepney.io.asyncio instead.� )�
stacklevelc @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )� DBusProtocolc C s0 t � | _t� | _ttj�| _t�� | _d | _ d S �N)
r � auth_parserr �parserr �asyncio�Future�router�authentication� unique_name��self� r �;/usr/lib/python3/dist-packages/jeepney/integrate/asyncio.py�__init__ s
zDBusProtocol.__init__c C s || _ | j �dt� � d S )N� )� transport�writer )r r r r r �connection_made s z DBusProtocol.connection_madec C s2 | j �t� | j�d� | j| _| �| jj� d S )NT) r r r r �
set_result�data_received_post_auth�
data_receivedr �bufferr r r r �_authenticated s zDBusProtocol._authenticatedc C sD | j �|� | j jr| �� d S | j jr | j�t| j j�� d S d S r )r �feed�
authenticatedr% �errorr �
set_exceptionr )r �datar r r r# ! s �zDBusProtocol.data_receivedc C s" | j �|�D ]}| j�|� qd S r )r r& r �incoming)r r* �msgr r r r" ( s �z$DBusProtocol.data_received_post_authc C s6 | j �� s td��| j�|�}|�� }| j�|� |S )Nz/Wait for authentication before sending messages)r �done� RuntimeErrorr �outgoing� serialiser r )r �message�futurer* r r r � send_message, s
zDBusProtocol.send_messagec � s( �|j jtjkr td��| �|�I d H S )Nz&Only method call messages have replies)�header� message_typer � method_call� TypeErrorr3 )r r1 r r r �send_and_get_reply5 s �z DBusProtocol.send_and_get_replyN)
�__name__�
__module__� __qualname__r r r% r# r" r3 r8 r r r r r s r c s0 e Zd ZdZ� fdd�Zdd� Zdd� Z� ZS )�Proxyz�An asyncio proxy for calling D-Bus methods
:param msggen: A message generator object.
:param DBusProtocol proto: Protocol object to send and receive messages.
c s t � �|� || _d S r )�superr � _protocol)r �msggen�protocol�� __class__r r r A s
zProxy.__init__c C s d� | j| j�S )Nz
Proxy({}, {}))�format�_msggenr> r r r r �__repr__E s zProxy.__repr__c s � �fdd�}|S )Nc � s4 �� | i |��}|j jtju sJ ��j�|�I d H S r )r4 r5 r r6 r> r8 )�args�kwargsr, ��make_msgr r r �innerI s �z!Proxy._method_call.<locals>.innerr )r rI rJ r rH r � _method_callH s zProxy._method_call)r9 r: r; �__doc__r rE rK �
__classcell__r r rA r r< ; s
r< �SESSIONc � sd �|d u r t �� }|jtt| �d�I d H \}}|jI d H tt|�} | �� I d H }|d |_ ||fS )N)�pathr )
r �get_event_loop�create_unix_connectionr r r r< r
�Hellor )�bus�loop�t�p� hello_replyr r r �connect_and_authenticateQ s �
rX )rN N)rL r �warningsr �jeepneyr r � jeepney.authr r r r � jeepney.busr �jeepney.bus_messagesr
�jeepney.routingr �jeepney.wrappersr �Protocolr r< rX r r r r �<module> s �,