1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
Ë
¸^i2ãóè—dZddlZddlZddlmZmZmZmZmZm    Z    m
Z
m Z m Z ddl mZddlmZddlmZddlmZdd    lmZdd
lmZd Zd Zd ej6cxkxrdkncZej6dkZexseZGd„de
«Zedd«Z edd«Z!e ee"gedfZ#e edgedfZ$Gd„de«Z%de&de&fd„Z'de&ddde"fd„Z(e(Z)    ddl*m+Z+e+jRZ,ese,Z)yy#e-$rYywxYw)z"Http related parsers and protocol.éN)    Ú TYPE_CHECKINGÚAnyÚ    AwaitableÚCallableÚIterableÚListÚ
NamedTupleÚOptionalÚUnion)Ú CIMultiDicté)ÚAbstractStreamWriter)Ú BaseProtocol)ÚClientConnectionResetError)ÚZLibCompressor)Ú NO_EXTENSIONS)Ú StreamWriterÚ HttpVersionÚ HttpVersion10Ú HttpVersion11i)éé r)rré)ré é    có"—eZdZUeed<eed<y)rÚmajorÚminorN)Ú__name__Ú
__module__Ú __qualname__ÚintÚ__annotations__©óõfH:\项目\archive\测试组\脚本\Change_password\venv_build\Lib\site-packages\aiohttp/http_writer.pyrr's …Ø ƒJØ „Jr%rúCIMultiDict[str]c óЗeZdZUdZeeed<dZeed<dZ    eed<dZ
ee ed<        d*de de jd    ed
ed df
d „Zed ee j&fd „«Zed e fd„«Zd+d„Z    d,dedeed dfd„Zdeeeefd dfd„Zdeed dfd„Zdeeeddfd dfd„Z deeeddfded dfd„Z!dddœdeeeefded ed dfd!„Z"d"ed#d$d dfd%„Z#d+d&„Z$d+d'„Z%d-ded dfd(„Z&d+d)„Z'y).rNÚlengthFÚchunkedÚ_eofÚ    _compressÚprotocolÚloopÚ on_chunk_sentÚon_headers_sentÚreturncóX—||_||_||_||_d|_d|_y)NF)Ú    _protocolr.Ú_on_chunk_sentÚ_on_headers_sentÚ _headers_bufÚ_headers_written)Úselfr-r.r/r0s     r&Ú__init__zStreamWriter.__init__;s2€ð"ˆŒØˆŒ    Ø.;ˆÔØ2AˆÔØ-1ˆÔØ&+ˆÕr%có.—|jjS©N)r3Ú    transport©r8s r&r<zStreamWriter.transportIs€à~‰~×'Ñ'Ð'r%có—|jSr;)r3r=s r&r-zStreamWriter.protocolMs €à~‰~Ðr%có—d|_y)NT)r*r=s r&Úenable_chunkingzStreamWriter.enable_chunkingQs    €Øˆ r%ÚencodingÚstrategycó(—t||¬«|_y)N)rArB)rr,)r8rArBs   r&Úenable_compressionzStreamWriter.enable_compressionTs€ô(°ÀHÔMˆr%Úchunkcóö—t|«}|xj|z c_|xj|z c_|jj}||j «r t d«‚|j|«y)Nú!Cannot write to closing transport)ÚlenÚ buffer_sizeÚ output_sizer3r<Ú
is_closingrÚwrite)r8rEÚsizer<s    r&Ú_writezStreamWriter._writeYse€Ü5‹zˆØ ×Ò˜DÑ ÕØ ×Ò˜DÑ ÕØ—N‘N×,Ñ,ˆ    Ø Ð      × 4Ñ 4Ô 6Ü,Ð-PÓQÐ Q؏‰˜Õr%Úchunkscón—d}|D]}|t|«z }Œ|xj|z c_|xj|z c_|jj}||j «r t d«‚ts    |tkr!|jdj|««y|j|«y)NrrGr%) rHrIrJr3r<rKrÚSKIP_WRITELINESÚMIN_PAYLOAD_FOR_WRITELINESrLÚjoinÚ
writelines)r8rOrMrEr<s     r&Ú _writelineszStreamWriter._writelinesbs €ØˆØò    ˆEØ ”C˜“JÑ ‰Dð    à ×Ò˜DÑ ÕØ ×Ò˜DÑ ÕØ—N‘N×,Ñ,ˆ    Ø Ð      × 4Ñ 4Ô 6Ü,Ð-PÓQÐ QÝ ˜dÔ%?Ò?Ø O‰O˜CŸH™H VÓ,Õ -à ×  Ñ   Õ (r%zmemoryview[int]zmemoryview[bytes]cóh—t|«d›djd«}|j||df«y)z+Write a chunk with proper chunked encoding.Úxú
Úasciió
N)rHÚencoderU)r8rEÚ chunk_len_pres   r&Ú_write_chunked_payloadz#StreamWriter._write_chunked_payloadps6€ô˜u›: a˜.¨Ð-×4Ñ4°WÓ=ˆ Ø ×ј-¨°Ð8Õ9r%Úis_eofcóž—d|_|j}d|_tr|€J‚|js(|r|j    ||f«y|j |«y|rLt |«d›djd«}|r|j    |||df«y|j    |||df«y|r|j    |df«y|j |«y)    zASend buffered headers with payload, coalescing into single write.TNrWrXrYó
0
 
rZó0
 
)r7r6rr*rUrNrHr[)r8rEr^Ú headers_bufr\s     r&Ú_send_headers_with_payloadz'StreamWriter._send_headers_with_payloadwsـð!%ˆÔØ×'Ñ'ˆ Ø ˆÔå ðÐ*Ð *Ð*à|Š|áØ× Ñ  +¨uÐ!5Ô6ð ð— ‘ ˜KÔ(Ø ñ Ü" 5›z¨!˜n¨DÐ1×8Ñ8¸ÓAˆMÙØ× Ñ  +¨}¸eÐEUÐ!VÕWà× Ñ  +¨}¸eÀWÐ!MÕNÙ Ø × Ñ ˜k¨<Ð8Õ 9à K‰K˜ Õ $r%Ti)ÚdrainÚLIMITrdrecƒófK—|j|j|«ƒd{–—†t|t«r)|jt    |«k7r|j d«}|j &|j j|«ƒd{–—†}|sy|jHt    |«}|j|k\r|j|z
|_n|d|j}d|_|sy|jrO|jsC|j|d«|r.|j|kDrd|_ |j«ƒd{–—†y|rb|jr|j|«n|j!|«|r0|j|kDr d|_ |j«ƒd{–—†yyyy7Œ„7Œ7Œp7Œ­w)zÊ
        Writes chunk of data to a stream.
 
        write_eof() indicates end of stream.
        writer can't be used after write_eof() method being called.
        write() return drain future.
        NÚcrF)r4Ú
isinstanceÚ
memoryviewÚnbytesrHÚcastr,Úcompressr)r6r7rcrIrdr*r]rN)r8rErdreÚ    chunk_lens     r&rLzStreamWriter.write›s}èø€ð × Ñ Ð *Ø×%Ñ% eÓ,× ,Ð ,ä eœZÔ (؏|‰|œs 5›zÒ)àŸ
™
 3›à >‰>Ð %ØŸ.™.×1Ñ1°%Ó8×8ˆEÙØà ;‰;Ð "ܘE›
ˆI؏{‰{˜iÒ'Ø"Ÿk™k¨IÑ5• à˜m § ¡ Ð,Ø” ÙØð × Ò  T×%:Ò%:Ø × +Ñ +¨E°5Ô 9Ù˜×)Ñ)¨EÒ1Ø#$Ô Ø—j‘j“l×"Ð"Ø á Ø|Š|Ø×+Ñ+¨EÕ2à— ‘ ˜EÔ"á˜×)Ñ)¨EÒ1Ø#$Ô Ø—j‘j“l×"Ñ"ð2ˆuð ð= -ùð9ùð&#øð#úsH‚!F1£F'¤A'F1 F* B0F1Ä<F-Ä=A!F1ÆF/Æ    F1Æ*F1Æ-F1Æ/F1Ú status_lineÚheadersr'cƒóŽK—|j|j|«ƒd{–—†t||«}d|_||_y7Œ­w)zWrite headers to the stream.NF)r5Ú_serialize_headersr7r6)r8rnroÚbufs    r&Ú write_headerszStreamWriter.write_headersÒsIèø€ð ×  Ñ  Ð ,Ø×'Ñ'¨Ó0× 0Ð 0ä  ¨gÓ6ˆØ %ˆÔ؈Õð     1ús‚!A£A¤ Acó —|jr |jryd|_|j}d|_tr|€J‚|j|«y)z3Force sending buffered headers if not already sent.NT)r6r7rrN©r8rbs  r&Ú send_headerszStreamWriter.send_headersÝsL€à× Ò  D×$9Ò$9Ø à $ˆÔØ×'Ñ'ˆ Ø ˆÔå àÐ*Ð *Ð*à  ‰ KÕ r%cóv—|jry|jrp|jsdd|_|j}d|_tr|€J‚|jr|j |df«d|_y|j |«d|_y|jr|jr|j d«d|_y)z&Indicate that the message is complete.NTra)r+r6r7rr*rUrNrus  r&Úset_eofzStreamWriter.set_eofìs©€à 9Š9Ø ð × Ò  T×%:Ò%:Ø$(ˆDÔ !Ø×+Ñ+ˆKØ $ˆDÔ åà"Ð.Ð.Ð.ð|Š|Ø× Ñ  +¨|Ð!<Ô=ðˆ    ð — ‘ ˜KÔ(ð
ˆ    ð    \Š\˜d×3Ò3à K‰K˜ Ô %àˆ    r%cƒóîK—|jry|r%|j|j|«ƒd{–—†|jr²g}d}|rA|jj|«ƒd{–—†x}rt    |«}|j |«|jj «}|t    |«z }|j |«|sJ‚|jr•|js‰d|_|j}d|_|jr.|d›djd«}|j||g|¢d‘­«n|j|g|¢­«|j«ƒd{–—†d|_y|jr-|d›djd«}|j|g|¢d‘­«n4t    |«dkDr|j|«n|j|d«|j«ƒd{–—†d|_y|jr>|js2|j|d«|j«ƒd{–—†d|_y|jrd|r1|jt    |«d›djd«|df«n|jd«|j«ƒd{–—†d|_y|r)|j|«|j«ƒd{–—†d|_y7Œ±7Œ~7Œ7Œ7Œ»7ŒM7Œ­w)    NrTrWrXrYr`r ra)r+r4r,rlrHÚappendÚflushr6r7r*r[rUrdrNrc)r8rErOÚ
chunks_lenÚcompressed_chunkÚ flush_chunkrbr\s        r&Ú    write_eofzStreamWriter.write_eofsÂèø€Ø 9Š9Ø á T×(Ñ(Ð4Ø×%Ñ% eÓ,× ,Ð ,ð >‹>Ø"$ˆF؈JÙ°D·N±N×4KÑ4KÈEÓ4R×.RÐRÐ*ÐRÜ Ð!1Ó2
Ø— ‘ Ð.Ô/àŸ.™.×.Ñ.Ó0ˆKØ œ#˜kÓ*Ñ *ˆJØ M‰M˜+Ô &ÙÐ :ð× Ò ¨×)>Ò)>Ø(,Ô%Ø"×/Ñ/ Ø$(Ô!à—<’<à'1°! n°DÐ$9×$@Ñ$@ÀÓ$IMØ×$Ñ$Ø$ mÐO°fÐOÐ>NÑOõð
×$Ñ$ kÐ%;°FÑ%;Ô<Ø—j‘j“l×"Ð"Ø ”    Øð|Š|Ø#-¨a .°Р5× <Ñ <¸WÓ E Ø× Ñ  -Ð!K°&Ð!KÐ:JÑ!KÕLܐV“˜q’Ø× Ñ  Õ(à— ‘ ˜F 1™IÔ&Ø—*‘*“,× Ð ØˆDŒIØ ð × Ò  T×%:Ò%:à × +Ñ +¨E°4Ô 8Ø—*‘*“,× Ð ØˆDŒIØ ð <Š<ÙàנѠܘE›
 1~ TÐ*×1Ñ1°'Ó:¸EÐCSÐTõð— ‘ ˜LÔ)Ø—*‘*“,× Ð ØˆDŒIØ á Ø K‰K˜Ô Ø—*‘*“,× Ð àˆ    ðO -ùð /Sùð0#ùð ùð øð øð ús‚0K5²K#³5K5Á(K&Á)C3K5ÅK)ÅB K5Ç)K,Ç*A    K5È3K/È4A/K5Ê#K1Ê$2K5ËK3Ë K5Ë&K5Ë)K5Ë,K5Ë/K5Ë1K5Ë3K5cƒóŒK—|j}|j&|jr|j«ƒd{–—†yyy7Œ­w)zFlush the write buffer.
 
        The intended use is to write
 
          await w.write(data)
          await w.drain()
        N)r3r<Ú_pausedÚ _drain_helper)r8r-s  r&rdzStreamWriter.drainUsBèø€ð—>‘>ˆØ × Ñ Ð )¨h×.>Ò.>Ø×(Ñ(Ó*× *Ñ *ð/?Ð )Ø *ús‚8AºA»A)NN)r1N)ÚdeflateN)r%)(rr r!r)r
r"r#r*Úboolr+r,rrÚasyncioÚAbstractEventLoopÚ_T_OnChunkSentÚ_T_OnHeadersSentr9ÚpropertyÚ    Transportr<r-r@ÚstrrDr ÚbytesÚ    bytearrayrirNrrUr]rcrLrsrvrxrrdr$r%r&rr4sø…à €FˆHS‰MӠ؀GˆTÓØ€Dˆ$ÓØ*.€Iˆx˜Ñ'Ó.ð )-Ø,0ñ ,àð ,ð×'Ñ'ð ,ð&ð     ,ð
*ð ,ð
ó ,ðð(˜8 G×$5Ñ$5Ñ6ò(óð(ðð˜,òóðóðDHñNØðNØ3;¸C±=ðNà     óNð
˜E %¨°JÐ">Ñ?ðÀDóð ) (¨5¡/ð )°dó )ð:ؘ5 )Ð->Ð@SÐSÑTð:à     ó:ð"%àU˜IÐ'8Ð:MÐMÑNð"%ðð"%ð
ó    "%ðPØò 5#àU˜I zÐ1Ñ2ð5#ðð    5#ð
ð 5#ð
ó 5#ðn     Øð     Ø);ð     à     ó     ó !óñ6L UðL°TóLô\
+r%rÚstringr1có,—d|vsd|vr td«‚|S)Nú ú
zRNewline or carriage return detected in headers. Potential header injection attack.)Ú
ValueError)rŽs r&Ú _safe_headerr“bs(€Ø ˆv~˜ ™Üð 1ó
ð    
ð €Mr%rnrocó†—d„|j«D«}|dzdj|«zdz}|jd«S)Nc3óVK—|]!\}}t|«dzt|«z–—Œ#y­w)z: N)r“)Ú.0ÚkÚvs   r&ú    <genexpr>z(_py_serialize_headers.<locals>.<genexpr>ls&èø€ÒXÁÀÀ1”< “? TÑ)¬L¸«OÕ;ÑXùs‚')rXz
 
zutf-8)ÚitemsrSr[)rnroÚ headers_genÚlines    r&Ú_py_serialize_headersrks>€ÙXÈÏ É ËÔX€KØ ˜Ñ  &§+¡+¨kÓ":Ñ :¸ZÑ G€DØ ;‰;wÓ Ðr%).Ú__doc__r…ÚsysÚtypingrrrrrrr    r
r Ú    multidictr ÚabcrÚ base_protocolrÚclient_exceptionsrÚcompression_utilsrÚhelpersrÚ__all__rRÚ version_infoÚIS_PY313_BEFORE_313_2ÚIS_PY_BEFORE_312_9rQrrrrŒr‡rˆrr‹r“rrqÚaiohttp._http_writerÚ _http_writerÚ_c_serialize_headersÚ ImportErrorr$r%r&ú<module>r¯sIðÙ(ãÛ
÷
÷
õ
õ"å%Ý'Ý9Ý-Ý"à
K€ð"ÐØ" c×&6Ñ&6ÖC¸ÔCÐØ×%Ñ%¨
Ñ2ÐØ'Ò=Ð+=€ô*ôñ
˜A˜qÓ!€ Ù˜A˜qÓ!€ ð˜( E 7¨I°d©OÐ#;Ñ<Ñ=€Ø˜HÐ&8Ð%9¸9ÀT¹?Ð%JÑKÑLÐôk+Ð'ôk+ð\    ˜ð óð  sð Ð5Gð ÈEó ð +Ðð    Ý/à'×:Ñ:ÐÙ Ø1Ñð øàò    Ùð    úsÃC)Ã)C1Ã0C1