+ jDX~Rt^RIHt^RIHtHtHtHtHt^RI H t ^RI H t Rs RsRsRsRsRt!RR4tR.tR#) zc HTTP/2 server connection implementation. Uses the hyper-h2 library for HTTP/2 protocol handling. )BytesIO) HTTP2ErrorHTTP2ProtocolErrorHTTP2ConnectionErrorHTTP2NotAvailableHTTP2ErrorCode) HTTP2Stream) HTTP2RequestNc\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 ImportErrorrN/var/www/idalgo/venv/lib/python3.14/site-packages/gunicorn/http2/connection.py _import_h2rs8 "#&&.* "!!"s ,Aca]tRt^/toRtRtRtRtRRltRt Rt R t R t R t R tR tRtRtRRltRtRRltRtRRltRRltRRltRt]R4tRtRtRtVtR#) HTTP2ServerConnectionzHTTP/2 server-side connection handler. Manages the HTTP/2 connection state and multiplexed streams. This class wraps the h2 library and provides a higher-level interface for gunicorn workers. ic \4WnW nW0n/Vn.VnVP VnVPVn VPVn VPVn \PRRR7p\ P#VR7Vn\'4VnRVnRVnR#)zInitialize an HTTP/2 server connection. Args: cfg: Gunicorn configuration object sock: SSL socket with completed handshake client_addr: Client address tuple (host, port) Raises: HTTP2NotAvailable: If h2 library is not installed Fzutf-8) client_sideheader_encoding)rN)rcfgsock client_addrstreams_pending_requestshttp2_initial_window_sizeinitial_window_sizehttp2_max_concurrent_streamsmax_concurrent_streamshttp2_max_frame_sizemax_frame_sizehttp2_max_header_list_sizemax_header_list_sizerH2Configurationr H2Connectionh2_connr _read_buffer_closed _initialized)selfr$r%r&rs&&&& r__init__HTTP2ServerConnection.__init__:s   & "$$'#@#@ &)&F&F#!66$'$B$B!++#, ''v'6 $I !rc  VP'dR#VPP\PP VP \PPVP\PPVP\PPVP/4VPP4VP4RVnR#)z|Send initial HTTP/2 settings to client. Should be called after the SSL handshake completes and before processing any data. NT)r6r3update_settingsr SettingCodesMAX_CONCURRENT_STREAMSr,INITIAL_WINDOW_SIZEr*MAX_FRAME_SIZEr.MAX_HEADER_LIST_SIZEr0initiate_connection_send_pending_datar7s&rrA)HTTP2ServerConnection.initiate_connectiones      $$  % % < Y>Y  % % 9 94;S;S  % % 4 4d6I6I  % % : :D> ? ?  z>> ? ?  . .u 5 z:: ; ;11%8 8rc VPpVPp\W 4pW@PV&VP VRR7R#)zcHandle RequestReceived event (HEADERS frame). Args: event: RequestReceived event with headers F end_streamN) stream_idheadersrr'receive_headers)r7r^rxrystreams&& rrd.HTTP2ServerConnection._handle_request_receivedsC OO --Y-"( Y w59rc VPpVPpVPPV4pVfR#VP VRR7\ V4^8d`VP P\ V4VR7VP P\ V4RR7VP4R#R# \\P3d%TP\PR7R#i;i)zHandle DataReceived event. Args: event: DataReceived event with body data Returns: None (request completion handled by StreamEnded) NFrv)rxrF)rxr[r'getrLlenr3increment_flow_control_windowrB ValueErrorrrMrNrrO)r7r^rxr[r{s&& rrf+HTTP2ServerConnection._handle_data_receivedsOO zz!!), >DU3 t9q= I ::3t9PY:Z ::3t9PT:U'')   ? ?@ I n&G&G H  IsAB>>;C=<C=c VPpVPPV4pVfR#RVnRVnVP 'dVP P 4\W0PVP4#)zsHandle StreamEnded event. Args: event: StreamEnded event Returns: HTTP2Request for the completed request NT) rxr'r~request_complete_body_complete _body_eventsetr r$r&r7r^rxr{s&& rrh*HTTP2ServerConnection._handle_stream_endedsrOO !!), > #' $        " " $FHHd.>.>??rc VPpVPPV4pVeVPVP4R#R#)zQHandle StreamReset event (RST_STREAM frame). Args: event: StreamReset event N)rxr'r~resetrGrs&& rrj*HTTP2ServerConnection._handle_stream_reset/s> OO !!),   LL)) * rc RVnR#)z_Handle ConnectionTerminated event (GOAWAY frame). Args: event: ConnectionTerminated event TNr5rss&&rrp3HTTP2ServerConnection._handle_connection_terminated<s  rc VPpVPPV4pVfR#VPVP4\ W0P VP4#)zHandle TrailersReceived event. Args: event: TrailersReceived event with trailer headers Returns: HTTP2Request if this completes the request N)rxr'r~receive_trailersryr r$r&rs&& rrr/HTTP2ServerConnection._handle_trailers_receivedEsTOO !!), > .FHHd.>.>??rc VPPVP4pVe5VPVPVP VP R7R#R#)zjHandle PriorityUpdated event (PRIORITY frame). Args: event: PriorityUpdated event with priority info N)weight depends_on exclusive)r'r~rxupdate_priorityrrr)r7r^r{s&& rrm.HTTP2ServerConnection._handle_priority_updatedYsQ !!%//2    " "|| ++// #  rc zV^d8gV^8d\RV 24hVPPV4pVf\RV R24hR\V43.pVF/wrgVP VP 4\V434K1 VP PWRR7VP4R#)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:statusFrv) rr'r~rPrZlowerr3 send_headersrB)r7rxstatusryr{response_headersnamevalues&&&& rsend_informational(HTTP2ServerConnection.send_informationalgs C<6S==fXFG G!!), >wyk<= ='F 45"KD  # #TZZ\3u:$> ?# !!)%!P !rc RVPPV4pVfR#R\V43.pVF/wrxVPVP 4\V434K1 VRJ;'g\ V4^8Hp VP PWV R7VPWiR7VP4V'd$\ V4^8dVPWRR7R# \Pd&TP4TPT4R#i;i)aYSend 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 Raises: HTTP2Error: If stream not found or in invalid state Returns: bool: True if response sent, False if stream was already closed NFrrvT)r'r~rPrZrrr3rrB send_datarStreamClosedErrorrNcleanup_stream) r7rxrrybodyr{rrrrws &&&&& r send_response#HTTP2ServerConnection.send_responses!!), >'F 45"KD  # #TZZ\3u:$> ?#T\33SY!^   LL % %ij % Y    0  H  # # %D A y4@//  LLN    *  sA*C,,6D&%D&c ^RIp^2pVP4pVPVPVP4Rp\T4EFpTPPT4pT^8dTpEM TPRR7pT'gKGTPPTP4p T 'g RTnMTPP%T 4p T Fep \'T \(P*4'dT P,T8XdRpMDK:\'T \(P.4'gK\RTnRpM TP14EKM TPPT4pTP34T# \ \ 3dRu#i;i \\\P 3dKOi;i \P dKli;i TP34i;i)zsWait for flow control window to become positive. Returns: int: Available window size, or -1 if waiting failed Ng?)timeoutT) selectorsDefaultSelectorregisterr% EVENT_READ TypeErrorrranger3local_flow_control_windowselectrHrIrJrKrrXr5rLrbrrirxrorBrN) r7rxrmax_wait_attemptsselresult_ availablereadyincomingrr^s && r_wait_for_flow_control_window3HTTP2ServerConnection._wait_for_flow_control_windows  ++-C LLI$8$8 9 % ,- LLBB9M q=&F 3 /5#'99>>$2G2G#H$'+ !%!:!:8!D"(%eZ-C-CDD$);)+ % <(z/N/NOO+/DL%'F!"(//1 ?.D?? J IIK Y:& I  $Wn.J.JK*77& IIKss6FA G3%F.9G3 G3 G&AG3?G3F+*F+. GG3GG3G0+G3/G00G33Hc VPPV4pVfR#TpV'dVPPV4p\ W`P \ V44pV^8:dJVP4VPV4pV^8:dR#\ W`P \ V44pVRVpWWRpT;'d\ V4^8Hp VPPWV R7VP4KVPW#R7R# \P\P3d&TP4TPT4R#i;i)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 NFrvT)r'r~r3rminr.rrBrrrrrMrNr) r7rxr[rwr{ data_to_sendr chunk_sizechunkis_finals &&&& rrHTTP2ServerConnection.send_datas:!!), >   LLBB9M  ,?,?\ARS ?++- $ B B9 MI A~$!$Y0C0CSEV!WJ$[j1+K8 %@@#l*;q*@ &&yH&M'')   T  900.2Q2QR  LLN    *  s%DA)D0D ADAE%$E%c &VPPV4pVfR#VP'gR#.pVFWwrVVP4pVP R4'd\ RV R24hVP V\V434KY VPPWRR7VPV4VP4R# \Pd&TP4TPT4R#i;i)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 F:zPseudo-header 'z' not allowed in trailersTrv)r'r~response_headers_sentr startswithrrZrPr3r send_trailersrBrrrNr)r7rxtrailersr{trailer_headersrrlnames&&& rr#HTTP2ServerConnection.send_trailerss !!), >+++#KDJJLE$$ ?4&8Q!RSS  " "E3u:#6 7 $  LL % %iT % R   1  # # %//  LLN    *  s>C6DDc V'dVP4MRpR\\V443.pV'dVPR4VP WWT4R#)zSend an error response on a stream. Args: stream_id: The stream ID status_code: HTTP status code message: Optional error message body rzcontent-lengthN)z content-typeztext/plain; charset=utf-8)encoderPrrZr)r7rx status_codemessagerrys&&&& r send_error HTTP2ServerConnection.send_errorEsI$+w~~$c#d)n56  NNH I 97Arc VPPV4pVeVPV4VPP WR7VP 4R#)zReset a stream with RST_STREAM. Args: stream_id: The stream ID to reset error_code: HTTP/2 error code (default: CANCEL) NrF)r'r~rr3 reset_streamrB)r7rxrGr{s&&& rr"HTTP2ServerConnection.reset_streamTsK!!),   LL $ !!)!C !rc 0VP'dR#RVnVf8VP'd$\VPP44M^pVPP VR7VP 4R# \dR#i;i)zClose the connection gracefully with GOAWAY. Args: error_code: HTTP/2 error code (default: NO_ERROR) last_stream_id: Last processed stream ID (default: highest) NTrF)r5r'maxkeysr3close_connectionrB Exception)r7rGlast_stream_ids&&&rrNHTTP2ServerConnection.closebsv <<<   !9=S!2!2!451N  LL ) )Z ) @  # # %   s,B BBc VPP4pV'dVPPV4R#R# \\ 3dpRTn\RT 24hRp?ii;i)z,Send any pending data from h2 to the socket.TzSocket write error: N)r3rr%sendallrJrKr5r)r7r[r\s& rrB(HTTP2ServerConnection._send_pending_dataxsg||((*  G !!$' W% G# *-A!+EFF GsAA.A))A.c VP#)zCheck if connection is closed.rrCs&r is_closedHTTP2ServerConnection.is_closeds||rc >VPPVR4R#)z^Remove a stream after processing is complete. Args: stream_id: The stream ID to clean up N)r'pop)r7rxs&&rr$HTTP2ServerConnection.cleanup_streams D)rcNR\VP4 RVP R2#)z)rr'r5rCs&r__repr__HTTP2ServerConnection.__repr__s04<<()*ll^1 & r) r5r6r(r4r$r&r3r*r,r.r0r%r')N)F))N) __name__ __module__ __qualname____firstlineno____doc__rIr8rArLrYrdrfrhrjrprrrmrrrrrrrrNrBpropertyrrr__static_attributes____classdictcell__) __classdict__s@rr r /s)"V!*@"D$L:" D@4 +@( "@*X8t*X*X B ",G*  rr )riorerrorsrrrrrr{rr_r r rrrrrr __all__rrrrsX   !     ""e  e  P # #r