o 4jty @s<ddlZddlZddlZddlZddlZddlmZddlmZm 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@dZAerddlBZBd dlCmDZDe e)e3dedged?Z(dkd@dAZ)dkdBdCZ*dDe dd$fdEdFZ+dkdGdHZ,dkdIdJZ-dKe.dLe/dMe d$Bdd$fdNdOZ0dPe1dQe1dd$fdRdSZ2dPe1dQe1dd$fdTdUZ3dkdVdWZ4dKe.dXe d$BdYe#e.ge5e/fdee/e ffdZd[Z6dkd\d]Z7dKe.d^e/dXe d$Bdee/e ffd_d`Z8 a $ $dldKe.dbed2e d$Bdced$Bde/f dddeZ9dfe:de#e.ge5e/ffdgdhZ;Z connected disconnected)formatrr1 transportr|r5r5r6__repr__ s  zRequestHandler.__repr__zssl.SSLContextcC|jdurdS|jdS)zReturn SSLContext if available.N sslcontextrget_extra_inforr5r5r6 ssl_contexts  zRequestHandler.ssl_contextNcCr)zReturn peername if available.Npeernamerrr5r5r6r  zRequestHandler.peernamecCr)zReturn sockname if available.Nsocknamerrr5r5r6r&rzRequestHandler.socknamecC|jSN)rNrr5r5r6rf1sz RequestHandler.keepalive_timeout.@timeoutc sd|_|jdur|j|jr^|j|_z&t|4IdH|jIdHWdIdHn 1IdHs7wYWn tj tj fy]d|_t j dkr[t }r[|r[Ynwz@t|4IdH+|jduru|jt |jdur|jst|jIdHWdIdHn 1IdHswYWntj tj fyt j dkrt }r|rYnw|jdur|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^rMcancelra_loop create_futurerUrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr__cancelrWdoneshield force_close)r|rtaskr5r5r6shutdown5sT   (    (    zRequestHandler.shutdownrcst|ttj|}|jrt||jdusJ|j|||j}t j dkr4tj | |dd}n| | }||_dS)Nr Trn eager_start)rtconnection_mader r TransportrKr!rHrrrTaskstart create_taskrW)r|rreal_transportrnrr~r5r6rgs    zRequestHandler.connection_mader=cs|jdurdS|j|||jj}|t|d|_d|_d|_d|_|jdur2|j |j durE|dur?t d}|j ||rQ|j durQ|j d|_ |jdurc|jd|_dSdS)NzConnection lost)rHconnection_losthandler_cancellationrrtrJrI_parserrMrr_ConnectionResetErrorrrWrXfeed_eof)r|r=rr~r5r6rxs.          zRequestHandler.connection_lostr}data_received_cbcCs<|jdusJ||_||_|jr|j|jd|_dSdS)Nrr)rXrYrT feed_data)r|r}rr5r5r6 set_parsers zRequestHandler.set_parsercCsdSrr5rr5r5r6 eof_receivedszRequestHandler.eof_receiveddatac Csz|js|jrdS|jdur|js|jdusJz |j|\}}}Wn!tyC}ztd||jdt fg}d}d}WYd}~nd}~ww|D]\}}|j d7_ |j ||fqF|j }|rl|durl|sl|d|js{t|j |jkr{|||_|r|r||_dSdSdS|jdur|jr|r|j|7_dS|r|jdur||j|\} }| r|dSdSdS)Ni)r<r=r>Frrr)r^r]rX _upgradedrrrr;r>rrFrPappendrVr set_resultrSlenrQ_pause_msg_queue_readingrTrYclose) r|rmessagesupgradedtailr=msgpayloadwaitereofr5r5r6 data_receivedsJ      zRequestHandler.data_receivedcCrr)rSrr5r5r6_reading_paused_for_msg_queuesz,RequestHandler._reading_paused_for_msg_queuecCs:d|_|jdurz|jWdStyYdSwdS)NT)rSr pause_readingrrr5r5r6rs  z'RequestHandler._pause_msg_queue_readingcCsh|js|dt|j|jkrdSd|_|js0|jdur2z|jWdSt y/YdSwdSdS)NrrF) rrrrPrQrS_reading_pausedrresume_readingrrr5r5r6_resume_msg_queue_readings  z(RequestHandler._resume_msg_queue_readingvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rGrMr)r|rr5r5r6 keep_alives   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)r]rVrrr5r5r6rszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)r^rVrrrrr5r5r6r s    zRequestHandler.force_closerequestresponsetimecCsF|jr|jdur!tr|dusJ|j|||j|dSdSdSr)rbrr logrr)r|rrrr5r5r6 log_accesss  zRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSr)r[rZr|rrr5r5r6 log_debugszRequestHandler.log_debugcOs|jj|i|dSr)rZ exceptionrr5r5r6 log_exception!szRequestHandler.log_exceptioncCsjd|_|js |js dS|j}|}|j}||kr#|||j|_dS|jr1|j s3| dSdSdSr) rMr^rGrrrLcall_at_process_keepaliverVrr)r|rnnow close_timer5r5r6r$s  z!RequestHandler._process_keepalive start_timervc sd|_zzz||_||IdH}Wd|_nd|_wWnwty;}z|}||||IdH\}}WYd}~ntd}~wtjyCtjyn}z|jd|d||d}||||IdH\}}WYd}~nAd}~wt y}z||d|}||||IdH\}}WYd}~nd}~wwt |ddrt dt ||||IdH\}}Wd|_|jdur|jd||fSd|_|jdur|jdww) NTzRequest handler timed out.exc_infoi__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception instead)rar_r"finish_responserrrr handle_error ExceptiongetattrwarningswarnDeprecationWarningrUr)r|rrrvrespr=resetr5r5r6_handle_request5sL$ $$    zRequestHandler._handle_requestc s||j}|j}|dus J|j}d}|jdusJ|jdus J|js&|jsrrwriterrvrcororrrirend_ttr=rr5r5r6r`s            6  0  *         zRequestHandler.startrc sF||jdur@|jdd|_|jr@|j|j\}}}||_|D]\}}|jd7_|j||fq%|j dus@Jz|j } Wn-t yr|durV| dn| d|t } t| j| j| j| jd}|j } Ynwz| |IdH|IdHWnty|||||dfYSw|||||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_upgradedrrTrrFrPrrVprepareAttributeErrorrr#r&r<rrr write_eofrr) r|rrrrrrrr prepare_methr=r5r5r6rsF          zRequestHandler.finish_responserr<r>c Cs,|jdkrt|tr|jjd|j|dn |jd|j|d|jjdkr(t dd}|t j krt j j dt j j }t j j}d}|jr[tt t}Wdn1sVwYd |jd d vr|rpt|}d |d }d|d|d|d}d }n |r|}|d|}t|||d} | | 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/plain Nz text/htmlAcceptz

Traceback:

z
zz

z

z z )r<r content_type)rFrrrZr[remoterr output_sizerrINTERNAL_SERVER_ERRORvaluephrase descriptionrr traceback format_excrget html_escaper&r) r|rr<r=r>cttitlertbrr5r5r6r$sN       zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrrcs|jjjSr)rr<r=r>)rrr|r5r6handleresz3RequestHandler._make_error_handler..handler)r%r')r|rrr5rr6rbsz"RequestHandler._make_error_handler)rr)rN)rNN)=r1r2r3r4 __slots__rr$r LOG_FORMATrrAbstractEventLooprxrr typerrBr?rurrr rtuplerrpropertyrfr BaseTransportrrArrrrrbytesrrrrrrrr%r'rr rrrrrrrrr;r __classcell__r5r5r~r6r(cs '+     \"  "  2# 1        +  2 >)Rrasyncio.streamsrrr collectionsrcollections.abcrrr contextlibrhtmlrrhttprloggingr typingr r r r attryarl propcacherabcrr base_protocolrrhelpersrrrrrrrrhttp_exceptionsrrrrstreamsrr tcp_helpersr!web_exceptionsr"r#web_logr$ web_requestr% web_responser&r'__all__rsssl web_serverr,_RequestFactory_RequestHandlerURLrrr)r*rsr;r_MsgTyper(r5r5r5r6s|