+ TŎii^RIt^RIt^RIt^RIt^RIt^RIHt^RIHt^RI H t ^RI H t ^RIHt^RIHtHtHtHtHtHtHtHtHtHtHt^RIt^RIt^RIHt^R I H!t!H"t"^R I#H$t$^R I%H&t&^R I H't'H(t(H)t)H*t*H+t+^R I,H-t-^RI.H/t/H0t0^RI1H2t2H3t3^RI4H5t5^RI6H7t7H8t8^RI9H:t:^RI;Ht>H?t?R$t@]'d ^RIAtA^RIBHCtC]]*]3R]"R.]<3,tD]]<.]]?,3,tE]*!RR])//RRRR]P!R44 tG!RR]H4tI!RR]H4tJ]J!4tK]P!RRRR 7!R!R"44tM]]]*]M3,]33,tN!R#R]$4tOR#)%N)deque)suppress)escape) HTTPStatus)Logger) TYPE_CHECKINGAny AwaitableCallableDequeOptionalSequenceTupleTypeUnioncast)under_cached_property)AbstractAccessLoggerAbstractStreamWriter) BaseProtocol) ceil_timeout)HttpProcessingErrorHttpRequestParser HttpVersion10RawRequestMessage StreamWriter) BadHttpMethod) access_logger server_logger) EMPTY_PAYLOAD StreamReader) tcp_keepalive) HTTPExceptionHTTPInternalServerError) AccessLogger) BaseRequest)ResponseStreamResponseRequestHandlerRequestPayloadErrorPayloadAccessError)Serverzasyncio.Task[None]UNKNOWN/TFc]tRt^StRtRtR#)r*zPayload parsing error.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r0c/Users/ahmad/.openclaw/workspace/scripts/.venv/lib/python3.14/site-packages/aiohttp/web_protocol.pyr*r*Ss r8c]tRt^WtRtRtR#)r+z-Payload was accessed after response was sent.r0Nr1r0r8r9r+r+Ws7r8) auto_attribsfrozenslotsc,a]tRt^^toV3RltRtVtR#)_ErrInfoc><V^8dQh/S[;R&S[;R&S[;R&#)statusexcmessage)int BaseExceptionstr)format __classdict__s"r9 __annotate___ErrInfo.__annotate__^s( K L r8r0N)r2r3r4r5__annotate_func__r7__classdictcell__)rIs@r9r?r?^sr8r?cTaa]tRt^htoRtREtRRRRR]R ]R]R ]PRR R R RRRR RRRRFRRR^/V3RlV3Rlllt V3RlRlt ] V3RlRl4t ] V3RlRl4t]V3RlRl4tRGV3R lR!lltV3R"lV3R#lltV3R$lV3R%lltV3R&lR'ltV3R(lR)ltV3R*lR+ltV3R,lR-ltV3R.lR/ltV3R0lR1ltV3R2lR3ltV3R4lR5ltV3R6lR7ltV3R8lR9ltV3R:lR;ltV3R<lR=ltV3R>lR?lt RHV3R@lRAllt!V3RBlRClt"RDt#Vt$V;t%#)Ir)aHTTP 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 loggerdebug access_logkeepalive_timeouti.r"Taccess_log_classaccess_log_formatF max_line_sizei max_headersimax_field_sizelingering_timeg$@ read_bufsizeauto_decompresstimeout_ceil_thresholdc <V^8dQhRRRS[PRS[RS[RS[RS[S[,RS[R S[R S[R S[R S[R S[RS[RS[RS[RS[/#)rAmanagerr,looprRr"rOrSrQrTrPrUrVrWrXrYrZr[) asyncioAbstractEventLoopfloatboolrrrrGrE)rHrIs"r9rJRequestHandler.__annotate__sO)O)O)'' O) ! O)O)O)34O)O)O)O)O)O)O) !O)"#O)$%O)&!&'O)r8c <\SV`V4^VnRVnRVnWnVP VnVPVn W@n RVn RVn W0n \V 4Vn\!4VnRVnRVnRVnRVnRVnRVn\1VVVV V V \2VR7Vn^Vn\V4VnWPnWnWpn V'd*V!Wx4Vn!VPBPDVn#MRVn!RVn#RVn$RVn%RVn&/Vn'R# \8\:3dLi;i)rFNgr8)rUrWrVpayload_exceptionrZ)(super__init___request_count _keepalive_current_request_managerrequest_handler_request_handlerrequest_factory_request_factory_tcp_keepalive_next_keepalive_close_time_keepalive_handle_keepalive_timeoutra_lingering_timer _messages _message_tail_waiter_handler_waiter _task_handler_upgrade_payload_parserrr*_request_parser_timeout_ceil_threshold TypeError ValueErrorrOrPrQrenabled_logging_enabled_close _force_close_request_in_progress_cache)selfr]r^rRr"rOrSrQrTrPrUrVrWrXrYrZr[ __class__s&&$$$$$$$$$$$$$$$r9rgRequestHandler.__init__sp*  7;*1 ;B;R;R;B;R;R+*-';?"3$^4*/' 7; ?C;? $($>D !!%D $)D ! !$)!&( %:&   sEE('E(c <V^8dQhRS[/#rAreturn)rG)rHrIs"r9rJrcs  # r8cvRPVPPVPeR4#R4#)z<{} {}> connected disconnected)rHrr2 transportrs&r9__repr__RequestHandler.__repr__s; NN # #>>5K  ;I  r8c.<V^8dQhRS[R,/#)rArzssl.SSLContext)r )rHrIs"r9rJrc s  X&67 r8c XVPfR#VPPR4#)zReturn SSLContext if available.N sslcontextrget_extra_infors&r9 ssl_contextRequestHandler.ssl_contexts1 ~~%  ..|< r8c ~<V^8dQhRS[S[S[S[S[S[S[S[3,S[S[S[3,3,,/#r)r rrGrrE)rHrIs"r9rJrcs<  %U3S##56c3hGH I r8c XVPfR#VPPR4#)zReturn peername if available.Npeernamerrs&r9rRequestHandler.peernames1~~%  ..z: r8c <V^8dQhRS[/#r)ra)rHrIs"r9rJrcs''5'r8cVP#N)rsrs&r9rR RequestHandler.keepalive_timeouts&&&r8c4<V^8dQhRS[S[,RR/#)rAtimeoutrN)r ra)rHrIs"r9rJrc s00huo00r8c "RVnVPeVPP4VP'daVPP 4Vn\V4;_uu_4GRjxL VP GRjxL RRR4GRjxL \V4;_uu_4GRjxL VPe/VPP!\P!44VP"eIVP"P%4'g)\P&!VP"4GRjxL RRR4GRjxL TP"eTP"P4TP)4R#EL"ELEL +GRjxL 'giEL;i \P\P3dURTn\PR8d5\P!4;p'dTP4'dhELi;iELLL +GRjxL 'giL;i \P\P3dN\PR8d5\P!4;p'dTP4'dhELpi;i5i)zDo worker process exit preparations. We need to clean up everything and stop accepting requests. It is especially important for keep-alive connections. TN )rrrcancelr_loop create_futurerxrr_CancelledError TimeoutErrorsys version_info current_task cancellingrj_cancelrydoneshield force_close)rrtasks&& r9shutdownRequestHandler.shutdown s !  ! ! -  " " ) ) +  $ $ $$(::#;#;#=D  '000....10 #G,,,((4))11'2H2H2JK%%1$:L:L:Q:Q:S:S!..););<<< -,    )    % % ' =1.1000**G,@,@A '+$$$/!(!5!5!777)) - = -,,, &&(<(<=   G+$1133T3OO%%  sGAKK$G;F<G?F&F F& GF# G%I"<H?=I"A*I+#III I"II"#:KG F&#G&G ,F/- G 8G :G>KGAH<!H<7H<8K;H<<K?I"II"I I I I I"KI""AK9KKKKKc8<V^8dQhRS[PRR/#)rArrN)r_ BaseTransport)rHrIs"r9rJrcRs!"")>)>"4"r8c<\SV`V4\\PV4pVP 'd \ V4VPfQhVPPW4VPp\PR8d)\P!VP4VRR7pMVPVP44pW@nR#)NTr^ eager_startr )rfconnection_maderr_ Transportrpr"rkrrrTaskstart create_taskry)rrreal_transportr^rrs&& r9rRequestHandler.connection_madeRs  *g//;     . )}}((( %%d;zz   w &<< 4TJD##DJJL1D!r8c4<V^8dQhRS[S[,RR/#)rArCrN)r rF)rHrIs"r9rJrccs ((8M#:(t(r8c<VPfR#VPPW4VPPpVP4\SV`V4RVnRVnRVnRVnVPeVPP4VPe+Vf \R4pVPPV4V'd)VPeVPP4RVn VPe$VPP4RVnR#R#)NzConnection lost)rkconnection_losthandler_cancellationrrfrormr|rrrrjConnectionResetErrorrryr{feed_eof)rrCrrs&& r9rRequestHandler.connection_lostcs  ==  %%d0 $}}AA  $ $ $#  ! ! -  " " ) ) +  ,{*+<=  ! ! ) )# . D$6$6$B    % % '!    +  ) ) +#'D  ,r8c$<V^8dQhRS[RR/#)rAparserrNr )rHrIs"r9rJrcs%%%%r8cVPeQhWnVP'd/VPPVP4RVnR#R#)Nr8)r{rv feed_data)rrs&&r9 set_parserRequestHandler.set_parsersM##+++%      * *4+=+= >!$D  r8c<V^8dQhRR/#rArNr0)rHrIs"r9rJrcs  d r8cR#rr0rs&r9 eof_receivedRequestHandler.eof_receiveds r8c$<V^8dQhRS[RR/#)rAdatarN)bytes)rHrIs"r9rJrcs%%%%D%r8cVP'gVP'dR#VPfVP'gVPfQhVPP V4wr#pT;'gRF:wrgV;P^, un VPPWg34K< VPpV'd,Ve(VP4'gVPR4W0nV'dV'd W@nR#R#R#VPf6VP'd$V'dV;P V, unR#V'd:VPP V4wrV 'dVP#4R#R#R# \ d.p\RYUPR7\3.pRpRpRp?ELdRp?ii;i)Ni)rBrCrDFr8r0)rrr{rzr|rrr?rDr rhruappendrwr set_resultrvclose) rrmessagesupgradedtailrCmsgpayloadwaitereofs && r9 data_receivedRequestHandler.data_receivedsr         ' ''3 33 +/+?+?+I+I$+O(D!)B ##q(#%%sn5!/\\FF.v{{}}!!$'$MD%)"!x ! ! )dmmm   $ & ,,66t> % NN "!DN &r8c@<V^8dQhRS[RS[RS[S[,RR/#)rArequestresponsetimerN)r&r(r ra)rHrIs"r9rJrcs7PP"P.<PDLUOP Pr8cVP'd`VPeP\'dVfQhVPPWVPP 4V, 4R#R#R#r)rrrlogrr)rrrrs&&&&r9 log_accessRequestHandler.log_accesss[  T%7%7%C}'''    " "7djjoo6G$6N O&D r8c*<V^8dQhRS[RS[RR/#rAargskwrNr)rHrIs"r9rJrcs"++s+#+$+r8cfVP'dVPP!V/VBR#R#r)rPrOrrrs&*,r9 log_debugRequestHandler.log_debugs' ::: KK  t *r * r8c*<V^8dQhRS[RS[RR/#rr)rHrIs"r9rJrcs"++3+c+d+r8c>VPP!V/VBR#r)rO exceptionrs&*,r9 log_exceptionRequestHandler.log_exceptions t*r*r8c<V^8dQhRR/#rr0)rHrIs"r9rJrcsDr8cRVnVP'gVP'gR#VPpVP 4pVP pW#8d#VP W0P4VnR#VP'd5VPP4'gVP4R#R#R#r) rrrrirrrqcall_at_process_keepaliverwrr)rr^now close_times& r9r !RequestHandler._process_keepalives!%    DOOO zziik44  %)\\*>U>U%VD "  <<< 1 1 3 3    !41J"JK ) ~t# $ )r8c"RVnWnV!V4GRjxL pRVn\VRR4'd\P!R\ 4VP WV4GRjxL wrERTnTPeTPPR4YE3#L RTni;iLG \d*pTpTP YT4GRjxL wrERp?LrRp?i\Pdh\PdMpTPRTR7TPTR4pTP YT4GRjxL wrERp?LRp?i\d<pTPTRT4pTP YT4GRjxL wrERp?EL*Rp?ii;i RTnTPeTPPR4ii;i5i) TN__http_exception__Fzlreturning HTTPException object is deprecated (#2415) and will be removed, please raise the exception insteadzRequest handler timed out.exc_infoi)rrjgetattrwarningswarnDeprecationWarningfinish_responser#r_rrr handle_error Exceptionrxr)rrrrlrespresetrCs&&&& r9_handle_requestRequestHandler._handle_requests %)! 6 -(/%,W55(,%t1599 9' !% 4 4WJ OOKD(-D %##/$$//5{?6(,%.P- PD $ 4 4WJ OOOKD%%%  ## P NN7#N F$$Wc2D $ 4 4WJ OOOKD% P$$Wc37D $ 4 4WJ OOOKD% P).D %##/$$//50sGB)B'B)B7AF&-B5.F&43G'B)) B22B75F&7 F#C&CC&!F&&F#=F#F#:E EEF& F#'F#((FFFF&F##F&&3GGc<V^8dQhRR/#rr0)rHrIs"r9rJrcsG'G'TG'r8c v "VPpVPpVfQhVPpRpVPfQhVPfQhVP 'EgVP 'g2VP4VnVPGRjxL RVnVP P4wrVVP'dVP4MRpV;P^, un \W4p\V\4'dVP!V4p \"pM VPp TPTTTTVP$;'g\&P(!V44p VP+WV 4p \,P.R 8d\&P0!WRR7p MVP3V 4p V GRjxL wrM? T 'dATP7R4RT nTP:Ef'TEe"TP7R4EM\=TP>4Tn TPC4'EgTPDpTP 'gT'dTP7RT4TP4pY,pTPC4'geTT8d^\GTT, 4;_uu_4GRjxL TPI4GRjxL RRR4GRjxL TP4pKzTPC4'g4TP 'g"TP7R4TPQ4TPS\T4RT nTP:fTeTP7R4TP@'dxTP^'gfTP 'gTTP4T,pTTn0TPbf%TPeTTPf4Tn1EKEKVP 'g4RVnVP:eVP:PQ4R#R#R#EL RTni;iEL \4dDTP7R4RT nTP:eKTfKTP7R4Ki;iELELEL +GRjxL 'giEL;i \&PJ\&PL3dN\,P.R 8d5\&P(!4;p'dTPO4'dhELSi;i \&PJd$TP7R4TPW4h\Xd/pTP[R TR 7TPW4Rp?ELcRp?i\\dTPW4hi;i RT nTP:fTeTP7R4iii;i5i) 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. NTrz&Ignored premature client disconnectionz'Ignored premature client disconnection.z(Ignored premature client disconnection 2z'Start lingering close timer for %s sec.zUncompleted request.zUnhandled exceptionrrr)4rrkrsrormrrurrwpopleftrrrequests_countr isinstancer?_make_error_handlerERRORryr_rr rrrrConnectionErrorr_taskrrbrriis_eofrtrreadanyrrrr set_exception_PAYLOAD_ACCESS_ERRORrrrrFrrqrrr r )rr^r]rRrrDrrwriterrlrcororrrXr end_ttrCrs& r9rRequestHandler.startszz--""" 33$$000$$000###>>>(#'#5#5#7DL,,&&#'DL#~~557 G$(#8#8#8DIIKdE  " "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+D*1//*;$;$;,E+D'+iik#>>++D4E4E4E'=> %%&;<!% >>)d.>NN#LMt{{{4;L;L;L!YY[+<< 2</))1-1\\"D$;$;.D*2    !%D ~~)$$&*!]'#'DLF#-&NN#KLl!% >>)d.>NN#LMu4,E$;,E+D+D+D!( 6 68L8LM& # 0 0G ;*1*>*>*@%@Q%@$%LLNN % &)) GH  " #""#83"G  ""    " !% >>)d.>NN#LM/?)sAX9"X95$RQ=RCX9%X9AU;RR RU;(U;:X9X9X9(AU;7U;?*U;*T%T%S &T)S)=S#>S) T S&T$U;:U; 6U;;X9>X9X9"A%X95X9=R R  X9 RS+U;,X9X9 X9SU; T#S)&T)T /S20 T ;T = TAU8U83U84U;7U88U;;?X;X<#W%X% X2XX.X66X9c X<V^8dQhRS[RS[RS[S[,RS[S[S[3,/#)rArrrr)r&r(r rarrb)rHrIs"r9rJrcs;(("(*8(FNuo( ~t# $(r8c "VP4VPeaVPPR4RVnVP'd-VPP VP4RVnVP pV!V4GRjxL VP!4GRjxL TP%YT4TR3# \dTfTPR4M TPRPT44\4p\TPTPTPTPR7pTP pLi;iLL \"dTP%YT4TR3u#i;i5i)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. NFr8z+Missing return statement on request handlerz7Web-handler should return a response instance, got {!r})rBreasontextheadersT)_finishr| set_upgradedrzrvrprepareAttributeErrorrrHr$r'rBr6r7r8 write_eofr)r)rrrr prepare_methrCs&&&& r9rRequestHandler.finish_responsesX     +  - -e 4!DM!!!$$..t/A/AB%(" (<Traceback: 
z
zV{title}

{title}

{msg} )titlerz )rBr7 content_type)rhr&rrOrPremoterr/ output_sizer)rINTERNAL_SERVER_ERRORrH descriptionrr traceback format_excr8get html_escaper'r) rrrBrCrDctrDrtbrs &&&&& r9rRequestHandler.handle_errors   ! # 3 (F(F KK  0'..3     0'..3   >> % % )!)   Z55 5*11*2R2RSE22>>CBzzzi(("--/B)goo11(B??$RB6rd&AC0&u&.  !C&.3.v"E  -)(s F66 G cN<V^8dQhRS[RS[S[.S[S[,3,/#)rAerr_infor)r?r r&r r()rHrIs"r9rJrcs.  ;->!:: ;r8caaRVV3RllpV#)c0V^8dQhR\R\/#)rArr)r&r()rHs"r9rJ8RequestHandler._make_error_handler..__annotate__s  ; > r8cp<"SPVSPSPSP4#5ir)rrBrCrD)rrRrs&r9handler3RequestHandler._make_error_handler..handlers0$$(,,8H8H s36r0)rrRrWsff r9r'"RequestHandler._make_error_handlers   r8)rrrjrrxrirrrsrtrrkrvrurqr{rhrormrr|ryrpr}rzrwrQrrPrOr)rhrirkrmrorprqrrrsrtrurvrxrwryrzr{r|_reading_pausedrOrPrQrrrrjr}rrri)g.@)rNN)&r2r3r4r5r6 __slots__rr%r LOG_FORMATrgrrrrpropertyrRrrrrrrrrrrrrr r rrrr'r7rM __classcell__)rrIs@@r9r)r)hs%NIBO) $( O)#O)'O)8DO)+O)".!8!8O)O)"O)!O)#O) !%!O)""#O)$!%%O)&)*'O)O)b      ''00d"""((@%%  %%N**""""PP++++"))VG'G'R((T<<|r8)r)r*r+)Pr_asyncio.streamsrrJr collectionsr contextlibrhtmlrrMhttprloggingrtypingrr r r r r rrrrrattryarl propcacherabcrr base_protocolrhelpersrrrrrrhttp_exceptionsrrrrstreamsr r! tcp_helpersr"web_exceptionsr#r$web_logr% web_requestr& web_responser'r(__all__ssl web_serverr,_RequestFactory_RequestHandlerURLr(rr*r+r.sr?_MsgTyper)r0r8r9r{sb &     +;'!+-0&B!$2 I"  K=)N*CCD   HHSM !)!88+,T$d34 ((23\A Bp \p r8