384 lines
56 KiB
Plaintext
384 lines
56 KiB
Plaintext
|
Ë
|
|||
|
|
JÀjãÏ ã ó — d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
|
|||
|
|
Z
|
|||
|
|
d dl Z d dl m
|
|||
|
|
Z
|
|||
|
|
d dlmZ d dlmZ d dlmZ e j* rddlmZ d dlZdd lm Z dd
|
|||
|
|
lm Z dd l m Z dd l m!Z!m"Z"m#Z# dd
|
|||
|
|
l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ ddl0m1Z1m2Z2 ddl3m4Z4 e j* rddl5m6Z6 ejn e8« Z9 G d„ d« Z: G d„ de:« Z; G d„ d« Z< G d„ de:« Z=e� G d„ de:« Z> ej~ dk\ rd d l@mAZA nd d lBmAZA d ZC G d „ d e:« ZD G d!„ d"e:« ZEd*d#„ZF G d$„ d%« ZG G d&„ d'ej� « ZI G d(„ d)eI« Zy# e$ r d dlZY �Œw xY w# e$ r dZY �Œ w xY w# e$ r d ZCY Œaw xY w)+é )Ú annotationsN)Úcontextmanager)Ú HTTPMessage)Ú HTTPResponse)Útimeouté )ÚBaseHTTPConnection)Úutil)Ú
|
|||
|
|
_TYPE_BODY)ÚHTTPHeaderDict)Ú BaseSSLErrorÚHTTPConnectionÚ
|
|||
|
|
HTTPException) ÚBodyNotHttplibCompatibleÚ DecodeErrorÚDependencyWarningÚ HTTPErrorÚIncompleteReadÚInvalidChunkLengthÚ
|
|||
|
|
InvalidHeaderÚ
|
|||
|
|
ProtocolErrorÚReadTimeoutErrorÚResponseNotChunkedÚSSLError)Ú is_fp_closedÚis_response_to_head)ÚRetry)ÚHTTPConnectionPoolc ó0 — e Zd Zddd„Zedd„« Zdd„Zy) ÚContentDecoderc ó — t « ‚©N©ÚNotImplementedError©ÚselfÚdataÚ
|
|||
|
|
max_lengths úS/home/antigravity/intellecton/venv/lib/python3.12/site-packages/urllib3/response.pyÚ
|
|||
|
|
decompresszContentDecoder.decompress7 ó € Ü!Ó#Ð#ó c ó — t « ‚r" r# ©r& s r) Úhas_unconsumed_tailz"ContentDecoder.has_unconsumed_tail: ó € ä!Ó#Ð#r, c ó — t « ‚r" r# r. s r) ÚflushzContentDecoder.flush> r+ r, N©éÿÿÿÿ©r' Úbytesr( ÚintÚreturnr6 ©r8 Úbool©r8 r6 )Ú__name__Ú
|
|||
|
|
__module__Ú __qualname__r* Úpropertyr/ r2 © r, r) r r 6 s „ ô$ð ò$ó ð$ô$r, r c ó8 — e Zd Zdd„Zddd„Zed d„« Zd
|
|||
|
|
d„Zy) ÚDeflateDecoderc ó` — d| _ d| _ d| _ t j « | _ y )NTr, )Ú
|
|||
|
|
_first_tryÚ_first_try_dataÚ _unfed_dataÚzlibÚ
|
|||
|
|
decompressobjÚ_objr. s r) Ú__init__zDeflateDecoder.__init__C s) € Ø ˆŒØ "ˆÔ Ø ˆÔÜ×&Ñ&Ó(ˆ� r, c óŽ — | j |z }d| _ |s| j j s|S |}|dk rd}n
|
|||
|
|
|dk( r|| _ y| j s4| j j | j j |z |¬« S | xj
|
|||
|
|
|z
|
|||
|
|
c_ | j j ||¬« }|rd| _ d| _ |S # t j $ rd d| _ t
|
|||
|
|
j t j « | _ | j | j
|
|||
|
|
|¬« d| _ cY S # d| _ w xY ww xY w)Nr, r ©r( F)
|
|||
|
|
rF rI Úunconsumed_tailrD r* rE rG ÚerrorrH Ú MAX_WBITS)r& r' r( Úoriginal_max_lengthÚ decompresseds r) r* zDeflateDecoder.decompressI s? € Ø× Ñ $Ñ&ˆØ ˆÔÙ˜DŸI™I× 5Ò 5؈KØ (ÐØ Ò "؉JØ
|
|||
|
|
AÒ
|
|||
|
|
%ð
|
|||
|
|
$ˆDÔ Øð �ŠØ—9‘9×'Ñ'Ø— ‘ ×)Ñ)¨DÑ0¸Zð (ó ð
|
|||
|
|
ð
|
|||
|
|
|
|||
|
|
× Ò Ñ$Õ ð +Ø Ÿ9™9×/Ñ/°ÀÐ/ÓLˆLÙØ"'�”Ø'*�Ô$Ø Ð øä�z‰zò +Ø #ˆDŒOÜ ×*Ñ*¬D¯N©N¨?Ó;ˆDŒIð
|
|||
|
|
+Ø—‘Ø×(Ñ(Ð5Hð 'ó ð (+�×$ø s�Õ$úð +ús%  .C
|
|||
|
|
Ã
|
|||
|
|
AEÄ D7Ä-EÄ7 E Å Ec óŒ — t | j « xs. t | j j « xr
|
|||
|
|
| j S r" )r: rF rI rM rD r. s r) r/ z"DeflateDecoder.has_unconsumed_tails s8 € ä�D×$Ñ$Ó%ò
|
|||
|
|
Ü �—‘×*Ñ*Ó +Ò C°D·O±OÐ0Cð
|
|||
|
|
r, c ó6 — | j j « S r" ©rI r2 r. s r) r2 zDeflateDecoder.flushy ó € Ø�y‰y�‰Ó Ð r, N©r8 ÚNoner3 r5 r9 r; ©r< r= r> rJ r* r? r/ r2 r@ r, r) rB rB B s& „ ó)ô (+ðT ò
|
|||
|
|
ó ð
|
|||
|
|
ô
|
|||
|
|
!r, rB c ó — e Zd ZdZdZdZy)ÚGzipDecoderStater r é N)r< r= r> Ú FIRST_MEMBERÚ
|
|||
|
|
OTHER_MEMBERSÚ SWALLOW_DATAr@ r, r) rZ rZ } s „ Ø€LØ€MØ�Lr, rZ c ó8 — e Zd Zdd„Zddd„Zed d„« Zd
|
|||
|
|
d„Zy) Ú GzipDecoderc ó’ — t j dt j z « | _ t j
|
|||
|
|
| _ d| _ y )Né r, )rG rH rO rI rZ r\ Ú_stateÚ_unconsumed_tailr. s r) rJ zGzipDecoder.__init__„ s2 € Ü×&Ñ& r¬D¯N©NÑ':Ó;ˆŒ Ü&×3Ñ3ˆŒ Ø #ˆÕ r, c
|
|||
|
|
ó — t « }| j t j k( r t |« S |dk( r| xj
|
|||
|
|
|z
|
|||
|
|
c_ y| j
|
|||
|
|
|z }|s!| j j r t |« S || j j |t |t |« z
|
|||
|
|
d« ¬« z
|
|||
|
|
}| j j xs | j j x| _ }|dkD rt |« |k\ r t |« S |s t |« S | j j r@t j | _ t j dt j" z « | _ Œï# t j $ rJ | j }t j | _ d| _ |t j k( r
|
|||
|
|
t |« cY S ‚ w xY w)Nr r, rL rb )Ú bytearrayrc rZ r^ r6 rd rI Úeofr* ÚmaxÚlenrG rN r] rM Ú unused_datarH rO )r& r' r( ÚretÚprevious_states r) r* zGzipDecoder.decompress‰ sŽ € Ü‹kˆØ �;‰;Ô*×7Ñ7Ò 7ܘ“:Ð à ˜Š?ð
|
|||
|
|
|
|||
|
|
× !Ò ! TÑ )Õ !Øð ×$Ñ$ tÑ+ˆÙ˜Ÿ ™ Ÿ
|
|||
|
|
š
|
|||
|
|
ܘ“:Ð àð
|
|||
|
|
Ø�t—y‘y×+Ñ+ؤS¨´c¸#³hÑ)>ÀÓ%Bð ,ó ñ �ð — ‘ ×)Ñ)ÒB¨T¯Y©Y×-BÑ-Bð
|
|||
|
|
ˆDÔ ! Dð ˜AŠ~¤# c£(¨jÒ"8Øô �S‹zÐñ Ü ˜S“zÐ!ð �y‰y�}Š}Ü .× <Ñ <�” Ü × .Ñ .¨r´D·N±NÑ/BÓ C�” ð7 øô
|
|||
|
|
—:‘:ò
|
|||
|
|
Ø!%§¡�ä .× ;Ñ ;�” Ø(+�Ô%Ø!Ô%5×%CÑ%CÒCä ›:Ò%Øð
|
|||
|
|
ús Â6E0 Å0AG
|
|||
|
|
Ç G
|
|||
|
|
c ó, — t | j « S r" )r: rd r. s r) r/ z GzipDecoder.has_unconsumed_tail» s € ä�D×)Ñ)Ó*Ð*r, c ó6 — | j j « S r" rT r. s r) r2 zGzipDecoder.flush¿ rU r, NrV r3 r5 r9 r; rX r@ r, r) r` r` ƒ s& „ ó$ô
|
|||
|
|
0ðd ò+ó ð+ô!r, r` c óB — e Zd Zdd„Zdd d„Zdd
|
|||
|
|
d„Zed d„« Zd d„Zy)
|
|||
|
|
Ú
|
|||
|
|
BrotliDecoderc óè — t j « | _ t | j d« r"t | d| j j
|
|||
|
|
« y t | d| j j « y )Nr* Ú _decompress)ÚbrotliÚ DecompressorrI ÚhasattrÚsetattrr* Úprocessr. s r) rJ zBrotliDecoder.__init__É sL € Ü ×+Ñ+Ó-ˆDŒIÜ�t—y‘y ,Ô/ܘ˜m¨T¯Y©Y×-AÑ-AÕB䘘m¨T¯Y©Y×->Ñ->Õ?r, c ó — t « ‚r" r# )r& r' Úoutput_buffer_limits r) rr zBrotliDecoder._decompressÑ s € Ü%Ó'Ð 'r, c óÊ — |dkD r| j ||¬« S | j |« S # t $ r. t j dt « | j |« cY S w xY w)Nr )ry z;Brotli >= 1.2.0 is required to prevent decompression bombs.)rr Ú TypeErrorÚwarningsÚwarnr r% s r) r* zBrotliDecoder.decompressÔ sk € ð
|
|||
|
|
.Ø ’>Ø ×+Ñ+¨DÀjÐ+ÓQÐQà ×+Ñ+¨DÓ1Ð1øÜ ò
|
|||
|
|
.ô —
|
|||
|
|
‘
|
|||
|
|
ØQÜ%ôð ×'Ñ'¨Ó-Ò-ð
|
|||
|
|
.ús ‚+ š+ «4A"Á!A"c óX — | j j « S # t $ r Y yw xY w)NF)rI Úcan_accept_more_dataÚAttributeErrorr. s r) r/ z!BrotliDecoder.has_unconsumed_tailã s/ € ð
|
|||
|
|
Ø Ÿ9™9×9Ñ9Ó;Ð;Ð;øÜ!ò
|
|||
|
|
Ù ð
|
|||
|
|
ús ‚ � )¨)c ód — t | j d« r| j j « S y)Nr2 r, )ru rI r2 r. s r) r2 zBrotliDecoder.flushê s$ € Ü�t—y‘y 'Ô*Ø—y‘y—‘Ó(Ð(Ør, NrV r3 )r' r6 ry r7 r8 r6 r5 r9 r; ) r< r= r> rJ rr r* r? r/ r2 r@ r, r) rp rp Å s+ „ ó @ô (ô
|
|||
|
|
.ð
|
|||
|
|
ò ó
|
|||
|
|
ð ô r, rp )é é )ÚzstdTc ó8 — e Zd Zdd„Zddd„Zed d„« Zd
|
|||
|
|
d„Zy) Ú ZstdDecoderc ó6 — t j « | _ y r" )r„ ÚZstdDecompressorrI r. s r) rJ zZstdDecoder.__init__û s € Ü ×-Ñ-Ó/ˆD�Ir, c óR — |s
|
|||
|
|
| j sy| j j r2| j j |z }t j
|
|||
|
|
« | _ | j j
|
|||
|
|
||¬« }t |« }|g}| j j rÿ| j j ré|dk s||k rß| j j }| j j st j
|
|||
|
|
« | _ | j j
|
|||
|
|
||dkD r||z
|
|||
|
|
nd¬« }t |« x}r|j |« ||z
|
|||
|
|
}n| j j rn8| j j r"| j j r |dk rŒÙ||k rŒßdj |« S )Nr, rL r r4 ) r/ rI rg rj r„ rˆ r* ri Ú needs_inputÚappendÚjoin)r& r' r( ÚpartÚlengthÚ
|
|||
|
|
data_partsrj Ú part_lengths r) r* zZstdDecoder.decompressþ sZ € Ù × 8Ò 8ØØ�y‰y�}Š}Ø—y‘y×,Ñ,¨tÑ3�Ü × 1Ñ 1Ó 3�” Ø—9‘9×'Ñ'¨¸Ð'ÓDˆDܘ“YˆFØ ˜ˆJð — ‘ —
|
|||
|
|
’
|
|||
|
|
Ø—I‘I×)Ò)Ø !’^ v°
|
|||
|
|
Ò':à "Ÿi™i× 3Ñ 3� Ø—y‘y×,Ò,Ü $× 5Ñ 5Ó 7�D”IØ—y‘y×+Ñ+Ø Ø8BÀQº
|
|||
|
|
¨VÒ 3ÈBð ,ó �ô #& d£)Ð+�;Ð+Ø ×%Ñ% dÔ+ؘkÑ)‘FØ—Y‘Y×*Ò*Øð — ‘ —
|
|||
|
|
’
|
|||
|
|
Ø—I‘I×)Ò)Ø !“^ v°
|
|||
|
|
Ó':ð —8‘8˜JÓ'Ð 'r, c ó¢ — | j j xs | j j xs t | j j « S r" )rI rŠ rg r: rj r. s r) r/ z ZstdDecoder.has_unconsumed_tail s> € à Ÿ ™ ×-Ñ-Ò>°·±· ± Ð?ò Ä4Ø— ‘ ×%Ñ%óDð
|
|||
|
|
r, c óF — | j j s t d« ‚y)Nz Zstandard data is incompleter, )rI rg r r. s r) r2 zZstdDecoder.flush& s € Ø—9‘9—=’=Ü!Ð"@ÓAÐAØr, NrV r3 r5 r9 r; rX r@ r, r) r† r† ú s& „ ó 0ô (ðD
|
|||
|
|
ò ó
|
|||
|
|
ð ô
|
|||
|
|
r, r† Fc ó@ — e Zd ZdZdZdd„Zd d„Zd
|
|||
|
|
d d„Zed d„« Z y)
|
|||
|
|
Ú MultiDecodera
|
|||
|
|
From RFC7231:
|
|||
|
|
If one or more encodings have been applied to a representation, the
|
|||
|
|
sender that applied the encodings MUST generate a Content-Encoding
|
|||
|
|
header field that lists the content codings in the order in which
|
|||
|
|
they were applied.
|
|||
|
|
é c ó$ — |j d« D �cg c] }|j « ‘Œ }}t |« | j kD r$t dt |« › d| j › �« ‚|D �cg c]
|
|||
|
|
}t |« ‘Œ c}| _ y c c}w c c}w )Nú,z)Too many content encodings in the chain: z > )ÚsplitÚstripri Úmax_decode_linksr Ú _get_decoderÚ _decoders)r& ÚmodesÚmÚ encodingsÚes r) rJ zMultiDecoder.__init__9 s„ € Ø(-¯ © °CÓ(8Ö9 1�Q—W‘W•YÐ9ˆ Ð9Ü ˆy‹>˜D× 1Ñ 1Ò 1Ü Ø;Ü�y“>Ð" # d×&;Ñ&;Ð%<ð>óð
|
|||
|
|
ð 4=Ö=¨aœ, q�/Ò=ˆ�ùò
|
|||
|
|
:ùò >s ”BÁ-B
|
|||
|
|
c ó< — | j d j « S ©Nr )rœ r2 r. s r) r2 zMultiDecoder.flushB s € Ø�~‰~˜aÑ ×&Ñ&Ó(Ð(r, c óB — |dk r-t | j « D ] }|j |« }Œ |S t « } d}t | j « D ]& }|j ||t |« z
|
|||
|
|
¬« }|sŒ%d}Œ( ||z
|
|||
|
|
}|rt |« |k\ r t |« S d}Œc)Nr TFrL r, )Úreversedrœ r* rf ri r6 )r& r' r( Údrk Úany_datas r) r* zMultiDecoder.decompressE s € Ø ˜Š?Ü ˜dŸn™nÓ-ò
|
|||
|
|
*�Ø—|‘| DÓ)‘ð
|
|||
|
|
*àˆKä‹kˆð Ø ˆHÜ ˜dŸn™nÓ-ò
|
|||
|
|
$�Ø—|‘| D°ZÄ#ÀcÃ(Ñ5J�|ÓK�ÚØ #‘Hð
|
|||
|
|
$ð
|
|||
|
|
�4‰KˆCÙœs 3›x¨:Ò 5Ü ˜S“zÐ!؈Dð r, c ó: — t d„ | j D « « S )Nc 3 ó4 K — | ] }|j –— Œ y wr" )r/ )Ú.0r¥ s r) ú <genexpr>z3MultiDecoder.has_unconsumed_tail.<locals>.<genexpr>a s è ø€ ÒA¨Q�1×(Õ(ÑAùs ‚)Úanyrœ r. s r) r/ z MultiDecoder.has_unconsumed_tail_ s € äÑA°$·.±.ÔAÓAÐAr, N)r� Ústrr8 rW r; r3 r5 r9 )
|
|||
|
|
r< r= r> Ú__doc__rš rJ r2 r* r? r/ r@ r, r) r” r” , s4 „ ñð Ðó>ó)ôð4 òBó ñBr, r” c ó¤ — d| v r t | « S | dv r
|
|||
|
|
t « S t �| dk( r
|
|||
|
|
t « S t r| dk( r
|
|||
|
|
t « S t
|
|||
|
|
« S )Nr— )Úgzipúx-gzipÚbrr„ )r” r` rs rp ÚHAS_ZSTDr† rB )Úmodes r) r› r› d sU € Ø
|
|||
|
|
ˆd�{ܘDÓ!Ð!ð Ð!Ñ!Ü‹}Ð ä
|
|||
|
|
Иd dšlÜ ‹Ð å�D˜F’NÜ‹}Ð ä Ó Ðr, c ó8 — e Zd ZdZdd„Zd d„Zd
|
|||
|
|
d„Zd d„Zd d„Zy)
|
|||
|
|
ÚBytesQueueBuffera˜ Memory-efficient bytes buffer
|
|||
|
|
|
|||
|
|
To return decoded data in read() and still follow the BufferedIOBase API, we need a
|
|||
|
|
buffer to always return the correct amount of bytes.
|
|||
|
|
|
|||
|
|
This buffer should be filled using calls to put()
|
|||
|
|
|
|||
|
|
Our maximum memory usage is determined by the sum of the size of:
|
|||
|
|
|
|||
|
|
* self.buffer, which contains the full data
|
|||
|
|
* the largest chunk that we will copy in get()
|
|||
|
|
c óD — t j « | _ d| _ y r¢ )Ú collectionsÚdequeÚbufferÚ_sizer. s r) rJ zBytesQueueBuffer.__init__„ s € Ü?J×?PÑ?PÓ?RˆŒ ؈�
|
|||
|
|
r, c ó — | j S r" )rº r. s r) Ú__len__zBytesQueueBuffer.__len__ˆ s € Ø�z‰zÐr, c óv — | j j |« | xj t |« z
|
|||
|
|
c_ y r" )r¹ r‹ rº ri ©r& r' s r) ÚputzBytesQueueBuffer.put‹ s& € Ø � ‰ ×ј4Ô Ø �
|
|||
|
|
Š
|
|||
|
|
”c˜$“iÑ Ž
|
|||
|
|
r, c óH — |dk( ry| j s t d« ‚|dk r t d« ‚t | j d « |k( rLt | j d t
|
|||
|
|
« r/| xj |z c_ | j j « S d}t j « }||k rä||z
|
|||
|
|
}| j j « }t |« }||k rgt |« }|d | ||d }}|j |« | j j |« | xj |z c_ |j « S |j |« | xj |z c_ ||z
|
|||
|
|
}| j s |j « S ||k rŒä|j « S )Nr r, zbuffer is emptyzn should be > 0)r¹ Ú RuntimeErrorÚ
|
|||
|
|
ValueErrorri Ú
|
|||
|
|
isinstancer6 rº ÚpopleftÚioÚBytesIOÚ
|
|||
|
|
memoryviewÚwriteÚ
|
|||
|
|
appendleftÚgetvalue) r& ÚnÚfetchedrk Ú remainingÚchunkÚ chunk_lengthÚ
|
|||
|
|
left_chunkÚ right_chunks r) ÚgetzBytesQueueBuffer.get� sl € Ø �Š6ØØ—’Ü Ð 0Ó1Ð 1Ø
|
|||
|
|
�ŠUÜ Ð .Ó/Ð /ä ˆt�{‰{˜1‰~Ó !Ò #¬
|
|||
|
|
°4·;±;¸q±>Ä5Ô(IØ �JŠJ˜!‰O�JØ—;‘;×&Ñ&Ó(Ð (àˆÜ�j‰j‹lˆØ˜ŠkؘG™ ˆIØ—K‘K×'Ñ'Ó)ˆEÜ ˜u›:ˆLؘ<Ò'Ü" 5Ó)�Ø*/°
|
|||
|
|
°Ð*;¸UÀ9À:Ð=N˜K�
|
|||
|
|
Ø— ‘ ˜*Ô%Ø— ‘ ×&Ñ& {Ô3Ø—
|
|||
|
|
’
|
|||
|
|
˜iÑ'•
|
|||
|
|
Øð �|‰|‹~Ð ð — ‘ ˜%Ô Ø—
|
|||
|
|
’
|
|||
|
|
˜lÑ*•
|
|||
|
|
Ø �|Ñ #ˆGà—;’;Øà�|‰|‹~Ð ð' ˜‹kð& �|‰|‹~Ð r, c ót ‡— | j Š‰s| j dk( sJ ‚yt ‰« dk( r1‰j « }t |t
|
|||
|
|
« ra|j
|
|||
|
|
« }nPt j « }|j ˆfd„t t ‰« « D « « |j « }d| _ |S )Nr r, r c 3 ó> •K — | ] }‰j « –— Œ y wr" )rÄ )r© Ú_r¹ s €r) rª z+BytesQueueBuffer.get_all.<locals>.<genexpr>½ s øè ø€ ÒH°˜6Ÿ>™>×+ÑHùs ƒ ) r¹ rº ri Úpoprà rÇ ÚtobytesrÅ rÆ Ú
|
|||
|
|
writelinesÚrangerÊ )r& Úresultrk r¹ s @r) Úget_allzBytesQueueBuffer.get_all² sŒ ø€ Ø—‘ˆÙØ—:‘: ’?Ð "�?ØÜ ˆv‹;˜!Ò Ø—Z‘Z“\ˆFܘ&¤*Ô-Ø Ÿ ™ Ó)‘ä—*‘*“,ˆCØ �N‰NÓH´U¼3¸v»;Ó5GÔHÔ HØ—\‘\“^ˆF؈Œ
|
|||
|
|
؈
|
|||
|
|
r, NrV ©r8 r7 )r' r6 r8 rW )rË r7 r8 r6 r; ) r< r= r> r rJ r¼ r¿ rÒ rÛ r@ r, r) rµ rµ v s! „ ñ ó óó ó! ôFr, rµ c ó^ — e Zd ZU g d¢Ze�edgz
|
|||
|
|
Zeredgz
|
|||
|
|
Zg d¢Zeej fZ
|
|||
|
|
de d< e�e
|
|||
|
|
ej fz
|
|||
|
|
Z
|
|||
|
|
ere
|
|||
|
|
e j fz
|
|||
|
|
Z
|
|||
|
|
dddœ d"d „Zd#d
|
|||
|
|
„Zed$d „« Zd%d „Zed&d
|
|||
|
|
„« Zej( d'd„« Zed(d„« Zed)d„« Zej( d*d„« Z d+ d,d„Z d- d.d„Z d/ d0d„Z d/ d,d„Zd1d„Zd1d„Z d1d„Z d1d„Z d1d„Z d2 d3d„Z d$d „Z!d4d „Z"d5d „Z#d2d6d „Z$d5d „Z%d&d!„Z&y)7ÚBaseHTTPResponse)r¯ r° ÚdeflateNr± r„ )i- i. i/ i3 i4 ztuple[type[Exception], ...]ÚDECODER_ERROR_CLASSES)ÚheadersÚretriesc ó~ — t |t « r|| _ nt |« | _ || _ || _ || _ || _ || _ d| _ || _ || _
|
|||
|
|
d| _ | j j dd« j « } d„ | j d« D « }
|
|||
|
|
d|
|
|||
|
|
v rd| _ d | _ | y )NFztransfer-encodingÚ c 3 ó< K — | ] }|j « –— Œ y wr" )r™ )r© Úencs r) rª z,BaseHTTPResponse.__init__.<locals>.<genexpr>î s è ø€ Ò> S�S—Y‘Y—[Ñ>ùs ‚ r— ÚchunkedT)rà r rá ÚstatusÚversionÚversion_stringÚreasonÚdecode_contentÚ_has_decoded_contentÚ _request_urlrâ rç rÒ Úlowerr˜ Ú_decoder) r& rá rè ré rê rë rì Ú request_urlrâ Útr_encrŸ s r) rJ zBaseHTTPResponse.__init__Ò s° € ô �gœ~Ô .Ø"ˆD�Lä)¨'Ó2ˆDŒLØ ˆŒ Ø ˆŒ Ø ,ˆÔØ ˆŒ Ø ,ˆÔØ$)ˆÔ!Ø(3ˆÔØ ˆŒ à ˆŒ Ø— ‘ ×!Ñ!Ð"5°rÓ:×@Ñ@ÓBˆá>¨F¯L©L¸Ó,=Ô>ˆ Ø ˜ Ñ !Ø ˆDŒLà/3ˆŒ
|
|||
|
|
Ú r, c ój — | j | j v r| j j d« S y)a
|
|||
|
|
Should we redirect and where to?
|
|||
|
|
|
|||
|
|
:returns: Truthy redirect location string if we got a redirect status
|
|||
|
|
code and valid location. ``None`` if redirect status and no
|
|||
|
|
location. ``False`` if not a redirect status code.
|
|||
|
|
ÚlocationF)rè ÚREDIRECT_STATUSESrá rÒ r. s r) Úget_redirect_locationz&BaseHTTPResponse.get_redirect_locationõ s. € ð �;‰;˜$×0Ñ0Ñ 0Ø—<‘<×#Ñ# JÓ/Ð /Ør, c ó — t « ‚r" r# r. s r) r' zBaseHTTPResponse.data r0 r, c ób — | j j d« }t j |« S )aÄ
|
|||
|
|
Deserializes the body of the HTTP response as a Python object.
|
|||
|
|
|
|||
|
|
The body of the HTTP response must be encoded using UTF-8, as per
|
|||
|
|
`RFC 8529 Section 8.1 <https://www.rfc-editor.org/rfc/rfc8259#section-8.1>`_.
|
|||
|
|
|
|||
|
|
To use a custom JSON decoder pass the result of :attr:`HTTPResponse.data` to
|
|||
|
|
your custom decoder instead.
|
|||
|
|
|
|||
|
|
If the body of the HTTP response is not decodable to UTF-8, a
|
|||
|
|
`UnicodeDecodeError` will be raised. If the body of the HTTP response is not a
|
|||
|
|
valid JSON document, a `json.JSONDecodeError` will be raised.
|
|||
|
|
|
|||
|
|
Read more :ref:`here <json_content>`.
|
|||
|
|
|
|||
|
|
:returns: The body of the HTTP response as a Python object.
|
|||
|
|
zutf-8)r' ÚdecodeÚ_jsonÚloadsr¾ s r) ÚjsonzBaseHTTPResponse.json s' € ð$ �y‰y× Ñ Ó(ˆÜ�{‰{˜4Ó Ð r, c ó — t « ‚r" r# r. s r) ÚurlzBaseHTTPResponse.url r0 r, c ó — t « ‚r" r# ©r& rþ s r) rþ zBaseHTTPResponse.url r0 r, c ó — t « ‚r" r# r. s r) Ú
|
|||
|
|
connectionzBaseHTTPResponse.connection" r0 r, c ó — | j S r" )Ú_retriesr. s r) râ zBaseHTTPResponse.retries& s € à�}‰}Ð r, c ój — |�*|j r |j d j | _ || _ y )Nr4 )ÚhistoryÚredirect_locationrþ r )r& râ s r) râ zBaseHTTPResponse.retries* s- € ð Ð 7§?¢?Ø —‘ rÑ*×<Ñ<ˆDŒHØ ˆ�
|
|||
|
|
r, c ó — t « ‚r" r# ©r& Úamtrì s r) ÚstreamzBaseHTTPResponse.stream1 s
|
|||
|
|
€ ô "Ó#Ð#r, c ó — t « ‚r" r# )r& r
|
|||
|
|
rì Ú
|
|||
|
|
cache_contents r) ÚreadzBaseHTTPResponse.read6 s
|
|||
|
|
€ ô "Ó#Ð#r, c ó — t « ‚r" r# r s r) Úread1zBaseHTTPResponse.read1> ó
|
|||
|
|
€ ô
|
|||
|
|
"Ó#Ð#r, c ó — t « ‚r" r# r s r) Ú read_chunkedz BaseHTTPResponse.read_chunkedE r r, c ó — t « ‚r" r# r. s r) Ú release_connz BaseHTTPResponse.release_connL r+ r, c ó — t « ‚r" r# r. s r) Ú
|
|||
|
|
drain_connzBaseHTTPResponse.drain_connO r+ r, c ó — t « ‚r" r# r. s r) ÚshutdownzBaseHTTPResponse.shutdownR r+ r, c ó — t « ‚r" r# r. s r) ÚclosezBaseHTTPResponse.closeU r+ r, c óz — | j j dd« j « }| j €€|| j v rt |« | _ yd|v r\|j
|
|||
|
|
d« D �cg c]. }|j « | j v r|j « ‘Œ0 }}|rt |« | _ yyyyc c}w )z=
|
|||
|
|
Set-up the _decoder attribute if necessary.
|
|||
|
|
úcontent-encodingrä Nr— )rá rÒ rï rð ÚCONTENT_DECODERSr› r˜ r™ )r& Úcontent_encodingr rŸ s r) Ú
|
|||
|
|
_init_decoderz BaseHTTPResponse._init_decoderX s½ € ð Ÿ<™<×+Ñ+Ð,>ÀÓC×IÑIÓKÐØ �=‰=Ð Ø 4×#8Ñ#8Ñ8Ü ,Ð-=Ó >�•
|
|||
|
|
ØÐ(Ñ(ð .× 3Ñ 3°CÓ 8ö àØ—w‘w“y D×$9Ñ$9Ñ9ð —G‘G•Ið � ð ñ
|
|||
|
|
Ü$0Ð1AÓ$B�D•Mð ð
|
|||
|
|
)ð !ùò s Á-3B8c óv — |s| j r t d« ‚|S |�|rd} | j r$| j j ||¬« }d| _ |r|| j « z
|
|||
|
|
}|S # | j $ r?}| j
|
|||
|
|
j
|
|||
|
|
dd« j « }t d|z |« |‚d}~ww xY w) zN
|
|||
|
|
Decode the data passed in and potentially flush the decoder.
|
|||
|
|
ú_Calling read(decode_content=False) is not supported after read(decode_content=True) was called.Nr4 rL Tr rä zEReceived response with content-encoding: %s, but failed to decode it.)
|
|||
|
|
rí rÁ rð r* rà rá rÒ rï r Ú_flush_decoder)r& r' rì Ú
|
|||
|
|
flush_decoderr( r r s r) Ú_decodezBaseHTTPResponse._decodek sÛ € ñ Ø×(Ò(Ü"ð<óð ð ˆKà Ð ¡ ؈Jð
|
|||
|
|
Ø�}Š}Ø—}‘}×/Ñ/°ÀÐ/ÓL�Ø,0�Ô)ñ Ø �D×'Ñ'Ó)Ñ )ˆDàˆ øð ×)Ñ)ò Ø #Ÿ|™|× /Ñ /Ð0BÀBÓ G× MÑ MÓ OÐ Ü ð'Ø)9ñ:àóð ð
|
|||
|
|
ûð ús £0A* Á*B8Á9:B3Â3B8c óˆ — | j r6| j j d« | j j « z S y)zk
|
|||
|
|
Flushes the decoder. Should only be called if the decoder is actually
|
|||
|
|
being used.
|
|||
|
|
r, )rð r* r2 r. s r) r# z BaseHTTPResponse._flush_decoder� s5 € ð
|
|||
|
|
�=Š=Ø—=‘=×+Ñ+¨CÓ0°4·=±=×3FÑ3FÓ3HÑHÐ HØr, c ó† — | j t |« « }t |« dk( ry||d t |« t |« S r¢ )r ri )r& ÚbÚtemps r) ÚreadintozBaseHTTPResponse.readintoš s; € Ø�y‰yœ˜Q›Ó ˆÜ ˆt‹9˜Š>Øà !ˆAˆk”�D“ ˆNÜ�t“9Ð r, c ó — | j S r" ©rá r. s r) Ú
|
|||
|
|
getheaderszBaseHTTPResponse.getheaders£ ó € Ø�|‰|Ðr, c ó: — | j j ||« S r" )rá rÒ )r& ÚnameÚdefaults r) Ú getheaderzBaseHTTPResponse.getheader¦ s € Ø�|‰|× Ñ gÓ.Ð.r, c ó — | j S r" r, r. s r) ÚinfozBaseHTTPResponse.infoª r. r, c ó — | j S r" )rþ r. s r) ÚgeturlzBaseHTTPResponse.geturl s € Ø�x‰xˆr, )rá ú>typing.Mapping[str, str] | typing.Mapping[bytes, bytes] | Nonerè r7 ré r7 rê r¬ rë ú
|
|||
|
|
str | Nonerì r: rñ r8 râ ú Retry | Noner8 rW )r8 z"str | None | typing.Literal[False]r; )r8 z
|
|||
|
|
typing.Any©r8 r8 ©rþ r8 r8 rW )r8 zBaseHTTPConnection | None)r8 r9 )râ r9 r8 rW ©i N)r
|
|||
|
|
ú
|
|||
|
|
int | Nonerì ú bool | Noner8 útyping.Iterator[bytes]©NNF©r
|
|||
|
|
r= rì r> r
|
|||
|
|
r: r8 r6 ©NN©r
|
|||
|
|
r= rì r> r8 r6 rV r" )
|
|||
|
|
r' r6 rì r> r$ r: r( r= r8 r6 )r( zbytearray | memoryview[int]r8 r7 )r8 r )r0 r¬ r1 r8 r8 r8 )'r< r= r> r rs r² rõ ÚIOErrorrG rN rà Ú__annotations__r„ Ú ZstdErrorrJ rö r? r' rü rþ Úsetterr râ r r r r r r r r r r% r# r* r- r2 r4 r6 r@ r, r) rÞ rÞ Ã sˆ … Ú4ÐØ
|
|||
|
|
ÐؘT˜FÑ"ÐÙؘV˜HÑ$ÐÚ1Ðà:AÀ4Ç:Á:Ð9NÐÐ6ÓNØ
|
|||
|
|
ÐØ &§,¡, Ñ0Ð áØ $§.¡.Ð!2Ñ2Ð ð
|
|||
|
|
SWð !%ñ!*ð Pð!*ð ð !*ð
|
|||
|
|
ð !*ð ð
|
|||
|
|
!*ð ð!*ð ð!*ð ð!*ð ð!*ð
|
|||
|
|
ó!*óF
|
|||
|
|
ð ò$ó ð$ó!ð* ò$ó ð$ð ‡Z�Zò$ó ð$ð ò$ó ð$ð ò ó ð ð
|
|||
|
|
‡^�^ò ó ð ð FJð$Ø ð$Ø7Bð$à ó$ð Ø&*Ø #ð $à
|
|||
|
|
ð$ð $ð$ð ð $ð
|
|||
|
|
|
|||
|
|
ó $ð Ø&*ð$à
|
|||
|
|
ð$ð $ð$ð
|
|||
|
|
ó $ð Ø&*ð$à
|
|||
|
|
ð$ð $ð$ð
|
|||
|
|
ó $ó$ó$ó$ó$óCð0 "&ð #àð#ð $ð#ð ð #ð
|
|||
|
|
ð #ð
|
|||
|
|
ó
|
|||
|
|
#óJó ó ô/ó ôr, rÞ c ó ‡ — e Zd ZdZ d d ˆ fd„
|
|||
|
|
Zd!d„Zd!d„Zed"d„« Zed#d„« Z d$d„Z
|
|||
|
|
d%d„Z d&d „Z e
|
|||
|
|
d'd
|
|||
|
|
„« Z d(d d œ d)d
|
|||
|
|
„Z d(d d œ d)d„Z d* d+d„Z d, d-d„Z d. d/d„Zd$d„Zd!d„Zd!d„Zed$d„« Zd%d„Zd!d„Zd$d„Zd!d„Zd0d„Z d, d/d„Z ed1d „« Z e j> d2d „« Z d3d „Z ˆ xZ!S )4r aá
|
|||
|
|
HTTP Response container.
|
|||
|
|
|
|||
|
|
Backwards-compatible with :class:`http.client.HTTPResponse` but the response ``body`` is
|
|||
|
|
loaded and decoded on-demand when the ``data`` property is accessed. This
|
|||
|
|
class is also compatible with the Python standard library's :mod:`io`
|
|||
|
|
module, and can hence be treated as a readable object in the context of that
|
|||
|
|
framework.
|
|||
|
|
|
|||
|
|
Extra parameters for behaviour not present in :class:`http.client.HTTPResponse`:
|
|||
|
|
|
|||
|
|
:param preload_content:
|
|||
|
|
If True, the response's body will be preloaded during construction.
|
|||
|
|
|
|||
|
|
:param decode_content:
|
|||
|
|
If True, will attempt to decode the body based on the
|
|||
|
|
'content-encoding' header.
|
|||
|
|
|
|||
|
|
:param original_response:
|
|||
|
|
When this HTTPResponse wrapper is generated from an :class:`http.client.HTTPResponse`
|
|||
|
|
object, it's convenient to include the original for debug purposes. It's
|
|||
|
|
otherwise unused.
|
|||
|
|
|
|||
|
|
:param retries:
|
|||
|
|
The retries contains the last :class:`~urllib3.util.retry.Retry` that
|
|||
|
|
was used during the request.
|
|||
|
|
|
|||
|
|
:param enforce_content_length:
|
|||
|
|
Enforce content length checking. Body returned by server must match
|
|||
|
|
value of Content-Length header, if present. Otherwise, raise error.
|
|||
|
|
c
|
|||
|
|
óØ •— t ‰| � ||||||||
|
|||
|
|
¬« || _ || _ d | _ d| _ d | _ | | _ d| _ | | _ |r t |t t f« r|| _ |
|
|||
|
|
| _
|
|||
|
|
| | _ t |d« r|| _ || _ d | _ | j% |« | _ t) « | _ |r%| j s| j- |¬« | _ y y y )N)rá rè ré rê rë rì rñ râ Fr r ©rì )ÚsuperrJ Úenforce_content_lengthÚ
|
|||
|
|
auto_closeÚ_bodyÚ_uncached_read_occurredÚ_fpÚ_original_responseÚ_fp_bytes_readÚmsgrà r¬ r6 Ú_poolÚ _connectionru Ú_sock_shutdownÚ
|
|||
|
|
chunk_leftÚ _init_lengthÚlength_remainingrµ Ú_decoded_bufferr )r& Úbodyrá rè ré rê rë Úpreload_contentrì Úoriginal_responseÚpoolr rS râ rL Úrequest_methodrñ rM Ú
|
|||
|
|
sock_shutdownÚ __class__s €r) rJ zHTTPResponse.__init__Ò sû ø€ ô* ‰ÑØØØØ)ØØ)Ø#Øð ô
|
|||
|
|
ð '=ˆÔ#Ø$ˆŒàˆŒ
|
|||
|
|
Ø',ˆÔ$Ø04ˆŒØ"3ˆÔ Ø ˆÔ؈Œá ”J˜t¤c¬5 \Ô2Ø ˆDŒJàˆŒ
|
|||
|
|
Ø%ˆÔä �4˜Ô ؈DŒHØ +ˆÔð '+ˆŒð !%× 1Ñ 1°.Ó AˆÔ ô 0Ó 1ˆÔ ñ 4§:¢:Ø Ÿ™°.˜ÓAˆD�Jð $.ˆ?r, c óŽ — | j r | j sy | j j | j « d | _ y r" )rT rU Ú _put_connr. s r) r zHTTPResponse.release_conn s4 € Ø�zŠz ×!1Ò!1Øà �
|
|||
|
|
‰
|
|||
|
|
× Ñ ˜T× -Ñ -Ô.Ø ˆÕr, c óª — | j « | j
|
|||
|
|
rt
|
|||
|
|
« | _ d| _ yy# t t t t f$ r Y Œ?w xY w)zÏ
|
|||
|
|
Read and discard any remaining HTTP response data in the response connection.
|
|||
|
|
|
|||
|
|
Unread data in the HTTPResponse connection blocks the connection from being released back to the pool.
|
|||
|
|
N) Ú _raw_readr ÚOSErrorr
|
|||
|
|
r rí rµ rZ rð r. s r) r zHTTPResponse.drain_conn sR € ð Ø �N‰NÔ ð × $Ò $ô $4Ó#5ˆDÔ Ø ˆD�Mð %øô œ7¤L´-Ð@ò Ù ð ús ‚6 ¶AÁAc óp — | j r | j S | j r| j d¬« S y )NT)r
|
|||
|
|
)rN rP r r. s r) r' zHTTPResponse.data* s0 € ð �:Š:Ø—:‘:Ð à �8Š8Ø—9‘9¨4�9Ó0Ð 0àr, c ó — | j S r" )rU r. s r) r zHTTPResponse.connection5 s € à× Ñ Ð r, c ó, — t | j « S r" )r rP r. s r) ÚisclosedzHTTPResponse.isclosed9 s € ܘDŸH™HÓ%Ð%r, c ó — | j S )zÙ
|
|||
|
|
Obtain the number of bytes pulled over the wire so far. May differ from
|
|||
|
|
the amount of content returned by :meth:`HTTPResponse.read`
|
|||
|
|
if bytes are encoded on the wire (e.g, compressed).
|
|||
|
|
)rR r. s r) ÚtellzHTTPResponse.tell< s € ð ×"Ñ"Ð"r, c óê — | j j d« }|�~| j rt j d« y |j d« D �ch c]
|
|||
|
|
}t
|
|||
|
|
|« ’Œ }}t |« dkD rt d|z « ‚|j « }|dk rd}nd} t
|
|||
|
|
| j « }|dv sd |cxk rd
|
|||
|
|
k sn |d k( rd}|S c c}w # t $ r d}Y ŒBw xY w# t $ r d}Y Œ=w xY w) zM
|
|||
|
|
Set initial length value for Response content if available.
|
|||
|
|
zcontent-lengthNzÒReceived response with both Content-Length and Transfer-Encoding set. This is expressly forbidden by RFC 7230 sec 3.3.2. Ignoring Content-Length and attempting to process response as Transfer-Encoding: chunked.r— r z8Content-Length contained multiple unmatching values (%s)r )éÌ i0 éd éÈ ÚHEAD) rá rÒ rç ÚlogÚwarningr˜ r7 ri r rÖ r rè )r& r_ Úcontent_lengthÚvalÚlengthsrŽ rè s r) rX zHTTPResponse._init_lengthD s € ð
|
|||
|
|
&*§\¡\×%5Ñ%5Ð6FÓ%Gˆà Ð %Ø�|Š|ô — ‘ ð ôð ð
|
|||
|
|
"ð 0>×/CÑ/CÀCÓ/HÖI¨œ3˜s�8ÐI�ÐIÜ�w“< !Ò#Ü'ð1Ø3AñBóð ð !Ÿ™› �ð ˜A’:Ø !‘Fð ˆFð ܘŸ™Ó%ˆFð
|
|||
|
|
�ZÑ 3¨&Ô#6°3Ô#6¸.ÈFÒ:R؈Fàˆ
|
|||
|
|
ùò7 Jøô ò
|
|||
|
|
Ø ’ð
|
|||
|
|
ûô ò ØŠFð ús6 ÁC ÁCÁ&.C Â C$ ÃC Ã C!Ã C!Ã$ C2Ã1C2c # ó® K — d} d–— d}|sL| j r| j j « | j r| j j « | j r,| j j « r| j « yyy# t $ r }t | j dd« |‚d}~wt $ r}t |« |‚d}~wt
|
|||
|
|
$ rL}|j �)|j � |j |j k( rd}nd|›�}t ||« |‚d}~wt t f$ r}t d|›�|« |‚d}~ww xY w# |sL| j r| j j « | j r| j j « | j r,| j j « r| j « w w w xY ww)zç
|
|||
|
|
Catch low-level python exceptions, instead re-raising urllib3
|
|||
|
|
variants, so that low-level exceptions are not leaked in the
|
|||
|
|
high-level api.
|
|||
|
|
|
|||
|
|
On exit, release the connection back to the pool.
|
|||
|
|
FNzRead timed out.z!Response may not contain content.zConnection broken: T)Ú
|
|||
|
|
SocketTimeoutr rT r
|
|||
|
|
r r ÚexpectedÚpartialr r rf rQ r rU rj r )r& Ú
|
|||
|
|
clean_exitr Úargs r) Ú_error_catcherzHTTPResponse._error_catcher| sº è ø€ ð ˆ
|
|||
|
|
ð1 $ð
|
|||
|
|
KÛð6 ˆJñ ð ×*Ò*Ø×+Ñ+×1Ñ1Ô3ð
|
|||
|
|
×#Ò#Ø×$Ñ$×*Ñ*Ô,ð ×&Ò&¨4×+BÑ+B×+KÑ+KÔ+MØ×!Ñ!Õ#ð ,NÐ&øôY !ò
|
|||
|
|
Sô ' t§z¡z°4Ð9JÓKÐQRÐRûä ò
|
|||
|
|
)ä ˜q“k qÐ(ûä!ò
|
|||
|
|
3à—J‘JÐ*ØŸ ™ Ð-ØŸ
|
|||
|
|
™
|
|||
|
|
q§y¡y jÒ0à=‘Cà /°¨uÐ5�CÜ# C¨Ó+°Ð2ûä!¤7Ð+ò
|
|||
|
|
KÜ#Ð&9¸!¸Ð$?ÀÓCÈÐJûð
|
|||
|
|
Kûñ ð ×*Ò*Ø×+Ñ+×1Ñ1Ô3ð
|
|||
|
|
×#Ò#Ø×$Ñ$×*Ñ*Ô,ð ×&Ò&¨4×+BÑ+B×+KÑ+KÔ+MØ×!Ñ!Õ#ð ,NÐ&üs_ ‚G‡B ‹E
|
|||
|
|
�BGÂ EÂ B5Â5 EÃ C
|
|||
|
|
Ã
|
|||
|
|
EÃAD Ä EÄ2EÅEÅE
|
|||
|
|
Å
|
|||
|
|
BGÇGF©r c ó¼ — | j sJ ‚d}|r||kD s |€Ô| j rÈ| j |kD r¹t j r©|r| j j |« S t j « }d}|�|dk7 r_|�t ||« }||z }n|}| j j |« }|s |j « S |j |« ~|€ŒY|dk7 rŒ_|j « S |r7|�| j j |« S | j j « S |�| j j |« S | j j « S )a†
|
|||
|
|
Read a response with the thought that reading the number of bytes
|
|||
|
|
larger than can fit in a 32-bit int at a time via SSL in some
|
|||
|
|
known cases leads to an overflow error that has to be prevented
|
|||
|
|
if `amt` or `self.length_remaining` indicate that a problem may
|
|||
|
|
happen.
|
|||
|
|
|
|||
|
|
This happens to urllib3 injected with pyOpenSSL-backed SSL-support.
|
|||
|
|
iÿÿÿi r ) rP rY r
|
|||
|
|
Ú IS_PYOPENSSLr rÅ rÆ Úminr rÈ rÊ )r& r
|
|||
|
|
r Ú c_int_maxr¹ Ú
|
|||
|
|
max_chunk_amtÚ chunk_amtr' s r) Ú_fp_readzHTTPResponse._fp_readº s; € ð �xŠxˆˆxØ ˆ á
|
|||
|
|
�S˜9’_à� Ø×)Ò)Ø×)Ñ)¨IÒ5ä× Ò ÙØ—x‘x—~‘~ iÓ0Ð0Ü—Z‘Z“\ˆFð "ˆMØ�+ ¨¢Ø�?Ü # C¨ Ó 7�Iؘ9Ñ$‘Cà -�IØ—x‘x—}‘} YÓ/�ÙØð —?‘?Ó$Ð $ð — ‘ ˜TÔ"Øð ‘+ ¨£ð —?‘?Ó$Ð $Ù
|
|||
|
|
Ø*-¨/�4—8‘8—>‘> #Ó&Ð O¸t¿x¹x¿~¹~Ó?OÐ Oð *-¨ �4—8‘8—=‘= Ó%Ð M¸d¿h¹h¿m¹m»oÐ Mr, c ó¤ — | j €yt | j dd« }| j « 5 |s| j ||¬« nd}|�h|dk7 rc|sa| j j « | j
|
|||
|
|
rv| j �j| j dk7 r[t | j | j « ‚|r9|dk7 r|r| j t |« k( r| j j « ddd« rH| xj t |« z
|
|||
|
|
c_ | j � | xj t |« z c_ |S # 1 sw Y ŒUxY w)z7
|
|||
|
|
Reads `amt` of bytes from the socket.
|
|||
|
|
NÚclosedFr~ r, r )
|
|||
|
|
rP Úgetattrr} r… r rL rY r rR ri )r& r
|
|||
|
|
r Ú fp_closedr' s r) re zHTTPResponse._raw_readï s$ € ð �8‰8Ð Øä˜DŸH™H h°Ó6ˆ à
|
|||
|
|
×
|
|||
|
|
Ñ
|
|||
|
|
Ó
|
|||
|
|
"ñ !Ù:C�4—=‘= ¨E�=Ô2ȈD؈ 3¨!¢8±Dð —‘—‘Ô à×/Ò/Ø ×-Ñ-Ð9Ø ×-Ñ-°Ò2ô )¨×)<Ñ)<¸d×>SÑ>SÓTÐTÙؘ’¡$¨4×+@Ñ+@ÄCÈÃIÒ+Mð —‘—‘Ô ÷= !ñ@ Ø × Ò ¤3 t£9Ñ ,Õ Ø×$Ñ$Ð0Ø×%Ò%¬¨T«Ñ2Õ%؈ ÷I !ð !ús µB=EÅEc óš — | j « |€ | j }|r|dk rd}n·|�µd}| j rt| j j r^t | j
|
|||
|
|
« |k rF| j
|
|||
|
|
d|d|t | j
|
|||
|
|
« z
|
|||
|
|
¬« }| j
|
|||
|
|
j |« t | j
|
|||
|
|
« |k\ r| j
|
|||
|
|
j |« S | j |« }|sd| _
|
|||
|
|
|du xs
|