File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/compression_utils.cpython-310.pyc
Back
o ;j�= � @ s U d dl Z d dlZd dlZd dlmZmZ d dlmZ d dlm Z m Z m Z m Z m Z ejdkr5d dlmZ nd dlmZ eeedd f Zzzd dlZW n eyW d dlZY nw d ZW n eyf d ZY nw zejd krtd d lmZ nd d lmZ d ZW n ey� d ZY nw dZ d Z dZ G dd� de �Z G dd� de �Z G dd� de �Z!G dd� de d d�Z"G dd� d�Z#e#e�Z$e#e%d< d e!d dfd d �Z& d.d e'dB d!e(d e)fd"d#�Z*G d$d%� d%e�Z+G d&d'� d'�Z,G d(d)� d)e+�Z-G d*d+� d+e+�Z.G d,d-� d-e+�Z/dS )/� N)�ABC�abstractmethod)�Executor)�Any�Final�Protocol� TypedDict�cast)� � )�Buffer)�Unionzmemoryview[int]zmemoryview[bytes]TF)r � )�ZstdDecompressori ���c @ s2 e Zd Zdedefdd�Zd dedefdd�Zd S ) �ZLibCompressObjProtocol�data�returnc C � d S �N� ��selfr r r �M/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/compression_utils.py�compress, � z ZLibCompressObjProtocol.compress.�modec C r r r �r r r r r �flush- r z ZLibCompressObjProtocol.flushN�.)�__name__� __module__� __qualname__r �bytesr �intr r r r r r + s r c @ sn e Zd Zddededefdd�Zddedefdd �Zede fd d ��Z edefd d ��Z edefdd��Z dS )�ZLibDecompressObjProtocol.r � max_lengthr c C r r r �r r r& r r r � decompress1 r z$ZLibDecompressObjProtocol.decompress�lengthc C r r r �r r) r r r r 2 r z ZLibDecompressObjProtocol.flushc C r r r �r r r r �eof4 � z ZLibDecompressObjProtocol.eofc C r r r r+ r r r �unconsumed_tail7 r- z)ZLibDecompressObjProtocol.unconsumed_tailc C r r r r+ r r r � unused_data: r- z%ZLibDecompressObjProtocol.unused_dataNr ) r r! r" r r$ r# r( r �property�boolr, r. r/ r r r r r% 0 s r% c @ s� e Zd ZU eed< eed< eed< eed< eed< ddeded ed ed ed ed B defdd�Z dd ed edefdd�Z dded edede fdd�Z dd ededede fdd�Z d S )�ZLibBackendProtocol� MAX_WBITS� Z_FULL_FLUSH� Z_SYNC_FLUSH� Z_BEST_SPEED�Z_FINISH.�level�method�wbits�memLevel�strategy�zdictNr c C r r r )r r8 r9 r: r; r< r= r r r � compressobjE s z ZLibBackendProtocol.compressobjc C r r r )r r: r= r r r � decompressobjN � z!ZLibBackendProtocol.decompressobjr c C r r r )r r r8 r: r r r r R r@ z ZLibBackendProtocol.compress�bufsizec C r r r )r r r: rA r r r r( U r@ z ZLibBackendProtocol.decompress)......)..) r r! r" r$ �__annotations__r r r> r% r? r# r r( r r r r r2 > sn ������� � ��� ����� ������r2 c @ s& e Zd ZU eed< eed< eed< dS )�CompressObjArgsr: r< r8 N)r r! r" r$ rB r r r r rC Z s rC )�totalc @ s� e Zd Zdefdd�Zedefdd��Zedefdd��Z edefd d ��Z edefd d ��Z edefd d��Z edefdd��Z dededefdd�Zdededefdd�Zdedededefdd�Zdedededefdd�Zd edefd d �Zd S ) �ZLibBackendWrapper� _zlib_backendc C s || _ d S r )rF )r rF r r r �__init__a � zZLibBackendWrapper.__init__r c C s t | jdd�S )Nr Z undefined��getattrrF r+ r r r �named s zZLibBackendWrapper.namec C � | j jS r )rF r3 r+ r r r r3 h � z ZLibBackendWrapper.MAX_WBITSc C rL r )rF r4 r+ r r r r4 l rM z ZLibBackendWrapper.Z_FULL_FLUSHc C rL r )rF r5 r+ r r r r5 p rM z ZLibBackendWrapper.Z_SYNC_FLUSHc C rL r )rF r6 r+ r r r r6 t rM z ZLibBackendWrapper.Z_BEST_SPEEDc C rL r )rF r7 r+ r r r r7 x rM zZLibBackendWrapper.Z_FINISH�args�kwargsc O � | j j|i |��S r )rF r> �r rN rO r r r r> | � z ZLibBackendWrapper.compressobjc O rP r )rF r? rQ r r r r? rR z ZLibBackendWrapper.decompressobjr c O � | j j|g|�R i |��S r )rF r �r r rN rO r r r r � � zZLibBackendWrapper.compressc O rS r )rF r( rT r r r r( � rU z ZLibBackendWrapper.decompress�attrnamec C s t | j|�S r rI )r rV r r r � __getattr__� � z ZLibBackendWrapper.__getattr__N)r r! r" r2 rG r0 �strrK r$ r3 r4 r5 r6 r7 r r r> r% r? r r# r r( rW r r r r rE ` s& rE � ZLibBackend�new_zlib_backendr c C s | t _d S r )rZ rF )r[ r r r �set_zlib_backend� rH r\ �encoding�suppress_deflate_headerc C s$ | dkr dt j S |rt j S t jS )N�gzip� )rZ r3 )r] r^ r r r �encoding_to_mode� s ra c @ sz e Zd ZdefdedB dedB fdd�Zeefde dede fd d ��Z efde dede fd d �Z e edefd d���ZdS )�DecompressionBaseHandlerN�executor�max_sync_chunk_sizec C s || _ || _dS )z&Base class for decompression handlers.N)� _executor�_max_sync_chunk_size�r rc rd r r r rG � s z!DecompressionBaseHandler.__init__r r& r c C � dS ��Decompress the given data.Nr r' r r r �decompress_sync� r z(DecompressionBaseHandler.decompress_syncc � sD �| j dur t|�| j kr t�� �| j| j||�I dH S | �||�S ri )rf �len�asyncioZget_event_loop�run_in_executorre rk r' r r r r( � s � � z#DecompressionBaseHandler.decompressc C rh )z7Return True if more output is available by passing b"".Nr r+ r r r �data_available� r z'DecompressionBaseHandler.data_available)r r! r" �MAX_SYNC_CHUNK_SIZEr r$ rG r �ZLIB_MAX_LENGTH_UNLIMITEDr r# rk r( r0 r1 ro r r r r rb � s8 �� � ��� ���� � rb c @ s� e Zd ZddddddefdedB dededB dedB dedB dedB d edB fd d �Zd e d e fdd�Z d e d e fdd�Z ddedB d e fdd�Z dS )�ZLibCompressorNFr] r^ r8 r: r< rc rd c C sv || _ || _|d u rt||�n|| _ttj�| _i }| j|d< |d ur'||d< |d ur/||d< | jjdi |��| _d S )Nr: r< r8 r ) re rf ra �_moderE rZ rF r> � _compressor) r r] r^ r8 r: r< rc rd rO r r r rG � s �� zZLibCompressor.__init__r r c C s | j �|�S r )rt r r r r r � compress_sync� rX z ZLibCompressor.compress_syncc � sF �| j duo t|�| j k}|r t�� �| j| jj|�I dH S | �|�S )a Compress the data and returned the compressed bytes. Note that flush() must be called after the last call to compress() If the data size is large than the max_sync_chunk_size, the compression will be done in the executor. Otherwise, the compression will be done in the event loop. **WARNING: This method is NOT cancellation-safe when used with flush().** If this operation is cancelled, the compressor state may be corrupted. The connection MUST be closed after cancellation to avoid data corruption in subsequent compress operations. For cancellation-safe compression (e.g., WebSocket), the caller MUST wrap compress() + flush() + send operations in a shield and lock to ensure atomicity. N) rf rl rm Zget_running_looprn re rt r ru )r r Zshould_use_executorr r r r � s � � � zZLibCompressor.compressr c C s | j �|dur |�S | jj�S )a Flush the compressor synchronously. **WARNING: This method is NOT cancellation-safe when called after compress().** The flush() operation accesses shared compressor state. If compress() was cancelled, calling flush() may result in corrupted data. The connection MUST be closed after compress() cancellation. For cancellation-safe compression (e.g., WebSocket), the caller MUST wrap compress() + flush() + send operations in a shield and lock to ensure atomicity. N)rt r rF r7 r r r r r � s ��zZLibCompressor.flushr )r r! r" rp rY r1 r$ r rG r r# ru r r r r r r rr � s4 ������� � rr c s� e Zd ZdddefdedB dededB dedB f� fdd� Ze fd e d ed e fd d �Z dded e fdd�Z ed efdd��Zed efdd��Z� ZS )�ZLibDecompressorNFr] r^ rc rd c sJ t � j||d� t||�| _ttj�| _| jj| jd�| _d| _ d | _ d S )N�rc rd �r: F) �superrG ra rs rE rZ rF r? � _decompressor� _last_empty�_pending_unused_data)r r] r^ rc rd �� __class__r r rG s zZLibDecompressor.__init__r r& r c C s� | j d ur| j t|� }d | _ | j�| jj| |�}|dk| _| jjr^| jjr^| jj}| jj | j d�| _|t krF|t |�8 }|dkrF|| _ n| j�||�}|dk| _||7 }| jjr^| jjs'| jjrr| j | jj krr| jj | j d�| _|S )N� rx r )r| r# rz r( r. r{ r, r/ rF r? rs rq rl r3 )r r r& �resultZunused�chunkr r r rk s, � �z ZLibDecompressor.decompress_syncr r) c C s |dkr | j �|�S | j �� S �Nr )rz r r* r r r r ? s ���zZLibDecompressor.flushc C s t | jj�p| j p| jd uS r )r1 rz r. r{ r| r+ r r r ro F s ��z ZLibDecompressor.data_availablec C rL r )rz r, r+ r r r r, N rM zZLibDecompressor.eof)r )r r! r" rp rY r1 r r$ rG rq r r# rk r r0 ro r, � __classcell__r r r} r rv s6 �������� �$rv c �r e Zd ZdefdedB dedB ddf� fdd� Zefdedede fd d �Z de fd d �Z e de fd d��Z� ZS )�BrotliDecompressorNrc rd r c s0 t std��t�� | _d| _t� j||d� dS )z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` moduleFrw N)� HAS_BROTLI� RuntimeError�brotliZ Decompressor�_objr{ ry rG rg r} r r rG W s � zBrotliDecompressor.__init__r r& c C s| t | jd�r |tkrtt| j�|��}n#tt| j�||��}n|tkr-tt| j�|��}n tt| j�||��}|dk| _|S )rj r( r )�hasattrr� rq r r# r( �processr{ )r r r& r� r r r rk f s z"BrotliDecompressor.decompress_syncc C s t | jd�rtt| j�� �S dS )zFlush the decompressor.r r )r� r� r r# r r+ r r r r x s zBrotliDecompressor.flushc C s | j �� o | j S r )r� Z is_finishedr{ r+ r r r ro ~ s z!BrotliDecompressor.data_available�r r! r" rp r r$ rG rq r r# rk r r0 r1 ro r� r r r} r r� S s* ������� �r� c r� )�ZSTDDecompressorNrc rd r c s. t std��t� | _d | _t� j||d� d S )NzOThe zstd decompression is not available. Please install `backports.zstd` modulerw )�HAS_ZSTDr� r r� r| ry rG rg r} r r rG � s �zZSTDDecompressor.__init__r r& c C s� |t krtn|}| jd ur| j| }d | _| j�||�}| jjrO| jjrO| jj}t� | _|tkr>|t|�8 }|dkr>|| _n|| j�||�7 }| jjrO| jjs$| jjrWt� | _|S r� ) rq �ZSTD_MAX_LENGTH_UNLIMITEDr| r� r( r, r/ r rl )r r r& Zzstd_max_lengthr� r/ r r r rk � s* �� � z ZSTDDecompressor.decompress_syncc C rh )Nr r r+ r r r r � r- zZSTDDecompressor.flushc C s | j j o | j j p| jd uS r )r� � needs_inputr, r| r+ r r r ro � s ��z ZSTDDecompressor.data_availabler� r r r} r r� � s* ������� �&r� )NF)0rm �sys�zlib�abcr r �concurrent.futuresr �typingr r r r r � version_info�collections.abcr r r# � bytearrayZ brotlicffir� � ImportErrorr� Zcompression.zstdr Zbackports.zstdr� rp rq r� r r% r2 rC rE rZ rB r\ rY r1 r$ ra rb rr rv r� r� r r r r �<module> sh � � � -��� � #KG0
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings