File manager - Edit - /opt/gsutil/third_party/urllib3/src/urllib3/util/__pycache__/wait.cpython-39.pyc
Back
a '�ofG � @ s� d dl mZ d dlZd dlZd dlmZ ddgZddddd dd �dd�Zddddd dd �d d�Zdd�dd�Z ddddd dd �dd�a ddd dd�dd�Zddd dd�dd�ZdS )� )�annotationsN)�partial� wait_for_read�wait_for_writeFz socket.socket�bool�float | None)�sock�read�write�timeout�returnc C sb |s|st d��g }g }|r&|�| � |r4|�| � ttj|||�}||�\}}} t|p^|p^| �S )N�2must specify at least one of read=True, write=True)�RuntimeError�appendr �selectr ) r r r r ZrcheckZwcheck�fnZrreadyZwreadyZxready� r �8/opt/gsutil/third_party/urllib3/src/urllib3/util/wait.py�select_wait_for_socket! s r c sd |s|st d��d}|r"|tjO }|r0|tjO }t�� � � �| |� ddd�� fdd�}t||��S )Nr r r zlist[tuple[int, int]])�tr c s | d ur| d9 } � � | �S )Ni� )�poll)r �Zpoll_objr r �do_pollJ s z%poll_wait_for_socket.<locals>.do_poll)r r �POLLIN�POLLOUTr �registerr )r r r r �maskr r r r �poll_wait_for_socket9 s r )r c C s8 zt �� } | �d� W n ttfy. Y dS 0 dS d S )Nr FT)r r �AttributeError�OSErrorr r r r �_have_working_pollR s r c C s( t � rtanttd�rtat| |||�S )Nr )r r �wait_for_socket�hasattrr r )r r r r r r r r! _ s r! )r r r c C s 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 q s c C s t | d|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# r$ r r r r x s )FFN)FFN)FFN)N)N) � __future__r r �socket� functoolsr �__all__r r r r! r r r r r r �<module> s&