FM / __pycache_

/usr/lib/python3/dist-packages/jeepney/io/__pycache__/

/usr/lib/python3/dist-packages/jeepney/io/__pycache__

Name	Size	Mode	Actions
asyncio.cpython-310.pyc	8938	0644	edit dl rm
blocking.cpython-310.pyc	12797	0644	edit dl rm
common.cpython-310.pyc	3817	0644	edit dl rm
threading.cpython-310.pyc	10812	0644	edit dl rm
tornado.cpython-310.pyc	8270	0644	edit dl rm
trio.cpython-310.pyc	14271	0644	edit dl rm
__init__.cpython-310.pyc	189	0644	edit dl rm

Edit: /usr/lib/python3/dist-packages/jeepney/io/__pycache__/tornado.cpython-310.pyc (8270B)

o ��`��@sRddlmZmZmZddlmZddlZddlmZddl m Z ddlmZddl mZddlmZdd lmZmZdd lmZmZmZmZddlmZddlmZmZmZmZdd l m!Z!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(m)Z)m*Z*m+Z+m,Z,e ddd�Gdd�d�Z-d"dd�Z.Gdd�d�Z/Gdd�de!�Z0Gdd�d�Z1d"d d!�Z2dS)#�)�as_completed�Future�wait_for)�countN)�Optional)�warn)�IOLoop)�IOStream)�Event)�Queue� QueueFull)� SASLParser�make_auth_external�BEGIN�AuthenticationError)�get_bus)�Parser�MessageType�Message�MessageFlag)� ProxyBase� unwrap_msg)�Router)�message_bus�)�MessageFilters�FilterHandle�ReplyMatcher�RouterClosed�check_replyablezsjeepney.io.tornado is deprecated. Tornado is now built on top of asyncio, so please use jeepney.io.asyncio instead.�)� stacklevelc@sDeZdZdefdd�Zdd�defdd�Zd efd d�Zdd �ZdS)�DBusConnection�streamcCs$||_t�|_tdd�|_d|_dS)Nr)�start)r#r�parserr�outgoing_serial�unique_name)�selfr#�r)�4/usr/lib/python3/dist-packages/jeepney/io/tornado.py�__init__s zDBusConnection.__init__N��serial�messagec�s0�|dur t|j�}|j�|�|��IdHdS�N)�nextr&r#�write� serialise�r(r.r-r)r)r*�send!s� zDBusConnection.send�returnc�s>� |j��}|dur |S|jjddd�IdH}|j�|�q)NTi��partial)r%�get_next_messager#� read_bytes�add_data)r(�msg�br)r)r*�receive's� �zDBusConnection.receivecC�|j��dSr/)r#�close�r(r)r)r*r?0�zDBusConnection.close) �__name__� __module__�__qualname__r r+rr4r=r?r)r)r)r*r"s r"�SESSIONc�s��t|�}ttjtjd��}|�|�IdH|�dt��IdHt�}|js?|� |j ddd�IdH�|jrr/)r[�setr@r)r)r*�stoprrAzDBusRouter.stopcCs|Sr/r)r@r)r)r*� __enter__uszDBusRouter.__enter__cCs|��dS)NF)rh�r(�exc_type�exc_val�exc_tbr)r)r*�__exit__xszDBusRouter.__exit__cCs|jjSr/)rUr'r@r)r)r*r'~szDBusRouter.unique_namer.c�sF�|jjtjkr|jjtj@st|�|�IdH�S|� |�IdHdSr/) �header�message_typer� method_return�flagsr�no_reply_expectedrrbr4)r(r.r)r)r*�send_message�s��zDBusRouter.send_messager;c CsH|j�|�rdS|j�|�D]}z|j�|�Wqty!YqwdS)zHandle one received messageN)rY�dispatchrZ�matchesrc� put_nowaitr)r(r;rfr)r)r*� _dispatch�s��zDBusRouter._dispatchc�sx�z1 t|j��|j��g�D]"}|IdH}|dur&Wd|_|j��dS|�|�|j � |�qqd|_|j��w)z'Receiver loop - runs in a separate taskTNF)rrUr=r[�wait� is_runningrY�drop_allrxrV�incoming)r(�coror;r)r)r*r^�s� ��zDBusRouter._receiver)rBrCrDr"r+r4rbrrrfrhrirn�propertyr'rrtrxr^r)r)r)r*rOKs rOcs2eZdZdef�fdd�Zdd�Zdd�Z�ZS)rPrVcst��|�||_dSr/)�superr+�_router)r(�msggenrV�� __class__r)r*r+�s zProxy.__init__cCsd�|j|j�S)Nz Proxy({}, {}))�format�_msggenr�r@r)r)r*�__repr__�szProxy.__repr__cs��fdd�}|S)Nc�s8��|i|��}|jjtjusJ�t�j�|�IdH�Sr/)rorpr�method_callrr�rb)�args�kwargsr;��make_msgr(r)r*�inner�s�z!Proxy._method_call..innerr))r(r�r�r)r�r*�_method_call�szProxy._method_call)rBrCrDrOr+r�r�� __classcell__r)r)r�r*rP�srPc@s.eZdZdZdZd dd�Zdd�Zdd�ZdS) �_RouterContextNrEcCs ||_dSr/�rR)r(rRr)r)r*r+�s z_RouterContext.__init__c�s&�t|j�IdH|_t|j�|_|jSr/)rXrRrUrOrVr@r)r)r*� __aenter__�s�z_RouterContext.__aenter__c�s�|j��|j��dSr/)rVrhrUr?rjr)r)r*� __aexit__�s� z_RouterContext.__aexit__�rE)rBrCrDrUrVr+r�r�r)r)r)r*r��s r�cCst|�S)a�Open a D-Bus 'router' to send and receive messages. Use as an async context manager:: async with open_dbus_router() as req: ... :param str bus: 'SESSION' or 'SYSTEM' or a supported address. :return: :class:`DBusRouter` This is a shortcut for:: conn = await open_dbus_connection() async with conn: async with conn.router() as req: ... )r�r�r)r)r*�open_dbus_router�sr�r�)3�asynciorrr� itertoolsrrI�typingr�warningsr�tornado.ioloopr�tornado.iostreamr � tornado.locksr �tornado.queuesrr�jeepney.authr rrr�jeepney.busr�jeepney.low_levelrrrr�jeepney.wrappersrr�jeepney.routingr�jeepney.bus_messagesr�commonrrrrrr"rXrOrPr�r�r)r)r)r*�s2� ^