← Back
Editing: connection.cpython-313.pyc
� :��i> � �Z � / S Qr SSKJr S/r " S S\5 rS rS S jr " S S \5 rg) )�Client�Listener�Pipe� )�QueueNc �F � \ rS rSrS S jrS rS r\S 5 rS r S r S r g) r � Nc �$ � [ U5 U l g �N)r �_backlog_queue)�self�address�family�backlogs �G/opt/alt/python313/lib64/python3.13/multiprocessing/dummy/connection.py�__init__�Listener.__init__ s � � #�G�n��� c �B � [ U R R 5 6 $ r )� Connectionr �get�r s r �accept�Listener.accept s � ��4�.�.�2�2�4�5�5r c � � S U l g r �r r s r �close�Listener.close s � � "��r c � � U R $ r r r s r r �Listener.address s � ��"�"�"r c � � U $ r � r s r � __enter__�Listener.__enter__! � � �� r c �$ � U R 5 g r �r �r �exc_type� exc_value�exc_tbs r �__exit__�Listener.__exit__$ � � � � � � r r )NN� ) �__name__� __module__� __qualname__�__firstlineno__r r r �propertyr r" r+ �__static_attributes__r! r r r r s/ � �-�6�#� �#� �#��r r c �b � [ 5 [ 5 p!U R X!45 [ X5 $ r )r �putr )r �_in�_outs r r r ( s& � ������ �K�K�� � � �c� � r c �T � [ 5 [ 5 p![ X5 [ X!5 4$ r )r r )�duplex�a�bs r r r . s" � � �7�E�G�q� �a� �Z�� -� -�-r c �6 � \ rS rSrS rS S jrS rS rS rSr g) r �3 c �| � X l Xl UR =U l U l UR =U l U l g r )r8 r7 r6 �send� send_bytesr �recv� recv_bytes)r r7 r8 s r r �Connection.__init__5 s0 � �� ���&*�h�h�.�� �D�O�&)�g�g�-�� �D�Or c �2 � U R R 5 S:� a gUS:: a gU R R U R R R U5 S S S 5 U R R 5 S:� $ ! , ( d f N+= f)Nr T� F)r7 �qsize� not_empty�wait)r �timeouts r �poll�Connection.poll; sk � � �8�8�>�>� �a� �� �c�>�� �X�X� � � �H�H� � � #� #�G� ,� ��x�x�~�~� �!�#�#� � �s �&B� Bc � � g r r! r s r r �Connection.closeD s � � r c � � U $ r r! r s r r" �Connection.__enter__G r$ r c �$ � U R 5 g r r& r' s r r+ �Connection.__exit__J r- r )r7 r8 rB rC r@ rA N)rF ) r/ r0 r1 r2 r rK r r" r+ r4 r! r r r r 3 s � �.� $� ��r r )T) �__all__�queuer �families�objectr r r r r! r r �<module>rW s: �� +�� � �6���v� �,!� .� �� r
Save File
Cancel