£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyÊ¦•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~èŠ©ÊÇí`ÔÑ©úë™µ'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶ê×Ó¼ãžªéUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£ÔÏ¯rs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowÐø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! ��Yf/�@ssdddgZddlmZdgZGdd�de�Zdd�Zdd d�ZGd d�de�ZdS)�Client�Listener�Pipe�)�QueueNc@sgeZdZddddd�Zdd�Zdd�Zed d ��Zdd�Zd d�Z dS)rN�cCst|�|_dS)N)r�_backlog_queue)�self�addressZfamilyZbacklog�r �E/opt/alt/python35/lib64/python3.5/multiprocessing/dummy/connection.py�__init__szListener.__init__cCst|jj��S)N)� Connectionr�get)rr r r�acceptszListener.acceptcCs d|_dS)N)r)rr r r�closeszListener.closecCs|jS)N)r)rr r r�szListener.cCs|S)Nr )rr r r� __enter__szListener.__enter__cCs|j�dS)N)r)r�exc_type� exc_value�exc_tbr r r�__exit__"szListener.__exit__) �__name__� __module__�__qualname__rrr�propertyr rrr r r rrscCs3t�t�}}|j||f�t||�S)N)r�putr )r �_in�_outr r rr&sTcCs/t�t�}}t||�t||�fS)N)rr )Zduplex�a�br r rr,sc@sOeZdZdd�Zddd�Zdd�Zdd �Zd d�ZdS) r cCs<||_||_|j|_|_|j|_|_dS)N)rrr�sendZ send_bytesrZrecvZ recv_bytes)rrrr r rr3s zConnection.__init__gc Csc|jj�dkrdS|dkr)dS|jj�|jjj|�WdQRX|jj�dkS)NrTgF)rZqsizeZ not_empty�wait)rZtimeoutr r r�poll9s zConnection.pollcCsdS)Nr )rr r rrBszConnection.closecCs|S)Nr )rr r rrEszConnection.__enter__cCs|j�dS)N)r)rrrrr r rrHszConnection.__exit__N)rrrrr"rrrr r r rr 1s r ) �__all__ZqueuerZfamilies�objectrrrr r r r r� s