/g6hSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r SSK J r SSKJr SSKJrJrJrJrJrJrJrJrJrJrJr SSKrSSKrSS KJrJ r SS K!J"r" SS K#J$r$ SS K J%r%J&r&J'r'J(r(J)r) SS K*J+r+ SSK,J-r-J.r. SSK/J0r0J1r1 SSK2J3r3 SSK4J5r5J6r6 SSK7J8r8 SSK9J:r: SSK;J\(aSSK?J@r@ \\(\1S\ S/\:4rA\\:/\\=4rB\("SS\'00SSSS\R"S55 rD"SS\E5rF"SS \E5rG\G"5rH\R"SSSS!9"S"S#55rJ\\\(\J4\14rK"S$S\"5rLg)%N)deque)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriter) BadHttpMethod) access_logger server_logger) EMPTY_PAYLOAD StreamReader) tcp_keepalive) HTTPExceptionHTTPInternalServerError) AccessLogger) BaseRequest)ResponseStreamResponse)RequestHandlerRequestPayloadErrorPayloadAccessError)Serverr)zasyncio.Task[None]UNKNOWN/TFc\rSrSrSrSrg)r*PzPayload parsing error.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r1YC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiohttp/web_protocol.pyr*r*Ps r9r*c\rSrSrSrSrg)r+Tz-Payload was accessed after response was sent.r1Nr2r1r9r:r+r+Ts7r9r+) auto_attribsfrozenslotsc4\rSrSr%\\S'\\S'\\S'Srg)_ErrInfo[statusexcmessager1N) r3r4r5r6int__annotations__ BaseExceptionstrr8r1r9r:rArA[s K  Lr9rAc!^\rSrSrSrSrSS\\\\RSSSSS S SS S .S SS\ RS\ S\ S\S\\S\S\S\ S\S\S\S\ S\S\ S\ 4 U4SjjjrS\4S jr\S\ 4S!j5rSGS"\\ SS#4S$jjrS%\ R2SS#4U4S&jjrS'\\SS#4U4S(jjrS)\SS#4S*jrSHS+jrS,\ SS#4S-jr!S.\ SS#4S/jr"SHS0jr#SHS1jr$S2\%S3\&S4\ SS#4S5jr'S6\S7\SS#4S8jr(S6\S7\SS#4S9jr)SHS:jr*S2\%S;\ S<\+\%/\,\&4S\-\&\ 44S=jr.SHS>jr/S2\%S?\&S;\ S\-\&\ 44S@jr0SIS2\%SA\S'\\SB\\S\&4 SCjjr1SD\2S\+\%/\,\&44SEjr3SFr4U=r5$)Jr)eaHTTP 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_progressi.TFiig$@i)keepalive_timeoutr"r_access_log_classraaccess_log_formatr` max_line_size max_headersmax_field_sizelingering_time read_bufsizeauto_decompresstimeout_ceil_thresholdmanagerr,looprhr"r_rirarjr`rkrlrmrnrorprqc x>[TU]U5 SUlSUlSUlXlUR UlURUl X@l SUl SUl X0l [U 5Ul[!5UlSUlSUlSUlSUlSUlSUl[1UUUU U U [2US9UlSUl[U5UlXPlXlXpl U(aU"Xx5Ul!OSUl!SUl"SUl#SUl$g![8[:4a NVf=f)NrFgr9)rkrmrlpayload_exceptionrprg)%super__init__rLrMrdrNrequest_handlerrOrequest_factoryrPrQrRrSrTfloatrUrrVrWrYrXrZr[r\rr*r]re TypeError ValueErrorr_r`rarrbrcrf)selfrrrsrhr"r_rirarjr`rkrlrmrnrorprq __class__s r:rwRequestHandler.__init__sM*  7;*1 ;B;R;R;B;R;R+*-';?"3$^4*/' 7; ?C;? $( connected disconnected)formatr~r3 transportr}s r:__repr__RequestHandler.__repr__s; NN # #>>5K  ;I  r9cUR$N)rTrs r:rh RequestHandler.keepalive_timeouts&&&r9timeoutNcj# SUlURbURR5 UR(aXURR 5Ul[U5IShvN UR IShvN SSS5IShvN [U5IShvN URb.URR![R"55 UR"bGUR"R%5(d([R&"UR"5IShvN SSS5IShvN UR"bUR"R5 UR)5 gGNGNN!,IShvN (df  GN =f![R[R4aQ SUl[RS:a2[R"5=n(aUR5(aeGNf=fGNwNN!,IShvN (df  N=f![R[R4aJ [RS:a2[R"5=n(aUR5(aeGNaf=f7f)zDo worker process exit preparations. We need to clean up everything and stop accepting requests. It is especially important for keep-alive connections. TN )rcrScancelrf_loop create_futurerXrasyncioCancelledError TimeoutErrorsys version_info current_task cancellingrd_cancelrZdoneshield force_close)r}rtasks r:shutdownRequestHandler.shutdowns !  ! ! -  " " ) ) +  $ $$(::#;#;#=D  '00....10 #G,,((4))11'2H2H2JK%%1$:L:L:Q:Q:S:S!..););<<< -,    )    % % ' =1.1000**G,@,@A '+$$$/!(!5!5!777)) - = -,,, &&(<(<=   G+$1133T3OO%%  sAJ3"F)1F2F)5FF F F)F F)I*H!+I.B H(9H$:H(> I H& I8J3F) F F)F&F  F&!F)$J3&F))A1HJ3HJ3!I$H(&I(H?.H1 / H?;I>J3?IA*J0,J3/J00J3rc>[TU]U5 [[RU5nUR (a [ U5 URceURRX5 URn[RS:a%[R"UR5USS9nOURUR55nX@lg)Nr Trs eager_start)rvconnection_maderr TransportrQr"rNrrrTaskstart create_taskrZ)r}rreal_transportrsrr~s r:rRequestHandler.connection_made6s  *g//;    . )}}((( %%d;zz   w &<< 4TJD##DJJL1D!r9rDc|>URcgURRX5 URRnUR5 [TU]U5 SUlSUlSUlSUlURbURR5 URb)Uc [S5nURRU5 U(a'URbURR5 SUl URb"URR5 SUlgg)NzConnection lost)rNconnection_losthandler_cancellationrrvrPrOr]rSrrdConnectionResetErrorrrZr\feed_eof)r}rDrr~s r:rRequestHandler.connection_lostGs  ==  %%d0 $}}AA  $ $ $#  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . D$6$6$B    % % '!    +  ) ) +#'D  ,r9parsercURbeXlUR(a-URRUR5 SUlgg)Nr9)r\rW feed_data)r}rs r: set_parserRequestHandler.set_parsergsJ##+++%     * *4+=+= >!$D  r9cgrr1rs r: eof_receivedRequestHandler.eof_receivedqs r9datac|UR(dUR(agURcUR(dURceURR U5up#nU=(d SH6upgU=RS- sl URRXg45 M8 URnU(a)Ub&UR5(dURS5 X0lU(aU(aX@lgggURc.UR(aU(aU=R U- slgU(a6URR U5upU (aUR#5 ggg![ a*n[SXURS9[4/nSnSnSnAGNFSnAff=f)Ni)rCrDrEFr9r1r)rcrbr\r[r]rrrArEr rLrVappendrYr set_resultrWclose) r}rmessagesupgradedtailrDmsgpayloadwaitereofs r: data_receivedRequestHandler.data_receivedtsg        ' ''3 33 +/+?+?+I+I$+O(D!)B ##q(#%%sn5!/\\FF.v{{}}!!$'$MD%)"!x ! ! )dmm   $ & ,,66t> % NN "!DN &r9requestresponsetimecURbTURR(a8URRXURR 5U- 5 gggr)renabledlogrr)r}rrrs r: log_accessRequestHandler.log_accesssM    )d.@.@.H.H    " "7djjoo6G$6N O/I )r9argskwc`UR(aURR"U0UD6 ggr)r`r_r}rrs r: log_debugRequestHandler.log_debugs% :: KK  t *r * r9c<URR"U0UD6 gr)r_ exceptionrs r: log_exceptionRequestHandler.log_exceptions t*r*r9cxSUlUR(dUR(dgURnUR 5nUR nX#:a!UR X0R5UlgUR(a1URR5(dUR5 gggr) rSrcrMrrrRcall_at_process_keepaliverYrr)r}rsnow close_times r:r!RequestHandler._process_keepalives!%   DOO zziik44  %)\\*>U>U%VD "  << 1 1 3 3    !4UR5S5 SU lUR8Gc.UGb*UR5S5 GO[;UR<5UlURA5(GdURBnUR (dU(aUR5S U5 UR5nX-nURA5(drUU:al[EUU- 5IShvN URG5IShvN SSS5IShvN UR5nURA5(dUU:aMlURA5(d2UR (d!UR5S 5 URO5 URQ[R5 SU lUR8cUbUR5S5 UR>(akUR\(dZUR (dIUR5U-nUUl/UR`c!URcUURd5Ul0OOUR (dGMUR (d0SUlUR8bUR8RO5 gggGN!SUlf=fGN![2aA UR5S5 SU lUR8bMUcMUR5S5 Mf=fGNGNGN!,IShvN (df  GN=f![$RH[$RJ4aJ [*R,S :a2[$R&"5=n(aURM5(aeGNHf=f![$RHa# UR5S5 URU5 e[Va+nURYS US 9 URU5 SnAGNUSnAf[Za URU5 ef=f!SU lUR8cUbUR5S5 fff=f7f)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)3rrNrTrPrOrcrVrrYpopleftrrequests_countr isinstancerA_make_error_handlerERRORrZrrrrrrrConnectionErrorr_taskrboolrrMis_eofrUrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrHrbrRrSrr)r}rsrrrhrrErrwriterrxrcororrrnrend_ttrDrs r:rRequestHandler.startszz--""" 33$$000$$000###>>(#'#5#5#7DL,,&&#'DL#~~557 GIIKE  " "a ' "!$-F'8,,"&":":7"C"&"7"7 ++""@g&:&:4&@ GC N++GOL##w."<<TJD++D1D(,*KD NN#MN`!% >>)d.>NN#LM_#'t"7~~''%)%9%9N,,E~#iik # 4 &&-nn&6&63;+7 +D+D*1//*;$;$;,E+D'+iik '.nn&6&63;#>>++D4E4E'=> %%&;<!% >>)d.>NN#LMt{{4;L;L!YY[+<< 2</))1-1\\"D$;$;.D*]###b  !%D ~~)$$&*!Y'#'DLB#-&NN#KLl!% >>)d.>NN#LMu4,E$;,E+D+D+D!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLNN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sQA-X0$QQQCX"A U0Q-5Q*6Q-<UX+X/XA:U=-S*R;+S.SR>S SS/SAU B6XAXQ Q''X*Q--R8U XX$X7R88U;S>SSS S SSA*U  U U  U?W V5/W5WW,XXrc # UR5 URb_URRS5 SUlUR(a,URR UR5 SUlUR nU"U5IShvN UR!5IShvN UR%XU5 US4$![a UcURS5 O URSRU55 [5n[URURURURS9nUR nNf=fNN!["a UR%XU5 US4s$f=f7f)zPrepare 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. NFr9z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})rCreasontextheadersT)_finishr] set_upgradedr[rWrprepareAttributeErrorrrr$r'rCrrr write_eofrr)r}rrr prepare_methrDs r:rRequestHandler.finish_responsesU     +  - -e 4!DM!!$$..t/A/AB%(" (<FFFrCrEcFURS:Xa;[U[5(a&URR SUR US9 OUR SUR US9 URRS:a [S5eSnU[R:XaSR[R5n[RRnSnUR(a-[[5 [ R""5nSSS5 S UR$R'S S 5;a*U(a[)U5nS US 3nSRXgS9nS nOU(aUnUS-U-n[+X$US9n U R-5 U $!,(df  N=f)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 )rCr content_type)rLrrr_r`remoterr output_sizerrINTERNAL_SERVER_ERRORr descriptionrr traceback format_excrget html_escaper'r) r}rrCrDrEctrrtbrs r:rRequestHandler.handle_errors{   ! # 3 (F(F KK  0'..3     0'..3   >> % % )!)   Z55 5*11*2R2RSE22>>CBzzi("--/B)goo11(B??$RB6rd&AC0&u&.  !C&.3.v"E  -)(s =F F err_infoc4^^S[S[4UU4SjjnU$)Nrrcp># TRUTRTRTR5$7fr)rrCrDrE)rr(r}s r:handler3RequestHandler._make_error_handler..handlers0$$(,,8H8H s36)r&r()r}r(r+s`` r:r"RequestHandler._make_error_handlers" ; >   r9)rbrdrcrXrMrSrTrUrNrWrVrRr\rLrPrOrfr]rZrQrer[rYrarr`r_r)g.@)rN)rNN)6r3r4r5r6r7 __slots__rr%r LOG_FORMATrAbstractEventLooprzrrrrrIrFrwrpropertyrhr r BaseTransportrrHrr rrbytesrrrrr&r(rrrrr r rrrrrrArr8 __classcell__)r~s@r:r)r)es%NIJ$("&7C*!-!8!8! " $! $()'L*L*'' L* ! L*L*L*34L*L*L*L*L*L*L* !L*"#L*$%L*&!&'L*L*\ # '5''0huo00d")>)>"4""(8M#:(t(@%%% %%%D%N*d*t*""P"P.<PDIP P +s+#+$++3+c+d+")))";->1J"JK ) ~t# $ )VE'N("(*8(FK( ~t# $(Z'+!% <<<m $ < # <  <|  ;->!:: ;r9)Mrasyncio.streamsrr!r collectionsr contextlibrhtmlrr$httprloggingrtypingrr r r r r rrrrrattryarlabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__ web_serverr,_RequestFactory_RequestHandlerURLrrr*r+rsrA_MsgTyper)r1r9r:rOs\ &     ;'!+-0&B!$2 I"  K=)N*CCD   HHSM !)!88+,T$d34 ((23\A BS \S r9