관리-도구
편집 파일: wait.cpython-312.pyc
� G��e � �� � d dl Z d dlZd dlZd dlmZ d dlmZ g d�Z G d� de � Z ej dk\ rd � Z nd � Z dd �Z dd �Zd � Zd� Zd� add�Zdd�Zy# e$ r d dlmZ Y �Lw xY w)� N)�partial)� monotonic)�time)�NoWayToWaitForSocketError� wait_for_read�wait_for_writec � � e Zd Zy)r N)�__name__� __module__� __qualname__� � ��/builddir/build/BUILDROOT/alt-python312-pip-23.3.1-1.el8.x86_64/opt/alt/python312/lib/python3.12/site-packages/pip/_vendor/urllib3/util/wait.pyr r s � �r r )� � c � � | |� S �Nr )�fn�timeouts r �_retry_on_intrr * s � ��'�{�r c �" � |� t d� }n t � |z } | |� S # t t j f$ rO}|j d t j k7 r� |t � z }|dk rd}|t d� k( rd }Y d }~�md }~ww xY w)N�infr )�floatr �OSError�select�error�args�errno�EINTR)r r �deadline�es r r r / s� � � �?� �U�|�H� �{�W�,�H�� ��'�{�"���V�\�\�*� ��6�6�!�9�� � �+�� &��� 4�G� ��{�"#�� �%��,�.�"&�� �� �s �& �B�AB � Bc �� � |s |s t d� �g }g }|r|j | � |r|j | � t t j |||� }t ||� \ }}} t |xs |xs | � 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 sy � � ���O�P�P� �F� �F� �� � �d�� �� � �d�� �� � ���� 7�B� +�B�� 8��F�F�F� ��*�&�*�F� +�+r c � �� |s |s t d� �d}|r|t j z }|r|t j z }t j � ��j | |� �fd�}t t ||� � S )Nr# r c �4 �� | �| dz } �j | � 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 so �� � ���O�P�P� �D� � �� � � �� � ���� ���{�{�}�H� ���d�D�!� � ��w��0� 1�1r c � � t d� �)Nz no select-equivalent available)r �r �kwargss r �null_wait_for_socketr> m s � � #�$D� E�Er c � � t j � } t | j d� y# t t f$ r Y yw xY w)Nr TF)r r2 r �AttributeErrorr )r4 s r �_have_working_pollrA q s> � ���;�;�=���x�}�}�a�(� �� �G� $� ���s �*- �?�?c �t � 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 ~ s3 � � ��.�� ��� "�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 s� �� � � � �'� � K�� � � �4 ���v� �� �.,�&2�(F� � ,� =�>��Y � '�&�'�s �A � A'�&A'