j*pdZddlmZmZddlmZddlmZGddeZGdd Z d dgZ d S) zd HTTP/2 stream state management. Each HTTP/2 stream represents a single request/response exchange. )Enumauto)BytesIO)HTTP2StreamErrorceZdZdZeZeZeZeZeZ eZ eZ dS) StreamStatez8HTTP/2 stream states as defined in RFC 7540 Section 5.1.N) __name__ __module__ __qualname____doc__rIDLERESERVED_LOCALRESERVED_REMOTEOPENHALF_CLOSED_LOCALHALF_CLOSED_REMOTECLOSEDb/var/www/finuniver-perm.ru/html/student/venv/lib/python3.11/site-packages/gunicorn/http2/stream.pyr r scBB 466DTVVNdffO 466D TVVFFFrr ceZdZdZdZedZedZedZedZ ddZ dd Z d Z dd Z dd Zd ZddZdZddZdZdZdZdZdZdZdZdS) HTTP2StreamzRepresents a single HTTP/2 stream. Manages stream state, headers, and body data for a single request/response exchange within an HTTP/2 connection. c8||_||_tj|_g|_t |_d|_d|_ d|_ d|_ |j |_ d|_d|_d|_d|_d|_g|_d|_d|_dS)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)selfrrs r__init__zHTTP2Stream.__init__%s#$!%  "#II %!&%*"!&&9 "& "#$ "'#rc|jdzdkS)z;Check if this is a client-initiated stream (odd stream ID).rrr/s ris_client_streamzHTTP2Stream.is_client_streamO~!Q&&rc|jdzdkS)zr,appendr-setr writer@r!r.r/datarCs r receive_datazHTTP2Stream.receive_datas "A AA   '   $ $T * * * ' $$&&& %%%  '  # # % % %$(D !"&D  ' $$&&&&&  ' ' ' 'rc|js"t|jd|jj||_|d|_dS)zmProcess received trailing headers. Args: trailers: List of (name, value) tuples z!Cannot receive trailers in state TN)r:rrrr>r'r@r!r/r's rreceive_trailerszHTTP2Stream.receive_trailerss^  "EDJOEE  !  !!! $rc|js"t|jd|jjd|_d|_|r|d|_dSdS)zMark headers as sent. Args: headers: List of (name, value) tuples to send end_stream: True if this completes the response Raises: HTTP2StreamError: If headers cannot be sent in current state zCannot send headers in state TN) r<rrrr>r"r#_half_close_localr$rAs r send_headerszHTTP2Stream.send_headerssx} "A AA  !%%)"  *  " " $ $ $%)D " " " * *rc|js"t|jd|jj|r|d|_dSdS)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)r<rrrr>rPr$rIs r send_datazHTTP2Stream.send_datash} ">TZ_>>   *  " " $ $ $%)D " " " * *rc|js"t|jd|jj||_|d|_dS)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)r<rrrr>r(rPr$rMs r send_trailerszHTTP2Stream.send_trailerss^} "BBB "*    !%rcDtj|_d|_d|_dS)zvReset this stream with RST_STREAM. Args: error_code: HTTP/2 error code (default: CANCEL) TNr rrr$r!)r/ error_codes rresetzHTTP2Stream.resets$ !' !% $rcDtj|_d|_d|_dS)zClose this stream normally.TNrXr4s rclosezHTTP2Stream.closes" ' !% $rNcx|#tdtd||_|||_| ||_dSdS)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_prioritysP  #&q#c6*:*:#;#;D  !'1D $  &/D # # # ! rc|jtjkrtj|_dS|jtjkrtj|_dSt |jd|jj)z(Transition to half-closed (local) state.z!Cannot half-close local in state N) rr rrrrrrr>r4s rrPzHTTP2Stream._half_close_local sd :) ) )$6DJJJ Z;9 9 9$+DJJJ"EDJOEE rc|jtjkrtj|_dS|jtjkrtj|_dSt |jd|jj)z)Transition to half-closed (remote) state.z"Cannot half-close remote in state N) rr rrrrrrr>r4s rr@zHTTP2Stream._half_close_remotesd :) ) )$7DJJJ Z;8 8 8$+DJJJ"FTZ_FF rc4|jS)zbGet the complete request body. Returns: bytes: The request body data )r getvaluer4s rget_request_bodyzHTTP2Stream.get_request_body%s  ))+++rcdKddl}|j@||_|js|jr|j |jr|jdS|jrdS|j|jd{Vc)zRead next body chunk asynchronously for streaming. Returns: bytes: Next chunk of body data, or None if body is complete. rN) asyncior-Eventr,r.rGpopclearwait)r/rks rread_body_chunkzHTTP2Stream.read_body_chunk-s    #&}}D   'D$7 ' $$&&& *  0(,,Q///" t   " " $ $ $"'')) ) ) ) ) ) ) ) *rcXi}|jD]\}}|dr|||< |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_headersJsB/ % %KD%s## %$t  rc$d|jDS)zGet regular (non-pseudo) headers from request. Returns: list: List of (name, value) tuples for regular headers cFg|]\}}|d||fS)rr)rs).0r>rus r z3HTTP2Stream.get_regular_headers..]sB   e??3'' 5M   r)rr4s rget_regular_headerszHTTP2Stream.get_regular_headersWs&   #3    rc Rd|jd|jjd|jd|jd S)Nz)rrr>r!r$r4s r__repr__zHTTP2Stream.__repr__csR 7t~ 7 7Z_ 7 7 1 7 7"3 7 7 7 r)F)rV)NNN)r r r r r0propertyr5r8r:r<rDrKrNrQrSrUrZr\rdrPr@rirprvr{r~rrrrrs ($($($T''X'''X'  X   X ))))0''''@%%% ****.****(&&&$%%%%%%% 0 0 0 0      ,,,***:            rrN) r enumrriorerrorsrr r__all__rrrrs  $$$$$$     $   K K K K K K K K \ - (r