� ���gG���ddlmZddlZddlZddlmZddgZ ddd�Z ddd�Zdd�Z ddd�a ddd�Z ddd�Z dS)�)� annotationsN)�partial� wait_for_read�wait_for_writeF�sock� socket.socket�read�bool�write�timeout� float | None�returnc��|s|std���g}g}|r|�|��|r|�|��ttj|||��}||��\}}} t |p|p| ��S)N�2must specify at least one of read=True, write=True)� RuntimeError�appendr�selectr ) rr r r �rcheck�wcheck�fn�rready�wready�xreadys �a/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/urllib3/util/wait.py�select_wait_for_socketr!s��� �Q��Q��O�P�P�P� �F� �F� ��� � �d���� ��� � �d���� ������ 7� 7�B��R��[�[��F�F�F� ��*�&�*�F� +� +�+�c���|s|std���d}|r|tjz}|r|tjz}tj�����||��d�fd� }t ||����S) Nrr�tr r�list[tuple[int, int]]c�<��|�|dz}��|��S)Ni�)�poll)r�poll_objs �r�do_pollz%poll_wait_for_socket.<locals>.do_pollJs#��� �=� ��I�A��}�}�Q���r)rr rr)rr�POLLIN�POLLOUTr!�registerr )rr r r �maskr#r"s @r�poll_wait_for_socketr(9s���� �Q��Q��O�P�P�P� �D� �� �� ��� �� ������{�}�}�H� ���d�D�!�!�!� � � � � � � ���� � � !� !�!rc�� tj��}|�d��dS#ttf$rYdSwxYw)NrTF)rr!�AttributeError�OSError)r"s r�_have_working_pollr,RsT����;�=�=��� � �a�����t�� �G� $�����u�u����s�(,�A�Ac��t��rtanttd��rt at||||��S)Nr)r,r(�wait_for_socket�hasattrrr)rr r r s rr.r._sD�����1�.��� ��� "� "�1�0�� �4��u�g� 6� 6�6rc�&�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.�rr s rrrqs�� �4�d�G� <� <� <�<rc�&�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 r1r2s rrrxs�� �4�t�W� =� =� =�=r)FFN) rrr r r r r r rr )rr )N)rrr r rr ) � __future__rr�socket� functoolsr�__all__rr(r,r.rr�rr�<module>r9s��"�"�"�"�"�"� � � � � � � � ������� �,� -��8�� � ,�,�,�,�,�4�� � "�"�"�"�"�2 � � � ��� � 7�7�7�7�7�$=�=�=�=�=�>�>�>�>�>�>�>r
Memory