File: //usr/lib/python3/dist-packages/jeepney/io/tests/__pycache__/conftest.cpython-310.pyc
o
���`�
� @ s� d dl mZ d dlZd dlZd dlmZmZmZmZm Z m
Z
d dl m Z m
Z
mZ e�� dd� �Ze�� dd� �Ze�� d d
� �ZdS ) � )�
TemporaryFileN)� DBusAddress� HeaderFields� message_bus� MessageType� new_error�new_method_return)�open_dbus_connection�
DBusRouter�Proxyc # � � d} t | dd�}tddd��?� t� ��}tt|��| �\}W d � n1 s(w Y |dks3J �� fdd �}tj|dd
�}|�� |V W d � n1 sQw Y |� � d S ) Nz1io.gitlab.takluyver.jeepney.tests.respond_with_fd�/��bus_name� object_path�SESSIONT��bus�
enable_fds� c s� � � � } | jjtju rJ| jjtj dkrBtd�� }|� d� |�
d� t | d|f�}� � |� W d � d S 1 s<w Y n� � t
| d�� q)NT�GetFDzw+�readmer �h�NoMethod)�receive�header� message_typer � method_call�fieldsr �memberr �write�seekr �sendr )�msg�tf�rep��conn� �;/usr/lib/python3/dist-packages/jeepney/io/tests/conftest.py� _reply_once s
"��z$respond_with_fd.<locals>._reply_once��target�daemon�
r r r
r r � RequestName� threading�Thread�start�join��name�addr�router�statusr* � reply_threadr( r& r) �respond_with_fd s �
� � r: c # r ) Nz.io.gitlab.takluyver.jeepney.tests.read_from_fdr
r r Tr r c s� � � � } | jjtju rJ| jjtj dkrB| jd � d��}|�
d� |� � }W d � n1 s1w Y � � t
| d|f�� d S � � t| d�� q)NT�ReadFDr �rb�ayr )r r r r r r r r �body�to_filer! �readr" r r )r# �f�br& r( r) r* 5 s
��z!read_from_fd.<locals>._reply_oncer+ r. r4 r( r& r) � read_from_fd+ s �
�
� rC c c sZ � d} t d�� }|�| � |�� |�d� || fV W d � d S 1 s&w Y d S )Ns abc123zw+br )r r �flushr! )�datar$ r( r( r) �temp_file_and_contentsI s �
"�rF )�tempfiler r0 �pytest�jeepneyr r r r r r �jeepney.io.threadingr r
r �fixturer: rC rF r( r( r( r) �<module> s