Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/redis/__pycache__/_compat.cpython-39.pyc
Ðазад
a a�hB � @ sn d Z ddlZddlZddlZdd� Zdd� Zdd� Zejd d k s^ejd d kr�ejd dk r�ddlZdd � Z dd� Z dd� Zndd� Z dd� Zejd d k �rddlZzddl mZ W n" ey� G dd� de�ZY n0 dZdd� Zee �Z ee�Zee�Zee�Zee�Zejd d k �r�ddlmZ ddlmZmZ ddlmZmZ ddlmZ ddlmZ dd � Zd!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,lmZ ddl-mZ d-d"� Z d.d$� Z!d/d&� Z"d0d(� Z#d1d � Ze$Z$e.Z%e/Ze0Ze1Z&e2Z'e2Z(e3Z)e+Z+zdd2l-m4Z4m5Z5m6Z6 W n( e�yh dd2lm4Z4m5Z5m6Z6 Y n0 dS )3z5Internal module for Python 2 backwards compatibility.� Nc O s | j |i |��S �N)�sendall��sock�args�kwargs� r �}/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/redis/_compat.pyr s r c O s | j |i |��S r )�shutdownr r r r r s r c O s | j |g|�R i |��S r )�wrap_socket)�contextr r r r r r �ssl_wrap_socket s r � � � c O s d\}}d}z| � � }W n ty* Y n0 |r<t�� | }z�|rt|rtt�� }||krft�tjd��n| �|| � z$d}||i |��W W |r�| �|� S tjy� } z*|jd tj kr�W Y d }~q>� W Y d }~q>d }~0 0 q>W |r�| �|� n|�r| �|� 0 d S )N)Ng Fz timed outTr ) � gettimeout�AttributeError�time�socket�error�errno�EWOULDBLOCK� settimeoutr ZEINTR) �s�funcr r �timeout�deadlineZ attempted�now�er r r �_retryable_call s8 ��r c O s t | | jg|�R i |��S r )r �recvr r r r r @ s r c O s t | | jg|�R i |��S r )r � recv_intor r r r r! C s r! c O s | j |i |��S r )r r r r r r G s c O s | j |i |��S 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# )z!The handshake operation timed outzThe read operation timed outzThe write operation timed outc s t �� �� fdd��}|S )Nc s~ z�| i |��W S t yx } zPt|j�dkr<t|jd �p>d� t� fdd�tD ��rbtj|j� �� W Y d }~n d }~0 0 d S )Nr r � c 3 s | ]}|� v V qd S r r )�.0�x��messager r � <genexpr>g � 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 r4 r r3 r �_handle_ssl_timeout` s r7 )�unquote)�parse_qs�urlparse)�imap�izip)�letters)�Queuec G s@ zt | g|�R � W S ty: t| ��d�}t |� Y S 0 dS )z* return the unicode representation of obj Z string_escapeN)r0 �UnicodeDecodeError�str�encode)�objr Z ascii_textr r r �safe_unicode{ s rC c C s | � � S r )� iteritems�r* r r r rD � s rD c C s | � � S r )�iterkeysrE r r r rF � s rF c C s | � � S r )� itervaluesrE r r r rG � s rG c C s t | t�r| S | �dd�S �Nzutf-8�replace)� isinstancer@ rA rE r r r � nativestr� s rK c C s | � � S r )�nextrE r r r rL � s rL )r9 r8 r: )� ascii_lettersc C s t | �� �S r )�iter�itemsrE r r r rD � s c C s t | �� �S r )rN �keysrE r r r rF � s c C s t | �� �S r )rN �valuesrE r r r rG � s c C s t | t�r| S | �dd�S rH )rJ r@ �decoderE r r r rK � s c C s t | t�r| �dd�} t| �S rH )rJ �bytesrR r@ )�valuer r r rC � s )� LifoQueue�Empty�Full)7r'