o Fhi @s8ddlZddlZddlZddlZddlZddlmZddlmZddl 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@erddlAZAd dlBmCZCee*e3de"dgeZ&dbd?d@Z'dbdAdBZ(dCe)dDe*dEee dd+fdFdGZ+dHe!dIe!dd+fdJdKZ,dHe!dIe!dd+fdLdMZ-dbdNdOZ.dCe)dPee dQe/e)ge0e*fdee*e ffdRdSZ1dbdTdUZ2dCe)dVe*dPee dee*e ffdWdXZ3 Y + +dcdCe)dZed1eed[eede*f d\d]Z4d^e5de/e)ge0e*ffd_d`Z6Z7S)dr)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"rVaccess_log_classrXaccess_log_formatrW max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr,looprar"rVrbrXrcrWrdrerfrgrhrirjc st|d|_d|_d|_||_|j|_|j|_ ||_ d|_ d|_ ||_ t| |_t|_d|_d|_d|_d|_d|_d|_t|||| | | t|d|_d|_zt||_Wn ttfycYnw||_| |_||_ |r{||||_!|j!j"|_#nd|_!d|_#d|_$d|_%d|_&i|_'dS)NrFg)rdrfrepayload_exceptionrir`)(super__init__rCrDr[rErequest_handlerrFrequest_factoryrGrHrIrJrKfloatrLrrMrNrPrOrQrRrSrr*rTr\ TypeError ValueErrorrVrWrXrenabledr^rYrZr]r_)selfrkrlrar"rVrbrXrcrWrdrerfrgrhrirj __class__r5r6rpsb     zRequestHandler.__init__returncCs d|jj|jdur dSdS)Nz<{} {}> connected disconnected)formatryr1 transportrwr5r5r6__repr__s  zRequestHandler.__repr__zssl.SSLContextcC|jdurdS|jdS)zReturn SSLContext if available.N sslcontextr~get_extra_inforr5r5r6 ssl_contexts  zRequestHandler.ssl_contextcCr)zReturn peername if available.Npeernamerrr5r5r6rs  zRequestHandler.peernamecCs|jSN)rKrr5r5r6rasz RequestHandler.keepalive_timeout.@timeoutNc 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 )rZrJcancelr]_loop create_futurerOrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingr[_cancelrQdoneshield force_close)rwrtaskr5r5r6shutdown sT   (    (    zRequestHandler.shutdownr~cst|ttj|}|jrt||jdusJ|j|||j}t j dkr4tj | |dd}n| | }||_dS)Nr Trl eager_start)roconnection_maderr TransportrHr"rErrrTaskstart create_taskrQ)rwr~real_transportrlrrxr5r6rRs    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)rEconnection_losthandler_cancellationrrorGrFrTrJrr[ConnectionResetErrorrrQrSfeed_eof)rwr=rrxr5r6rcs.          zRequestHandler.connection_lostparsercCs6|jdusJ||_|jr|j|jd|_dSdS)Nrm)rSrN feed_data)rwrr5r5r6 set_parsers  zRequestHandler.set_parsercCsdSrr5rr5r5r6 eof_receivedszRequestHandler.eof_receiveddatac CsN|js|jrdS|jdur~|js~|jdusJz |j|\}}}Wn!tyC}ztd||jdt fg}d}d}WYd}~nd}~ww|pGdD]\}}|j d7_ |j ||fqH|j }|rn|durn|sn|d||_|rz|r|||_dSdSdS|jdur|jr|r|j|7_dS|r|j|\} }| r|dSdSdS)Ni)r<r=r>Frmr5r)rZrYrSrRrTrrr;r>r rCrMappendrPr set_resultrNclose) rwrmessagesupgradedtailr=msgpayloadwaitereofr5r5r6 data_receiveds>    zRequestHandler.data_receivedvalcCs$||_|jr|jd|_dSdS)zMSet keep-alive connection mode. :param bool val: new state. N)rDrJr)rwrr5r5r6 keep_alives   zRequestHandler.keep_alivecCsd|_|jr |jdSdS)zClose connection. Stop accepting new pipelining messages and close connection when handlers done processing messages. TN)rYrPrrr5r5r6rszRequestHandler.closecCs8d|_|jr |j|jdur|jd|_dSdS)zForcefully close connection.TN)rZrPrr~rrr5r5r6rs    zRequestHandler.force_closerequestresponsetimecCsH|jdur |jjr"tr|dusJ|j|||j|dSdSdSr)rrvrlogrr)rwrrrr5r5r6 log_accesss  zRequestHandler.log_accessargskwcOs |jr|jj|i|dSdSr)rWrVrwrrr5r5r6 log_debugszRequestHandler.log_debugcOs|jj|i|dSr)rV exceptionrr5r5r6 log_exceptionszRequestHandler.log_exceptioncCsjd|_|js |js dS|j}|}|j}||kr#|||j|_dS|jr1|j s3| dSdSdSr) rJrZrDrrrIcall_at_process_keepaliverPrr)rwrlnow close_timer5r5r6rs  z!RequestHandler._process_keepalive start_timerqc 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)r]r[r#finish_responserrrr handle_error ExceptiongetattrwarningswarnDeprecationWarningrOr)rwrrrqrespr=resetr5r5r6_handle_requestsL$ $$    zRequestHandler._handle_requestc sJ|j}|j}|dus J|j}d}|jdusJ|jdus J|js |jsrrwriterrqrcororrrgrend_ttr=rr5r5r6rs          6  0  *        s zRequestHandler.startrc s||jdur |jdd|_|jr |j|jd|_z|j}Wn-tyR|dur6|dn|d |t }t |j |j |j|jd}|j}Ynwz||IdH|IdHWntyw|||||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. NFrmz+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})r<reasontextheadersT)_finishrT set_upgradedrRrNrprepareAttributeErrorrr}r$r'r<rrr write_eofrr)rwrrr prepare_methr=r5r5r6rs@         zRequestHandler.finish_responserr<r>c Cs|jdkrt|tr|jjd|j|dn |jd|j|d|jjdkr(t dd}|t j krd t j }t j j }d}|jrVtt t}Wdn1sQwYd |jd d vru|rkt|}d |d }dj ||d}d }n |ry|}|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/plainz{0.value} {0.phrase}Nz text/htmlAcceptz

Traceback:

z
zV{title}

{title}

{msg} )titlerz )r<r content_type)rCrrrVrWremoterr output_sizerrINTERNAL_SERVER_ERRORr} descriptionrr traceback format_excrget html_escaper'r) rwrr<r=r>ctrrtbrr5r5r6rsD        zRequestHandler.handle_errorerr_infocsdtdtffdd }|S)Nrrzcs|jjjSr)rr<r=r>)rrrwr5r6handlersz3RequestHandler._make_error_handler..handler)r&r()rwrrr5rr6rsz"RequestHandler._make_error_handler)r)rzN)rNN)8r1r2r3r4 __slots__rr%r LOG_FORMATrAbstractEventLooprsrrrrrBr?rprrr rrrrpropertyrar BaseTransportrrArrrrbytesrrrrr&r(rrrrr r rrrrr;r __classcell__r5r5rxr6r)hs''     Q$  2 '      +   - >)Prasyncio.streamsrrr collectionsr contextlibrhtmlrrhttprloggingrtypingrrr r r r r rrrrattryarl propcacherabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__ssl web_serverr,_RequestFactory_RequestHandlerURLrrr*r+rsr;_MsgTyper)r5r5r5r6sx     4