ڊj:dZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZddlmZddlmZddlmZGd d Zd Zd ZiZd ZdadaedDcic]}||ddj=dc}ZdZ GddZ!dZ"dZ#GddZ$GddZ%GddejLZ'ycc}w)z ASGI protocol handler for gunicorn. Implements asyncio.Protocol to handle HTTP/1.x and HTTP/2 connections and dispatch to ASGI applications. N) AsyncUnreader)PythonProtocolCallbackRequest ParseErrorLimitRequestLineLimitRequestHeadersInvalidChunkExtension)AsyncUWSGIRequest) NoMoreData) negotiation)UWSGIParseExceptionceZdZdZdZdZy) _RequestTimezLightweight request time container compatible with logging atoms. Uses time.monotonic() elapsed seconds instead of datetime.now() syscalls. Provides .seconds and .microseconds attributes for glogging.py compatibility. )seconds microsecondscdt||_t||jz dz|_y)Ni@B)intrr)selfelapseds [/var/www/io.vulcan-creative.com/venv/lib/python3.12/site-packages/gunicorn/asgi/protocol.py__init__z_RequestTime.__init__%s(7| 4< A  A sServer: gunicorn/asgi rgi@x latin-1ic8eZdZdZdZdZdZdZdZdZ dZ y ) FlowControlzManage transport-level write flow control. Blocks send() when transport buffer exceeds high water mark, preventing memory issues with large streaming responses. ) _transport read_paused write_paused_is_writable_eventc||_d|_d|_tj|_|j j yNF)r5r6r7asyncioEventr8set)r transports rrzFlowControl.__init__^s9# !")--/ ##%rcTK|jjd{y7w)z!Wait until transport is writable.N)r8waitrs rdrainzFlowControl.draines%%**,,,s (&(c`|js"d|_|jjyyNT)r6r5 pause_readingrAs rrEzFlowControl.pause_readingis(#D  OO ) ) + rc`|jr"d|_|jjyyr:)r6r5resume_readingrAs rrGzFlowControl.resume_readingns(   $D  OO * * , rc`|js"d|_|jjyyrD)r7r8clearrAs r pause_writingzFlowControl.pause_writingss*  $D   # # ) ) +!rc`|jr"d|_|jjyyr:)r7r8r=rAs rresume_writingzFlowControl.resume_writingxs*    %D   # # ' ' ) rN) rrrrrrrBrErGrJrLrrrr4r4Vs- TI&-, - , *rr4ctj}|tz dk\r$ddlm}d|ddj da|at S) z1Get cached Date header, updating once per second.?r) formatdatezDate: T)usegmtr1r2)time_cached_date_time email.utilsrOencode_cached_date_header)nowrOs r_get_cached_date_headerrW~sL ))+C #%* &z'>&?tDKKIV rc ||f}|tvr-d|dd|dd|d|d }|jdt|<t|S)zGet cached status line bytes.HTTP/r. r1r2)_CACHED_STATUS_LINESrT)versionstatusreasonkeylines r_get_cached_status_linercs\ F C &&wqzl!GAJ    #  "' rc`|r,|jj||jyy)z7Feed a body chunk directly (called by parser callback).N)rprk _wake_waiterrchunks rfeedzBodyReceiver.feeds(  LL   &     rc2d|_|jy)z1Mark body as complete (called when message ends).TN)rqrzrAs r set_completezBodyReceiver.set_completes rc2d|_|jy)z/Signal that the client transport has gone away.TN)rsrzrAs rsignal_disconnectzBodyReceiver.signal_disconnects  rc6|jxs |jS)z?True when the receiver should yield http.disconnect to the app.)rsrtrAs r _disconnectedzBodyReceiver._disconnecteds||6t666rc|j7|jjs|jjdyyy)z#Wake up any pending receive() call.N)rudone set_resultrAs rrzzBodyReceiver._wake_waiters6 << #DLL,=,=,? LL # #D )-@ #rcK|jrddiS|jr|jd{ddiS|jr|j S|j r d|_ddddS|j jd k(r*|j jsd|_d|_ddddS|jjr d|_ ddiS|jd{|jS77w) z:ASGI receive callable - returns body chunks or disconnect.typehttp.disconnectNT http.requestrFrbody more_bodyr) rrr_wait_for_disconnectrp _pop_chunkrqrvcontent_lengthchunkedrwrs_wait_for_data_build_receive_resultrAs rreceivezBodyReceiver.receives   -. .   ++- - --. . <<??$ $ >>"&D *CeL L << & &! +DLL4H4H!DN"&D *CeL L == DL-. . !!###))++9 .6 $s"0DC<B4D'C>(D>Dc|jjd}t|jxs |j }|sd|_d||dS)z/Pop a chunk and return the appropriate message.rTrr)rppopboolrqrr)rr|mores rrzBodyReceiver._pop_chunksH   #DLL!7%7"&D &DIIrc|jrddiS|jr|jS|jr d|_ddddSd|_ddiS)z,Build receive result after waiting for data.rrTrrFr)rrprrqrrrtrAs rrz"BodyReceiver._build_receive_results]   -. . <<??$ $ >>"&D *CeL L #')**rcK|js|js |jrytj}|j |_t|jdd}| t|ddnd}|r|dkrd} tj|j |d{d|_y7 #tj$r d|_ Y&wxYw#d|_wxYww)z*Wait for body data to arrive via callback.Ncfgtimeoutr>@rT) rprqrr;get_event_loop create_futurerugetattrrwwait_for TimeoutErrorrt)rlooprrs rrzBodyReceiver._wait_for_datas <<4>>T-?-? %%'))+ dmmUD136?'#y$/'Q,G ""4<<A A A DL B## + '+D #  + DLsHBC"$B6'B4(B6,C"4B66CCCC CC"c$K|jry|jjrd|_ytj}|j |_ |j d{d|_d|_y7#d|_d|_wxYww)zWait for connection to close after body is finished. This is needed for ASGI apps (like Django) that call receive() to listen for client disconnect after the request body is consumed. NT)rsrwr;rrru)rrs rrz!BodyReceiver._wait_for_disconnect4s <<  == DL %%'))+  ,,  DLDL DLDLs0ABA='A;(A=,B;A==B  BN)rrrrrrr}rrpropertyrrzrrrrrrrrrorosW II    77* %,NJ+$ : rroceZdZdZdZdZdZdZdZdZ dZ dZ d9dZ e dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&d Z'd!Z(d"Z)d#Z*d$Z+d%Z,d&Z-d'Z.d(Z/d)Z0d*Z1d+Z2e3d,Z4e3d-Z5e d.Z6d:d/Z7d0Z8d1Z9d2Z:d;d3Z;d4Zd7Z?d8Z@y)< ASGIProtocolzHTTP/1.1 protocol handler for ASGI applications. Handles connection lifecycle, request parsing, and ASGI app invocation. Uses callback-based parsing (H1CProtocol/PythonProtocol) for efficient incremental parsing in data_received(). NFc||_|j|_|j|_|j|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_d|_y)NFri)workerrlogasgiappr>reader _h2c_buffer _h2c_timer_h2c_upgrade_ok_h2c_upgrade_settings_h2c_upgrade_bodywriter_task req_countrs_conn_lost_handled_body_receiver_response_buffer_reading_paused_max_buffer_size_keepalive_handle_callback_parser_request_ready_current_request_is_ssl _flow_control _websocket)rrs rrzASGIProtocol.__init__cs ::::;;   %%)"!%   #("!% % )"&!%" $ "rcL||_|jxjdz c_|jd}|rut |dri|j }|dk(rTt j|_|jjj|j|||_ y|jd}tj|j|rd|_||_t%||_|j)t*d |_|jjj/tj0|j2|_y|du|_||_t%||_|j)t*|j7y) z(Called when a connection is established.r[ ssl_objectselected_alpn_protocolh2NpeernameF)highr)r>rnr_connsget_extra_infohasattrrr; StreamReaderrr create_task_handle_http2_connectionrr prior_knowledge_allowedrrrr4rset_write_buffer_limitsHIGH_WATER_LIMITr call_laterH2C_PREFACE_TIMEOUT_h2c_undecided_timeoutr _start_http1)rr>ralpnrs rconnection_madezASGIProtocol.connection_madesb" !--l; '*.FG446Dt|%224 ![[--9911)ZH ++J7  . .txx B!DL#DK!,Y!7D   - -3C - D"D "kk..99//1L1LDO "-  )3))/?)@ rctj|_|j|jj d}t j|j|xrt|jd|_ |jjj|j|_|r|j#|yy)zCommit to HTTP/1.x and replay anything already read. Called straight from connection_made(), and again when h2c sniffing gives up on a connection that turned out to speak HTTP/1 after all. r remainingN)r;r<r_setup_callback_parserr>rr upgrade_allowedrrrrrrr_handle_connectionr_feed_callback_parser)rbufferedrs rrzASGIProtocol._start_http1s &mmo ##%>>00<  ' '( ; <--{; [[%%11$2I2I2KL   & &x 0 rcZ|jl ddl}ddlm}d|_||_t |d|_t |dd|_t |dd|_t |dd|_ |jS|jS#t$rd|_d|_Y|jSwxYw) z:Check if H1CProtocol is available (cached at class level).Nr) H1CProtocolTrrr F) _h1c_available gunicorn_h1cr_h1c_protocol_classr_h1c_has_limitsr_h1c_limit_request_line_h1c_limit_request_headers_h1c_invalid_chunk_extension ImportError)clsrrs r_check_h1c_protocol_availablez*ASGIProtocol._check_h1c_protocol_availables    % ,#4%)"*5'&-l= 0.4.1) and no incompatible flags, else PythonProtocol - fast: Require H1CProtocol >= 0.4.1 (error if unavailable or incompatible flags) - python: Use PythonProtocol only http_parserautoFproxy_protocoloffpythonfastz,gunicorn_h1c required for http_parser='fast'zigunicorn_h1c >= 0.4.1 required for http_parser='fast'. Please upgrade: pip install --upgrade gunicorn_h1czqhttp_parser='fast' is incompatible with compatibility flags: %s. Use http_parser='python' or disable these flags.z, ri)on_headers_completeon_bodyon_message_completelimit_request_linelimit_request_fieldslimit_request_field_size!permit_unconventional_http_method"permit_unconventional_http_versionrNr)rr_FAST_PARSER_INCOMPATIBLE_FLAGSrkrr RuntimeErrorrrjoinrr_on_headers_complete_on_body_on_message_completerrrrr>rr#r/proxy_allow_ipsproxy_allow_networksr) rparser_setting incompatibleflag parser_classr parser_kwargs cfg_proxyr normalizedtrusteds rrz#ASGIProtocol._setup_callback_parsers:!=&A 88 *Dtxxu-##D) * 488-u 5 >    0 1 X %)L v %557"#QRR//"I"Gii -. (;;L224 00+?? - "XX88  "|~'E!,  $(#<#<}}#'#<#<"4$(HH$A$A(,(I(I151[1[26((2]2]   > )  *:EBIE!>>88D0: .HH,,HH113 @G)E ./27 ./ , =} =rctj|j|j|_t |j||_|jr@tj|j|_ |jt|_ y|jr|jj|jjdk(S)z'Callback: request headers are complete.)is_sslFsHEAD)r from_parserrrrrorrr upgrade_settingsr bytearrayrrr=methodrAs rrz!ASGIProtocol._on_headers_completeHs!0 ; ;  ! !$,,!  +4+@+@$G   )4)E)E%%*'D &))5*3&       # # %$$++w66rc|j|xj|z c_y|jr|jj|yy)z#Callback: received body data chunk.N)rrr}r{s rrzASGIProtocol._on_bodycsF  ! ! -  " "e + "        $ $U + rcR|jr|jjyy)z$Callback: request is fully received.N)rrrAs rrz!ASGIProtocol._on_message_completens"       , , . rctj}|8t||r,|jdt ||j ytj }|8t||r,|jdt ||j ytj}|8t||r,|jdt ||j yy)zHandle gunicorn_h1c exceptions with appropriate HTTP status codes. Returns True if the exception was handled, False otherwise. TF)rrr&_send_error_responsestr_close_transportrr)rexch1c_limit_lineh1c_limit_headers h1c_chunk_exts r_handle_h1c_exceptionz"ASGIProtocol._handle_h1c_exceptionss &==  %*S.*I  % %c3s8 4  ! ! #(CC  (Z=N-O  % %c3s8 4  ! ! #$AA  $C)G  % %c3s8 4  ! ! #rcx|jr|jj|y|j|j|y|jr|jj|n|j r|j |sy|js"|jr|jyyy)z/Called when data is received on the connection.N) r feed_datar _h2c_feedrrrr_is_buffer_full_pause_reading)rdatas r data_receivedzASGIProtocol.data_receiveds ?? OO % %d +     ' NN4  ;; KK ! !$ '  " "--d3##(<(<(>    !)?#rc|xj|z c_tj|j}|tjury|jdc}|_|j |tj ur|j |ytj|jr#|jdd|jy|j|y)z7Accumulate bytes until the connection preface resolves.Nr!Invalid HTTP/2 connection preface) rr preface_matchPARTIAL_h2c_cancel_timerMATCH _h2c_startmismatch_is_errorrrrr)rr%staters rr"zASGIProtocol._h2c_feeds D ))$*:*:; K'' ' %)%5%5t"$"  K%% % OOH %   ( ( 2  % %c+N O  ! ! #  (#rctj|_|jjj |j |jd|_|jj|y)z;Commit to HTTP/2 and replay the bytes read while undecided.N) r;rrrrrrr>rr!rrs rr-zASGIProtocol._h2c_startsV**, [[%%11  ) )$..$ ?   h'rcd|_|jy|jdc}|_tj|js|j |y|j dd|jy)a:Nothing conclusive arrived in time. With prior knowledge alone the peer is expected to speak HTTP/2, so stalling mid-preface is refused rather than downgraded. Where an upgrade is also on offer, a quiet client is just a quiet client and the ordinary HTTP/1 timeouts apply. Nrr()rrr r.rrrrr1s rrz#ASGIProtocol._h2c_undecided_timeoutso    # %)%5%5t"$",,TXX6   h '  !!#'JK rc`|j"|jjd|_yyN)rcancelrAs rr+zASGIProtocol._h2c_cancel_timers( ?? & OO " " $"DO 'rc8 |jj||j|jSy#t$r5}|j dt ||jYd}~yd}~wt$r5}|j dt ||jYd}~yd}~wttf$r5}|j dt ||jYd}~yd}~wt$r}|j|rYd}~yd}~wwxYw)zFeed data to callback parser, handling parse errors. Returns True if parsing should continue, False if connection was closed. NTrFrr) rr}r_h2c_arm_upgraderrrrrr r Exceptionrrr%es rrz"ASGIProtocol._feed_callback_parsers    ! ! & &t ,))5,,..   % %c3q6 2  ! ! #"   % %c3q6 2  ! ! #%z2   % %c3q6 2  ! ! # ))!,   s?6: D+A33 D?+B//D+C11 D=DDDc|j}|jsy|jrKd|_d|_|j dd|j |jjy|j}d|_tj|_ |r|jj||jjy)aHand the connection over to HTTP/2 once the request is complete. Runs synchronously, inside data_received(), because that is what stops the connection preface and the frames behind it from reaching the HTTP/1 parser. Installing the reader here also gives later data_received() calls somewhere to land while the connection loop is still waking up. Returns True to keep feeding HTTP/1, as _feed_callback_parser does. TNrzUpgrade request tail too largeF)r is_completeremaining_truncatedrrrrrr=rr;rrr!)rparserpendings rr7zASGIProtocol._h2c_arm_upgrades&&!!  % %*.D &%)D "  % %c+K L  ! ! #    # # %""$ $**,  KK ! !' * !rc|jrBt|jdr,t|jj|jkDSy)z/Check if internal buffer is full (HTTP/2 only)._bufferF)rrlenrArrAs rr#zASGIProtocol._is_buffer_fulls9 ;;74;; :t{{**+d.C.CC Crc|js0|jr#d|_ |jjyyy#ttf$rYywxYw)z1Pause reading from transport due to backpressure.TN)rr>rEAttributeErrorrrAs rr$zASGIProtocol._pause_readingsO###'D  ,,.)7##L1  >AAc|jr0|jr#d|_ |jjyyy#ttf$rYywxYw)zResume reading from transport.FN)rr>rGrDrrAs r_resume_readingzASGIProtocol._resume_reading!sO   DNN#(D  --/%3 #L1  rEc|jr|jj|jj}|dkDr6|jj j ||j|_yy)z6Arm keepalive timeout timer after response completion.rN)rr5r keepaliverrr_keepalive_timeout)rkeepalive_timeouts r_arm_keepalive_timerz!ASGIProtocol._arm_keepalive_timer*sb  ! !  " " ) ) + HH.. q %)[[%5%5%@%@!4#:#:&D " !rc`|jr"|jjd|_yy)z0Cancel keepalive timer when new request arrives.N)rr5rAs r_cancel_keepalive_timerz$ASGIProtocol._cancel_keepalive_timer4s*  ! !  " " ) ) +%)D " "rc$|jy)z&Called when keepalive timeout expires.N)rrAs rrJzASGIProtocol._keepalive_timeout:s rc|jryd|_d|_d|_|j|jxj dzc_|j |jr|jj|jr|jj|j|jj|jr|jjsht|jdd}|dkDr1|jj j#||j$y|jj'yyy)aCalled when the connection is lost or closed. Instead of immediately cancelling the task, we signal a disconnect event and send an http.disconnect message to the receive queue. This allows the ASGI app to clean up resources (like database connections) gracefully before the task is cancelled. See: https://github.com/benoitc/gunicorn/issues/3484 NTr[asgi_disconnect_grace_periodr)rrsrr+rrrNrfeed_eofrrrrrrrrr_cancel_task_if_pendingr5)rr grace_periods rconnection_lostzASGIProtocol.connection_lost>s  " " "&    ! $$& ;; KK " ?? OO $ $ &    *    1 1 3 ::djjoo/"488-KQOLa   ++ 00  !!#0:rc|jr6|jjs|jjyyy)z9Cancel the task if it's still pending after grace period.N)rrr5rAs rrTz$ASGIProtocol._cancel_task_if_pendingps- ::djjoo/ JJ   0:rcR|jr|jjyy)z>Called by transport when write buffer exceeds high water mark.N)rrJrAs rrJzASGIProtocol.pause_writingus"       , , . rcR|jr|jjyy)zBCalled by transport when write buffer drains below low water mark.N)rrLrAs rrLzASGIProtocol.resume_writingzs"       - - / rc> |jj|y#t$re}|jtjtj tj fvr |jjdYd}~yYd}~yd}~wttf$rYywxYw)axWrite data to transport, handling connection errors gracefully. Catches exceptions that occur when the client has disconnected: - OSError with errno EPIPE, ECONNRESET, ENOTCONN - RuntimeError when transport is closing/closed - AttributeError when transport is None These are silently ignored since the client is already gone. zSocket error writing response.N) r>writeOSErrorerrnoEPIPE ECONNRESETENOTCONNr exceptionrrDr9s r _safe_writezASGIProtocol._safe_writesw  NN  & Ewwu{{E,<,r|j>jAd|_d|_|jjC|jE|j sJ|j y77#tj$rY,wxYw777|#tj$rYNtF$r&}|j0jId |Yd}~wd}~wwxYw#|j wxYww) aBMain request handling loop using callback-based parser. Uses synchronous parsing in data_received(), avoiding the async overhead of pull-based parsing. The parser fires callbacks when headers and body data are available, and this loop waits on events rather than actively parsing. rsocknamerwhttpuwsgiNr[,Autorestarting worker after current request.FzError handling connection: %s)%r>rrr_handle_connection_uwsgirrsrrNris_setr@r;CancelledErrorr_effective_peernamer_handle_h2c_upgrade_is_websocket_upgrade_handle_websocket_handle_http_requestrnr max_requestsrinfoaliverIrrqrGrresetrIrLr8ra) rrrd protocol_typerveffective_peerrIreceiverr:s rrzASGIProtocol._handle_connections[ $~~44Z@H~~44Z@H$DHHj&AM'33HhGGGf  ! ! #cll!#,,.**113"1166888<<4#8#8#@//"&!9!9(!C--9227;;;--g600(NSSS#'";";X~#  !#;;>>T[[%=%==HHMM"PQ(-DKK% %I  (9(9xx)) ..'0B0B$$&(())//1)-%&*###))+))+Ullb  ! ! #iH9"11< TZ%%   C HH  > B B C  ! ! #sM-A'L+K*,L1M-A LK0,K--K01ALL  -L6L 7LLELM-*L-K00LLLL LLM%M'M/M MMMM**M-cKt|j}|jsc|xjdz c_ t j |j |||jd{}|j|r|j|||d{y|j|||d{}|jxjdz c_|jj|jj k\r.|jj#dd|j_d}|r|jj$sy|j j&sy|j)d{|jsbyy7#t$rYyt$r&}|jjd|Yd}~yd}~wwxYw7277Yw)z0Handle uWSGI protocol connections (legacy path).r[NzuWSGI parse error: %srgF)rrrsrr parserr r rdebugrmrnrorrprqrrrsrI drain_body)rrrdunreaderrvr:rIs rrhz%ASGIProtocol._handle_connection_uwsgisz -,, NNa N  1 7 7HHNN !))'2,,WhIII#778I KKNNa N{{~~!9!99 LM$) !! DKK$5$588%%$$& & &S,,  & 6:  J& 's8G/F *F +F /'GGG2G 3CG4G5GG F GGGG;GGG GGcK|j}t|jxsd}d|_d|_|jj t j |j|jd|||fd{y7w)zServe an Upgrade: h2c request over HTTP/2. The 101 goes out here rather than in _h2c_arm_upgrade so that nothing can write between it and the SETTINGS frame the HTTP/2 handler sends. rN)upgrade)rrirr>r[r UPGRADE_101r)rrvsettingsrs rrlz ASGIProtocol._handle_h2c_upgrade&s --T++2s3%)"!% [445++ NND8Wd*C,   sBB B B c|jdk7ryd}d}|jD]1\}}|dk(r|j}|dk(s"|j}3|dk(xr|xrd|vS)a Check if request is a WebSocket upgrade. Per RFC 6455 Section 4.1, the opening handshake requires: - HTTP method MUST be GET - Upgrade header MUST be "websocket" (case-insensitive) - Connection header MUST contain "Upgrade" GETFNUPGRADE CONNECTION websocketr~)rrhlower)rrvr~ connectionrlrms rrmz"ASGIProtocol._is_websocket_upgrade5sv >>U " "?? +KD%y ++-%"[[]  + +%P*Pj9PPrcKddlm}d|_|j|||}||j||j |j }||_|jd{y7w)z!Handle WebSocket upgrade request.r)WebSocketProtocolN) gunicorn.asgi.websocketrr_build_websocket_scoper>rrrrun)rrvrdrrscope ws_protocols rrnzASGIProtocol._handle_websocketJs_=!%++GXxH' NNE488TXX &oosA$A.&A,'A.c 8  Kj||}ddd dd dd_dgdj} f d}jj} t j }jjjj||j|d{  sjddd t!t j |z } |r?j#||} t%} jj'| | | nd} d} jj)j| | j/ryjj0xrjj2S7#tj$rjjdY t!t j z } |r?j#||} t%} jj'| | | nd} d} jj)j| | y#t*$rjj-dYywxYwt*$r rjjd n1jj-d sjdddY t!t j z } |r?j#||} t%} jj'| | | nd} d} jj)j| | y#t*$rjj-dYywxYwwxYw#t*$rjj-dYfwxYw# t!t j z } |r?j#||} t%} jj'| | | nd} d} jj)j| | w#t*$rjj-dYwwxYwxYww) zHandle a single HTTP request.FNrcH Kjry|d}|dk(r7|jd}|jdg}j||y|dk(rr td yd|d|jdgd}d}D]E\}}t |t r|j n|j }|d vrd}=|d vsBd}dGjj r-|s|r)jjrd}d}d| xr| xrjd k\xr } | rdtd gzjy|d k(r<s td yr td y|jdd} |jdd} r/| r+s)jjdjdd} | rOj!| t#| z j$r"j$j'd{| swrDj(r&j+j(dzd_n@j+dn.j(r"j+j(d_dyyy7w)Nrhttp.response.informationalr_rhhttp.response.startResponse already startedTF)content-lengthcontent-length)transfer-encodingtransfer-encodingr[r[)rschunkedhttp.response.bodyResponse not startedResponse already completerrr\ASGI app sent body bytes on a no-body response (method=%s status=%s); dropping per RFC 9110.)rs0 )rsget_send_informationalrr&rr_response_omits_bodyr_strip_body_framing_headers _response_forbids_content_lengthr^list_send_response_startrwarning _send_bodyrBrrBrrb)messagemsg_type info_status info_headershas_content_lengthhas_transfer_encodingrl_ name_lower needs_chunkedrr exc_to_raise omits_bodyomits_body_warnedrvresponse_completeresponse_headers response_sentresponse_startedresponse_statusr use_chunkeds rsendz/ASGIProtocol._handle_http_request..sendps||vH88%kk(3 &{{9b9 ((lGL00##/0J#KL#' ")("3#*;;y"#= &+"(-%/+GD!1;D#1FDJJLJ!%JJ-1*#'RR04-&* +"66w~~W #59N'+'G'G(/($<<_M-2*,1)"'K +*'11'61''  !"&K'+,<'=Ac@d'd$))/;KWU11'#/0F#GL$#/0K#LL{{63/#KK U; $5((L#NNO -1)DOOD+O>!SY.M))"0066888 "00 ,,T-B-B\-QR48D1 ,,\:..(()>)>?04-(,%!E2@9sCJ"EJ" J !BJ"Internal Server Errorz'Request cancelled (client disconnected)Exception in post_request hookz7Exception after response complete (client disconnected)Error in ASGI application)_build_http_scoperrraccess_log_enabledrQ monotonicr pre_requestrrrrr;rjrzr_build_environreaccess post_requestr8ra should_closersrI)rrvrdrr body_receiverrr request_start request_timeenvironresprrrrrrrrrs`` @@@@@@@@@rroz!ASGIProtocol._handle_http_request[s*&&w(C !   !!% ++ r -r -j"XX88/ E NN,M HH g 6((5-"7"7> > >'""$))#/FG"%. E+DNN,<},LM %"11'8XNG+O=M}]DHHOOD'7LI"GD%%dkk7GTJ    !{{  7TXX%7%77c ?%%  HHNND E$ E+DNN,<},LM %"11'8XNG+O=M}]DHHOOD'7LI"GD%%dkk7GTJ E""#CD E9 !XY""#>?'--c3JK&)O E+DNN,<},LM %"11'8XNG+O=M}]DHHOOD'7LI"GD%%dkk7GTJ E""#CD E9 8 E""#CD E E+DNN,<},LM %"11'8XNG+O=M}]DHHOOD'7LI"GD%%dkk7GTJ E""#CD EsAR,AF4F2F4&B N23?R2F44.N/"O$B I21R2$JRJRAN/4O6B NR$N+(R*N++R.N//O2$ORORRB Q-,R-$RRRRRc ,t|dd}t|tr t|}nUg}|jD]D\}}|j |j j d|j dfFt|}t|} dddd|jdd |jd |j|j|j|jr |jnd |jr|jj dnd |jjxsd ||| d } t!|j"dr|j"j$| d<t!|drd|j&|j(di| d<| S)z*Build ASGI HTTP scope from parsed request. headers_bytesNr2re3.02.4r^ spec_versionrrZr[r rr http_versionrschemepathraw_path query_string root_pathrhserverclientr/priority_weighthttp.response.priorityweight depends_on extensions)rr&rrhrkrrTr#r^rrrrqueryrrrrr/rpriority_depends_on) rrvrdrrrhrlrmrrrs rrzASGIProtocol._build_http_scopesv $? mT *=)GG& Z e 3 3I > Y@WXY Z%X.$X. %u=&q12!GOOA4F3GHnnnnLL,3,<,<((#?F}}GMM00;RU++1r   4;; (![[..E'N 7- .(%55")"="=+#E,  rc |j|j|j|jxsdd|jdd|jd|r|dndd}|j D]\}}d|j dd z}|||<!|S) z8Build minimal WSGI-like environ dict for access logging.rrYrrZr[-REQUEST_METHODRAW_URI PATH_INFO QUERY_STRINGSERVER_PROTOCOL REMOTE_ADDRHTTP_r)rurirrr^rhreplacerrvrdrrrlrmras rrzASGIProtocol._build_environKs&nn{{ #MM/R!&wq'9&:!GOOArrrrs rrkz ASGIProtocol._effective_peernames 488-u 5 >O#  HH $ $ HH ) ) + O&&?Ewv4d;4Ohh}- hh}-  +"5O[))rc<|dk(xs|dvxsd|cxkxrdkScS)zReturn True when the response MUST NOT have a body (RFC 9110). Applies to HEAD requests and to status codes that semantically carry no body: 1xx informational, 204 No Content, 304 Not Modified. HEAD)0dr)rr_s rrz!ASGIProtocol._response_omits_bodys: f  ## #f"s" # rc0|dk(xsd|cxkxrdkScS)u/Per RFC 9110 §6.4.2 a server MUST NOT send Content-Length on 1xx or 204 responses. HEAD and 304 are NOT covered: HEAD MAY include the Content-Length the same GET would have returned, and 304 MAY include the Content-Length the unconditional response would have carried. rr r r)r_s rrz-ASGIProtocol._response_forbids_content_lengths#}3v 3 33 33rcddh}|j|r|jddh|Dcgc];\}}t|tr|j n|j |vr||f=c}}Scc}}w)a4Remove framing headers that must not appear on a no-body response. Transfer-Encoding is always stripped (chunked framing implies a body we will not send). Content-Length is stripped only when the status forbids it (1xx / 204); HEAD and 304 keep app-supplied Content-Length. rrrr)rupdater&rr)rrhr_ forbiddennvs rrz(ASGIProtocol._strip_body_framing_headerssy*+>?  / / 7   /1AB C& q!'3/ QWWYyPF   sAA2c|r|r@t|}tj|xs|ddjd}||zdz}nd}|jr&|j |j|zd|_y|r|j |yy|jr&|j |j|zd|_y|r|j |yy)zySend response body chunk. Combines buffered headers with first body chunk for efficient write batching. r0r1r2rrN)rB_CHUNK_PREFIXESrrTrrb)rrrsizeprefix chunk_datas rrzASGIProtocol._send_bodys 4y(,,T2Wao6L6LY6W#d]W4  $$  !6!6!CD(,%  ,$$  !6!6!=>(,%  &rc|jd}d|d|dt|d}|j|jd|j|y)zSend an error response.zutf-8z HTTP/1.1 r\z, Content-Type: text/plain Content-Length: z Connection: close r2N)rTrBrb)rr_rrrs rrz!ASGIProtocol._send_error_response/sa~~g&xq *"4yk*   34 rciddddddddd d d d d ddddddddddddddddddd d!d"id#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAdB}|j|dCS)Dz'Get HTTP reason phrase for status code.r ContinueezSwitching Protocolsgz Early Hintsr OKCreatedAcceptedrz No ContentzPartial Contenti-zMoved Permanentlyi.Foundi/z See Otherr z Not Modifiedi3zTemporary Redirecti4zPermanent Redirectrz Bad Requesti Unauthorizedi Forbiddeniz Not FoundizMethod Not AllowedizRequest TimeoutiConflictiGoneizLength RequiredizPayload Too Largerz URI Too LongizUnsupported Media TypeizUnprocessable EntityizToo Many RequestsrrizNot Implementediz Bad GatewayizService UnavailableizGateway TimeoutUnknown)r)rr_reasonss rrzASGIProtocol._get_reason_phrase<s" " &"  "   "  "  "  "  ""  $"  "  "  "  %"  %"  " !" " #" $ %" & %'" ( ")" * +" , -" . "/" 0 $1" 2 3" 4 )5" 6 '7" 8 $9" : (;" < "=" > ?" @ &A" B "C" F{{69--rc|jrd|jsW |jjr|jj|jj d|_yyy#t $rYwxYw)zClose the transport safely. Calls write_eof() first if supported to signal end of writing, which helps ensure buffered data is flushed before closing. TN)r>rs can_write_eof write_eofcloser8rAs rrzASGIProtocol._close_transportcsj >>$,, >>//1NN,,.$$& DL#/>   sAA22 A>=A>cK ddlm}|jd}|jd}|j}t j |}t j ||||jj} ||j|| |} | | jd{| |_ nc|\} } } | j| | | d{}| |_ |j|| ||d{|jxjdz c_| js|jj r | j#dd{}|D]}|j|| ||d{ |jxjt-|z c_|jj|jj.k\r-|j(j1d d |j_n#| js|jj rt7|d r# |jj9d{|j;y777o7#tj$$rYgt&$r&}|j(j+d |Yd}~d}~wwxYw7?#tj2$rYt&$r&}|j(j5d |Yd}~d}~wwxYw7#t&$rYwxYw#t7|d r4 |jj9d{7n#t&$rYnwxYw|j;wxYww)a4Handle an HTTP/2 connection. ``upgrade`` is set when the connection arrives over Upgrade: h2c and carries ``(settings, http1_req, body)``. The request that asked for the upgrade becomes stream 1 and is served before the receive loop starts, per RFC 7540 section 3.2. r)AsyncHTTP2ConnectionrrdNr[rNrzHTTP/2 receive error: %srgFzHTTP/2 connection error: %s_h2_conn)gunicorn.http2.async_connectionr.rrr;StreamReaderProtocol StreamWriterrrrinitiate_connectionr/initiate_upgrade_serve_http2_requestrp is_closedrs receive_datarr8rrzrBrqrrrjrarr,r)rr>rr~r.rrdrrwrh2_connr http1_reqrupgradedrequestsr:reqs rrz%ASGIProtocol._handle_http2_connectionss? $ L // ;H // ;H[[F33F;H))8VT[[-=-=F +&&(G11333 ' ,3))T!(!9!9i"// ' //gx;;; !#''DKK,=,=%,%9%9#%9%FFH$:C33Wh::::  #h-/;;>>T[[%=%==HHMM"PQ(-DKK%)''DKK,=,=6tZ(----///  ! ! #Y4/; G++ HHNN#=qA :%%   A HH  Run one HTTP/2 request, answering 500 rather than dropping it.NzError handling HTTP/2 requestr) _handle_http2_requestr8rra send_errorstream stream_idrcleanup_stream)rr<r8rdrr:s rr5z!ASGIProtocol._serve_http2_requests 9,,S'8XN N N  " "3::#7#7 8 O  HH  > ? (()=)=sCFKKK      " "3::#7#7 8syC-AAA&C-A CB;-3B' B#!B'&B;' B30B;2B33B;6C;CC'C**C-cg}|D]h\}}t|tr|jd}t|tr|jd}|j|j |fj|S)z?Convert ASGI headers to HTTP/2 format (lowercase string names).r2)r&rirjrkr)rrhresultrlrms r_convert_h2_headersz ASGIProtocol._convert_h2_headerssh" 1KD%$&{{9-%' Y/ MM4::</ 0  1  rc Kjjjjj ||}dddddddgddfd}f d}j j }tj} jjjj|||d{sjddd{dnsj} dtfg} | j!| jjrIj"j%| d j%| d j'd{ t-tj| z } |r?j/||} t1}j j3|| | nd} d}jj5j| |y7P727#t($r>j j+d sjddd{7dYwxYw#t($rj j+d YywxYw# t-tj| z } |r?j/||} t1}j j3|| | nd} d}jj5j| |w#t($rj j+d YwwxYwxYww) zHandle a single HTTP/2 request with streaming support. Streams both request and response body chunks immediately, avoiding buffering entire uploads and enabling SSE, streaming downloads, and other real-time use cases. FNrrcKjjdk(rddiSs0jr$jsdj }d|ddS t j jd d{}|ddd ddSjrdd|j dS7-#t j$rddicYSwxYww) NCLOSEDrrTrFrrrr) r/rlrequest_complete _body_chunksget_request_bodyr;rread_body_chunkr_body_complete)rr| body_receivedr@s rrz3ASGIProtocol._handle_http2_request..receives~!2!2h!> 122!V%<%B,?B.)C ,B..CC CC c K|d}|dk(rP|jd}|jdg}j|} j||d{y|dk(rDr td yd|dj j |jdgy|dk(rhs td  yr td  y|jd d }|jd d}r/|r+s)j jdj dd } sj}dtfg}|j| jj}| td y jj|d|j|d jd{d |r+ j|| d{t|z |s!|s jd dd{dyy|dk(rLs td y|jdg} j| } j!| d{yy7777a7w)Nrrr_rhrrTrrrrrrFr:statusz Stream closed end_streamhttp.response.trailersz)Cannot send trailers before body complete)rrEsend_informationalrrrrrrextendstreamsr8 send_headers_send_pending_data send_datarB send_trailers)rrrrrhrr response_hdrsr@trailer_headerstrailersrr8 headers_sentrrrvrrrrrrrAs rrz0ASGIProtocol._handle_http2_request..sends vH88%kk(3 &{{9b9 22<@00KQQQ00##/0J#KL#' ")("3"66NNO5 #*;;y"#= 11'#/0F#GL$#/0K#LL{{63/#KK U; $5((L#NNO -1)D$"667GHG&/_1E%F$GM!((1%__00;F~'3O'D OO00MV[0\'' %'H!44666#'L!++ItI +VVV!SY.M %// 34/PPP(,% ! 55(#/0[#\L")++i"<33OD++Ix@@@ 6ARd7 W QAs\AI2I'E$I2=I*> I2I,-I2 I. AI2 I0!I2*I2,I2.I20I2rrPTrQrr)r@rArVr_build_http2_scoperrrQrrrrrr?rErrUr8rWrXr8rar_build_http2_environrerr)rrvr8rdrrrrrrrhr[rrrrNrr^rrrrrrrr@rAs``` @@@@@@@@@@@@rr>z"ASGIProtocol._handle_http2_requestsGNN,, $$Y/''8D !  !   ) VR AR AR Aj"XX88( , E HH g 6((5'40 0 0'""$((C9PQQQ"%"223CD"+S-A!B C $$W- ,,Y7OO00MVZ0['' $'G!44666 E+DNN,<},LM %"778TG+')9=DHHOOD'7LI"GD%%dkk7GTJQ 1R7 & HH  : ;((C9PQQQ"%  && E""#CD E E+DNN,<},LM %"778TG+')9=DHHOOD'7LI"GD%%dkk7GTJ E""#CD EsBM1,%I*B J 7M18I;I>Ir_r`rrrrrSsNO"!%#' 2h'R1*""6'# P>d76 ,/ ."*$*( $# 8 D *  0$d / 0 &c$J-'^  Q* "A8F+Z$$L5800d*6    44    ': %.N G$R 9 GER)Vrr)(rr;r]r'rQgunicorn.asgi.unreaderrgunicorn.asgi.parserrrrrrr gunicorn.asgi.uwsgir gunicorn.http.errorsr gunicorn.http2r gunicorn.uwsgi.errorsr rr#r/r]rrUrRrangerTrrr4rWrcreroProtocolr)is0rros   02+&5 F F5(4?DElK11Tl)))44K%*%*P % / / m m `D7##DGLs#B?