Edit File: wait.cpython-311.pyc
� 4�gh � �� � d dl Z d dlZd dlZd dlmZ d dlmZ n# e$ r d dlmZ Y nw xY wg d�Z G d� de � � Z ej dk rd � Z nd � Z dd �Z dd �Zd� Zd� Zd� add�Zdd�ZdS )� N)�partial)� monotonic)�time)�NoWayToWaitForSocketError� wait_for_read�wait_for_writec � � e Zd ZdS )r N)�__name__� __module__� __qualname__� � �}/builddir/build/BUILD/imunify360-venv-2.6.0/opt/imunify360/venv/lib/python3.11/site-packages/pip/_vendor/urllib3/util/wait.pyr r s � � � � � ��Dr r )� � c � � | |� � S �Nr )�fn�timeouts r �_retry_on_intrr * s � ��r�'�{�{�r c �< � |�t d� � }nt � � |z } | |� � S # t t j f$ rT}|j d t j k r� |t � � z }|dk rd}|t d� � k rd }Y d }~�rd }~ww xY w)N�infTr )�floatr �OSError�select�error�args�errno�EINTR)r r �deadline�es r r r / s� � � �?� �U�|�|�H�H� �{�{�W�,�H� � ��r�'�{�{�"���V�\�*� � � ��6�!�9�� �+�+�� &���� 4�G� ��{�{�"#�� �%��,�,�.�.�"&�� �H�H�H�H����� ���s � 1 �B�A B�BFc � � |s|st d� � �g }g }|r|� | � � |r|� | � � t t j |||� � }t ||� � \ }}} t |p|p| � � S )N�2must specify at least one of read=True, write=True)� RuntimeError�appendr r r �bool) �sock�read�writer �rcheck�wcheckr �rready�wready�xreadys r �select_wait_for_socketr/ F s� � � � Q�� Q��O�P�P�P� �F� �F� � �� � �d���� � �� � �d���� �� ���� 7� 7�B� +�B�� 8� 8��F�F�F� ��*�&�*�F� +� +�+r c � �� |s|st d� � �d}|r|t j z }|r|t j z }t j � � ��� | |� � �fd�}t t ||� � � � S )Nr# r c �< �� | �| dz } �� | � � S )Ni� )�poll)�t�poll_objs �r �do_pollz%poll_wait_for_socket.<locals>.do_polle s# �� � �=� ��I�A��}�}�Q� � � r )r$ r �POLLIN�POLLOUTr2 �registerr& r )r' r( r) r �maskr5 r4 s @r �poll_wait_for_socketr: Y s� �� � � Q�� Q��O�P�P�P� �D� � � �� � �� � � ��� ���{�}�}�H� ���d�D�!�!�!� � � � � � ��w��0�0� 1� 1�1r c � � t d� � �)Nz no select-equivalent available)r �r �kwargss r �null_wait_for_socketr> m s � � #�$D� E� E�Er c � � t j � � } t | j d� � dS # t t f$ r Y dS w xY w)Nr TF)r r2 r �AttributeErrorr )r4 s r �_have_working_pollrA q sT � ���;�=�=���x�}�a�(�(�(� �t�� �G� $� � � ��u�u����s �(, �A� Ac � � t � � rt an$t t d� � rt ant at | i |��S )Nr )rA r: �wait_for_socket�hasattrr r/ r> r< s r rC rC ~ sJ � � ��� /�.��� ��� "� "� /�0���.�� �D� +�F� +� +�+r c �& � t | d|�� � S )z�Waits for reading to be available on a given socket. Returns True if the socket is readable, or False if the timeout expired. T)r( r �rC �r' r s r r r � s � � �4�d�G� <� <� <�<r c �& � t | d|�� � S )z�Waits for writing to be available on a given socket. Returns True if the socket is readable, or False if the timeout expired. T)r) r rF rG s r r r � s � � �4�t�W� =� =� =�=r )FFNr )r r �sys� functoolsr r r � ImportError�__all__� Exceptionr � version_infor r/ r: r> rA rC r r r r r �<module>rO st �� � � � � � � � � � � � � � � � � � �'� � � � � � � ��� '� '� '�&�&�&�&�&�&�&�&�'���� K� J� J�� � � � � � � � � �4 ��v� � �� � � � � � �.,� ,� ,� ,�&2� 2� 2� 2�(F� F� F� � � � ,� ,� ,� =� =� =� =�>� >� >� >� >� >s � � )�)
Back to File Manager