File: //usr/local/CyberCP/lib/python3.10/site-packages/asyncssh/__pycache__/compression.cpython-310.pyc
o
�hB � @ sl U d Z ddlmZmZmZ ddlZg Zee ed< g Z ee ed< i Z
i Z i Z G dd� d�Z
G dd � d �Zeg ee
f Zeg ee f Zd'd d �ZG d
d� de
�ZG dd� de�Zdededededed
df dd�Zd
ee fdd�Zd
ee fdd�Zded
efd d �Zded
ee
fd d �Zded
ee fd d!�Zed"eed#d$� ed%eed$d$� ed&eed#d#� dS )(zSSH compression handlers� )�Callable�List�OptionalN� _cmp_algs�_default_cmp_algsc @ �& e Zd ZdZdedee fdd�ZdS )�
Compressorz Base class for data compressor�data�returnc C � t �)z
Compress data��NotImplementedError��selfr � r �G/usr/local/CyberCP/lib/python3.10/site-packages/asyncssh/compression.py�compress& � zCompressor.compressN)�__name__�
__module__� __qualname__�__doc__�bytesr r r r r r r # � r c @ r )� Decompressorz Base class for data decompressorr r
c C r )zDecompress datar r r r r �
decompress/ r zDecompressor.decompressN)r r r r r r r r r r r r , r r r
c C s dS )z*Compressor/decompressor for no compressionNr r r r r �_none9 r r c @ �0 e Zd ZdZd dd�Zdedee fdd�ZdS )
�
_ZLibCompressz9Wrapper class to force a sync flush and handle exceptionsr
Nc C � t �� | _d S �N)�zlib� compressobj�_comp�r r r r �__init__B � z_ZLibCompress.__init__r c C s4 z| j �|�| j �tj� W S tjy Y dS w )z4Compress data using zlib compression with sync flushN)r# r �flushr! � Z_SYNC_FLUSH�errorr r r r r E s
��z_ZLibCompress.compress�r
N)r r r r r% r r r r r r r r ? �
r c @ r )
�_ZLibDecompressz"Wrapper class to handle exceptionsr
Nc C r r )r! �
decompressobj�_decompr$ r r r r% R r& z_ZLibDecompress.__init__r c C s& z| j �|�W S tjy Y dS w )z&Decompress data using zlib compressionN)r. r r! r) r r r r r U s
�z_ZLibDecompress.decompressr* )r r r r r% r r r r r r r r, O r+ r, �alg�
compressor� decompressor�
after_auth�defaultc C s4 t �| � |r t�| � |t| < |t| < |t| < dS )z Register a compression algorithmN)r �appendr � _cmp_params�_cmp_compressors�_cmp_decompressors)r/ r0 r1 r2 r3 r r r �register_compression_alg^ s
r8 c C � t S )z'Return supported compression algorithms)r r r r r �get_compression_algsn r r: c C r9 )z%Return default compression algorithms)r r r r r � get_default_compression_algst r r; c C s t | S )z�Get parameters of a compression algorithm
This function returns whether or not a compression algorithm should
be delayed until after authentication completes.
)r5 �r/ r r r �get_compression_paramsz s r= c C �
t | � S )zwReturn an instance of a compressor
This function returns an object that can be used for data compression.
)r6 r< r r r �get_compressor� �
r? c C r> )z{Return an instance of a decompressor
This function returns an object that can be used for data decompression.
)r7 r< r r r �get_decompressor� r@ rA s noneFTs zlib@openssh.coms zlibr* )r �typingr r r r! r r �__annotations__r r5 r6 r7 r r �_CompressorType�_DecompressorTyper r r, �boolr8 r: r; r= r? rA r r r r �<module> sL
���
�
���