F/jtyddlZddlZddlZddlZddlZddlmZddlmZm 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 K  Lr7r>c!TeZdZdZdZddeeeejddddde dd d d d d e jde de dedeededede dededede dede de f fdZdefdZededfd Zedeeeeeefzeeefzd!zfd"Zedeeeeeefzeeefzd!zfd#Zede fd$ZdLd%e d!zdd!fd&Zd'e j<dd!ffd( Zd)e d!zdd!ffd* Z! dMd+e"d,e#gd!fd!zdd!fd-Z$dNd.Z%d/e&dd!fd0Z'de fd1Z(dNd2Z)dNd3Z*d4e dd!fd5Z+dNd6Z,dNd7Z-d8e.d9e/d:e d!zdd!fd;Z0dZ2dt|_tdz|_d|_t |||| | | t |t }t |||d|_d|_ d|_ ||_ |j|_ |j|_| |_| |_| |_||_d|_d|_||_t/| |_t3|_d|_d|_d|_d|_d|_d|_ d|_! t/||_!||_$| |_%||_&|r*||||_'|jNjP|_)nd|_'d|_)d|_*d|_+d|_,i|_-y#tDtFf$rY}wxYw)NF)rIrGrHpayload_exceptionromax_msg_queue_sizergr7ri).MAX_MSG_QUEUE_SIZErUrVrWrr*super__init__rJrKrcrLrequest_handlerrMrequest_factoryrNrIrHrGrOrPrQrRfloatrSrrTrXr]rZrYr[r\rd TypeError ValueErrorr^r_r`renabledrfrarbrerg)selfrqrrrjr"r^rkr`rlr_rIrHrGrmrnrorpparser __class__s r8ryzRequestHandler.__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 ! !$)!&( %:&   sF FFreturncrdj|jj|jdSdS)Nz<{} {}> connected disconnected)formatrr2 transportrs r8__repr__zRequestHandler.__repr__ s; NN # #>>5K  ;I  r7zssl.SSLContextcT|jdS|jjdS)zReturn SSLContext if available.N sslcontextrget_extra_infors r8 ssl_contextzRequestHandler.ssl_contexts1 ~~%  ..|< r7NcT|jdS|jjdS)zReturn peername if available.Npeernamerrs r8rzRequestHandler.peername1~~%  ..z: r7cT|jdS|jjdS)zReturn sockname if available.Nsocknamerrs r8rzRequestHandler.sockname&rr7c|jSN)rRrs r8rjz RequestHandler.keepalive_timeout1s&&&r7timeoutcKd|_|j|jj|jrX|jj |_ t|4d{|j d{dddd{ t|4d{|j-|jj!tj|j"A|j"j%s'tj&|j"d{dddd{|j"|j"j|j)y7 77#1d{7swYxYw#tjtjf$rEd|_tjdk\r'tjx}r|jrYewxYw7Y77#1d{7swYxYw#tjtjf$r>tjdk\r'tjx}r|jrY:wxYww)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.shutdown5s !  ! ! -  " " ) ) +  $ $$(::#;#;#=D  '0//....// #G, = =((4))11'2H2H2JK%%1$:L:L:Q:Q:S!..););<<<  = =    )    % % ' =/.////**G,@,@A '+$$$/!(!5!5!777)  = =  = = = = &&(<(<=   G+$1133T3OO%  sAI=F+E6,F/E=?E9E= FE;FH$G=%H(BH*H+H/ H:H;H?7I=6F9E=;F=FF F FA$G:6I=9G::I==HHHH H HHAI:6I=9I::I=rct||ttj|}|j r t ||jJ|jj|||j}tjdk\r.tj|j|d}||_y|j|j}||_y)Nr Trr eager_start)rxconnection_maderr TransportrOr"rLrrrTaskstart create_taskr[)rrreal_transportrrrrs r8rzRequestHandler.connection_madegs  *g//;    . )}}((( %%dN;zz   w &<< 4TJD"##DJJL1D!r7r@ch|jy|jj|||jj}|jt||d|_d|_d|_d|_|j|jj|j(| td}|jj||r&|j|jjd|_ |j"|jjd|_yy)NzConnection lost)rLconnection_losthandler_cancellationrrxrNrM_parserrQrrcConnectionResetErrorrr[r\feed_eof)rr@rrs r8rzRequestHandler.connection_lostxs ==  %%dC0 $}}AA  $ $ $  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . D$6$6$B    % % '!    +  ) ) +#'D  ,r7rdata_received_cbc|jJ||_||_|jr-|jj|jd|_yy)Nr7)r\r]rX feed_data)rrrs r8 set_parserzRequestHandler.set_parsersV ##+++%!1     * *4+=+= >!$D  r7cyrr6rs r8 eof_receivedzRequestHandler.eof_receiveds r7datac|js |jry|j|js|jJ |jj |\}}}|D]7\}}|xjdz c_ |jj||f9|j}|r#|!|js|jd|j s2t#|j|j$k\r|j'||_|r |r||_yyy|j$|jr|r|xj(|z c_y|rN|j*|j+|jj |\} }| r|j-yyy#t $r.}td||jtfg}d}d}Yd}~sd}~wwxYw)Ni)r?r@rAFr7r)rbrar\ _upgradedrrrr>rAr rJrTappendrZr set_resultrWlenrU_pause_msg_queue_readingrXr]close) rrmessagesupgradedtailr@msgpayloadwaitereofs r8 data_receivedzRequestHandler.data_receiveds        '<<+ ++ +/<<+A+A$+G((D!) 6 W##q(#%%sGn5 6\\FF.v{{}!!$' **'4+C+CC--/%DND%)"!x ! ! )dnn   $ & %%1&&(,,66t> % ,,. &/  s 1 ==c|js4|jdt|j|jk\ryd|_|j s)|j |jjyyy#t$rYywxYw)Nr7F) rrrrTrUrW_reading_pausedrresume_readingrrs r8_resume_msg_queue_readingz(RequestHandler._resume_msg_queue_readings~~   s #4>>"d&>&>>!&##(B --/)C#/  s!A>> B  B valcn||_|jr"|jjd|_yy)zMSet keep-alive connection mode. :param bool val: new state. N)rKrQr)rrs r8 keep_alivezRequestHandler.keep_alives3   ! !  " " ) ) +%)D " "r7c`d|_|jr|jjyy)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rarZrrs r8rzRequestHandler.closes'  << LL   ! r7cd|_|jr|jj|j"|jj d|_yy)zForcefully close connection.TN)rbrZrrrrs r8rzRequestHandler.force_close sG  << LL   ! >> % NN "!DN &r7requestresponsetimec|jrP|jCtr|J|jj|||jj |z yyyr)rfrr logrr)rrrrs r8 log_accesszRequestHandler.log_accesssX  T%7%7%C'''    " "7Hdjjoo6G$6N O&D r7argskwcV|jr|jj|i|yyr)r_r^rrrs r8 log_debugzRequestHandler.log_debugs' :: DKK  t *r * r7c<|jj|i|yr)r^ exceptionrs r8 log_exceptionzRequestHandler.log_exception!s t*r*r7cRd|_|js |jsy|j}|j }|j }||kr"|j ||j|_y|jr,|jjs|jyyyr) rQrbrKrrrPcall_at_process_keepaliverZrr)rrrnow close_times r8rz!RequestHandler._process_keepalive$s!%   DOO zziik44  %)\\*d>U>U%VD "  << 1 1 3    !4t8j:d k\r't3j4x}r|j[rY wxYw#t2jV$r#|jCd|jctd$r.}|jgd | |jcYd}~!d}~wth$r|jcwxYw#d| _"|jF||jCdwwwxYww)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`sLzz--""" 33$$000$$000##>>(#'#5#5#7DL,,&&#'DL#~~557 GW ||' --/&&'4+F+FF..0$(#8#8DIIKdE  " "a ' "!$-F'8,"&":":7"C"&"7"7 ++""@g&:&:4&@ GC N++GUOL##w."<<4TJD++D1D(,*KD% NN#MN`!% >>)d.>NN#LM_#'t"7~~'%)%9%9N,,E~#iik #n 4 &&-nn&63;+7 +D!<!<*1//*;$;$;!<!<'+iik '.nn&63;#>>+D4E4E'=> %%&;<!% >>)d.>NN#LMt{{4;L;L!YY[+<< 2</))1-1\\"D$;$;.D*y##~  !%D ~~)$$&*!u'#'DL^#-&NN#KLl!% >>)d.>NN#LMu4!<$;!<!<!<!<!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sDA X#$Q4Q1Q4 D1X>AURRRU1*XA+U'S*.S /S*2SSS S*S)S*AUB X5FGFGFF F?<G>F??Gr?rAcF|jdk(r9t|tr)|jj d|j |n|j d|j ||jjdkDr tdd}|tjk(rtjjdtjj}tjj}d}|jr,tt 5t#j$}dddd |j&j)d d vr"|rt+|}d |d }d|d|d|d}d }n |r|}|dz|z}t-|||} | j/| S#1swYuxYw)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 )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 KK  0'..3     0'..3   >> % % )!)   Z55 5!77==>a @`@`@g@g?hiE22>>CBzzi(0"--/B0goo11(B??$RB6rd&AC#W%**/1/1 !C&.3.vG"E  -00s FF err_infoc0dtdtffd }|S)NrrcpKj|jjjSwr)rr?r@rA)rr1rs r8handlerz3RequestHandler._make_error_handler..handleres1$$(,,8H8H s36)r&r()rr1r4s`` r8rz"RequestHandler._make_error_handlerbs ; >  r7)g.@r)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!8!" $. $()'Z)Z)'' Z) ! Z)Z)Z)34Z)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 <  <|  ;->!:: ;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>r9_MsgTyper)r6r7r8r[s_ 99&55 +;D5+-0&B!$2 I "  K=)N*CCD    DHHSM !)!88+,T$d34 "X-|; <G \G r7