hiSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r SSK J r SSKJr SSKJrJrJrJrJrJrJrJrJrJrJr SSKrSSKrSSKJr S S K J!r!J"r" S S K#J$r$ S S K%J&r& S S K J'r'J(r(J)r)J*r*J+r+ S SK,J-r- S SK.J/r/J0r0 S SK1J2r2J3r3 S SK4J5r5 S SK6J7r7J8r8 S SK9J:r: S SK;Jr>J?r? Sr@\(a SSKArAS SKBJCrC \\*\3S\"S/\<4rD\\\\ S?\0\*/\1\+4S\\+\ 44S@jr2SKSAjr3S5\*SB\+S>\\ S\\+\ 44SCjr4SLS5\*SD\S*\\ SE\\S\+4 SFjjr5SG\6S\0\*/\1\+44SHjr7SIr8U=r9$)Mr*haHTTP protocol implementation. RequestHandler handles incoming HTTP request. It reads request line, request headers and request payload and calls handle_request() method. By default it always returns with 404 response. RequestHandler handles errors in incoming request, like bad status line, bad headers or incomplete payload. If any error occurs, connection gets closed. keepalive_timeout -- number of seconds before closing keep-alive connection tcp_keepalive -- TCP keep-alive is on, default is on debug -- enable debug mode logger -- custom logger object access_log_class -- custom class for access_logger access_log -- custom logging object access_log_format -- access log format string loop -- Optional event loop max_line_size -- Optional maximum header line size max_field_size -- Optional maximum header field size max_headers -- Optional maximum header size timeout_ceil_threshold -- Optional value to specify threshold to ceil() timeout values )_request_count _keepalive_manager_request_handler_request_factory_tcp_keepalive_next_keepalive_close_time_keepalive_handle_keepalive_timeout_lingering_time _messages _message_tail_handler_waiter_waiter _task_handler_upgrade_payload_parser_request_parser_reading_pausedloggerdebug access_logr_close _force_close_current_request_timeout_ceil_threshold_request_in_progress_logging_enabled_cachei.TFiig$@i)keepalive_timeoutr#r`access_log_classrbaccess_log_formatra max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr-looprkr#r`rlrbrmrarnrorprqrrrsrtc >[TU]U5 SUlSUlSUlXlUR UlURUl X@l SUl SUl X0l [U 5Ul[!5UlSUlSUlSUlSUlSUlSUl[1UUUU U U [2US9UlSUl[U5UlXPlXlXpl U(a)U"Xx5Ul!URBRDUl#OSUl!SUl#SUl$SUl%SUl&0Ul'g![8[:4a Nf=f)NrFgr:)rnrpropayload_exceptionrsrj)(super__init__rMrNrerOrequest_handlerrPrequest_factoryrQrRrSrTrUfloatrVrrWrXrZrYr[r\r]rr+r^rf TypeError ValueErrorr`rarbrenabledrhrcrdrgri)selfrurvrkr#r`rlrbrmrarnrorprqrrrsrt __class__s r;rzRequestHandler.__init__sp*  7;*1 ;B;R;R;B;R;R+*-';?"3$^4*/' 7; ?C;? $($>D !!%D $)D ! !$)!&( %:&   sEE"!E"returnctSRURRURbS5$S5$)Nz<{} {}> connected disconnected)formatrr4 transportrs r;__repr__RequestHandler.__repr__s; NN # #>>5K  ;I  r:zssl.SSLContextcVURcS$URRS5$)zReturn SSLContext if available.N sslcontextrget_extra_infors r; ssl_contextRequestHandler.ssl_contexts1 ~~%  ..|< r:cVURcS$URRS5$)zReturn peername if available.Npeernamerrs r;rRequestHandler.peernames1~~%  ..z: r:cUR$N)rUrs r;rk RequestHandler.keepalive_timeouts&&&r:timeoutNcj# SUlURbURR5 UR(aXURR 5Ul[U5IShvN UR IShvN SSS5IShvN [U5IShvN URb.URR![R"55 UR"bGUR"R%5(d([R&"UR"5IShvN SSS5IShvN UR"bUR"R5 UR)5 gGNGNN!,IShvN (df  GN =f![R[R4aQ SUl[RS:a2[R"5=n(aUR5(aeGNf=fGNwNN!,IShvN (df  N=f![R[R4aJ [RS:a2[R"5=n(aUR5(aeGNaf=f7f)zDo worker process exit preparations. We need to clean up everything and stop accepting requests. It is especially important for keep-alive connections. TN )rdrTcancelrg_loop create_futurerYrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingre_cancelr[doneshield force_close)rrtasks r;shutdownRequestHandler.shutdown s !  ! ! -  " " ) ) +  $ $$(::#;#;#=D  '00....10 #G,,((4))11'2H2H2JK%%1$:L:L:Q:Q:S:S!..););<<< -,    )    % % ' =1.1000**G,@,@A '+$$$/!(!5!5!777)) - = -,,, &&(<(<=   G+$1133T3OO%%  sAJ3"F)1F2F)5FF F F)F F)I*H!+I.B H(9H$:H(> I H& I8J3F) F F)F&F  F&!F)$J3&F))A1HJ3HJ3!I$H(&I(H?.H1 / H?;I>J3?IA*J0,J3/J00J3rc>[TU]U5 [[RU5nUR (a [ U5 URceURRX5 URn[RS:a%[R"UR5USS9nOURUR55nX@lg)Nr Trv eager_start)ryconnection_maderr TransportrRr#rOrrrTaskstart create_taskr[)rrreal_transportrvrrs r;rRequestHandler.connection_madeRs  *g//;    . )}}((( %%d;zz   w &<< 4TJD##DJJL1D!r:rEc|>URcgURRX5 URRnUR5 [TU]U5 SUlSUlSUlSUlURbURR5 URb)Uc [S5nURRU5 U(a'URbURR5 SUl URb"URR5 SUlgg)NzConnection lost)rOconnection_losthandler_cancellationrryrQrPr^rTrreConnectionResetErrorrr[r]feed_eof)rrErrs r;rRequestHandler.connection_lostcs  ==  %%d0 $}}AA  $ $ $#  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . D$6$6$B    % % '!    +  ) ) +#'D  ,r:parsercURbeXlUR(a-URRUR5 SUlgg)Nr:)r]rX feed_data)rrs r; set_parserRequestHandler.set_parsersJ##+++%     * *4+=+= >!$D  r:cgrr2rs r; eof_receivedRequestHandler.eof_receiveds r:datac|UR(dUR(agURcUR(dURceURR U5up#nU=(d SH6upgU=RS- sl URRXg45 M8 URnU(a)Ub&UR5(dURS5 X0lU(aU(aX@lgggURc.UR(aU(aU=R U- slgU(a6URR U5upU (aUR#5 ggg![ a*n[SXURS9[4/nSnSnSnAGNFSnAff=f)Ni)rDrErFFr:r2r)rdrcr]r\r^rrrBrFr!rMrWappendrZr set_resultrXclose) rrmessagesupgradedtailrEmsgpayloadwaitereofs r; data_receivedRequestHandler.data_receivedsg        ' ''3 33 +/+?+?+I+I$+O(D!)B ##q(#%%sn5!/\\FF.v{{}}!!$'$MD%)"!x ! ! )dmm   $ & ,,66t> % NN "!DN &r:requestresponsetimecURbdURR(aH[(aUceURRXURR 5U- 5 gggr)rrrlogrr)rrrrs r; log_accessRequestHandler.log_accesss^    )d.@.@.H.H}'''    " "7djjoo6G$6N O/I )r:argskwc`UR(aURR"U0UD6 ggr)rar`rrrs r; log_debugRequestHandler.log_debugs% :: KK  t *r * r:c<URR"U0UD6 gr)r` exceptionrs r; log_exceptionRequestHandler.log_exceptions t*r*r:cxSUlUR(dUR(dgURnUR 5nUR nX#:a!UR X0R5UlgUR(a1URR5(dUR5 gggr) rTrdrNrrrScall_at_process_keepaliverZrr)rrvnow close_times r;r!RequestHandler._process_keepalives!%   DOO zziik44  %)\\*>U>U%VD "  << 1 1 3 3    !4UR7S5 SU lUR:Gc.UGb*UR7S5 GO[=UR>5Ul URC5(GdURDnUR (dU(aUR7S U5 UR5nX-nURC5(drUU:al[GUU- 5IShvN URI5IShvN SSS5IShvN UR5nURC5(dUU:aMlURC5(d2UR (d!UR7S 5 URQ5 URS[T5 SU lUR:cUbUR7S5 UR@(akUR^(dZUR (dIUR5U-nUUl0URbc!UReUURf5Ul1OOUR (dGMUR (d0SUlUR:bUR:RQ5 gggGN!SUlf=fGN![4aA UR7S5 SU lUR:bMUcMUR7S5 Mf=fGNGNGN!,IShvN (df  GN=f![&RJ[&RL4aJ [,R.S :a2[&R("5=n(aURO5(aeGNHf=f![&RJa# UR7S5 URW5 e[Xa+nUR[S US 9 URW5 SnAGNUSnAf[\a URW5 ef=f!SU lUR:cUbUR7S5 fff=f7f)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. NrrTrz&Ignored premature client disconnectionz'Ignored premature client disconnection.z(Ignored premature client disconnection 2z'Start lingering close timer for %s sec.rzUncompleted request.zUnhandled exceptionr)4rrOrUrQrPrdrWrrZpopleftrhrrequests_countr isinstancerB_make_error_handlerERRORr[rrrrrrrConnectionErrorr_taskrboolrrNis_eofrVrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrIrcrSrTrr)rrvrurkrrFrrwriterr{rcororrrqrend_ttrErs r;rRequestHandler.startszz--""" 33$$000$$000###>>(#'#5#5#7DL,,&&#'DL#~~557 G$(#8#8DIIKdE  " "a ' "!$-F'8,,"&":":7"C"&"7"7 ++""@g&:&:4&@ GC N++GOL##w."<<TJD++D1D(,*KD NN#MN`!% >>)d.>NN#LM_#'t"7~~''%)%9%9N,,E~#iik # 4 &&-nn&6&63;+7 +D+D*1//*;$;$;,E+D'+iik '.nn&6&63;#>>++D4E4E'=> %%&;<!% >>)d.>NN#LMt{{4;L;L!YY[+<< 2</))1-1\\"D$;$;.D*a###f  !%D ~~)$$&*!]'#'DLF#-&NN#KLl!% >>)d.>NN#LMu4,E$;,E+D+D+D!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLNN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sQA-X0$Q1Q.Q1CX5A U#RQ= RU#)X>XXA:U#-S2=S>S2SSS S2%S&/S2AU#3B6X,AX.Q11 Q::X=RS U#X2X7X S  U#S2SS2S/S  S/*S22A*U U#U  U##?W'" WW*W''W**,XXrc # UR5 URb_URRS5 SUlUR(a,URR UR5 SUlUR nU"U5IShvN UR!5IShvN UR%XU5 US4$![a UcURS5 O URSRU55 [5n[URURURURS9nUR nNf=fNN!["a UR%XU5 US4s$f=f7f)zPrepare 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. NFr:z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})rDreasontextheadersT)_finishr^ set_upgradedr\rXrprepareAttributeErrorrrr%r(rDrrr write_eofr r)rrrr prepare_methrEs r;rRequestHandler.finish_responsesU     +  - -e 4!DM!!$$..t/A/AB%(" (<FFFrDrFcFURS:Xa;[U[5(a&URR SUR US9 OUR SUR US9 URRS:a [S5eSnU[R:XaSR[R5n[RRnSnUR(a-[[5 [ R""5nSSS5 S UR$R'S S 5;a*U(a[)U5nS US 3nSRXgS9nS nOU(aUnUS-U-n[+X$US9n U R-5 U $!,(df  N=f)zHandle errors. Returns HTTP response with specific status code. Logs additional information. It always closes current connection. rzError handling request from %srrzMResponse is sent already, cannot send another response with the error messagez text/plainz{0.value} {0.phrase}Nz text/htmlAcceptz

Traceback:

z
zV{title}

{title}

{msg} )titlerz )rDr content_type)rMr rr`raremoterr output_sizer rINTERNAL_SERVER_ERRORr descriptionrr traceback format_excrget html_escaper(r) rrrDrErFctr'rtbrs r;rRequestHandler.handle_errors{   ! # 3 (F(F KK  0'..3     0'..3   >> % % )!)   Z55 5*11*2R2RSE22>>CBzzi("--/B)goo11(B??$RB6rd&AC0&u&.  !C&.3.v"E  -)(s =F F err_infoc4^^S[S[4UU4SjjnU$)Nrrcp># TRUTRTRTR5$7fr)rrDrErF)rr4rs r;handler3RequestHandler._make_error_handler..handlers0$$(,,8H8H s36)r'r))rr4r7s`` r;r "RequestHandler._make_error_handlers" ; >   r:)rircrerdrYrNrTrUrVrhrOrXrWrSr]rMrQrPrgr^r[rRrfr\rZrbrrar`r)g.@)rN)rNN):r4r5r6r7r8 __slots__r r&r LOG_FORMATrAbstractEventLoopr}rrrrrJrGrzrrr rrrrpropertyrkr BaseTransportrrIrr rrbytesrrrrr'r)rrrrr r rrrrrBr r9 __classcell__)rs@r;r*r*hs%NIN$("&7C*!-!8!8! " $! $()'O)O)'' O) ! O)O)O)34O)O)O)O)O)O)O) !O)"#O)$%O)&!&'O)O)b #  X&67   %U3S##56c3hGH I  '5''0huo00d")>)>"4""(8M#:(t(@%%% %%%D%N*d*t*""P"P.<PDLUOP P+s+#+$++3+c+d+"))UO)";->1J"JK ) ~t# $ )VG'R("(*8(FNuo( ~t# $(Z'+!% <<<m $ < # <  <|  ;->!:: ;r:)Prasyncio.streamsrr-r collectionsr contextlibrhtmlrr0httprloggingrtypingrr r r r r rrrrrattryarl propcacherabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrr streamsr!r" tcp_helpersr#web_exceptionsr$r%web_logr& web_requestr' web_responser(r)__all__ssl web_serverr-_RequestFactory_RequestHandlerURLr rr+r,rsrB_MsgTyper*r2r:r;r]sb &     +;'!+-0&B!$2 I"  K=)N*CCD   HHSM !)!88+,T$d34 ((23\A Bp \p r: