File: //proc/self/root/usr/lib/python3.6/site-packages/redis/__pycache__/_compat.cpython-36.pyc
3
be�^B � @ sr d Z ddlZddlZddlZdd� Zdd� Zdd� Zejd d k s^ejd d kr�ejd
d k r�ddlZd d
� Z dd� Z
dd� Z ndd� Z
dd� Z ejd d k �rddl Z yddl
mZ W n$ ek
r� G dd� de�ZY nX d5Zdd� Zee
�Z
ee �Z ee�Zee�Zee�Zejd d k �r�dd lmZ dd lmZmZ dd lmZmZ dd lm Z dd l m Z d!d"� Z d#d$� Z d%d&� Z!d'd(� Z"d)d*� Z#d+d,� Z$e%Z%e&Z&e'Z'e(Z(e)Z)ej*Z+nxdd-l,mZmZmZ dd.lm Z dd l-m Z d/d$� Z d0d&� Z!d1d(� Z"d2d*� Z#d3d"� Z e$Z$e.Z%e/Ze0Ze1Z&e2Z'e2Z(e3Z)e+Z+ydd4l-m4Z4m5Z5m6Z6 W n* ek
�rl dd4l m4Z4m5Z5m6Z6 Y nX dS )6z5Internal module for Python 2 backwards compatibility.� Nc O s | j ||�S )N)�sendall)�sock�args�kwargs� r � /usr/lib/python3.6/_compat.pyr s r c O s | j ||�S )N)�shutdown)r r r r r r r s r c O s | j |f|�|�S )N)Z wrap_socket)�contextr r r r r r �ssl_wrap_socket s r
� � � c O s� d\}}d}y | j � }W n tk
r, Y nX |r>tj� | }z�x�|rx|rxtj� }||krjtjtjd��n| j|| � yd}|||�S tjk
r� } z|jd tj kr�wB� W Y d d }~X qBX qBW W d |r�| j|� X d S )N� Fz timed outTr )Nr )
Z
gettimeout�AttributeError�time�socket�error�errnoZ EWOULDBLOCKZ
settimeoutr ZEINTR) �s�funcr r �timeoutZdeadlineZ attemptedZnow�er r r �_retryable_call s0
r c O s t | | jf|�|�S )N)r �recv)r r r r r r r @ s r c O s t | | jf|�|�S )N)r � recv_into)r r r r r r r C s r c O s | j ||�S )N)r )r r r r r r r G s c O s | j ||�S )N)r )r r r r r r r J s )�SSLErrorc @ s e Zd ZdZdS )� _SSLErrorz4A replacement in case ssl.SSLError is not available.N)�__name__�
__module__� __qualname__�__doc__r r r r r V s r �!The handshake operation timed out� The read operation timed out� The write operation timed outc s t j� �� fdd��}|S )Nc sv y
�| |�S t k
rp } zJt|j�dkr8t|jd �p:d� t� fdd�tD ��r^tj|j� �� W Y d d }~X nX d S )Nr r � c 3 s | ]}|� kV qd S )Nr )�.0�x)�messager r � <genexpr>g s z7_handle_ssl_timeout.<locals>.wrapper.<locals>.<genexpr>)r �lenr �unicode�any� _EXPECTED_SSL_TIMEOUT_MESSAGESr r )r r r )r )r' r �wrappera s
z$_handle_ssl_timeout.<locals>.wrapper)� functools�wraps)r r- r )r r �_handle_ssl_timeout` s
r0 )�unquote)�parse_qs�urlparse)�imap�izip)�letters)�Queuec G s: yt | f|�� S tk
r4 t| �jd�}t |�S X dS )z* return the unicode representation of obj Z
string_escapeN)r* �UnicodeDecodeError�str�encode)�objr Z
ascii_textr r r � safe_unicode{ s
r< c C s | j � S )N)� iteritems)r& r r r r= � s r= c C s | j � S )N)�iterkeys)r& r r r r> � s r> c C s | j � S )N)�
itervalues)r& r r r r? � s r? c C s t | t�r| S | jdd�S )Nzutf-8�replace)�
isinstancer9 r: )r& r r r � nativestr� s rB c C s | j � S )N)�next)r& r r r rC � s rC )r2 r1 r3 )�
ascii_lettersc C s t | j� �S )N)�iter�items)r& r r r r= � s c C s t | j� �S )N)rE �keys)r& r r r r> � s c C s t | j� �S )N)rE �values)r& r r r r? � s c C s t | t�r| S | jdd�S )Nzutf-8r@ )rA r9 �decode)r& r r r rB � s c C s t | t�r| jdd�} t| �S )Nzutf-8r@ )rA �bytesrI r9 )�valuer r r r< � s
)� LifoQueue�Empty�Full)r! r" r# )7r r r �sysr r r
� version_infor r r r r. Zsslr r � ImportError� Exceptionr, r0 Zurllibr1 r3 r2 � itertoolsr4 r5 �stringr6 rD r7 r< r= r> r? rB rC ZunichrZxrangeZ
basestringr* Zlongr �BlockingIOErrorZ urllib.parseZqueue�chr�map�zip�ranger9 �intrL rM rN r r r r �<module> s� %