Ë
|
¸^i6/ ã óz U d dl Z d dlZd dlZd dlmZmZ d dlmZ d dlm Z m
|
Z
|
m Z m Z m Z mZ ej dk\ rd dlmZ nd dlmZ eeedd f Z d dlZd
|
Z ej d k\ rd d lmZ nd d lmZ d
|
Z dZ dZ d Z dZ G d de « Z! G d de « Z" G d de « Z# G d de d ¬« Z$ G d d« Z% e%e« Z&e%e'd < d e#d dfd Z( d-d e e) d!e*d e+fd"Z, G d# d$e« Z- G d% d&« Z. G d' d(e-« Z/ G d) d*e-« Z0 G d+ d,e-« Z1y# e$ r d dlZY Èw xY w# e$ r d ZY Ów xY w# e$ r d Z Y Áw xY w).é N)ÚABCÚabstractmethod)ÚExecutor)ÚAnyÚFinalÚOptionalÚProtocolÚ TypedDictÚcast)é é )ÚBuffer)ÚUnionzmemoryview[int]zmemoryview[bytes]TF)r é )ÚZstdDecompressori i éÿÿÿÿc ó. e Zd ZdedefdZddedefdZy)ÚZLibCompressObjProtocolÚdataÚreturnc ó y ©N© ©Úselfr s õl H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohttp/compression_utils.pyÚcompressz ZLibCompressObjProtocol.compress- ó ó Úmodec ó y r r ©r r s r Úflushz ZLibCompressObjProtocol.flush. r r N©.)Ú__name__Ú
|
__module__Ú __qualname__r Úbytesr Úintr# r r r r r , s Ø2VÐ2¨Ó2Ù5#Ð5¨5Ô5r r c óJ e Zd Zd dededefdZd dedefdZede fd« Z
|
y)
|
ÚZLibDecompressObjProtocolr Ú
|
max_lengthr c ó y r r ©r r r, s r Ú
|
decompressz$ZLibDecompressObjProtocol.decompress2 r r Úlengthc ó y r r ©r r0 s r r# z ZLibDecompressObjProtocol.flush3 r r c ó y r r ©r s r Úeofz ZLibDecompressObjProtocol.eof5 s Ø r Nr$ ) r% r& r' r r) r( r/ r# ÚpropertyÚboolr5 r r r r+ r+ 1 s4 ÙKvÐK°3ÐKÀÓKÙ7CÐ7¨UÓ7à Ø TÒ ó Ù r r+ c óÈ e Zd ZU eed< eed< eed< eed< eed< ddededed ed
|
ed ee d efd Z dded ed e fdZ
|
ddededed e fdZ ddededed e fdZ y)ÚZLibBackendProtocolÚ MAX_WBITSÚ Z_FULL_FLUSHÚ Z_SYNC_FLUSHÚ Z_BEST_SPEEDÚZ_FINISHÚlevelÚmethodÚwbitsÚmemLevelÚstrategyÚzdictr c ó y r r )r r? r@ rA rB rC rD s r Ú compressobjz ZLibBackendProtocol.compressobj@ s ð #&r c ó y r r )r rA rD s r Ú decompressobjz!ZLibBackendProtocol.decompressobjI s à$'r r c ó y r r )r r r? rA s r r z ZLibBackendProtocol.compressM ó àr Úbufsizec ó y r r )r r rA rK s r r/ z ZLibBackendProtocol.decompressP rJ r N)......)..)r% r& r' r) Ú__annotations__r r r rF r+ rH r( r r/ r r r r9 r9 9 sù
ØNØÓØÓØÓØMð ØØØØØ"%ñ&àð&ð ð&ð ð &ð
|
ð &ð ð &ð Ñ ð&ð
|
!ó&ð 14ñ(Øð(Ø'-ð(à "ó(ð
|
?BñØ&)ðØ8;ðØðà óð ADñØ&)ðØ:=ðØðà ôr r9 c ó, e Zd ZU eed< eed< eed< y)ÚCompressObjArgsrA rC r? N)r% r& r' r) rM r r r rO rO U s
Ø JØMØ Jr rO )Útotalc ó e Zd ZdefdZedefd« Zedefd« Z edefd« Z
|
edefd« Z edefd« Z edefd « Z d
|
ed edefd Zd
|
ed edefd Zded
|
ed edefdZded
|
ed edefdZdedefdZy)ÚZLibBackendWrapperÚ _zlib_backendc ó || _ y r )rS )r rS s r Ú__init__zZLibBackendWrapper.__init__\ s
|
Ø2?Õr r c ó0 t | j dd« S )Nr% Ú undefined©ÚgetattrrS r4 s r ÚnamezZLibBackendWrapper.name_ s ät×)Ñ)¨:°{ÓCÐCr c ó. | j j S r )rS r: r4 s r r: z ZLibBackendWrapper.MAX_WBITSc s à×!Ñ!×+Ñ+Ð+r c ó. | j j S r )rS r; r4 s r r; z ZLibBackendWrapper.Z_FULL_FLUSHg ó à×!Ñ!×.Ñ.Ð.r c ó. | j j S r )rS r< r4 s r r< z ZLibBackendWrapper.Z_SYNC_FLUSHk r] r c ó. | j j S r )rS r= r4 s r r= z ZLibBackendWrapper.Z_BEST_SPEEDo r] r c ó. | j j S r )rS r> r4 s r r> zZLibBackendWrapper.Z_FINISHs s à×!Ñ!×*Ñ*Ð*r ÚargsÚkwargsc ó: | j j |i |¤S r )rS rF ©r ra rb s r rF z ZLibBackendWrapper.compressobjw s Ø-t×!Ñ!×-Ñ-¨tÐ>°vÑ>Ð>r c ó: | j j |i |¤S r )rS rH rd s r rH z ZLibBackendWrapper.decompressobjz s Ø/t×!Ñ!×/Ñ/°Ð@¸Ñ@Ð@r r c óB | j j |g|¢i |¤S r )rS r ©r r ra rb s r r zZLibBackendWrapper.compress} s% Ø*t×!Ñ!×*Ñ*¨4ÐA°$ÒA¸&ÑAÐAr c óB | j j |g|¢i |¤S r )rS r/ rg s r r/ z ZLibBackendWrapper.decompress s% Ø,t×!Ñ!×,Ñ,¨TÐC°DÒC¸FÑCÐCr Úattrnamec ó. t | j |« S r rX )r ri s r Ú __getattr__z ZLibBackendWrapper.__getattr__ s Üt×)Ñ)¨8Ó4Ð4r N)r% r& r' r9 rU r6 ÚstrrZ r) r: r; r< r= r> r r rF r+ rH r r( r r/ rk r r r rR rR [ sO ð@Ð&9ó @ð ðDcò Dó ðDð ð,3ò ,ó ð,ð ð/cò /ó ð/ð ð/cò /ó ð/ð ð/cò /ó ð/ð ð+#ò +ó ð+ð? ð ?°ð ?Ð8Oó ?ðA 3ð A°#ð AÐ:Só AðBVð B¨Cð B¸3ð BÀ5ó BðDvð D¨cð D¸Sð DÀUó Dð5 Cð 5¨Cô 5r rR Ú ZLibBackendÚnew_zlib_backendr c ó | t _ y r )rm rS )rn s r Úset_zlib_backendrp s
|
Ø 0KÕ r ÚencodingÚsuppress_deflate_headerc óx | dk( rdt j z S |rt j S t j S )NÚgzipé )rm r: )rq rr s r Úencoding_to_moderv s9 ð 6ÒØK×)Ñ)Ñ)Ð)á%<K× !Ñ !Ð !ÐWÄ+×BWÑBWÐWr c óh e Zd Zdefdee dee fdZee fde
|
dede
|
fd« Z e fde
|
dede
|
fd Z y)
|
ÚDecompressionBaseHandlerNÚexecutorÚmax_sync_chunk_sizec ó || _ || _ y)z&Base class for decompression handlers.N)Ú _executorÚ_max_sync_chunk_size)r ry rz s r rU z!DecompressionBaseHandler.__init__ s ð "Ø$7Õ!r r r, r c ó y©úDecompress the given data.Nr r. s r Údecompress_syncz(DecompressionBaseHandler.decompress_sync£ r r c óþ K | j Zt |« | j kD rBt j « j | j
|
| j ||« d{ S | j ||« S 7 wr )r} ÚlenÚasyncioÚget_event_loopÚrun_in_executorr| r r. s r r/ z#DecompressionBaseHandler.decompress© st è ø ð
|
× %Ñ %Ð 1ÜD D× 5Ñ 5Ò5ä ×/Ñ/Ó1×AÑAØ × 4Ñ 4°d¸Jó÷ ð ð ×#Ñ# D¨*Ó5Ð5ðús A"A=Á$A;Á%A=) r% r& r' ÚMAX_SYNC_CHUNK_SIZEr r r) rU r ÚZLIB_MAX_LENGTH_UNLIMITEDr( r r/ r r r rx rx s| ð (,Ø-@ñ8à8Ñ$ð8ð & c]ó8ð à-Fñ)Øð)Ø'*ð)à ò)ó ð)ð .Gñ 6Øð 6Ø'*ð 6à ô 6r rx c ó e Zd Zddddddefdee dedee dee dee dee d ee fd
|
Z d e
|
d e
|
fd Z d e
|
d e
|
fdZ ddee d e
|
fdZ y)ÚZLibCompressorNFrq rr r? rA rC ry rz c ó || _ || _ | t ||« n|| _ t t
|
j « | _ i }| j |d< |||d< |||d< | j j di |¤| _ y )NrA rC r? r ) r| r} rv Ú_moderR rm rS rF Ú _compressor) r rq rr r? rA rC ry rz rb s r rU zZLibCompressor.__init__¸ s ð "Ø$7Ô!ð }ô XÐ'>Ô ?àð
|
ô
|
%7´{×7PÑ7PÓ$QÔà"$Ø **wØ Ð Ø!)F:Ñ Ø Ð Ø #F7OØ94×-Ñ-×9Ñ9ÑC¸FÑCÕr r r c ó8 | j j |« S r )r r r s r Ú compress_syncz ZLibCompressor.compress_syncÓ s Ø× Ñ ×(Ñ(¨Ó.Ð.r c ó K | j duxr t |« | j kD }|rKt j « j | j
|
| j j |« d{ S | j |« S 7 w)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) r} r r Úget_running_loopr r| r r r )r r Úshould_use_executors r r zZLibCompressor.compressÖ s è ø ð& × %Ñ %¨TÐ 1ò 6ÜD D× 5Ñ 5Ñ5ð ñ Ü ×1Ñ1Ó3×CÑCØ × 0Ñ 0× 9Ñ 9¸4ó÷ ð ð ×!Ñ! $Ó'Ð'ðús A1B Á3B Á4B r c óp | j j ||« S | j j « 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.
|
)r r# rS r> r" s r r# zZLibCompressor.flushò s> ð × Ñ ×%Ñ%ØÐ$Dó
|
ð
|
Ø*.×*<Ñ*<×*EÑ*Eó
|
ð
|
r r )r% r& r' r r rl r7 r) r rU r( r r r# r r r r r · sÀ ð #'Ø(-Ø #Ø #Ø"&Ø'+Ø-@ñDà3-ðDð "&ðDð }ð Dð
|
}ð Dð 3-ð Dð 8Ñ$ðDð & c]óDð6/ %ð /¨Eó /ð( 5ð (¨Uó (ñ8
|
( 3-ð
|
°5ô
|
r r c
|
ó e Zd Zdddefdee dedee dee f fd Z e
|
fde d ed
|
e fd Z dd ed
|
e fd Zed
|
efd« Z xZS )ÚZLibDecompressorNFrq rr ry rz c óÜ t | ||¬« t ||« | _ t t
|
j « | _ | j j | j ¬« | _ y )N©ry rz )rA ) ÚsuperrU rv r rR rm rS rH Ú _decompressor)r rq rr ry rz Ú __class__s r rU zZLibDecompressor.__init__ sZ ø ô Ñ (Ð@SÐÔTÜ% hÐ0GÓH
|
Ü$6´{×7PÑ7PÓ$QÔØ !× /Ñ /× =Ñ =ÀDÇJÁJÐ =Ó OÕr r r, r c ó: | j j ||« S r )r r/ r. s r r z ZLibDecompressor.decompress_sync s ð ×!Ñ!×,Ñ,¨T°:Ó>Ð>r r0 c óv |dkD r| j j |« S | j j « S )Nr )r r# r2 s r r# zZLibDecompressor.flush s? ð zð × Ñ × $Ñ $ VÓ ,ð
|
ð ×#Ñ#×)Ñ)Ó+ð
|
r c ó. | j j S r )r r5 r4 s r r5 zZLibDecompressor.eof s à×!Ñ!×%Ñ%Ð%r )r )r% r& r' r r rl r7 r r) rU r r r( r r# r6 r5 Ú __classcell__©r s @r r r s ø ð #'Ø(-Ø'+Ø-@ñ
|
Pà3-ð
|
Pð "&ð
|
Pð 8Ñ$ð
|
Pð
|
& c]õ
|
Pð /Hñ?Øð?Ø(+ð?à ó?ñ
|
|
Cð
|
¨ó
|
ð ð&Tò &ó ô&r r c ób e Zd Zdefdee dee ddf fd Zefde dede
|
fdZ de
|
fd Z xZ S )
|
ÚBrotliDecompressorNry rz r c ó| t s t d« t j « | _ t
|
| ||¬« y)z)Decompress data using the Brotli library.zIThe brotli decompression is not available. Please install `Brotli` moduler N)Ú
|
HAS_BROTLIÚ RuntimeErrorÚbrotliÚ DecompressorÚ_objr rU ©r ry rz r s r rU zBrotliDecompressor.__init__$ s? ø õ Ü ð1óð ô ×'Ñ'Ó) Ü Ñ (Ð@SÐÕTr r r, c óÖ t | j d« r*t t | j j ||« « S t t | j j ||« « S )r r/ )Úhasattrr§ r r( r/ Úprocessr. s r r z"BrotliDecompressor.decompress_sync2 sN ô 499lÔ +Ütyy× 3Ñ 3°D¸*Ó EÓFÐ FÜE499×,Ñ,¨T°:Ó>Ó?Ð?r c ó t | j d« r(t t | j j « « S y)zFlush the decompressor.r# r )rª r§ r r( r# r4 s r r# zBrotliDecompressor.flush: s+ ä 499gÔ &ÜtyyÓ 0Ó1Ð 1Ør )r% r& r' r r r r) rU r r r( r r# r r s @r r¡ r¡ sl ø ð (,Ø-@ñ Uà8Ñ$ð Uð & c]ð Uð
|
õ Uð /Hñ@Øð@Ø(+ð@à ó@ðu÷ r r¡ c ób e Zd Zdefdee dee ddf fd Zefde dede fdZ
|
de fd Z xZ S )
|
ÚZSTDDecompressorNry rz r c óh t s t d« t « | _ t | ||¬« y )NzOThe zstd decompression is not available. Please install `backports.zstd` moduler )ÚHAS_ZSTDr¤ r r§ r rU r¨ s r rU zZSTDDecompressor.__init__B s9 ø õ
|
Ü ð9óð ô %Ó& Ü Ñ (Ð@SÐÕTr r r, c ó\ |t k( rt n|}| j j ||« S r )r ÚZSTD_MAX_LENGTH_UNLIMITEDr§ r/ )r r r, Úzstd_max_lengths r r z ZSTDDecompressor.decompress_syncO s3 ð Ô 6Ò6õ &àð ð
|
yy×#Ñ# D¨/Ó:Ð:r c ó y)Nr r r4 s r r# zZSTDDecompressor.flush[ s Ør ) r% r& r' r r r r) rU r r( r r# r r s @r r® r® A sh ø ð (,Ø-@ñ Uà8Ñ$ð Uð & c]ð Uð
|
õ Uð .Gñ
|
;Øð
|
;Ø'*ð
|
;à ó
|
;ðu÷ r r® )NF)2r ÚsysÚzlibÚabcr r Úconcurrent.futuresr Útypingr r r r r
|
r Ú version_infoÚcollections.abcr r r( Ú bytearrayÚ
|
brotlicffir¥ Ú ImportErrorr£ Úcompression.zstdr Úbackports.zstdr° r ÚDEFAULT_MAX_DECOMPRESS_SIZEr r² r r+ r9 rO rR rm rM rp rl r7 r) rv rx r r r¡ r® r r r ú<module>r s£ ðÜ Û
|
Û ß #Ý 'ß B× Bà×ÑwÒ Þ&å à 5)Ð%6Ð8KÐKÑ LFððÛ#ð JðØ
|
×Ñ7Ò"Þ5å3àHð
|
Ð Ø #Ð ð Ð Ø Ð ô6hô 6ô
|
ô ô(ô ô8i uõ ÷ *5ñ *5ñZ #5°TÓ": Ð Ó :ð1Ð':ð 1¸tó 1ð
|
#Ø$)ñXØsmðXà !ðXð óXô6sô 6÷<H
|
ñ H
|
ôV&Ð/ô &ô< Ð1ô ôBÐ/õ øð_ ò Ýðûð ò ØJðûð ò ØHðúsB ÁD ÁD# Á D0 Ä D Ä D# Ä D Ä D# Ä#D-Ä,D-Ä0D:Ä9D:
|
