i*bSrSSKJrJr SSKJr SSKJr "SS\5r"SS 5r S S/r g ) zd HTTP/2 stream state management. Each HTTP/2 stream represents a single request/response exchange. )Enumauto)BytesIO)HTTP2StreamErrorcz\rSrSrSr\"5r\"5r\"5r\"5r \"5r \"5r \"5r Sr g) StreamStatez8HTTP/2 stream states as defined in RFC 7540 Section 5.1.N)__name__ __module__ __qualname____firstlineno____doc__rIDLERESERVED_LOCALRESERVED_REMOTEOPENHALF_CLOSED_LOCALHALF_CLOSED_REMOTECLOSED__static_attributes__r G/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/http2/stream.pyr r s8B 6DVNfO 6D VFrr c\rSrSrSrSr\S5r\S5r\S5r \S5r SSjr SS jr S r SS jrSS jrS rSSjrSrSSjrSrSrSrSrSrSrSrSrg) HTTP2StreamzRepresents a single HTTP/2 stream. Manages stream state, headers, and body data for a single request/response exchange within an HTTP/2 connection. c<XlX l[RUl/Ul[ 5UlSUlSUl SUl SUl URUl SUlSUlSUlSUlSUl/UlSUlSUlg)zInitialize an HTTP/2 stream. Args: stream_id: The unique stream identifier (odd for client-initiated) connection: The parent HTTP2ServerConnection FNr) stream_id connectionr rstaterequest_headersr request_bodyrequest_completeresponse_startedresponse_headers_sentresponse_completeinitial_window_size window_sizetrailersresponse_trailerspriority_weightpriority_depends_onpriority_exclusive _body_chunks _body_event_body_complete)selfr r!s r__init__HTTP2Stream.__init__%s#$!%%  "#I %!&%*"!&&99 "& "#$ "'#rc&URS-S:H$)z;Check if this is a client-initiated stream (odd stream ID).rr r3s ris_client_streamHTTP2Stream.is_client_streamO~~!Q&&rc&URS-S:H$)z    " " $%)D " rcUR(d-[URSURR35eXlUR 5 SUlg)zMark trailers as sent and close the stream. Args: trailers: List of (name, value) trailer tuples Raises: HTTP2StreamError: If trailers cannot be sent in current state zCannot send trailers in state TN)rDrr r"rGr,r\r(rXs r send_trailersHTTP2Stream.send_trailerssN}}"00AB "*  !%rcJ[RUlSUlSUlg)z^Reset this stream with RST_STREAM. Args: error_code: HTTP/2 error code (default: CANCEL) TNr rr"r(r%)r3 error_codes rresetHTTP2Stream.resets! !'' !% $rcJ[RUlSUlSUlg)zClose this stream normally.TNrfr9s rcloseHTTP2Stream.closes '' !% $rNcfUb[S[SU55UlUbX lUbX0lgg)zUpdate stream priority from PRIORITY frame. Args: weight: Priority weight (1-256), higher = more resources depends_on: Stream ID this stream depends on exclusive: Whether this is an exclusive dependency Nr)maxminr-r.r/)r3weight depends_on exclusives rupdate_priorityHTTP2Stream.update_prioritys=  #&q#c6*:#;D  !'1 $  &/ # !rc,UR[R:Xa[RUlgUR[R:Xa[R Ulg[ URSURR35e)z(Transition to half-closed (local) state.z!Cannot half-close local in state N) r"r rrrrrr rGr9s rr\HTTP2Stream._half_close_local sg ::)) )$66DJ ZZ;99 9$++DJ"3DJJOO3DE rc,UR[R:Xa[RUlgUR[R:Xa[R Ulg[ URSURR35e)z)Transition to half-closed (remote) state.z"Cannot half-close remote in state N) r"r rrrrrr rGr9s rrIHTTP2Stream._half_close_remotesg ::)) )$77DJ ZZ;88 8$++DJ"4TZZ__4EF rc6URR5$)zJGet the complete request body. Returns: bytes: The request body data )r$getvaluer9s rget_request_bodyHTTP2Stream.get_request_body%s   ))++rc# SSKnURcQUR5UlUR(dUR(aURR 5 UR(aURR S5$UR(agURR5 URR5IShvN M|N7f)z~Read next body chunk asynchronously for streaming. Returns: bytes: Next chunk of body data, or None if body is complete. rN) asyncior1Eventr0r2rQpopclearwait)r3rs rread_body_chunkHTTP2Stream.read_body_chunk-s     #&}}D   D$7$7  $$&  ((,,Q//""    " " $""'') ) ) *sCC$C"C$cl0nURH!up#URS5(dMX1U'M# U$)zExtract HTTP/2 pseudo-headers from request headers. Returns: dict: Mapping of pseudo-header names to values (e.g., {':method': 'GET', ':path': '/'}) :r# startswith)r3pseudorGvalues rget_pseudo_headersHTTP2Stream.get_pseudo_headersJs8//KDs##$t 0 rcURVVs/sH upURS5(aMX4PM" snn$s snnf)ztGet regular (non-pseudo) headers from request. Returns: list: List of (name, value) tuples for regular headers rr)r3rGrs rget_regular_headersHTTP2Stream.get_regular_headersWsA $33 3 ??3' TM3   s;;c SURSURRSURSURS3 $)Nz)r r"rGr%r(r9s r__repr__HTTP2Stream.__repr__csOt~~./ZZ__%& 1123!334A 7 r)r0r2r1r!r.r/r-r$r%r#r(r'r&r,r"r r+r*)F))NNN)r r rrrr4propertyr:r>rArDrMrUrYr]r`rcrhrkrtr\rIr|rrrrrr rrrrs ($T''''    )0'@% *.*(&$%% 0  ,*:    rrN) renumrriorerrorsrr r__all__r rrrs:  $ $ K K \ - (r