*GjtyddlZddlZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZddlmZddlmZmZmZmZddlZddlZdd lmZd d lmZmZd d l m!Z!m"Z"d d l#m$Z$m%Z%d dlm&Z&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@dZAer ddlBZBd dlCmDZDe e)e3dedger>Ys. KKK  LLLLLr7r>c!eZdZdZdZddeeeejddddde dd d d d d e j de de dedeededede dededede dede de f fdZdefdZededfd Zedeeeeeefzeeefzd!zfd"Zedeeeeeefzeeefzd!zfd#Zede fd$ZdNd&e d!zdd!fd'Zd(e jdd!ffd) Zd*e d!zdd!ffd+ Z! dOd,e"d-e#gd!fd!zdd!fd.Z$dPd/Z%d0e&dd!fd1Z'de fd2Z(dPd3Z)dPd4Z*d5e dd!fd6Z+dPd7Z,dPd8Z-d9e.d:e/d;e d!zdd!fd<Z0d=e1d>e1dd!fd?Z2d=e1d>e1dd!fd@Z3dPdAZ4d9e.dBe d!zdCe#e.ge5e/fdee/e ffdDZ6dPdEZ7d9e.dFe/dBe d!zdee/e ffdGZ8 dQd9e.dIed*e d!zdJed!zde/f dKZ9dLe:de#e.ge5e/ffdMZ;xZN>N-??D %)$6$>D ! !!%D $)D ! !$)!&( s&D;;EEreturncTd|jj|jdndS)Nz<{} {}> connected disconnected)formatrr2 transportrs 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..|<< r7NcH|jdn|jdS)zReturn peername if available.Npeernamerrs r8rzRequestHandler.peername+~% D..z:: r7cH|jdn|jdS)zReturn sockname if available.Nsocknamerrs r8rzRequestHandler.sockname&rr7c|jSN)rRrs r8rjz RequestHandler.keepalive_timeout1s &&r7.@timeoutclKd|_|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 )rbrQcancelre_loop create_futurerYrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrc_cancelr[doneshield force_close)rrtasks r8shutdownzRequestHandler.shutdown5sg !  ! -  " ) ) + + +  $ $(:#;#;#=#=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 Trr eager_start)rxconnection_maderr TransportrOr"rLrrrTaskstart create_taskr[)rrreal_transportrrrrs r8rzRequestHandler.connection_madegs  ***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)rLconnection_losthandler_cancellationrrxrNrM_parserrQrrcConnectionResetErrorrr[r\feed_eof)rr@rrs r8rzRequestHandler.connection_lostxs/ = F %%dC000 $}A  $$$ $ $  ! -  " ) ) + + +  ,{*+<==  ! ) )# . . .  (D$6$B   % % ' ' '!   +  ) ) + + +#'D  , +r7rdata_received_cbc|jJ||_||_|jr(|j|jd|_dSdS)Nr7)r\r]rX feed_data)rrrs r8 set_parserzRequestHandler.set_parsers` #+++%!1   %  * *4+= > > >!$D    % %r7cdSrr6rs r8 eof_receivedzRequestHandler.eof_receiveds r7datach|js|jrdS|j#|js|jJ |j|\}}}n:#t $r-}td||jtfg}d}d}Yd}~nd}~wwxYw|D]1\}}|xj dz c_ |j ||f2|j }|r+|)|s|d|js1t#|j |jkr|||_|r |r ||_dSdSdS|j|jr|r|xj|z c_dS|rP|j||j|\} }| r|dSdSdS)Ni)r?r@rAFr7r)rbrar\ _upgradedrrrr>rAr rJrTappendrZr set_resultrWlenrU_pause_msg_queue_readingrXr]close) rrmessagesupgradedtailr@msgpayloadwaitereofs r8 data_receivedzRequestHandler.data_receiveds:      F   ' '<+++ +/<+A+A$+G+G((DD&   Sc3;GGGW!  !) 6 6 W##q(##%%sGn5555\F (F.v{{}}.!!$''' * 0''4+CCC--///%DN *D *%)""" * * * * ! )dn ) )   $ &     %1&&(((,66t< % ,,......     & %s + 99c|js4|dt|j|jkrdSd|_|js4|j/ |jdS#t$rYdSwxYwdSdS)Nr7F) rrrrTrUrW_reading_pausedrresume_readingrrs r8_resume_msg_queue_readingz(RequestHandler._resume_msg_queue_readings~    s # # #4>""d&>>>!&# (B --/////.      (B(BsA-- A;:A;valcf||_|jr"|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rKrQr)rrs r8 keep_alivezRequestHandler.keep_alivesC   ! *  " ) ) + + +%)D " " " * *r7cXd|_|jr|jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rarZrrs r8rzRequestHandler.closes9  < " L   ! ! ! ! ! " "r7cd|_|jr|j|j"|jd|_dSdS)zForcefully close connection.TN)rbrZrrrrs r8rzRequestHandler.force_close sW  < " L   ! ! ! > % N " " "!DNNN & %r7requestresponsetimec|jrJ|jEtr|J|j|||j|z dSdSdSr)rfrr logrr)rrrrs r8 log_accesszRequestHandler.log_accesssp   PT%7%C ('''   " "7Hdjoo6G6G$6N O O O O O P P%C%Cr7argskwc<|jr|jj|i|dSdSr)r_r^rrrs r8 log_debugzRequestHandler.log_debugs6 : + DK t *r * * * * * + +r7c*|jj|i|dSr)r^ exceptionrs r8 log_exceptionzRequestHandler.log_exception!s" t*r*****r7c8d|_|js|jsdS|j}|}|j}||kr"|||j|_dS|jr/|j s| dSdSdSr) rQrbrKrrrPcall_at_process_keepaliverZrr)rrrnow close_times r8rz!RequestHandler._process_keepalive$s!%   DO  Fziikk4   %)\\*d>U%V%VD " F <  1 1 3 3             r7 start_timerzcKd|_ ||_||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)rercgetattrwarningswarnDeprecationWarningfinish_responser#rrrr handle_error ExceptionrYr)rrrrzrespresetr@s r8_handle_requestzRequestHandler._handle_request5s %)! 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|jsb|js; ||_|jd{Vd|_n #d|_wxYw|j \}}|j |j |j r1t|j|jkr||jr|nd}|xjdz c_t'||}t)|t*r||} t.}n|j} ||||||jpt3j|} || || } t8jdkrt3j| |d} n|| } | d{V\}} nK#t@$r>|!dYd| _"|j#||!dn[wxYw~ | r=|!d d| _"|j#||!dntI|j%|_&|'s|j(}|js-|r*|!d ||}||z} |'s||krtS||z 4d{V|*d{Vdddd{Vn#1d{VswxYwY|}|'s||kn[#t2j+t2j,f$r=t8jd kr*t3jx}r|-rYnwxYw|'s0|js)|!d |.|/t`n#t2j+$r+|!d|1td$r5}|3d | |1Yd}~n&d}~wth$r|1wxYwd| _"|j#||!dn,#d| _"|j#||!dwwwxYw|j&rT|j5sM|jsF||z}||_6|j7 |8||j9|_7nn|jb|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):rrLrRrNrMrbrTrrZpopleftrmessage_consumedrWrrVrrfrrequests_countr isinstancer>_make_error_handlerERRORr[rrrrrrrConnectionErrorr_taskrboolrrKis_eofrSrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrDrarPrQrr)rrrrqrjrrArrwriterrzrcororrrmrend_ttr@rs r8rzRequestHandler.start`s!z-""" 3$000$000#| > ((#'#5#5#7#7DL,&&&&&&&#'DLL4DL''''#~5577 GW |' --///& 1''4+FFF..000$(#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*y#| ~  '!%D ~)$$&&&&& ' '))s&A.. A7AQ , G87Q 8IQ ?IQ A/Q 32N%MN MNM 1NQ AO*'Q )O**A!Q T AS!+R>9T >#S!!T )T3rcJK||j|jdd|_|jrg|j|j\}}}||_|D]1\}}|xjdz c_|j||f2|j J |j } n|#t$ro|| 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. NFrz+Missing return statement on request handlerz3Web-handler should return a response instance, got )r?reasontextheadersT)_finishr set_upgradedrrXrrJrTrrZprepareAttributeErrorrr$r'r?rrr write_eofr r) rrrrrrrrr prepare_methr@s r8rzRequestHandler.finish_responses  < # L % %e , , ,"DN! ,,0L,B,B4CU,V,V))T%)"$,::LC''1,''N))3.9999|+++ (Traceback: 
z
zz

z

z z )r?r content_type)rJrrr^r_remoterr output_sizer r INTERNAL_SERVER_ERRORvaluephrase descriptionrr traceback format_excrget html_escaper'r) rrr?r@rActtitlertbrs r8rzRequestHandler.handle_error$s*  ! # # 3 (F(F # K  0'.3        0'.3     > % ) )!)   Z5 5 5!7=ii @`@giiE2>CBz 0i((00"-//B000000000000000go11(B????B$RBArAAAC1#11*/11111 !C&.3.vG"EEE  s%DD  D err_infoc4dtdtffd }|S)NrrcVK|jjjSr)rr?r@rA)rr2rs r8handlerz3RequestHandler._make_error_handler..handleres/$$(,8H r7)r&r()rr2r5s`` r8r z"RequestHandler._make_error_handlerbs< ; >        r7)rr)rN)rNN)=r2r3r4r5 __slots__rr%r LOG_FORMATrrAbstractEventLoopr|r r typerrErBryrrr rtuplerrpropertyrjr BaseTransportrrDrrrrrbytesrrrrrrrr&r(rr rrrrrrrrr>r  __classcell__)rs@r8r)r)cs%%N#IV$("&7C*!-!8!" $. $()'Z)Z)Z)Z)' Z) ! Z)Z)Z)34Z)Z)Z)Z)Z)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'''X'00edl0d0000d")>"4"""""""(=4#7(D((((((F7; % % %#2t8,t3 %  % % % %    /%/D////b&t&&&&"*d*t****""""""""P"P.<PDIDLP PPPP+s+#+$+++++3+c+d++++"))DL)";->1J"JK ) ~t# $ ))))VS'S'S'S'j-"-*8-FKdl- ~t# $----d$(" <<<<T ! < t <  <<<<|  ;->!:: ;r7)Rrasyncio.streamsrr+r collectionsrcollections.abcrrr contextlibrhtmlrr.httpr loggingr typingr r r rattryarl propcacherabcrr base_protocolrrhelpersrrrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__rwssl web_serverr-_RequestFactory_RequestHandlerURLr rr*r+rsr>r:_MsgTyper)r6r7r8r\s 9999999999&&&&&&555555555555 ++++++;;;;;;;;DDDDDDDD55555555+*****--------00000000&&&&&&BBBBBBBB!!!!!!$$$$$$22222222 I #JJJ""""""  K=)N*CCD    DHSMM  !!!!!)!!!88888888+*,,T$d33343 "X-|; <G G G G G \G G G G G r7