iPxSrSSKrSSKJrJrJrJrJr SSKJ r SSK J r Sq Sq SqSqSqSr"SS 5rS /rg) z Async HTTP/2 server connection implementation for ASGI workers. Uses the hyper-h2 library for HTTP/2 protocol handling with asyncio for non-blocking I/O. N) HTTP2ErrorHTTP2ProtocolErrorHTTP2ConnectionErrorHTTP2NotAvailableHTTP2ErrorCode) HTTP2Stream) HTTP2Requestc[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 ImportErrorrQ/var/www/ias/venv/lib/python3.13/site-packages/gunicorn/http2/async_connection.py _import_h2rs8 "#&&.* "!!"s)>c\rSrSrSrSrSrSrSSjrSr S r S r S r S r S rSrSrSrSSjrSrSSjrSrSSjrSSjrS SjrSr\S5rSrSrSrg)!AsyncHTTP2Connection0zAsync HTTP/2 server-side connection handler for ASGI. Manages the HTTP/2 connection state and multiplexed streams using asyncio for non-blocking I/O operations. ic[5 XlX lX0lX@l0Ul[ R"5UlURUl URUl URUlURUl["R%SSS9n[&R)US9UlSUlSUlSUlg)aInitialize an async HTTP/2 server connection. Args: cfg: Gunicorn configuration object reader: asyncio StreamReader writer: asyncio StreamWriter client_addr: Client address tuple (host, port) Raises: HTTP2NotAvailable: If h2 library is not installed Fzutf-8) client_sideheader_encoding)rN)rcfgreaderwriter client_addrstreamsasyncioQueue_request_queuehttp2_initial_window_sizeinitial_window_sizehttp2_max_concurrent_streamsmax_concurrent_streamshttp2_max_frame_sizemax_frame_sizehttp2_max_header_list_sizemax_header_list_sizerH2Configurationr H2Connectionh2_conn_closed _initialized _receive_task)selfr&r'r(r)rs r__init__AsyncHTTP2Connection.__init__:s    & &mmo$'#@#@ &)&F&F#!66$'$B$B!++#, ''v'6  !!rc # UR(agURR[RR UR [RRUR[RRUR[RRUR05 URR5 UR5IShvN SUlgN 7f)z|Send initial HTTP/2 settings to client. Should be called after the SSL handshake completes and before processing any data. NT)r:r8update_settingsr SettingCodesMAX_CONCURRENT_STREAMSr1INITIAL_WINDOW_SIZEr/MAX_FRAME_SIZEr3MAX_HEADER_LIST_SIZEr5initiate_connection_send_pending_datar<s rrF(AsyncHTTP2Connection.initiate_connectiones     $$  % % < Y>Y  % % 9 94;S;S  % % 4 4d6I6I  % % : :DC2C.C2K(C20C01C25KD"K?(K'K(K.C20C22DDDKK, E& E E&&K= F7F F77K"H10G31&H1HH11K J(I+)JK K9J<:KKKc.[U[R5(aURU5$[U[R5(aUR U5$[U[R 5(aURU5$[U[R5(aURU5 g[U[R5(ag[U[R5(aURU5 g[U[R5(ag[U[R5(aURU5 g[U[R 5(aUR#U5$g)zHandle a single h2 event. Args: event: h2 event object Returns: HTTP2Request if a request is complete, None otherwise N) isinstancerRequestReceived_handle_request_received DataReceived_handle_data_received StreamEnded_handle_stream_ended StreamReset_handle_stream_reset WindowUpdatedPriorityUpdated_handle_priority_updatedSettingsAcknowledgedConnectionTerminated_handle_connection_terminatedTrailersReceived_handle_trailers_receivedr<rfs rra"AsyncHTTP2Connection._handle_eventsI eZ77 8 8007 7 z66 7 7--e4 4 z55 6 6,,U3 3 z55 6 6  % %e ,"z77 8 8 z99 : :  ) )% 0z>> ? ?  z>> ? ?  . .u 5 z:: ; ;11%8 8rcURnURn[X 5nX@RU'UR USS9 g)z-Handle RequestReceived event (HEADERS frame).F end_streamN) stream_idheadersr r*receive_headers)r<rfrrstreams rrl-AsyncHTTP2Connection._handle_request_receivedsAOO --Y-"( Y w59rcURnURnURRU5nUcgUR USS9 [ U5S:aHUR R[ U5US9 UR R[ U5SS9 gg![[R4aC SUl UR R[RS9 g![a gf=ff=f)zHandle DataReceived event.NFr~r)rTrM)rrcr*getrTlenr8increment_flow_control_window ValueErrorrrUr9close_connectionrrW Exception)r<rfrrcrs rrn*AsyncHTTP2Connection._handle_data_receivedsOO zz!!), >DU3 t9q=  ::3t9PY:Z ::3t9PT:U ? ?@  $ LL11^=^=^1_!  s+AB !C='C++ C95C=8C99C=cURnURRU5nUcgSUl[ X0R UR 5$)zHandle StreamEnded event.NT)rr*rrequest_completer r&r)r<rfrrs rrp)AsyncHTTP2Connection._handle_stream_endedsFOO !!), >"&FHHd.>.>??rcURnURRU5nUbURUR5 gg)zHandle StreamReset event.N)rr*rresetrNrs rrr)AsyncHTTP2Connection._handle_stream_resets<OO !!),   LL)) * rcSUlg)z"Handle ConnectionTerminated event.TNr9r{s rrx2AsyncHTTP2Connection._handle_connection_terminated$s  rcURnURRU5nUcgURUR5 [ X0R UR5$)zHandle TrailersReceived event.N)rr*rreceive_trailersrr r&r)rs rrz.AsyncHTTP2Connection._handle_trailers_received(sPOO !!), > .FHHd.>.>??rcURRUR5nUb0URURUR UR S9 gg)zjHandle PriorityUpdated event (PRIORITY frame). Args: event: PriorityUpdated event with priority info N)weight depends_on exclusive)r*rrupdate_priorityrrr)r<rfrs rru-AsyncHTTP2Connection._handle_priority_updated3sQ !!%//2    " "|| ++// #  rc# US:dUS:a[SU35eURRU5nUc[SUS35eS[U54/nUH/upgUR UR 5[U545 M1 UR RXSS 9 UR5IShvN gN7f) 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:statusFr~) rr*rrXrblowerr8 send_headersrG)r<rstatusrrresponse_headersnamevalues rsend_informational'AsyncHTTP2Connection.send_informationalAs C<6S==fXFG G!!), >wyk<= ='F 45"KD  # #TZZ\3u:$> ?# !!)%!P%%'''sB8C:C;Cc`# URRU5nUcgS[U54/nUH/upxURUR 5[U545 M1 USL=(d [ U5S:Hn UR RXU S9 URXiS9 UR5IShvN U(a'[ U5S:aURXSS9IShvN gN3N![Ra$ UR5 URU5 gf=f7f)aSend 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 Returns: bool: True if response sent, False if stream was already closed NFrrr~T)r*rrXrbrrr8rrG send_datarStreamClosedErrorrVcleanup_stream) r<rrrbodyrrrrrs r send_response"AsyncHTTP2Connection.send_responseas!!), >'F 45"KD  # #TZZ\3u:$> ?#T\3SY!^   LL % %ij % Y    0  H))+ + +D A nnYnFFF ,G//  LLN    *  sNA>yII1}   !(!1!1KK$$T%:%:;"!\\66x@F!'%eZ-C-CDD$);') <'z/N/NOO+/DL#% "(11333$(DL3*>||55i@@14 '' !//  s7E9;E5E6AEE9E6E>E9EEEE9E$E9EEE6E9E62E95E66E9c# URRU5nUcgUnU(aURRU5n[ X`R [ U55nUS::aWUR5IShvN URU5IShvN nUS::ag[ X`R [ U55nUSUnXWSnU=(a [ U5S:Hn URRXU S9 UR5IShvN U(aMURX#S9 gNNN!![R[R4a$ UR5 URU5 gf=f7f)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 NFrr~T)r*rr8rminr3rrGrrrrrUrVr) r<rrcrr data_to_sendr chunk_sizechunkis_finals rrAsyncHTTP2Connection.send_datas`!!), >   LLBB9M  ,?,?\ARS ?11333&*&H&H&S SI A~$!$Y0C0CSEV!WJ$[j1+K8 %@#l*;q*@ &&yH&M--///#,&   T  94 S000.2Q2QR  LLN    * ss"E?AD4?D.D4D0 D4#E?$A,D4D2 D4D4-E?.D40D42D44AE<9E?;E<<E?c,# URRU5nUcgUR(dg/nUHVupVUR5nUR S5(a[ SUS35eUR U[U545 MX URRXSS9 URU5 UR5IShvN gN![Ra$ UR5 URU5 gf=f7f)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 NF:zPseudo-header 'z' not allowed in trailersTr~)r*rresponse_headers_sentr startswithrrbrXr8r send_trailersrGrrrVr)r<rtrailersrtrailer_headersrrlnames rr"AsyncHTTP2Connection.send_trailerss !!), >++#KDJJLE$$ ?4&8Q!RSS  " "E3u:#6 7 $  LL % %iT % R   1))+ + + ,//  LLN    *  s<BD>CCCDC5DDDDc# U(aUR5OSnS[[U554/nU(aURS5 UR XXT5IShvN gN7f)z#Send an error response on a stream.rzcontent-length)z content-typeztext/plain; charset=utf-8N)encoderXrrbr)r<r status_codemessagerrs r send_errorAsyncHTTP2Connection.send_errorsP#*w~~$c#d)n56  NNH I  GGGsAA( A&!A(c# URRU5nUbURU5 URR XS9 UR 5IShvN gN7f)zReset a stream with RST_STREAM.NrM)r*rrr8 reset_streamrG)r<rrNrs rr!AsyncHTTP2Connection.reset_streamsR!!),   LL $ !!)!C%%'''sAA&A$A&c# UR(agSUlUc6UR(a#[URR55OSnURR US9 UR 5IShvN URR5 URR5IShvN gNB![a NLf=fN![a gf=f7f)z,Close the connection gracefully with GOAWAY.NTrrM) r9r*maxkeysr8rrGrr(rV wait_closed)r<rNlast_stream_ids rrVAsyncHTTP2Connection.closes <<   !9=S!2!2!451N  LL ) )Z ) @))+ + +  KK   ++))+ + + ,    ,   slAC),CCC7C?CCC)C CC)CC)C C&#C)%C&&C)c*# URR5nU(a?URRU5 URR 5IShvN ggN![ [ 4anSUl[SU35eSnAff=f7f)z,Send any pending data from h2 to the socket.NTzSocket write error: ) r8rr(writedrainrRrSr9r)r<rcrds rrG'AsyncHTTP2Connection._send_pending_data0s||((*  G !!$'kk''))) *W% G# *-A!+EFF Gs:"B8A&A$A&"B$A&&B6B  BBcUR$)zCheck if connection is closed.rrHs r is_closedAsyncHTTP2Connection.is_closed;s||rc<URRUS5 g)z-Remove a stream after processing is complete.N)r*pop)r<rs rr#AsyncHTTP2Connection.cleanup_stream@s D)rcNS[UR5SURS3$)Nz)rr*r9rHs r__repr__AsyncHTTP2Connection.__repr__Ds04<<()*ll^1 & r)r9r:r;r-r&r)r8r/r1r3r5r'r*r()N)F))rN)__name__ __module__ __qualname____firstlineno____doc__rQr=rFrTrarlrnrprrrxrzrurrrrrrrrVrGpropertyrrr__static_attributes__rrrr!r!0s)"V!*F"P$L :: @+ @ (@&P&AP)V*XH(, G* rr!)rr+errorsrrrrrrr rgr r rrrrrr!__all__rrrrsX  !     ""Y Y x " "r