OwlCyberSecurity - MANAGER
Edit File: connection.cpython-312.opt-1.pyc
� �� h> � �X � g d �Z ddlmZ dgZ G d� de� Zd� Zd d�Z G d� d e� Zy) )�Client�Listener�Pipe� )�QueueNc �< � e Zd Zdd�Zd� Zd� Zed� � Zd� Zd� Z y) r Nc �$ � t |� | _ y �N)r �_backlog_queue)�self�address�family�backlogs �G/opt/alt/python312/lib64/python3.12/multiprocessing/dummy/connection.py�__init__zListener.__init__ s � � #�G�n��� c �B � t | j j � � S r )� Connectionr �get�r s r �acceptzListener.accept s � ��4�.�.�2�2�4�5�5r c � � d | _ y r �r r s r �closezListener.close s � � "��r c � � | j S r r r s r r zListener.address s � ��"�"�"r c � � | S r � r s r � __enter__zListener.__enter__! � � �� r c �$ � | j � y r �r �r �exc_type� exc_value�exc_tbs r �__exit__zListener.__exit__$ � � � � � � r )NN� ) �__name__� __module__� __qualname__r r r �propertyr r r% r r r r r s/ � �-�6�#� �#� �#��r r c �h � t � t � }}| j ||f� t ||� S r )r �putr )r �_in�_outs r r r ( s, � ������C� �K�K��s� � � �c�4� � r c �Z � t � t � }}t ||� t ||� fS r )r r )�duplex�a�bs r r r . s( � � �7�E�G�q�A� �a�� �Z��1� -� -�-r c �, � e Zd Zd� Zdd�Zd� Zd� Zd� Zy)r c � � || _ || _ |j x| _ | _ |j x| _ | _ y r )r/ r. r- �send� send_bytesr �recv� recv_bytes)r r. r/ s r r zConnection.__init__5 s4 � ��� ����&*�h�h�.�� �D�O�&)�g�g�-�� �D�Or c �$ � | j j � dkD ry|dk ry| j j 5 | j j j |� d d d � | j j � dkD S # 1 sw Y �&xY w)Nr T� F)r. �qsize� not_empty�wait)r �timeouts r �pollzConnection.poll; sk � � �8�8�>�>� �a� �� �c�>�� �X�X� � � �H�H� � � #� #�G� ,� ��x�x�~�~� �!�#�#� � �s �&B�Bc � � y r r r s r r zConnection.closeD s � � r c � � | S r r r s r r zConnection.__enter__G r r c �$ � | j � y r r r! s r r% zConnection.__exit__J r& r N)r; )r( r) r* r r@ r r r% r r r r r 3 s � �.� $� ��r r )T) �__all__�queuer �families�objectr r r r r r r �<module>rH s: �� +�� � �6���v� �,!� .� �� r