M~ d Z ddlZddlZddlmZmZmZmZmZm Z ddl
m Z ddl m
Z
ddlmZ ddlmZ dd lmZ d
Z G d d e Z edd Z edd Zeeeged f Zeed
ged f Z G d de
Zde de fdZ de dd
defdZ e Z ddl m!Z! e!j Z"ese"Z dS dS # e#$ r Y dS w xY w)z"Http related parsers and protocol. N)Any AwaitableCallable
NamedTupleOptionalUnion) CIMultiDict )AbstractStreamWriter) BaseProtocol)ZLibCompressor)
NO_EXTENSIONS) StreamWriter HttpVersion
HttpVersion10
HttpVersion11c $ e Zd ZU eed< eed< dS )r majorminorN)__name__
__module__ __qualname__int__annotations__ g/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/http_writer.pyr r s" JJJ JJJJJr r CIMultiDict[str]c e Zd Z d dedej dededdf
dZe de
ej fd Z e defd Z
d d
Zd ej fd ed
eddfdZdeddfdZddddedededdfdZdeddddfdZd deddfd Zd d ZdS )!r Nprotocolloop
on_chunk_senton_headers_sentreturnc || _ || _ d | _ d| _ d| _ d| _ d| _ d | _ d | _ || _ || _
d S )NFr ) _protocolr! lengthchunked buffer_size output_size_eof _compress
_drain_waiter_on_chunk_sent_on_headers_sent)selfr r! r" r# s r __init__zStreamWriter.__init__ s\ " 37 !.;2A r c | j j S N)r& transportr0 s r r4 zStreamWriter.transport5 s
~''r c | j S r3 )r& r5 s r r zStreamWriter.protocol9 s
~ r c d| _ d S )NT)r( r5 s r enable_chunkingz StreamWriter.enable_chunking= s
r deflateencodingstrategyc 2 t || | _ d S )N)r: r; )r
r, )r0 r: r; s r enable_compressionz StreamWriter.enable_compression@ s (HMMMr chunkc t | }| xj |z
c_ | xj |z
c_ | j }| j j r|| rt d | | d S )Nz!Cannot write to closing transport) lenr) r* r4 r& connected
is_closingConnectionResetErrorwrite)r0 r> sizer4 s r _writezStreamWriter._writeE s 5zz D D N ~' L9+< @T@T@V@V+<&'JKK K r Ti )drainLIMITrG rH c K | j | | d{V t |t r-|j t | k r| d }| j $| j | d{V }|sdS | j Dt | }| j |k r| j |z
| _ n|d| j }d| _ |sdS |ry| j r-dt | z
d }||z dz }| | | j |k r'|r'd| _ |
d{V dS dS dS dS )zWrites 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.
Ncr %x
asciis
)r.
isinstance
memoryviewnbytesr@ castr, compressr' r( encoderF r) rG )r0 r> rG rH chunk_len
chunk_len_pres r rD zStreamWriter.writeN s *%%e,, , , , , , , , eZ ( ( (|s5zz))
3 > % .11%88888888E
; "E
I{i'' "kI 5 m m, F #|
8!)CJJ!6 > >w G G
%-7 KK %''E'#$ jjll""""""""" # # ('''r status_lineheadersr c K | j | | d{V t || }| | dS )z*Write request/response status and headers.N)r/ _serialize_headersrF )r0 rU rV bufs r
write_headerszStreamWriter.write_headersy s` ,''00 0 0 0 0 0 0 0 !g66 Cr r c > K | j rd S |r"| j | | d {V | j ru|r | j | d {V }|| j z
}|r4| j r-dt
| z d }||z dz }n9| j r2|r.dt
| z d }||z dz }nd}|r| | | d {V d| _ d S )NrK rL s
0
s 0
T)
r+ r. r, rQ flushr( r@ rR rF rG )r0 r> rS s r write_eofzStreamWriter.write_eof sh 9 F -T(4%%e,, , , , , , , , > )
= "n 5 5e < <<<<<<< T^))++ +E
=
= %E
2 : :7 C C !E),<<|
) )!)CJJ!6 > >w G GI % -0@ @EE (E KK jjll r c d K | j j !| j d{V dS dS )zFlush the write buffer.
The intended use is to write
await w.write(data)
await w.drain()
N)r& r4
_drain_helperr5 s r rG zStreamWriter.drain sG > # /...00 0 0 0 0 0 0 0 0 0 0 /r )NN)r$ N)r )r r r r asyncioAbstractEventLoop_T_OnChunkSent_T_OnHeadersSentr1 propertyr Transportr4 r r8 zlibZ_DEFAULT_STRATEGYstrr r= bytesrF boolrD rZ r] rG r r r r r s
)-,0 B B B 'B & B
* B
B B B B, (8G$56 ( ( ( X( , X (9PN NN36N
N N N N
E d .2)# )# )#)#&*)#:=)#
)# )# )# )#V );
U T < 1 1 1 1 1 1r r stringr$ c 4 d| v sd| v rt d | S )N
zRNewline or carriage return detected in headers. Potential header injection attack.)
ValueError)rk s r _safe_headerrp s1 v~~
1
Mr rU rV c d | D }| dz d | z dz }| d S )Nc 3 ` K | ])\ }}t | d z t | z V *dS )z: N)rp ).0kvs r z(_py_serialize_headers.. s< XX1<??T)LOO;XXXXXXr z
z
zutf-8)itemsjoinrR )rU rV headers_genlines r _py_serialize_headersr{ sO XX
XXXK &++k":": :Z GD ;;w r )$__doc__r` rf typingr r r r r r multidictr abcr
base_protocolr compression_utilsr
helpersr __all__r r r ri rb rc r rh rp r{ rX aiohttp._http_writer _http_writer_c_serialize_headers ImportErrorr r r r s ( ( H H H H H H H H H H H H H H H H ! ! ! ! ! ! % % % % % % ' ' ' ' ' ' - - - - - - " " " " " "
K *
Aq!!
Aq!!
(E7IdO#;<=H&8%99T?%J KL M1 M1 M1 M1 M1' M1 M1 M1` s 5G E + //////': 2 12 2 DD s 2C CC