† hiddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZmZddlZddlZddlmZd d l m!Z!m"Z"d d l#m$Z$d d l%m&Z&d d l m'Z'm(Z(m)Z)m*Z*m+Z+d dl,m-Z-d dl.m/Z/m0Z0d dl1m2Z2m3Z3d dl4m5Z5d dl6m7Z7m8Z8d dl9m:Z:d dl;mZ>m?Z?dZ@er ddlAZAd dlBmCZCee*e3de"dger>^s. KKK  LLLLLr7r>c!FeZdZdZdZddeeeejdddddd dd d d d de j de de de deede dede dededede dede de f fdZdefdZeded fd!Zedeeeeeeeefeeefffd"Zede fd#ZdJd%ee dd&fd'Zd(e jdd&ffd) Zd*eedd&ffd+ Z d,e!dd&fd-Z"dKd.Z#d/e$dd&fd0Z%d1e dd&fd2Z&dKd3Z'dKd4Z(d5e)d6e*d7ee dd&fd8Z+d9e!d:e!dd&fd;Z,d9e!d:e!dd&fd<Z-dKd=Z.d5e)d>ee d?e/e)ge0e*fdee*e ffd@Z1dKdAZ2d5e)dBe*d>ee dee*e ffdCZ3 dLd5e)dEed*eedFeede*f dGZ4dHe5de/e)ge0e*ffdIZ6xZ7S)Mr*ajHTTP 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#rZaccess_log_classr\access_log_formatr[ max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr-looprer#rZrfr\rgr[rhrirjrkrlrmrnc t|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t!|_d|_d|_d|_d|_d|_d|_t1|||| | | t2||_d|_ t||_n#t8t:f$rYnwxYw||_| |_||_ |r#||||_!|j!j"|_#nd|_!d|_#d|_$d|_%d|_&i|_'dS)NrFgr7)rhrjripayload_exceptionrmrd)(super__init__rGrHr_rIrequest_handlerrJrequest_factoryrKrLrMrNrOfloatrPrrQrRrTrSrUrVrWrr+rXr` TypeError ValueErrorrZr[r\renabledrbr]r^rarc)selfrorprer#rZrfr\rgr[rhrirjrkrlrmrn __class__s r8rtzRequestHandler.__init__s*  7;*1 ;B;R;B;R+*-';?"3$^44*/'' 7; ?C;? $(D ! !!%D $)D ! !$)!&( s-DDDreturncTd|jj|jdndS)Nz<{} {}> connected disconnected)formatr|r2 transportr{s r8__repr__zRequestHandler.__repr__s0 N #>5KK>   r7zssl.SSLContextcH|jdn|jdS)zReturn SSLContext if available.N sslcontextrget_extra_infors r8 ssl_contextzRequestHandler.ssl_contexts+ ~% D..|<< r7cH|jdn|jdS)zReturn peername if available.Npeernamerrs r8rzRequestHandler.peernames+~% D..z:: r7c|jSN)rOrs r8rez RequestHandler.keepalive_timeouts &&r7.@timeoutNclKd|_|j|j|jr|j|_ t|4d{V|jd{Vdddd{Vn#1d{VswxYwYnb#tj tj f$rDd|_tj dkr*tj x}r|rYnwxYw t|4d{V|j+|jtj |j8|jstj|jd{Vdddd{Vn#1d{VswxYwYn[#tj tj f$r=tj dkr*tj x}r|rYnwxYw|j|j|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 )r^rNcancelra_loop create_futurerSrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr__cancelrUdoneshield force_close)r{rtasks r8shutdownzRequestHandler.shutdown sg !  ! -  " ) ) + + +  $ $(:#;#;#=#=D  '00////////........///////////////////////////*G,@A   '+$$//!(!5!7!770))0  #G,, = = = = = = = =(4)11'2H2J2JKKK%1$:L:Q:Q:S:S1!.);<<<<<<<<<  = = = = = = = = = = = = = = = = = = = = = = = = = = = &(<=    G++$1333T,OO%%,     )   % % ' ' ' soB%B3B BBBBAC65C6:F%A2FF% FF% F!F%%AG=<G=rct|ttj|}|jrt ||jJ|j|||j}tj dkr*tj | |d}n'| | }||_dS)Nr Trp eager_start)rsconnection_maderr TransportrLr#rIrrrTaskstart create_taskrU)r{rreal_transportrprr|s r8rzRequestHandler.connection_madeRs  ***g/;;   * . ) ) )}((( %%dN;;;z  w & &< 4TJJJDD##DJJLL11D!r7r@cR|jdS|j|||jj}|t |d|_d|_d|_d|_|j|j |j +|td}|j ||r |j |j d|_ |j"|jd|_dSdS)NzConnection lost)rIconnection_losthandler_cancellationrrsrKrJrXrNrr_ConnectionResetErrorrrUrWfeed_eof)r{r@rr|s r8rzRequestHandler.connection_lostcs0 = F %%dC000 $}A  $$$ $ $#  ! -  " ) ) + + +  ,{*+<==  ! ) )# . . .  (D$6$B   % % ' ' '!   +  ) ) + + +#'D  , +r7parserc|jJ||_|jr(|j|jd|_dSdS)Nr7)rWrR feed_data)r{rs r8 set_parserzRequestHandler.set_parsersV#+++%   %  * *4+= > > >!$D    % %r7cdSrr6rs r8 eof_receivedzRequestHandler.eof_receiveds r7datac|js|jrdS|j|js|jJ |j|\}}}n:#t $r-}td||jtfg}d}d}Yd}~nd}~wwxYw|pdD]1\}}|xj dz c_ |j ||f2|j }|r+|)|s|d||_|r |r ||_dSdSdS|j|jr|r|xj|z c_dS|r5|j|\} }| r|dSdSdS)Ni)r?r@rAFr7r6r)r^r]rWrVrXrrr>rAr!rGrQappendrTr set_resultrRclose) r{rmessagesupgradedtailr@msgpayloadwaitereofs r8 data_receivedzRequestHandler.data_receiveds      F   ' ''333 +/+?+I+I$+O+O((DD&   Sc3;GGGW!  !)B 6 6 W##q(##%%sGn5555\F (F.v{{}}.!!$'''$DM *D *%)""" * * * * ! )dm ) )   $ &     ,66t< % N " " "!DNNN & %r7requestresponsetimec|jO|jjrEtr|J|j|||j|z dSdSdSr)rrzrlogrr)r{rrrs r8 log_accesszRequestHandler.log_accesssl   )d.@.H ) ('''   " "7Hdjoo6G6G$6N O O O O O * ) ) )r7argskwc<|jr|jj|i|dSdSr)r[rZr{rrs r8 log_debugzRequestHandler.log_debugs6 : + DK t *r * * * * * + +r7c*|jj|i|dSr)rZ exceptionrs r8 log_exceptionzRequestHandler.log_exceptions" t*r*****r7c8d|_|js|jsdS|j}|}|j}||kr"|||j|_dS|jr/|j s| dSdSdSr) rNr^rHrrrMcall_at_process_keepaliverTrr)r{rpnow close_times r8rz!RequestHandler._process_keepalives!%   DO  Fziikk4   %)\\*d>U%V%VD " F <  1 1 3 3             r7 start_timerucKd|_ ||_||d{V}d|_n #d|_wxYw t|ddrtjdt ||||d{V\}}n#t$r,}|}||||d{V\}}Yd}~nd}~wtj $rtj $rW}| d|| |d}||||d{V\}}Yd}~nQd}~wt$rA}| |d|}||||d{V\}}Yd}~nd}~wwxYwd|_|j|jdn.#d|_|j|jdwwxYw||fS) NT__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception insteadzRequest handler timed out.exc_infoi)rar_getattrwarningswarnDeprecationWarningfinish_responser$rrrr handle_error ExceptionrSr)r{rrrurespresetr@s r8_handle_requestzRequestHandler._handle_requests %)! 6 -(/%,_W55555555(,%%%,,,,%t1599  9' !% 4 4WdJ O OOOOOOOKD%%- P P PD $ 4 4WdJ O OOOOOOOKD%%%%%%%    # P P P NN7#N F F F$$Wc22D $ 4 4WdJ O OOOOOOOKD%%%%%% P P P$$Wc377D $ 4 4WdJ O OOOOOOOKD%%%%%% P).D %#/$//555).D %#/$//55550U{sa,B 5BA F# E7"B61F#6!E7A D)$F#) E767E2-F#2E77F##+Gc K|j}|j}|J|j}d}|jJ|jJ|js |js; ||_|jd{Vd|_n #d|_wxYw|j \}}|j r| nd}|xj dz c_ t||}t|tr||} t"}n|j} ||||||jpt'j|} || || } t,jdkrt'j| |d} n|| } | d{V\}} nK#t4$r>|dYd| _|j||dn[wxYw~ | r=|d d| _|j||dnt=|j|_ |!s|j"}|js-|r*|d || }||z} |!s||krtG||z 4d{V|$d{Vdddd{Vn#1d{VswxYwY| }|!s||kn[#t&j%t&j&f$r=t,jd kr*t'jx}r|'rYnwxYw|!s0|js)|d |(|)tTn#t&j%$r+|d|+tX$r5}|-d | |+Yd}~n&d}~wt\$r|+wxYwd| _|j||dn,#d| _|j||dwwwxYw|j rT|j/sM|jsF| |z}||_0|j1 |2||j3|_1nn|j |js)d|_|j|j(dSdSdS)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)4rrIrOrKrJr^rQrrTpopleftrbrrequests_countr isinstancer>_make_error_handlerERRORrUrrrrrrrConnectionErrorr_taskrboolrrHis_eofrPrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrDr]rMrNrr)r{rprorerrArrwriterrurcororrrkrend_ttr@rs r8rzRequestHandler.startsz-""" 3$000$000#p > ((#'#5#5#7#7DL,&&&&&&&#'DLL4DL''''#~5577 GW$(#8BDIIKKKdE  " "a ' " "!$--F'8,, 8"&":":7"C"C"&"7 ++"@g&:4&@&@ GC N++GUOLL#w.."<4TJJJDD++D11D(,******KD%%&NN#KLLLl!% >)d.>NN#LMMMu NN#MNNN`!% >)d.>NN#LMMM_#'t"7"7~~''%%)%9N,&&E~#iikk #n 4 &&-nn&6&623;;+7 +D+D!<!<!<!<!<!<!<!<*1//*;*;$;$;$;$;$;$;$;!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<!<'+iikk '.nn&6&623;; !( 68LM&&& # 0G ; ;*1*>*@*@%@Q!<$%LLNN!<!& &#>>++%D4E%'=>>> %%&;<<<<)   GHHH  """ # # #""#83"GGG  """"""""      """ !% >)d.>NN#LMMM!% >)d.>NN#LMMMM*.> t{ 4;L !YY[[+<< 2</)1-1\\"D$;..D*a#p f  '!%D ~)$$&&&&& ' '))s&A.. A7?AO4 F O4 G(?O4'G((O4+A/O42L: K:(L:: LL:L1L:9O4:ANO4NA!O43R24AR 6+Q&!R2&#R  R22)SrcK||jN|jdd|_|jr&|j|jd|_ |j}n#t$r||dn(|d |t}t|j |j |j|j}|j}YnwxYw ||d{V|d{Vn+#t"$r|||||dfcYSwxYw|||||dfS)aPrepare 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. NFr7z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r?reasontextheadersT)_finishrX set_upgradedrVrRrprepareAttributeErrorrrr%r(r?rrr write_eofrr)r{rrr prepare_methr@s r8rzRequestHandler.finish_responses    +  - -e 4 4 4!DM! )$..t/ABBB%(" (=C>+D..%EErr?rAc|jdkr8t|tr#|jd|j|n|d|j||jjdkrtdd}|tj krd tj }tj j }d}|jr?tt5t!j}dddn #1swxYwYd |jd d vr1|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. 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 )r?r content_type)rGrrrZr[remoterr output_sizerrINTERNAL_SERVER_ERRORr descriptionrr traceback format_excrget html_escaper(r) r{rr?r@rActr rtbrs r8rzRequestHandler.handle_errors  ! # # 3 (F(F # K  0'.3        0'.3     > % ) )!)   Z5 5 5*11*2RSSE2>CBz 0i((00"-//B000000000000000go11(B????B$RBArAAAC0&u#&..  !C&.3.vG"EEE  sC??DDerr_infoc4dtdtffd }|S)Nrr}cVK|jjjSr)rr?r@rA)rrr{s r8handlerz3RequestHandler._make_error_handler..handlers/$$(,8H r7)r'r))r{rrs`` r8rz"RequestHandler._make_error_handlers< ; >        r7)r)r}N)rNN)8r2r3r4r5 __slots__r r&r LOG_FORMATrAbstractEventLooprwrrrrrErBrtrrr rrrrpropertyrer BaseTransportrrDrr rrbytesrrrrr'r)rrrrr r rrrrr>r __classcell__)r|s@r8r*r*hs(%%NIN$("&7C*!-!8! " $! $()'O)O)O)O)' O) ! O)O)O)34O)O)O)O)O)O)O) !O)"#O)$%O)&!&'O)O)O)O)O)O)b #     X&67     %U3S##56c3hGH I    '5'''X'00huo00000d")>"4"""""""(8M#:(t((((((@%%%%%%    %%%D%%%%N*d*t****""""""""P"P.<PDLUOP PPPP+s+#+$+++++3+c+d++++"))UO)";->1J"JK ) ~t# $ ))))VG'G'G'G'R("(*8(FNuo( ~t# $((((Z'+!% <<<<m $ < # <  <<<<|  ;->!:: ;r7)Prasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrr 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_RequestHandlerURLrrr+r,rsr>_MsgTyper*r6r7r8r@s &&&&&&                           ++++++;;;;;;;;''''''!!!!!!+*****--------00000000&&&&&&BBBBBBBB!!!!!!$$$$$$22222222 I#JJJ""""""  K=)N*CCD    DHSMM  !!!!!)!!!88888888+*,,T$d33343 ((23\A Bp p p p p \p p p p p r7