i1W|SrSSKJr SSKJrJrJrJrJr SSK J r SSK J r Sq SqSqSqSqSr"S S 5rS /rg) zc HTTP/2 server connection implementation. Uses the hyper-h2 library for HTTP/2 protocol handling. )BytesIO) HTTP2ErrorHTTP2ProtocolErrorHTTP2ConnectionErrorHTTP2NotAvailableHTTP2ErrorCode) HTTP2Stream) HTTP2RequestNc[bgSSKJq SSKJq SSKJq SSK J q SSK J q g![a [!5ef=f)z$Lazily import h2 library components.Nr)_h2 h2.connection connection h2.configconfig _h2_config h2.eventsevents _h2_events h2.exceptions exceptions_h2_exceptions h2.settingssettings _h2_settings ImportErrorrK/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/http2/connection.py _import_h2r s8 "#&&.* "!!"s)>c\rSrSrSrSrSrSrSSjrSr S r S r S r S r S rSrSrSrSSjrSrSSjrSrSSjrSSjrS SjrSr\S5rSrSrSrg)!HTTP2ServerConnection/zHTTP/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. icr[5 XlX lX0l0Ul/UlUR UlURUl URUl URUl [RSSS9n[ R#US9Ul['5UlSUlSUlg)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)r cfgsock 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 UR(agURR[RR UR [RRUR[RRUR[RRUR05 URR5 UR5 SUlg)z|Send initial HTTP/2 settings to client. Should be called after the SSL handshake completes and before processing any data. NT)r9r6update_settingsr SettingCodesMAX_CONCURRENT_STREAMSr/INITIAL_WINDOW_SIZEr-MAX_FRAME_SIZEr1MAX_HEADER_LIST_SIZEr3initiate_connection_send_pending_datar:s rrD)HTTP2ServerConnection.initiate_connectiones     $$  % % < Y>Y  % % 9 94;S;S  % % 4 4d6I6I  % % : :D> ? ?  z>> ? ?  . .u 5 z:: ; ;11%8 8rcURnURn[X 5nX@RU'UR USS9 g)zcHandle RequestReceived event (HEADERS frame). Args: event: RequestReceived event with headers F end_streamN) stream_idheadersr r*receive_headers)r:rar{r|streams rrg.HTTP2ServerConnection._handle_request_receivedsC OO --Y-"( Y w59rcURnURnURRU5nUcgUR USS9 [ U5S:aXUR R[ U5US9 UR R[ U5SS9 UR5 gg![[R4a UR[RS9 gf=f)zHandle DataReceived event. Args: event: DataReceived event with body data Returns: None (request completion handled by StreamEnded) NFryr)r{rI)r{r^r*getrOlenr6increment_flow_control_windowrE ValueErrorrrPrQr rR)r:rar{r^r~s rri+HTTP2ServerConnection._handle_data_receivedsOO zz!!), >DU3 t9q= I ::3t9PY:Z ::3t9PT:U'')   ? ?@ I n&G&G H  IsAB007C*)C*cURnURRU5nUcgSUl[ X0R UR 5$)zsHandle StreamEnded event. Args: event: StreamEnded event Returns: HTTP2Request for the completed request NT)r{r*rrequest_completer r'r)r:rar{r~s rrk*HTTP2ServerConnection._handle_stream_endedsLOO !!), >#'FHHd.>.>??rcURnURRU5nUbURUR5 gg)zQHandle StreamReset event (RST_STREAM frame). Args: event: StreamReset event N)r{r*rresetrJrs rrm*HTTP2ServerConnection._handle_stream_reset*s> OO !!),   LL)) * rcSUlg)z_Handle ConnectionTerminated event (GOAWAY frame). Args: event: ConnectionTerminated event TNr8rvs rrs3HTTP2ServerConnection._handle_connection_terminated7s  rcURnURRU5nUcgURUR5 [ X0R UR5$)zHandle TrailersReceived event. Args: event: TrailersReceived event with trailer headers Returns: HTTP2Request if this completes the request N)r{r*rreceive_trailersr|r r'r)rs rru/HTTP2ServerConnection._handle_trailers_received@sTOO !!), > .FHHd.>.>??rcURRUR5nUb0URURUR UR S9 gg)zjHandle PriorityUpdated event (PRIORITY frame). Args: event: PriorityUpdated event with priority info N)weight depends_on exclusive)r*rr{update_priorityrrr)r:rar~s rrp.HTTP2ServerConnection._handle_priority_updatedTsQ !!%//2    " "|| ++// #  rclUS:dUS:a[SU35eURRU5nUc[SUS35eS[U54/nUH/upgUR UR 5[U545 M1 UR RXSS 9 UR5 g) 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 dzInvalid informational status: NzStream z not found:statusFry) rr*rrSr]lowerr6 send_headersrE)r:r{statusr|r~response_headersnamevalues rsend_informational(HTTP2ServerConnection.send_informationalbs C<6S==fXFG G!!), >wyk<= ='F 45"KD  # #TZZ\3u:$> ?# !!)%!P !rc0URRU5nUcgS[U54/nUH/upxURUR 5[U545 M1 USL=(d [ U5S:Hn UR RXU S9 URXiS9 UR5 U(a[ U5S:aURXSS9 g![Ra$ UR5 URU5 gf=f)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 NFrrryT)r*rrSr]rrr6rrE send_datarStreamClosedErrorrQcleanup_stream) r:r{rr|bodyr~rrrrzs r send_response#HTTP2ServerConnection.send_responses!!), >'F 45"KD  # #TZZ\3u:$> ?#T\3SY!^   LL % %ij % Y    0  H  # # %D A y4@//  LLN    *  s=AC5DDcSSKnSnUR5nURURUR5 Sn[U5GHnURRU5nUS:aUn GOURSS9nU(dMBURRUR5n U (d SUl OURR%U 5n U Hbn ['U [(R*5(aU R,U:XaSn OCM8['U [(R.5(dMYSUlSn O UR15 GM O URRU5nUR35 U$![ [ 4a gf=f![[[R 4a  MKf=f![R a  Mgf=f!UR35 f=f)zsWait for flow control window to become positive. Returns: int: Available window size, or -1 if waiting failed rN2g?)timeoutT) selectorsDefaultSelectorregisterr( EVENT_READ TypeErrorrranger6local_flow_control_windowselectrKrLrMrNrr[r8rOrerrlr{rrrErQ) r:r{rmax_wait_attemptsselresult_ availablereadyincomingrras 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:&   $Wn.J.JK*77& IIKsm6F A G%%F"4G%G  AG%;?G% FF"GG%GG% G"G%!G""G%%G7cURRU5nUcgUnU(aURRU5n[ X`R [ U55nUS::aGUR5 URU5nUS::ag[ X`R [ U55nUSUnXWSnU=(a [ U5S:Hn URRXU S9 UR5 U(aMURX#S9 g![R[R4a$ UR5 URU5 gf=f)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 NFrryT)r*rr6rminr1rrErrrrrPrQr) r:r{r^rzr~ 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 A.DA0DDAEEcURRU5nUcgUR(dg/nUHVupVUR5nUR S5(a[ SUS35eUR U[U545 MX URRXSS9 URU5 UR5 g![Ra$ UR5 URU5 gf=f)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 trailersTry)r*rresponse_headers_sentr startswithrr]rSr6r send_trailersrErrrQr)r:r{trailersr~trailer_headersrrlnames rr#HTTP2ServerConnection.send_trailerss !!), >++#KDJJLE$$ ?4&8Q!RSS  " "E3u:#6 7 $  LL % %iT % R   1  # # %//  LLN    *  s;C 5DDcU(aUR5OSnS[[U554/nU(aURS5 UR XXT5 g)zSend an error response on a stream. Args: stream_id: The stream ID status_code: HTTP status code message: Optional error message body rzcontent-length)z content-typeztext/plain; charset=utf-8N)encoderSrr]r)r:r{ status_codemessagerr|s r send_error HTTP2ServerConnection.send_error@sI$+w~~$c#d)n56  NNH I 97ArcURRU5nUbURU5 URR XS9 UR 5 g)zReset a stream with RST_STREAM. Args: stream_id: The stream ID to reset error_code: HTTP/2 error code (default: CANCEL) NrI)r*rrr6 reset_streamrE)r:r{rJr~s rr"HTTP2ServerConnection.reset_streamOsK!!),   LL $ !!)!C !rcUR(agSUlUc6UR(a#[URR55OSnURR US9 UR 5 g![a gf=f)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) NTrrI)r8r*maxkeysr6close_connectionrE Exception)r:rJlast_stream_ids rrQHTTP2ServerConnection.close]sr <<   !9=S!2!2!451N  LL ) )Z ) @  # # %   s)A>> B  B cURR5nU(aURRU5 gg![[ 4anSUl[SU35eSnAff=f)z,Send any pending data from h2 to the socket.TzSocket write error: N)r6rr(sendallrMrNr8r)r:r^r_s rrE(HTTP2ServerConnection._send_pending_datassg||((*  G !!$' W% G# *-A!+EFF GsAA*A%%A*cUR$)zCheck if connection is closed.rrFs r is_closedHTTP2ServerConnection.is_closed}s||rc<URRUS5 g)z^Remove a stream after processing is complete. Args: stream_id: The stream ID to clean up N)r*pop)r:r{s rr$HTTP2ServerConnection.cleanup_streams D)rcNS[UR5SURS3$)Nz)rr*r8rFs r__repr__HTTP2ServerConnection.__repr__s04<<()*ll^1 & r) r8r9r+r7r'r)r6r-r/r1r3r(r*)N)F))rN)__name__ __module__ __qualname____firstlineno____doc__rLr;rDrOr\rgrirkrmrsrurprrrrrrrrQrEpropertyrrr__static_attributes__rrrr"r"/s)"V!*@"D$L:" D@* +@( "@*X8t*X*X B ",G* rr")riorerrorsrrrrr r~r rbr r rrrrr r"__all__rrrrsX   !     ""`  `  F # #r