e۟Bb d dl Z d dlZ d dlZd dlZd dlmZ d dlmZ d dlm Z
d dl m Z d dl
mZ d dlmZmZmZmZmZmZmZmZmZmZmZ d dlZd dl Z dd l m Z m Z dd
l m!Z! dd l"m#Z# dd l m$Z$m%Z%m&Z&m'Z'm(Z( dd
l)m*Z*m+Z+ ddl,m-Z-m.Z. ddl/m0Z0 ddl1m2Z2 ddl3m4Z4 ddl5m6Z6 ddl7m8Z8m9Z9 dZ:erddl;m e'dde&i i dddd e j? d
Z@ G d d eA ZB G d d eA ZC ejD ddd G d! d" ZEeee'eEf e.f ZF G d# de! ZGdS )$ N)deque)suppress)escape)
HTTPStatus)Logger)
TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast )AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout)HttpProcessingErrorHttpRequestParser
HttpVersion10RawRequestMessage StreamWriter)
access_logger
server_logger)
EMPTY_PAYLOAD StreamReader)
tcp_keepalive)
HTTPException) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr' zasyncio.Task[None]UNKNOWN/TFc e Zd ZdZdS )r( zPayload parsing error.N__name__
__module__ __qualname____doc__ h/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/aiohttp/web_protocol.pyr( r( N s r4 r( c e Zd ZdZdS )r) z-Payload was accessed after response was sent.Nr. r3 r4 r5 r) r) R s 7777r4 r) ) auto_attribsfrozenslotsc . e Zd ZU eed< eed< eed< dS )_ErrInfostatusexcmessageN)r/ r0 r1 int__annotations__
BaseExceptionstrr3 r4 r5 r; r; V s. KKK
LLLLLr4 r; c ! e Zd ZdZdZdZddeeeej ddddd d
dd d d
dde
j de de
dedee dedede
dededede ded e
d e f fd Zd efd Zed e fd! ZdHd#ee d d$fd%Zd&e
j d d$f fd' Zd(ee d d$f fd) Z d*e d d$fd+Z dId,Z d-e d d$fd.Z!d/e
d d$fd0Z"dId1Z#dId2Z$d3e%d4e&d5e d d$fd6Z'd7e d8e d d$fd9Z(d7e d8e d d$fd:Z)dId;Z*d3e%dZ.dId?Z/d3e%d@e&d connected disconnected)formatrt r/ transportrs s r5 __repr__zRequestHandler.__repr__ s0 N # >5KK>
r4 c | j S N)rL r{ s r5 r^ z RequestHandler.keepalive_timeout s &&r4 .@timeoutNc K d| _ | j | j | j r| j t t
j t
j 5 t | 4 d{V | j +| j
t j | j &| j s
| j d{V ddd d{V n# 1 d{V swxY w Y ddd n # 1 swxY w Y | j | j | j
"| j
d| _
dS dS )zDo worker process exit preparations.
We need to clean up everything and stop accepting requests.
It is especially important for keep-alive connections.
TN)rZ rK cancelrP r asyncioCancelledError TimeoutErrorr r[ _cancelrQ donerz close)rs r s r5 shutdownzRequestHandler.shutdown s& ! ! - " ) ) + + + < " L ! ! ! g,g.B
C
C - -#G,,
-
-
-
-
-
-
-
-(4)11'2H2J2JKKK%1$:L:Q:Q:S:S1 ,,,,,,,,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- - - - - - - - - - - - - - - - ) % % ' ' ' > % N " " " !DNNN & %s7 .DA C6$D6
D DD DDDrz c T t | t t j | }| j rt
| | j | | _
| j J | j | | d S r~ ) rl connection_mader r TransportrI r! _loop create_taskstartrQ rF )rs rz real_transportrt s r5 r z RequestHandler.connection_made s
*** g /;; * . ) ) ) !Z 3 3DJJLL A A}(((
%%dN;;;;;r4 r= c x | j d S | j | | t | | j j }d | _ d| _ d | _ d | _ d | _ | j | j | j
+|t d }| j
| | j
| j
|r | j | j d | _ | j "| j d | _ d S d S )NTzConnection lost)rF connection_lostrl handler_cancellationrZ rH rG rT rK r r[ ConnectionResetErrorr rP rQ rS feed_eof)rs r= r rt s r5 r z RequestHandler.connection_lost% sB = F
%%dC000
$$$ $} A
$ $ # ! - " ) ) + + + ,{*+<== ! ) )# . . . < # L ! ! ! (D$6$B % % ' ' ' ! + ) ) + + +#'D , +r4 parserc | j J || _ | j r(| j | j d| _ d S d S )Nr4 )rS rO feed_data)rs r s r5
set_parserzRequestHandler.set_parserI sV #+++ % % * *4+= > > >!$D % %r4 c d S r~ r3 r{ s r5 eof_receivedzRequestHandler.eof_receivedS s r4 datac | j s| j rd S | j | j s| j J | j | \ }}}n:# t $ r-}t d||j t fg}d}d}Y d }~nd }~ww xY w|pdD ]1\ }}| xj
dz
c_
| j ||f 2| j
}|r+|)| s| d || _ |r |r || _ d S d S d S | j | j r|r| xj |z
c_ d S |r5| j | \ } }| r| d S d S d S )Ni )r< r= r> Fr4 r3 r )rZ rY rS rR rT r r r; r> r rD rN appendrP r
set_resultrO r )
rs r messagesupgradedtailr= msgpayloadwaitereofs
r5
data_receivedz RequestHandler.data_receivedV s F '
''333
+/+?+I+I$+O+O((DD&
Sc3;GGG W !
!)B
6
6 W##q(##%%sGn5555\F
(F .v{{}} .!!$''' $DM
*D
*%)"""
*
*
*
*
!
)dm
)
) $ & ,66t< % N " " " !DNNN & %r4 requestresponsetimec | j 8| j ||| j |z
d S d S r~ )r logr r )rs r r r s r5
log_accesszRequestHandler.log_access sG ) " "7Hdjoo6G6G$6N O O O O O * )r4 argskwc < | j r | j j |i | d S d S r~ )rW rV rs r r s r5 log_debugzRequestHandler.log_debug s6 : + DK t *r * * * * * + +r4 c * | j j |i | d S r~ )rV exceptionr s r5
log_exceptionz RequestHandler.log_exception s" t*r*****r4 c | j s| j sd S | j | j z }| j r3| j |k r| d S | j | j | j
| _ d S r~ ) rZ rE rJ rL rP r r r
call_laterKEEPALIVE_RESCHEDULE_DELAY_process_keepaliverK )rs nexts r5 r z!RequestHandler._process_keepalive s DO F#d&== < z 4'' """ "&!6!6 + #"
"
r4
start_timern c K | j J || _ || d {V }d | _ n # d | _ w xY w t |dd rt j dt
| ||| d {V }n# t $ r)}|}| ||| d {V }Y d }~nd }~wt j $ r t j
$ rT}| d| | |d }| ||| d {V }Y d }~nNd }~wt $ r>}| |d| }| ||| d {V }Y d }~nd }~ww xY w||fS )N__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception insteadzRequest handler timed out.exc_infoi )rG r[ getattrwarningswarnDeprecationWarningfinish_responser" r r r r handle_error Exception)rs r r rn respresetr= s r5 _handle_requestz RequestHandler._handle_request s. $000 J
-(/% ,_W 5 5555555(,%%%,,,,% t 1599
9 ' ..wjIIIIIIIIEE- J J JD ..wjIIIIIIIIEEEEEE% # J J J NN7#N F F F$$Wc22D ..wjIIIIIIIIEEEEEE J J J$$Wc377D ..wjIIIIIIIIEEEEEE J U{s= . B 7B
E- B22!E-A
D""
E-/4E((E-c K | j }| j }|J | j }|J | j }d}| j J | j J | j s| j sZ | | _ | j d{V n # t j $ r Y d| _ nDw xY w d| _ n # d| _ w xY w| j \ }}|
}|xj dz
c_ t | | } t! |t" r | | }
t& }n| j }
| ||| | | } | j | | ||
} | d{V \ }}
n# t j t, f$ r | d Y | j || d n | j s^| j rU| j sN|J| j
}|| _ | j #| ||z | j | _ nnnw xY w~ |
r| d | j || d n\| j s^| j rU| j sN|J| j
}|| _ | j #| ||z | j | _ nnnt? |j | _ |! s_| j" }| j s |r | d| |
}||z }tG t j$ t j 5 |! s||k rtK ||z
4 d{V |& d{V ddd d{V n# 1 d{V swxY w Y |
}|! s||k ddd n # 1 swxY w Y |! s0| j s)| d | ' |( tS n1# t j $ r | d Y | j || d n | j s^| j rU| j sN|J| j
}|| _ | j #| ||z | j | _ nnntT $ r<}| j+ r| , d |
| - Y d}~nEd}~wt\ $ r5}| , d |
| - Y d}~nd}~ww xY w| j || d n| j s\| j rT| j sM|J| j
}|| _ | j #| ||z | j | _ nnn# | j || d ne| j s^| j rT| j sM|J| j
}|| _ | j #| ||z | j | _ n Y n w xY w| j | j s)d| _ | j | j ' dS dS dS ) a_ Process incoming request.
It reads request line, request headers and request payload, then
calls handle_request() method. Subclass has to override
handle_request(). start() handles various exceptions in request
or response handling. Connection is being closed always unless
keep_alive(True) specified.
Nr z&Ignored premature client disconnectionz'Ignored premature client disconnection.z(Ignored premature client disconnection 2z'Start lingering close timer for %s sec.zUncompleted request.z'Ignored premature client disconnection zUnhandled runtime exceptionr zUnhandled exception)/r rQ rF rL rH rG rZ rN
create_futurerP r r popleftr requests_countr
isinstancer; _make_error_handlerERRORr r ConnectionErrorr rz rE rY rJ rK call_atr boolr is_eofrM r r r readanyr
set_exceptionr) RuntimeErrorrW r r r )rs ri handlerrh r^ r r> r r writerrn r taskr nowrd end_tr= s r5 r zRequestHandler.start s z$"""-""" 3$000$000# ^ >
((#'#5#5#7#7DL ,&&&&&&&& - #'DLL ' $(DLL4DL'''' #~ 5 5 7 7 GWIIKKE " "a ' " "!$--F'8,,
8"&":":7"C"C "&"7++GWdFGTTGE
z--((% II (,******KD%% .@ NN#KLLL^ >)d.>NN#LMMMM *
t{
,8"&*//"3"3C36D 0 # 5 =9= $'*;$;T=T:" :" 6 g
NN#MNNNR >)d.>NN#LMMMM *
t{
,8"&*//"3"3C36D 0 # 5 =9= $'*;$;T=T:" :" 6 Q #'t"7"7 ~~'' %%)%9N ,
2
2 E~ #iikk #n 4 %g&:G>++ %D4E % '=>>>
%%&8&:&:;;;;)
HIII >)d.>NN#LMMMM *
t{
,8"&*//"3"3C36D 0 # 5 =9= $'*;$;T=T:" :" 6
#
#
#: T&&'Ds&SSS """"""""
#
#
#""#83"GGG """"""""
# >)d.>NN#LMMMM *
t{
,8"&*//"3"3C36D 0 # 5 =9= $'*;$;T=T:" :" 6 >)d.>NN#LMMMM *
t{
,8"&*//"3"3C36D 0 # 5 =9= $'*;$;T=T:" :" 6 } # ^ B '!%D ~)$$&&&&& ' '))s &A2 1B 2B B B B B!/R
7 F R
+H7.R
6H77R
BR
-3P O
;P
O PO 1P R
P R
P A(R
X>
$V8.X> 6 V8?2U61X> 6
V8+V3.X> 3V88X> >B[[r c K | j N| j d d| _ | j r&| j | j d| _ |j }nA# t $ r4 |t d t d | w xY w || d{V | d{V |
||| dS # t $ r |
||| Y dS w xY w)a Prepare the response and write_eof, then log access.
This has to
be called within the context of any exception so the access logger
can get exception information. Returns True if the client disconnects
prematurely.
NFr4 z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r}T) rT set_upgradedrR rO r prepareAttributeErrorr ry write_eofr r )rs r r r prepare_meths r5 r z RequestHandler.finish_responseZ s[ + - -e 4 4 4 !DM!
)$..t/ABBB%("
B #+C' '!D D r r< r> c | d| |j j dk rt d d}|t j k rd t j }t j j }d}| j r?t t 5 t j }ddd n # 1 swxY w Y d|j
d d
v r1|rt | }d | d }d
|| }d}n |r|}|dz |z }t! ||| } | | S )zHandle errors.
Returns HTTP response with specific status code. Logs additional
information. It always closes current connection.
zError handling requestr r zMResponse is sent already, cannot send another response with the error messagez
text/plainz{0.value} {0.phrase}Nz text/htmlAccept zTraceback:
z
zV{title}
{title}
{msg}
)titler z
)r< text content_type)r r output_sizer r INTERNAL_SERVER_ERRORry descriptionrW r r traceback
format_excheadersget html_escaper% r )
rs r r< r= r> ctr r tbr s
r5 r zRequestHandler.handle_error s
3cBBB > % ) )!)
Z5 5 5*11*2RSSE 2>CBz
0 i(( 0 0"-//B0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 go 1 1(B ? ??? B$R BArAAAC0 &u#&.. ! C &.3.vG"EEE s B66B:=B:err_infoc 4 dt dt f fd }|S )Nr ru c V K | j j j S r~ )r r< r= r> )r r rs s r5 r z3RequestHandler._make_error_handler..handler s/ $$ (,8H
r4 )r$ r& )rs r r s `` r5 r z"RequestHandler._make_error_handler s< ; >
r4 )r )ru N)r NN)5r/ r0 r1 r2 r __slots__r r# r
LOG_FORMATr AbstractEventLooprp r r r r rB r? rm r| propertyr^ r
r
BaseTransportr rA r r r r bytesr r r r r$ r& r r r r r r
r r r r r r; r
__classcell__)rt s @r5 r' r' ` s % %N "# ID $( "&7C *!-!8 ! " $ ! $()%H" H" H"H" ' H"
! H"
H" H" 34H" H" H" H" H" H" H" H" !H"" #H"$ !&%H" H" H" H" H" H"T
#
'5 ' ' ' X' " "huo " " " " "> <)> <4 < < < < < <"(8M#: "(t "( "( "( "( "( "(H% % % % % %
% % % D % % % % N*d *t * * * *" " " "" " " "P"P.<PDIP
P P P P +s +# +$ + + + ++3 +c +d + + + +
&% % % ";->1J"JK %
~t# $ % % % %Nw' w' w' w'r#"#*8#FK#
# # # #P '+!% 1 1 1 1 m
$ 1
# 1
1 1 1 1f ;->!:: ; r4 )Hr asyncio.streamsr r collectionsr
contextlibr htmlr r httpr loggingr typingr r r
r r r
r r r r r attryarlabcr r
base_protocolr helpersr r r r r r r r r streamsr r tcp_helpersr! web_exceptionsr" web_logr# web_requestr$ web_responser% r& __all__
web_serverr* _RequestFactory_RequestHandlerURLr r r( r) sr; _MsgTyper' r3 r4 r5 r s & & & & & & ; ; ; ; ; ; ; ; ' ' ' ' ' ' ! ! ! ! ! ! . - - - - - - - 0 0 0 0 0 0 0 0 & & & & & & ) ) ) ) ) ) ! ! ! ! ! ! $ $ $ $ $ $ 2 2 2 2 2 2 2 2
I #"""""" K=)N*CCD
DHSMM ! ! ! ! !) ! ! !8 8 8 8 8 8 8 8 T$d333 43 ((23\A BZ Z Z Z Z \ Z Z Z Z Z r4