1#@!#!123s

��JFIF�� 1#@!#!123s
: / lib / python3.10 / multiprocessing / dummy / __pycache__ /
Filename : connection.cpython-310.pyc
back
o

����E�h>����������������������@���sP���g�d��Z�ddlmZ�dgZG�dd��de�Zdd��Zd
d	d
�ZG�dd��de�ZdS�))�Client�Listener�Pipe�����)�QueueNc�������������������@���sB���e�Zd�Zddd�Zdd��Zdd��Zed	d
���Zdd��Zd
d��Z	dS�)r���N����c�����������������C���s���t�|�|�_d�S��N)r����_backlog_queue)�self�address�family�backlog��r
����7/usr/lib/python3.10/multiprocessing/dummy/connection.py�__init__�������zListener.__init__c�����������������C���s���t�|�j�����S�r���)�
Connectionr����get�r	���r
���r
���r����accept���r���zListener.acceptc�����������������C���s
���d�|�_�d�S�r����r���r���r
���r
���r����close���s���
zListener.closec�����������������C���s���|�j�S�r���r���r���r
���r
���r���r
������s���zListener.addressc�����������������C�������|�S�r���r
���r���r
���r
���r����	__enter__!�������zListener.__enter__c�����������������C�������|������d�S�r����r����r	����exc_type�	exc_value�exc_tbr
���r
���r����__exit__$�������zListener.__exit__)NNr���)
�__name__�
__module__�__qualname__r���r���r����propertyr
���r���r ���r
���r
���r
���r���r������s����

r���c�����������������C���s&���t���t���}}|��||f��t||�S�r���)r����putr���)r
����_in�_outr
���r
���r���r���(���s���
r���Tc�����������������C���s"���t���t���}}t||�t||�fS�r���)r���r���)�duplex�a�br
���r
���r���r���.���s���r���c�������������������@���s6���e�Zd�Zdd��Zd
dd�Zdd��Zdd	��Zd
d��ZdS�)r���c�����������������C���s,���||�_�||�_|j�|�_|�_|j�|�_|�_d�S�r���)r(���r'���r&����send�
send_bytesr����recv�
recv_bytes)r	���r'���r(���r
���r
���r���r���5���s���zConnection.__init__���������c�����������������C���sb���|�j����dkr	dS�|dkrdS�|�j�j��|�j�j�|��W�d�����n1�s%w���Y��|�j����dkS�)Nr���Tr0���F)r'����qsize�	not_empty�wait)r	����timeoutr
���r
���r����poll;���s���
�zConnection.pollc�����������������C���s���d�S�r���r
���r���r
���r
���r���r���D���r���zConnection.closec�����������������C���r���r���r
���r���r
���r
���r���r���G���r���zConnection.__enter__c�����������������C���r���r���r���r���r
���r
���r���r ���J���r!���zConnection.__exit__N)r0���)r"���r#���r$���r���r5���r���r���r ���r
���r
���r
���r���r���3���s����
	r���)T)	�__all__�queuer����families�objectr���r���r���r���r
���r
���r
���r����<module>���s���