codekingpro/portable-devtools
114k
1�
2 ��jG � �� � S SK Jr S SKrS SKrS SKJr SS/r S S
S jjr S S
S jjrSS jr S S
S jjq3SSS4 jjr SSS jjr g)� )� annotationsN)�partial�
wait_for_read�wait_for_writec �" � U( d U( d [ S5 e/ n/ nU( a UR U 5 U( a UR U 5 [ [ R XEU5 nU" U5 u pxn [ U=( d U=( d U 5 $ )N�2must specify at least one of read=True, write=True)� RuntimeError�appendr �select�bool)5�sock�read�write�timeout�rcheck�wcheck�fn�rready�wready�xreadys6 �WD:\code\apps\devtools\python\user_packages\Python313\site-packages\urllib3/util/wait.py�select_wait_for_socketr ! st � � ���O�P�P�
�F�
�F� ��
�
�d�� ��
�
�d�� 7�� � ��� 7�B� ��[��F�F� ��*�&�*�F� +�+� c � ^� U( d U( d [ S5 eSnU( a U[ R - nU( a U[ R - n[ R " 5 mTR X5 SU4S jjn[
U" U5 5 $ )Nr r c �6 >� U b U S- n TR U 5 $ )Ni� )�poll)�t�poll_objs �r �do_poll�%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 sm �� � ���O�P�P� �D� � ��
�
� �� � ���� ���{�{�}�H� ���d�!� �8 ��� � !�!r c �~ � [ R " 5 n U R S5 g! [ [ 4 a gf = f)Nr TF)r r �AttributeError�OSError)r s r �_have_working_pollr+ R s< � ���;�;�=���
�
�a�� ��
�G� $� ���s �&) �<�<c �| � [ 5 ( a [ qO[ [ S5 ( a [9 q[ XX#5 $ )Nr )r+ r' �wait_for_socket�hasattrr r )r
r r r s r r- r- _ s1 � � ���.�� ��� "� "�0�� �4�u� 6�6r c � � [ U SUS9$ )z~Waits for reading to be available on a given socket.10Returns True if the socket is readable, or False if the timeout expired.11T)r r �r- �r
r s r r r q s � � �4�d�G� <�<r c � � [ U SUS9$ )z~Waits for writing to be available on a given socket.12Returns True if the socket is readable, or False if the timeout expired.13T)r r r0 r1 s r r r x s � � �4�t�W� =�=r )FFN)14r
�
socket.socketr r r r r r! r" r )r" r )N)r
r3 r r! r" r )
�15__future__r r �socket� functoolsr �__all__r r' r+ r- r r � r r �<module>r9 s� �� "�
�
� � � ,�16-��8 �� � ,�17�,�18�,� �,� � ,�19 20� ,�4 �� � "�21�"�22�"� �"� � "�23 24� "�225� �� � 7�26�7�27�7� �7� � 7�28 29� 7�$=�>r