rp0jtySSKrSSKrSSKrSSKrSSKrSSKJr SSKJrJ r J r SSK J r SSK Jr SSKJr SSKJr SSKJrJrJrJr SSKrSSKrSS KJr S S KJrJr S S K J!r!J"r" S S K#J$r$J%r% S SKJ&r&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@SrA\(a SSKBrBS SKCJDrD \ \)\3S\S/\<4rE\ \SS"4U4S)jjr S*\!S"-SS"4U4S+jjr"SOS,\#S-\$/S"4S"-SS"4S.jjr%SPS/jr&S0\'SS"4S1jr(S\4S2jr)SPS3jr*SPS4jr+S5\SS"4S6jr,SPS7jr-SPS8jr.S9\/S:\0S;\ S"-SS"4S<jr1S=\2S>\2SS"4S?jr3S=\2S>\2SS"4S@jr4SPSAjr5S9\/SB\ S"-SC\$\//\6\04S\\0\44SDjr7SPSEjr8S9\/SF\0SB\ S"-S\\0\44SGjr9SQS9\/SH\S*\!S"-SI\S"-S\04 SJjjr:SK\;S\$\//\6\044SLjr$)Rr)caHTTP 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 )"max_field_size max_headers max_line_size_request_count _keepalive_manager_request_handler_request_factory_tcp_keepalive_next_keepalive_close_time_keepalive_handle_keepalive_timeout_lingering_time _messages_max_msg_queue_size_msg_queue_resume_size_msg_queue_paused _message_tail_handler_waiter_waiter _task_handler_payload_parser_data_received_cbloggerdebug access_logr_close _force_close_current_request_timeout_ceil_threshold_request_in_progress_logging_enabled_cachei.TFig$@)keepalive_timeoutr"rdaccess_log_classrfaccess_log_formatrerOrNrMlingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr-looprpr"rdrqrfrrrerOrNrMrsrtrurvc 0>[Ul[S-UlSUl[ UUUU U U [ U[S9 n[ TU]UU5 SUlSUl SUl Xl URUl URUlXlXlXlX@lSUlSUlX0l[/U 5Ul[35UlSUlSUlSUlSUlSUlSUl SUl![/U5Ul!XPl$Xl%Xpl&U(a)U"Xx5Ul'URNRPUl)OSUl'SUl)SUl*SUl+SUl,0Ul-g![D[F4a Nf=f)NF)rOrMrNpayload_exceptionrumax_msg_queue_sizergr:ro).MAX_MSG_QUEUE_SIZEr[r\r]rr*super__init__rPrQrirRrequest_handlerrSrequest_factoryrTrOrNrMrUrVrWrXfloatrYrrZr^rcr`r_rarbrj TypeError ValueErrorrdrerfrenabledrlrgrhrkrm)selfrwrxrpr"rdrqrfrrrerOrNrMrsrtrurvparser __class__s r;rRequestHandler.__init__s*$6 '9A&=#"'"   ')#1+1   v& 48'. 8?8O8O8?8O8O*&,+*-'8<"3$^4*/' <@48 <@8<$(./$ +01G+HD (  $ >N?D %)$6$6$>$>D !!%D $)D ! !$)!&( %:&   sFFFreturnctSRURRURbS5$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:NcVURcS$URRS5$)zReturn peername if available.Npeernamerrs r;rRequestHandler.peername1~~%  ..z: r:cVURcS$URRS5$)zReturn sockname if available.Nsocknamerrs r;rRequestHandler.sockname&rr:cUR$N)rXrs r;rp RequestHandler.keepalive_timeout1s&&&r:timeoutcj# 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 )rhrWcancelrk_loop create_futurer_rasyncioCancelledError TimeoutErrorsys version_info current_task cancellingri_cancelradoneshield force_close)rrtasks r;shutdownRequestHandler.shutdown5s !  ! ! -  " " ) ) +  $ $$(::#;#;#=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 Trx eager_start)r~connection_maderr TransportrUr"rRrrrTaskstart create_taskra)rrreal_transportrxrrs r;rRequestHandler.connection_madegs  *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)rRconnection_losthandler_cancellationrr~rTrS_parserrWrriConnectionResetErrorrrarbfeed_eof)rrErrs r;rRequestHandler.connection_lostxs  ==  %%d0 $}}AA  $ $ $  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . D$6$6$B    % % '!    +  ) ) +#'D  ,r:rdata_received_cbcURbeXlX lUR(a-URRUR5 SUlgg)Nr:)rbrcr^ feed_data)rrrs r; set_parserRequestHandler.set_parsersR ##+++%!1     * *4+=+= >!$D  r:cgrr2rs r; eof_receivedRequestHandler.eof_receiveds r:datac0UR(dUR(agURGcUR(GdURceURR U5up#nUH6upgU=RS- sl URRXg45 M8 URnU(a)Ub&UR5(dURS5 UR (d3[#UR5UR$:aUR'5 X0lU(aU(aX@lgggURc.UR(aU(aU=R(U- slgU(aSUR*bUR+5 URR U5upU (aUR-5 ggg![ a*n[SXURS9[4/nSnSnSnAGNSnAff=f)Ni)rDrErFFr:r)rhrgrb _upgradedrrrrBrFr rPrZappendr`r set_resultr]lenr[_pause_msg_queue_readingr^rcclose) rrmessagesupgradedtailrEmsgpayloadwaitereofs r; data_receivedRequestHandler.data_receiveds        '<<+ ++ +/<<+A+A$+G(D!) ##q(#%%sn5!)\\FF.v{{}}!!$' **'4+C+CC--/%ND%)"!x ! ! )dnn   $ & %%1&&(,,66t> % ,,. &/  s 2 ??c4UR(d5URS5 [UR5UR:agSUlUR (d*URbURR5 ggg![a gf=f)Nr:F) rrrrZr[r]_reading_pausedrresume_readingrrs r;_resume_msg_queue_reading(RequestHandler._resume_msg_queue_readings~~   s #4>>"d&>&>>!&##(B --/)C#/  s-B BBvalcvXlUR(a"URR5 SUlgg)z=Set keep-alive connection mode. :param bool val: new state. N)rQrWr)rrs r; keep_aliveRequestHandler.keep_alives1   ! !  " " ) ) +%)D " "r:cjSUlUR(aURR5 gg)zwClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rgr`rrs r;rRequestHandler.closes'  << LL   ! r:cSUlUR(aURR5 URb"URR 5 SUlgg)zForcefully close connection.TN)rhr`rrrrs r;rRequestHandler.force_close sG  << LL   ! >> % NN "!DN &r:requestresponsetimecUR(aVURbH[(aUceURRXURR 5U- 5 gggr)rlrr logrr)rrrrs r; log_accessRequestHandler.log_accesssX  T%7%7%C}'''    " "7djjoo6G$6N O&D r:argskwc`UR(aURR"U0UD6 ggr)rerdrrrs r; log_debugRequestHandler.log_debugs% :: KK  t *r * r:c<URR"U0UD6 gr)rd exceptionrs r; log_exceptionRequestHandler.log_exception!s t*r*r:cxSUlUR(dUR(dgURnUR 5nUR nX#:a!UR X0R5UlgUR(a1URR5(dUR5 gggr) rWrhrQrrrVcall_at_process_keepaliver`rr)rrxnow close_times r;r !RequestHandler._process_keepalive$s!%   DOO zziik44  %)\\*>U>U%VD "  << 1 1 3 3    !4URCS5 SU l"URFGc.UGb*URCS5 GO[IURJ5Ul&URO5(GdURPnUR (dU(aURCS U5 UR#5nX-nURO5(drUU:al[SUU- 5IShvN URU5IShvN SSS5IShvN UR#5nURO5(dUU:aMlURO5(d2UR (d!URCS 5 UR]5 UR_[`5 SU l"URFcUbURCS5 URL(akURj(dZUR (dIUR#5U-nUUl6URnc!URqUURr5Ul7OOUR (dGM9UR (d0SUlURFbURFR]5 gggGNE!SUlf=fGN![@aA URCS5 SU l"URFbMUcMURCS5 Mf=fGNGNGN!,IShvN (df  GN=f![2RV[2RX4aJ [8R:S :a2[2R4"5=n(aUR[5(aeGNHf=f![2RVa# URCS5 URc5 e[da+nURgS US 9 URc5 SnAGNUSnAf[ha URc5 ef=f!SU l"URFcUbURCS5 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):rrRrXrTrSrhrZrr`popleftrmessage_consumedr]rr\rrlrrequests_countr isinstancerB_make_error_handlerERRORrarrrrrrrConnectionErrorr_taskrboolrrQis_eofrYrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrIrgrVrWr r )rrxrwrprrFrrwriterrrcororrrsr end_ttrEr s r;rRequestHandler.start`sHzz--""" 33$$000$$000###>>(#'#5#5#7DL,,&&#'DL#~~557 G ||' --/&&'4+F+FF..0$(#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*y###~  !%D ~~)$$&*!u'#'DL^#-&NN#KLl!% >>)d.>NN#LMu4,E$;,E+D+D+D!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLNN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sQA-Z0$SSSEZ A W.S+3S(4S+:WZ)Z-ZA:W;-U(T9)U,UT<U UT?/UAWB6ZAZS S%%Z(S++T6WZZ"Z5T66W9U<U?UUU UUA*W W W  W?Y X3-Y3YY,ZZrc# UR5 URbURRS5 SUlUR(ayURR UR5upEnX`lUH6upxU=R S- slURRXx45 M8 URbeURn U "U5IShvN UR'5IShvN UR+XU5 US4$![aw UcURS5 OURSU<35 [5n [U RU R U R"U R$S9nURn Nf=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. NFrz+Missing return statement on request handlerz3Web-handler should return a response instance, got )rDreasontextheadersT)_finishr set_upgradedrr^rrPrZrr`prepareAttributeErrorrr$r'rDr4r5r6 write_eofr'r) rrrrrrrrr prepare_methrEs r;rRequestHandler.finish_responses  << # LL % %e ,"DN!!,0LL,B,B4CUCU,V)T%)"$,LC''1,'NN))3.9%- ||+++ (<F GA>FGFGF F GGGGrDrFcpURS:Xa;[U[5(a&URR SUR US9 OUR SUR US9 URRS:a [S5eSnU[R:Xa[RRS[RR3n[RRnSnUR(a-[[ 5 ["R$"5nSSS5 S UR&R)S S 5;a'U(a[+U5nS US 3nSUSUSUS3nS 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/plain Nz text/htmlAcceptz

Traceback:

z
zz

z

z z )rDr5 content_type)rPr$rrdreremoterr. output_sizer'r INTERNAL_SERVER_ERRORvaluephrase descriptionrr traceback format_excr6get html_escaper'r) rrrDrErFcttitlertbrs r;rRequestHandler.handle_error$s   ! # 3 (F(F KK  0'..3     0'..3   >> % % )!)   Z55 5!77==>a @`@`@g@g?hiE22>>CBzzi("--/B)goo11(B??$RB6rd&AC#W%**/1/1 !C&.3.v"E  -)(s F'' F5err_infoc4^^S[S[4UU4SjjnU$)Nrrcp># TRUTRTRTR5$7fr)rrDrErF)rrQrs r;handler3RequestHandler._make_error_handler..handleres0$$(,,8H8H s36)r&r()rrQrTs`` r;r%"RequestHandler._make_error_handlerbs" ; >   r:)%rmrgrircrhr_rQrWrXrYrlrRr[r^rZr]r\rVrrbrPrTrSrkrarUrjrr`rfrrerdrMrNrOr)g.@r)rN)rNN)?r4r5r6r7r8 __slots__rr%r LOG_FORMATrrAbstractEventLooprr)r typerrJrGrrrr rtuplerrpropertyrpr BaseTransportrrIrrrrrbytesrrrrrrrr&r(rr rrr rrrrrrBr%r9 __classcell__)rs@r;r)r)cs%N#IV$("&7C*!-!8!8!" $. $()'Z)Z)'' Z) ! Z)Z)Z)34Z)Z)Z)Z)Z)Z)Z) !Z)"#Z)$%Z)&!&'Z)Z)x #  X&67   uS#sC'( (5c? :T A   uS#sC'( (5c? :T A  '5''0edl0d0d")>)>"4""(=4#7(D(F7; % %#2t8,t3 %  % /%/D/b&t&"*d*t*""P"P.<PDIDLP P+s+#+$++3+c+d+"))DL)";->1J"JK ) ~t# $ )VS'j-"-*8-FKdl- ~t# $-d$(" <<<T ! < t <  <|  ;->!:: ;r:)Rrasyncio.streamsrrIr collectionsrcollections.abcrrr contextlibrhtmlrrLhttpr loggingr typingr r r rattryarl propcacherabcrr base_protocolrrhelpersrrrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__r}ssl web_serverr-_RequestFactory_RequestHandlerURLr&rr*r+r-srBr[_MsgTyper)r2r:r;r}s[ 99&55 +;D5+-0&B!$2 I "  K=)N*CCD   HHSM !)!88+,T$d34 "X-|; <G \G r: