Current File : /opt/hc_python/lib/python3.12/site-packages/urllib3/util/__pycache__//wait.cpython-312.pyc
�
I��gG � � � d dl mZ d dlZd dlZd dlmZ ddgZ d d
d�Z d d
d�Zdd�Z d d
d �a
ddd
�Z ddd �Z y)� )� annotationsN)�partial�
wait_for_read�wait_for_writec �� � |s
|s t d� �g }g }|r|j | � |r|j | � t t j |||� } ||� \ }}} t |xs |xs | � S )N�2must specify at least one of read=True, write=True)� RuntimeError�appendr �select�bool)
�sock�read�write�timeout�rcheck�wcheck�fn�rready�wready�xreadys
�@/opt/hc_python/lib/python3.12/site-packages/urllib3/util/wait.py�select_wait_for_socketr ! sx � � ���O�P�P�
�F�
�F� ��
�
�d�� ��
�
�d��
�� � ���� 7�B� ��[��F�F�F� ��*�&�*�F� +�+� c �� �� |s
|s t d� �d}|r|t j z }|r|t j z }t j � ��j | |� d�fd� }t
||� � S )Nr r c �4 �� | �| dz } �j | � S )Ni� )�poll)�t�poll_objs �r �do_pollz%poll_wait_for_socket.<locals>.do_pollJ s �� � �=�
��I�A��}�}�Q� � r )r � float | None�returnzlist[tuple[int, int]])r r �POLLIN�POLLOUTr �registerr )r
r r r �maskr r s @r �poll_wait_for_socketr& 9 so �� � ���O�P�P� �D� � ��
�
� �� � ���� ���{�{�}�H� ���d�D�!� �
��� � !�!r c �z � t j � } | j d� y# t t f$ r Y yw xY w)Nr TF)r r �AttributeError�OSError)r s r �_have_working_pollr* R s< � ���;�;�=���
�
�a�� ��
�G� $� ���s �%( �:�:c �l � t � rt ant t d� rt
at | |||� S )Nr )r* r& �wait_for_socket�hasattrr r )r
r r r s r r, r, _ s/ � � ��.�� ��� "�0�� �4��u�g� 6�6r 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 �r, �r
r s r r r q 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 r/ r0 s r r r x s � � �4�t�W� =�=r )FFN)
r
�
socket.socketr r r r r r r! r )r! r )N)r
r2 r r r! r )
�
__future__r r �socket� functoolsr �__all__r r& r* r, r r � r r �<module>r8 s� �� "�
�
� � � ,�
-��8 �� � ,�
�,�
�,� �,� � ,�
� ,�4 �� � "�
�"�
�"� �"� � "�
� "�2
� �� � 7�
�7�
�7� �7� � 7�
� 7�$=�>r 