7 d dl Z d dlZd dlmZ d dlmZmZ d dlZn# e $ r d dlZY nw xY wdZ
n
# e $ r dZ
Y nw xY wdZ ddee de
d efd
Z G d d Z G d
de Z G d de Z G d d ZdS ) N)Executor)OptionalcastTFi encodingsuppress_deflate_headerreturnc b | dk rdt j z S |r
t j n t j S )Ngzip )zlib MAX_WBITS)r r s m/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/compression_utils.pyencoding_to_moder s1 6DN"" 5 IDN??4>I c @ e Zd Zdefdedee dee fdZdS )ZlibBaseHandlerNmodeexecutormax_sync_chunk_sizec 0 || _ || _ || _ d S N)_mode _executor_max_sync_chunk_size)selfr r r s r __init__zZlibBaseHandler.__init__ s
!$7!!!r )__name__
__module__ __qualname__MAX_SYNC_CHUNK_SIZEintr r r r r r r sZ (,-@ 8 88 8$8 &c] 8 8 8 8 8 8r r c e Zd Zddddej defdee dedee dee de dee
d ee f fd
Z d e d e fd
Z
d e d e fdZej fde d e fdZ xZS )ZLibCompressorNFr r levelwbitsstrategyr r c , t |t || n||| |!t j | j | | _ n!t j | j || | _ t j | _ d S )Nr r r )r& r' )r& r' r% )
superr r r compressobjr _compressorasyncioLock_compress_lock) r r r r% r& r' r r __class__s r r zZLibCompressor.__init__* s } "(,CDDD 3
= # /dj8 T T TD # /j85 D &lnnr datar c 6 | j | S r )r, compressr r1 s r
compress_syncz ZLibCompressor.compress_syncC s ((...r c h K | j 4 d {V | j bt | | j k rJt j | j | j | d {V cd d d d {V S | | cd d d d {V S # 1 d {V swxY w Y d S r )r/ r lenr- get_event_looprun_in_executorr r5 r4 s r r3 zZLibCompressor.compressF s & , , , , , , , , )5II 999 $ 3 5 5 E END$6 , , , , , , , , , , , , , , %%d++ , , , , , , , , , , , , , , , , , , , , , , , , , , , , , ,s AB!:B!!
B+.B+r c 6 | j | S r )r, flush)r r s r r; zZLibCompressor.flushU s %%d+++r )r r r r Z_DEFAULT_STRATEGYr r strboolr! r r bytesr5 r3 Z_FINISHr;
__classcell__r0 s @r r$ r$ ) s' #'(- # # /'+-@- -3-- "&- } -
} -
- 8$- &c]- - - - - -2/% /E / / / /
,5
,U
,
,
,
, !%
, ,# ,% , , , , , , , ,r r$ c
e Zd Zdddefdee dedee dee f fd
Z dd e
d
ed e
fd Z dd e
d
ed e
fd
Z dded e
fdZ
ed efd Zed e
fd Zed e
fd Z xZS )ZLibDecompressorNFr r r r c t t || || t j | j | _ d S )Nr) )r& )r* r r r
decompressobjr
_decompressor)r r r r r r0 s r r zZLibDecompressor.__init__Z sZ !(,CDD 3
" /dj A A Ar r r1
max_lengthr c 8 | j || S r )rG
decompressr r1 rH s r decompress_syncz ZLibDecompressor.decompress_synch s !,,T:>>>r c K | j Qt | | j k r9t j | j | j || d {V S | || S r )r r7 r- r8 r9 r rL rK s r rJ zZLibDecompressor.decompressk s % 1D D 555 /11AA 4dJ
##D*555r lengthc t |dk r| j | n| j S )Nr )rG r; )r rN s r r; zZLibDecompressor.flushu s= zz
$ $V , , ,#))++
r c | j j S r )rG eofr s r rQ zZLibDecompressor.eof| s !%%r c | j j S r )rG unconsumed_tailrR s r rT z ZLibDecompressor.unconsumed_tail s !11r c | j j S r )rG unused_datarR s r rV z ZLibDecompressor.unused_data s !--r )r )r r r r r r= r> r r! r r? rL rJ r; propertyrQ rT rV rA rB s @r rD rD Y s #'(-'+-@ B B3- B "& B 8$ B
&c] B B B B B B ? ?E ?s ?5 ? ? ? ?6 6U 6 6E 6 6 6 6
C
&T & & & X& 2 2 2 2 X2 .U . . . X. . . . .r rD c 2 e Zd ZddZdedefdZdefdZdS )BrotliDecompressorr Nc b t st d t j | _ d S )NzIThe brotli decompression is not available. Please install `Brotli` module)
HAS_BROTLI RuntimeErrorbrotli Decompressor_objrR s r r zBrotliDecompressor.__init__ s7 1
')) r r1 c t | j d r-t t | j | S t t | j | S )NrJ )hasattrr_ r r? rJ processr4 s r rL z"BrotliDecompressor.decompress_sync sV 49l + + ;ty 3 3D 9 9:: :E49,,T22333r c t | j d r,t t | j S dS )Nr; r )ra r_ r r? r; rR s r r; zBrotliDecompressor.flush s7 49g & & 2ty 0 011 1sr )r N)r r r r r? rL r; r" r r rY rY se * * * *4E 4e 4 4 4 4
u r rY )NF)r- r concurrent.futuresr typingr r
brotlicffir] ImportErrorr[ r r= r> r! r r r$ rD rY r" r r rh s ' ' ' ' ' ' ! ! ! ! ! ! ! !#####
JJ JJJ #$)J JsmJ !J J J J J 8 8 8 8 8 8 8 8-, -, -, -, -,_ -, -, -,`-. -. -. -. -. -. -. -.` s 0 *0 *0 ::