+ jQzRt^RIt^RIHtHtHtHtHt^RIH t ^RI H t Rs Rs RsRsRsRt!RR4tR.tR#)z Async HTTP/2 server connection implementation for ASGI workers. Uses the hyper-h2 library for HTTP/2 protocol handling with asyncio for non-blocking I/O. N) HTTP2ErrorHTTP2ProtocolErrorHTTP2ConnectionErrorHTTP2NotAvailableHTTP2ErrorCode) HTTP2Stream) HTTP2Requestc\eR#^RIHs^RIHs^RIHs^RI H s ^RI H sR# \d \!4hi;i)z$Lazily import h2 library components.N)_h2 h2.connection connection h2.configconfig _h2_config h2.eventsevents _h2_events h2.exceptions exceptions_h2_exceptions h2.settingssettings _h2_settings ImportErrorrT/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/http2/async_connection.py _import_h2rs8 "#&&.* "!!"s ,Aca]tRt^0toRtRtRtRtRRltRt Rt R t R t R t R tR tRtRtRRltRtRRltRtRRltRRltRRltRt]R4tRtRtRtVtR#) AsyncHTTP2ConnectionzAsync HTTP/2 server-side connection handler for ASGI. Manages the HTTP/2 connection state and multiplexed streams using asyncio for non-blocking I/O operations. ic \4WnW nW0nW@n/Vn\ P!4VnVPVn VPVn VPVnVPVn\"P%RRR7p\&P)VR7VnRVnRVnRVnR#)aInitialize an async HTTP/2 server connection. Args: cfg: Gunicorn configuration object reader: asyncio StreamReader writer: asyncio StreamWriter client_addr: Client address tuple (host, port) Raises: HTTP2NotAvailable: If h2 library is not installed Fzutf-8) client_sideheader_encoding)rN)rcfgreaderwriter client_addrstreamsasyncioQueue_request_queuehttp2_initial_window_sizeinitial_window_sizehttp2_max_concurrent_streamsmax_concurrent_streamshttp2_max_frame_sizemax_frame_sizehttp2_max_header_list_sizemax_header_list_sizerH2Configurationr H2Connectionh2_conn_closed _initialized _receive_task)selfr#r$r%r&rs&&&&& r__init__AsyncHTTP2Connection.__init__:s    & &mmo$'#@#@ &)&F&F#!66$'$B$B!++#, ''v'6  !!rc "VP'dR#VPP\PP VP \PPVP\PPVP\PPVP/4VPP4VP4GRjxL RVnR#L 5i)z|Send initial HTTP/2 settings to client. Should be called after the SSL handshake completes and before processing any data. NT)r7r5update_settingsr SettingCodesMAX_CONCURRENT_STREAMSr.INITIAL_WINDOW_SIZEr,MAX_FRAME_SIZEr0MAX_HEADER_LIST_SIZEr2initiate_connection_send_pending_datar9s&rrC(AsyncHTTP2Connection.initiate_connectiones      $$  % % < Y>Y  % % 9 94;S;S  % % 4 4d6I6I  % % : :D> ? ?  z>> ? ?  . .u 5 z:: ; ;11%8 8rc VPpVPp\W 4pW@PV&VP VRR7R#)z-Handle RequestReceived event (HEADERS frame).F end_streamN) stream_idheadersrr'receive_headers)r9rcr}r~streams&& rri-AsyncHTTP2Connection._handle_request_receivedsAOO --Y-"( Y w59rc *VPpVPpVPPV4pVfR#VP VRR7\ V4^8dPVP P\ V4VR7VP P\ V4RR7R#R# \\P3dJRTn TP P\PR7R# \dR#i;ii;i)zHandle DataReceived event.NFr{)r}TrJ)r}r`r'getrQlenr5increment_flow_control_window ValueErrorrrRr6close_connectionrrT Exception)r9rcr}r`rs&& rrk*AsyncHTTP2Connection._handle_data_receivedsOO zz!!), >DU3 t9q=  ::3t9PY:Z ::3t9PT:U ? ?@  $ LL11^=^=^1_!  s+A B.."D*C>> D D DDc VPpVPPV4pVfR#RVnRVnVP 'dVP P 4\W0PVP4#)zHandle StreamEnded event.NT) r}r'rrequest_complete_body_complete _body_eventsetrr#r&r9rcr}rs&& rrm)AsyncHTTP2Connection._handle_stream_endedsnOO !!), > #' $        " " $FHHd.>.>??rc VPpVPPV4pVeVPVP4R#R#)zHandle StreamReset event.N)r}r'rresetrKrs&& rro)AsyncHTTP2Connection._handle_stream_reset#s<OO !!),   LL)) * rc RVnR#)z"Handle ConnectionTerminated event.TNr6rxs&&rru2AsyncHTTP2Connection._handle_connection_terminated+s  rc VPpVPPV4pVfR#VPVP4\ W0P VP4#)zHandle TrailersReceived event.N)r}r'rreceive_trailersr~rr#r&rs&& rrw.AsyncHTTP2Connection._handle_trailers_received/sPOO !!), > .FHHd.>.>??rc VPPVP4pVe5VPVPVP VP R7R#R#)zjHandle PriorityUpdated event (PRIORITY frame). Args: event: PriorityUpdated event with priority info N)weight depends_on exclusive)r'rr}update_priorityrrr)r9rcrs&& rrr-AsyncHTTP2Connection._handle_priority_updated:sQ !!%//2    " "|| ++// #  rc "V^d8gV^8d\RV 24hVPPV4pVf\RV R24hR\V43.pVF/wrgVP VP 4\V434K1 VP PWRR7VP4GRjxL R#L5i)avSend an informational response (1xx) on a stream. This is used for 103 Early Hints and other 1xx responses. Informational responses are sent before the final response and do not end the stream. Args: stream_id: The stream ID status: HTTP status code (100-199) headers: List of (name, value) header tuples Raises: HTTP2Error: If status is not in 1xx range zInvalid informational status: NzStream z not found:statusFr{) rr'rrUr_lowerr5 send_headersrD)r9r}statusr~rresponse_headersnamevalues&&&& rsend_informational'AsyncHTTP2Connection.send_informationalHs C<6S==fXFG G!!), >wyk<= ='F 45"KD  # #TZZ\3u:$> ?# !!)%!P%%'''sB>C CC c "VPPV4pVfR#R\V43.pVF/wrxVPVP 4\V434K1 VRJ;'g\ V4^8Hp VP PWV R7VPWiR7VP4GRjxL V'd,\ V4^8dVPWRR7GRjxL R#L9L \Pd&TP4TPT4R#i;i5i)aSend a response on a stream. Args: stream_id: The stream ID to respond on status: HTTP status code (int) headers: List of (name, value) header tuples body: Optional response body bytes Returns: bool: True if response sent, False if stream was already closed NFrr{T)r'rrUr_rrr5rrD send_datarStreamClosedErrorrScleanup_stream) r9r}rr~bodyrrrrr|s &&&&& r send_response"AsyncHTTP2Connection.send_responsehs!!), >'F 45"KD  # #TZZ\3u:$> ?#T\33SY!^   LL % %ij % Y    0  H))+ + +D A nnYnFFF ,G//  LLN    *  s[A/D?2D?ADC> D&D7D8D<D?>DD6D<8D?;D<<D?c "^2p\V4EF#pVPPV4pV^8dVu#\P!VP P VP4RR7GRjxL pV'dVPPV4pVFip\V\P4'dVPV8XdRuu#K<\V\P4'gK^RVnRuu# VP4GRjxL EKRVnRu# VPPV4#LL1 \P dEK`\"P$dRuu#i;i5i)zsWait for flow control window to become positive. Returns: int: Available window size, or -1 if waiting failed g?rHNT)ranger5local_flow_control_windowr(rLr$rMrNrQrgrrnr}rtr6rD TimeoutErrorrr])r9r}max_wait_attempts_ availableincomingrrcs&& r_wait_for_flow_control_window2AsyncHTTP2Connection._wait_for_flow_control_windowsM ()A >>yII1}   !(!1!1KK$$T%:%:;"!\\66x@F!'%eZ-C-CDD$);')  <'z/N/NOO+/DL#%I "(11333$(DLI3*>||55i@@14 '' !//   s8F>E9E: EAEFE E FE#E$E(F+E3 FEEF ,F0F F F F  Fc "VPPV4pVfR#TpV'dVPPV4p\ W`P \ V44pV^8:dZVP4GRjxL VPV4GRjxL pV^8:dR#\ W`P \ V44pVRVpWWRpT;'d\ V4^8Hp VPPWV R7VP4GRjxL KVPW#R7R#LLL \P\P3d&TP4TPT4R#i;i5i)zSend data on a stream. Args: stream_id: The stream ID data: Body data bytes end_stream: Whether this ends the stream Returns: bool: True if data sent, False if stream was already closed NFr{T)r'rr5rminr0rrDrrrrrRrSr) r9r}r`r|r data_to_sendr chunk_sizechunkis_finals &&&& rrAsyncHTTP2Connection.send_datasZ!!), >   LLBB9M  ,?,?\ARS ?11333&*&H&H&S SI A~$!$Y0C0CSEV!WJ$[j1+K8 %@@#l*;q*@ &&yH&M--///   T  94 S000.2Q2QR  LLN    * sw$FD;AD;D5D;D7 D;(F*0D;?D;D9D;3F5D;7D;9D;;AFFFFc B"VPPV4pVfR#VP'gR#.pVFWwrVVP4pVP R4'd\ RV R24hVP V\V434KY VPPWRR7VPV4VP4GRjxL R#L \Pd&TP4TPT4R#i;i5i)aSend trailing headers on a stream. Trailers are headers sent after the response body, commonly used for gRPC status codes, checksums, and timing information. Args: stream_id: The stream ID trailers: List of (name, value) trailer tuples Raises: HTTP2Error: If stream not found, headers not sent, or pseudo-headers used Returns: bool: True if trailers sent, False if stream was already closed NF:zPseudo-header 'z' not allowed in trailersTr{)r'rresponse_headers_sentr startswithrr_rUr5r send_trailersrDrrrSr)r9r}trailersrtrailer_headersrrlnames&&& rr"AsyncHTTP2Connection.send_trailerss !!), >+++#KDJJLE$$ ?4&8Q!RSS  " "E3u:#6 7 $  LL % %iT % R   1))+ + + ,//  LLN    *  sB3DA!DAC"C C"D C""6DDDDc "V'dVP4MRpR\\V443.pV'dVPR4VP WWT4GRjxL R#L5i)z#Send an error response on a stream.rzcontent-lengthN)z content-typeztext/plain; charset=utf-8)encoderUrr_r)r9r} status_codemessagerr~s&&&& r send_errorAsyncHTTP2Connection.send_errorsP#*w~~$c#d)n56  NNH I  GGGA A+"A)#A+c "VPPV4pVeVPV4VPP WR7VP 4GRjxL R#L5i)zReset a stream with RST_STREAM.NrJ)r'rrr5 reset_streamrD)r9r}rKrs&&& rr!AsyncHTTP2Connection.reset_streamsR!!),   LL $ !!)!C%%'''rc "VP'dR#RVnVf8VP'd$\VPP44M^pVPP VR7VP 4GRjxL VPP4VPP4GRjxL R#LC \dLNi;iL \dR#i;i5i)z,Close the connection gracefully with GOAWAY.NTrJ) r6r'maxkeysr5rrDrr%rS wait_closed)r9rKlast_stream_ids&&&rrSAsyncHTTP2Connection.close!s <<<   !9=S!2!2!451N  LL ) )Z ) @))+ + +  KK   ++))+ + + ,    ,   sp1C4%C4/C C  C7C"C C" C4 C CC4CC4 C"" C1-C40C11C4c 2"VPP4pV'dAVPPV4VPP 4GRjxL R#R#L \ \ 3dpRTn\RT 24hRp?ii;i5i)z,Send any pending data from h2 to the socket.NTzSocket write error: ) r5rr%writedrainrOrPr6r)r9r`ras& rrD'AsyncHTTP2Connection._send_pending_data7s||((*  G !!$'kk''))) *W% G# *-A!+EFF Gs:#B8A)A'A)#B'A))B:BBBc VP#)zCheck if connection is closed.rrEs&r is_closedAsyncHTTP2Connection.is_closedBs||rc >VPPVR4R#)z-Remove a stream after processing is complete.N)r'pop)r9r}s&&rr#AsyncHTTP2Connection.cleanup_streamGs D)rcNR\VP4 RVP R2#)z)rr'r6rEs&r__repr__AsyncHTTP2Connection.__repr__Ks04<<()*ll^1 & r)r6r7r8r*r#r&r5r,r.r0r2r$r'r%)N)F))N) __name__ __module__ __qualname____firstlineno____doc__rNr:rCrQr^rirkrmrorurwrrrrrrrrrrSrDpropertyrrr__static_attributes____classdictcell__) __classdict__s@rrr0s)"V!*F"P$L ::@$+ @ (@&P&AP)V*XH(, G*  rr)rr(errorsrrrrrrrrdrr rrrrrr__all__rrrrsX  !     ""` ` F " "r