| Server IP : 3.7.136.76 / Your IP : 216.73.216.142 Web Server : Apache/2.4.58 (Ubuntu) System : Linux ip-172-31-39-148 7.0.0-1010-aws #10~24.04.1-Ubuntu SMP PREEMPT Mon Jul 27 17:41:33 UTC 2026 x86_64 User : ubuntu ( 1000) PHP Version : 8.3.6 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /snap/core22/2955/lib/python3/dist-packages/urllib3/util/__pycache__/ |
Upload File : |
o
�~�` � @ s� d dl Z d dlZd dlZd dlmZ zd dlmZ W n ey) d dlmZ Y nw g d�ZG dd� de �Z
ej dkr@d d
� Z nd d
� Z dd
d�Z
ddd�Zdd� Zdd� Zdd� ad dd�Zd dd�ZdS ) � N)�partial)� monotonic)�time)�NoWayToWaitForSocketError�
wait_for_read�wait_for_writec @ s e Zd ZdS )r N)�__name__�
__module__� __qualname__� r r �3/usr/lib/python3/dist-packages/urllib3/util/wait.pyr s r )� � c C s | |�S �Nr )�fn�timeoutr r r �_retry_on_intr* � r c
C s� |d u r t d�}nt� | } z| |�W S ttjfyE } z"|jd tjkr(� |t� }|dk r3d}|t d�kr;d }W Y d }~qd }~ww )N�infTr )�floatr �OSError�select�error�args�errno�EINTR)r r �deadline�er r r r 0 s"
��Fc
C sd |s|st d��g }g }|r|�| � |r|�| � ttj|||�}t||�\}}} t|p0|p0| �S )N�2must specify at least one of read=True, write=True)� RuntimeError�appendr r r �bool)
�sock�read�writer �rcheck�wcheckr �rready�wready�xreadyr r r �select_wait_for_socketG s
r* c s^ |s|st d��d}|r|tjO }|r|tjO }t�� � � �| |� � fdd�}tt||��S )Nr r c s | d ur| d9 } � � | �S )Ni� )�poll)�t��poll_objr r �do_pollf s
z%poll_wait_for_socket.<locals>.do_poll)r r �POLLIN�POLLOUTr+ �registerr! r )r" r# r$ r �maskr/ r r- r �poll_wait_for_socketZ s
r4 c O s t d��)Nz no select-equivalent available)r �r �kwargsr r r �null_wait_for_socketn r r7 c C s4 z
t �� } t| jd� W dS ttfy Y dS w )Nr FT)r r+ r �AttributeErrorr r- r r r �_have_working_pollr s ��r9 c O s. t � rtan
ttd�rtantat| i |��S )Nr )r9 r4 �wait_for_socket�hasattrr r* r7 r5 r r r r: s
r: c C � t | d|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 r r r r � � r c C r< )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= r> r r r r � r? r )FFNr )r r �sys� functoolsr r r � ImportError�__all__� Exceptionr � version_infor r* r4 r7 r9 r: r r r r r r �<module> s* �