| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib64/python3.11/multiprocessing/dummy/__pycache__/ |
Upload File : |
�
�=Og> � �f � g d �Z ddlmZ dgZ G d� de� � Zd� Zd d�Z G d � d
e� � ZdS ) )�Client�Listener�Pipe� )�QueueNc �D � e Zd Zd d�Zd� Zd� Zed� � � Zd� Zd� Z dS )
r N� c �. � t |� � | _ d S �N)r �_backlog_queue)�self�address�family�backlogs �9/usr/lib64/python3.11/multiprocessing/dummy/connection.py�__init__zListener.__init__ s � � #�G�n�n����� c �B � t | j � � � � S r
)�
Connectionr �get�r s r �acceptzListener.accept s � ��4�.�2�2�4�4�5�5r c � � d | _ d S 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 �. � | � � � d S r
�r �r �exc_type� exc_value�exc_tbs r �__exit__zListener.__exit__$ � � � �
�
� � � � � r )NNr )
�__name__�
__module__� __qualname__r r r �propertyr
r r& r r r r r s � � � � � �-� -� -� -�6� 6� 6�#� #� #� �#� #� �X�#�� � �� � � � r r c � � t � � t � � }}| � ||f� � t ||� � S r
)r �putr )r
�_in�_outs r r r ( s9 � ��������C� �K�K��s� � � � � �c�4� � � r Tc �z � t � � t � � }}t ||� � t ||� � fS r
)r r )�duplex�a�bs r r r . s2 � � �7�7�E�G�G�q�A� �a�� � �Z��1� -� -� -�-r c �. � e Zd Zd� Zdd�Zd� Zd� Zd� ZdS ) r c �n � || _ || _ |j x| _ | _ |j x| _ | _ d S r
)r/ r. r- �send�
send_bytesr �recv�
recv_bytes)r r. r/ s r r zConnection.__init__5 s4 � ��� ����&*�h�.�� �D�O�&)�g�-�� �D�O�O�Or � c � � | j � � � dk rdS |dk rdS | j j 5 | j j � |� � d d d � � n # 1 swxY w Y | j � � � dk S )Nr Tr: F)r. �qsize� not_empty�wait)r �timeouts r �pollzConnection.poll; s� � � �8�>�>� � �a� � ��4� �c�>�>��5�
�X�
� -� -� �H� � #� #�G� ,� ,� ,� -� -� -� -� -� -� -� -� -� -� -���� -� -� -� -��x�~�~� � �!�#�#s � A � A$�'A$c � � d S r
r r s r r zConnection.closeD s � � �r c � � | S r
r r s r r zConnection.__enter__G r r c �. � | � � � d S 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 sd � � � � � �.� .� .� $� $� $� $�
�
�
�� � �� � � � r r )T) �__all__�queuer �families�objectr r r r r r r �<module>rH s� �� +�
*�
*�� � � � � � �
�6��� � � � �v� � � �,!� !� !� .� .� .� .�
� � � � �� � � � � r