OwlCyberSecurity - MANAGER
Edit File: wait.cpython-312.pyc
� ȓ�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