AҐi$bdZddlmZmZddlmZddlmZGddeZGdd Z d dgZ y ) zd HTTP/2 stream state management. Each HTTP/2 stream represents a single request/response exchange. )Enumauto)BytesIO)HTTP2StreamErrorcreZdZdZeZeZeZeZeZ eZ eZ y) StreamStatez8HTTP/2 stream states as defined in RFC 7540 Section 5.1.N) __name__ __module__ __qualname____doc__rIDLERESERVED_LOCALRESERVED_REMOTEOPENHALF_CLOSED_LOCALHALF_CLOSED_REMOTECLOSEDN/var/www/descvideos/venv/lib/python3.12/site-packages/gunicorn/http2/stream.pyr r s8B 6DVNfO 6D VFrr ceZdZdZdZedZedZedZedZ ddZ ddZ d Z dd Z dd Zd Zdd ZdZddZdZdZdZdZdZdZy) 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||_||_tj|_g|_t |_d|_d|_ d|_ d|_ |j|_ d|_d|_d|_d|_d|_y)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)selfrrs r__init__zHTTP2Stream.__init__%s#$!%%  "#I %!&%*"!&&99 "& "#$ "'rc&|jdzdk(S)z;Check if this is a client-initiated stream (odd stream ID).rrr,s ris_client_streamzHTTP2Stream.is_client_streamJ~~!Q&&rc&|jdzdk(S)zs r send_headerszHTTP2Stream.send_headerss`}}"/ /@A  !%%)"   " " $%)D " rc|js-t|jd|jj|r|j d|_yy)zMark data as sent. Args: data: Bytes to send end_stream: True if this completes the response Raises: HTTP2StreamError: If data cannot be sent in current state zCannot send data in state TN)r9rrrr;rKr$rDs r send_datazHTTP2Stream.send_datasP}}",TZZ__,=>    " " $%)D " rc|js-t|jd|jj||_|j d|_y)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)r9rrrr;r(rKr$rHs r send_trailerszHTTP2Stream.send_trailerssP}}"00AB "*  !%rcJtj|_d|_d|_y)zvReset this stream with RST_STREAM. Args: error_code: HTTP/2 error code (default: CANCEL) TNr rrr$r!)r, error_codes rresetzHTTP2Stream.resets! !'' !% $rcJtj|_d|_d|_y)zClose this stream normally.TNrRr1s rclosezHTTP2Stream.closes '' !% $rNcd|tdtd||_|||_|||_yy)aUpdate 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+)r,weight depends_on exclusives rupdate_priorityzHTTP2Stream.update_prioritysA  #&q#c6*:#;D  !'1D $  &/D # !rc(|jtjk(rtj|_y|jtjk(rtj |_yt |jd|jj)z(Transition to half-closed (local) state.z!Cannot half-close local in state N) rr rrrrrrr;r1s rrKzHTTP2Stream._half_close_localsg ::)) )$66DJ ZZ;99 9$++DJ"3DJJOO3DE rc(|jtjk(rtj|_y|jtjk(rtj |_yt |jd|jj)z)Transition to half-closed (remote) state.z"Cannot half-close remote in state N) rr rrrrrrr;r1s rr=zHTTP2Stream._half_close_remote sg ::)) )$77DJ ZZ;88 8$++DJ"4TZZ__4EF rc6|jjS)zbGet the complete request body. Returns: bytes: The request body data )r getvaluer1s rget_request_bodyzHTTP2Stream.get_request_bodys   ))++rc`i}|jD]\}}|jds|||<|S)zExtract HTTP/2 pseudo-headers from request headers. Returns: dict: Mapping of pseudo-header names to values (e.g., {':method': 'GET', ':path': '/'}) :r startswith)r,pseudor;values rget_pseudo_headerszHTTP2Stream.get_pseudo_headerss>// %KD%s#$t  % rcr|jDcgc]\}}|jds||fc}}Scc}}w)zGet regular (non-pseudo) headers from request. Returns: list: List of (name, value) tuples for regular headers rerf)r,r;ris rget_regular_headerszHTTP2Stream.get_regular_headers+s> $33 e??3'5M   s3c d|jd|jjd|jd|jd S)Nz)rrr;r!r$r1s r__repr__zHTTP2Stream.__repr__7sOt~~./ZZ__%& 1123!334A 7 r)F))NNN)r r r r r-propertyr2r5r7r9rArFrIrLrNrPrTrVr^rKr=rcrjrlrorrrrrs #(J''''    )0),% *.*(&$%% 0  ,    rrN) r enumrriorerrorsrr r__all__rrrrvs:  $ $ _ _ D - (r