F2jZ"UddlmZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZddlmZmZddlmZmZmZmZmZdd lmZd d lmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&d d lm'Z(d d lmZ)d dl*m+Z+ej,dZ-dgZ.dZ/e0dZ1e0dZ2e0dZ3e0dZ4e0dZ5e0Z6de7d<e8dZ9e:ddD]Z;d e9e;<[;GddeZ<GddeZ=Gdd eZ>Gd!d"eZ?Gd#d$eZ@Gd%d&eAZBGd'd(eBZCGd)d*eBZDGd+d,eBZEGd-d.eBZFGd/d0eBZGGd1d2eBZHGd3d4eBZIGd5d6eBZJGd7d8eBZKGd9d:eBZLdXd@ZMdYdCZNdZdEZOd[dFZP d\d]dMZQd^dOZRd^dPZSd_dRZTd^dSZUGdTdUZVGdVdWZWdS)`) annotationsN)EnumIntEnum)UINT_VAR_MAX_SIZE) BufferBufferReadErrorDecoderStreamErrorDecompressionFailedEncoderStreamError QpackDecoder QpackEncoder StreamBlockedencode_uint_var)QuicConnectionstream_is_unidirectional)DatagramFrameReceived QuicEventStopSendingReceivedStreamDataReceived StreamReset)QuicLoggerTrace) DatagramReceived DataReceivedGoawayReceivedH3EventHeadersHeadersReceivedInformationalHeadersReceivedPushPromiseReceivedWebTransportStreamDataReceived) StopSending)r)NoAvailablePushIDErrorhttp3h3)rr):status):method:scheme :authority:paths :protocol)r+r-)r+r,r-r.frozenset[bytes]_TRAILERS_PSEUDOA[cbeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdS) ErrorCode3r1iiiiiiiii i i i i iiiiiiN)__name__ __module__ __qualname__H3_DATAGRAM_ERROR H3_NO_ERRORH3_GENERAL_PROTOCOL_ERRORH3_INTERNAL_ERRORH3_STREAM_CREATION_ERRORH3_CLOSED_CRITICAL_STREAMH3_FRAME_UNEXPECTEDH3_FRAME_ERRORH3_EXCESSIVE_LOAD H3_ID_ERRORH3_SETTINGS_ERRORH3_MISSING_SETTINGSH3_REQUEST_REJECTEDH3_REQUEST_CANCELLEDH3_REQUEST_INCOMPLETEH3_MESSAGE_ERRORH3_CONNECT_ERRORH3_VERSION_FALLBACKQPACK_DECOMPRESSION_FAILEDQPACK_ENCODER_STREAM_ERRORQPACK_DECODER_STREAM_ERRORY/home/thesage/.hermes/hermes-agent/venv/lib/python3.11/site-packages/qh3/h3/connection.pyr5r5DsK %$ %NK !!&!&!&rPr5c6eZdZdZdZdZdZdZdZdZ dZ d Z d Z d S) FrameTyperrrr'r(r) r2N) r7r8r9DATAHEADERSPRIORITY CANCEL_PUSHSETTINGS PUSH_PROMISEGOAWAY MAX_PUSH_IDDUPLICATE_PUSHWEBTRANSPORT_STREAMrOrPrQrSrS\sC DGHKHL FKNrPrSceZdZdZdZdZdS) HeadersStaterrrN)r7r8r9INITIAL AFTER_HEADERSAFTER_TRAILERSrOrPrQrbrbisGMNNNrPrbc.eZdZdZdZdZdZdZdZdZ dZ d S) SettingrrTr6iwiB7`+!N) r7r8r9QPACK_MAX_TABLE_CAPACITYMAX_FIELD_SECTION_SIZEQPACK_BLOCKED_STREAMSENABLE_CONNECT_PROTOCOL H3_DATAGRAMH3_DATAGRAM_DRAFT05ENABLE_WEBTRANSPORTDUMMYrOrPrQrgrgosB" "K#$ EEErPrgc"eZdZdZdZdZdZdZdS) StreamTyperrrr'TN)r7r8r9CONTROLPUSH QPACK_ENCODER QPACK_DECODER WEBTRANSPORTrOrPrQrtrts'G DMMLLLrPrtc*eZdZdZejZdddZdS) ProtocolErrorz Base class for protocol errors. These errors are not exposed to the API user, they are handled in :meth:`H3Connection.handle_event`. reason_phrasestrc||_dSN)r~)selfr~s rQ__init__zProtocolError.__init__s*rPN)r})r~r)r7r8r9__doc__r5r< error_coderrOrPrQr|r|sA4J+++++++rPr|ceZdZejZdS)QpackDecompressionFailedN)r7r8r9r5rLrrOrPrQrr5JJJrPrceZdZejZdS)QpackDecoderStreamErrorN)r7r8r9r5rNrrOrPrQrrrrPrceZdZejZdS)QpackEncoderStreamErrorN)r7r8r9r5rMrrOrPrQrrrrPrceZdZejZdS)ClosedCriticalStreamN)r7r8r9r5r?rrOrPrQrrs4JJJrPrceZdZejZdS) FrameErrorN)r7r8r9r5rArrOrPrQrrs)JJJrPrceZdZejZdS)FrameUnexpectedN)r7r8r9r5r@rrOrPrQrr.JJJrPrceZdZejZdS) MessageErrorN)r7r8r9r5rIrrOrPrQrrs+JJJrPrceZdZejZdS)MissingSettingsErrorN)r7r8r9r5rErrOrPrQrrrrPrceZdZejZdS) SettingsErrorN)r7r8r9r5rDrrOrPrQrrs,JJJrPrceZdZejZdS)StreamCreationErrorN)r7r8r9r5r>rrOrPrQrrs3JJJrPr frame_typeint frame_databytesreturnct|}t|dtzz}|||||||jS)Nrcapacity)lenrr push_uint_var push_bytesdata)rr frame_lengthbufs rQ encode_framersiz??L ,->)>> ? ? ?Cj!!!l###NN: 8OrPsettingsdict[int, int]ctd}|D]/\}}||||0|jS)Nir)ritemsrr)rrsettingvalues rQencode_settingsrsa $   C"..**!! '""" %    8OrPrct|}|}|std|S)Nrz*MAX_PUSH_ID frame has extra trailing bytes)r pull_uint_vareofr)rr max_push_ids rQparse_max_push_idrsI d   C##%%K 7799GEFFF rPcXt|}i}|sv|}|}|tvrt d|dd||vrt d|dd|||<|vt |S)NrzSetting identifier 0xxz is reserved is included twice)rrrRESERVED_SETTINGSrdict)rrrrrs rQparse_settingsrs d   C!Hggii"##%%!!## ' ' ' O O O O OPP P h   U U U U UVV V!ggii" >>rPheadersrallowed_pseudo_headersrequired_pseudo_headersextract_header bytes | Nonecd}d}d}d}t}d} t} |D]\} } | D]} | | rtd| d|| | } | r| ddkrs|rtd| d| |vrtd| d| |vrtd| d || | d kr| }| d kr| }| d kr| }d }||s5||}tdt |d|dvr"|std|std| S)NFzHeader z contains uppercase lettersr:zPseudo-header z% is not allowed after regular headersz is not validrr-r.r,TzPseudo-headers z are missing)shttpshttpsz+Pseudo-header b':authority' cannot be emptyz&Pseudo-header b':path' cannot be empty)set_HAS_UPPERCASEraddissubset differencesorted)rrrrafter_pseudo_headers authoritypathschemeseen_pseudo_headersextracted_header_value _has_upperkeyrbmissings rQvalidate_headersrs !"IDF&)ee+/J(( U Q QA!} Q"#OS#O#O#OPPP Q  %*@*H%* "  (3q6R<<# "QSQQQ000"#HC#H#H#HIII)))"#MC#M#M#MNNN  # #C ( ( (m##!  ""$(  # + +,? @ @L)445HIIJVG__JJJKKK $$$ NLMM M IGHH H !!rPNonec>t|ttdSN)rr)r_PUSH_PROMISE_PSEUDOrs rQvalidate_push_promise_headersr%s,3 4rPc>t|ttdSr)r_REQUEST_ALLOWED_PSEUDO_REQUEST_REQUIRED_PSEUDOrs rQvalidate_request_headersr-s,6 8rP int | Nonect|ttd}|dS t|S#t$rt d|dwxYw)Nr*)rrrzInvalid :status value )r_RESPONSE_ALLOWED_PSEUDO_RESPONSE_REQUIRED_PSEUDOr ValueErrorr)r status_codes rQvalidate_response_headersr5s{ 07 9! !!!KtO; OOOCKCCDD$NOs 2Ac>t|ttdSr)rr0rs rQvalidate_trailersrFs,/ 0rPc&eZdZd dZd dZd dZd S) H3Stream stream_idrrrc d|_d|_t|_d|_d|_d|_tj|_ tj|_ d|_ d|_ ||_ d|_d|_d|_dS)NF)blockedblocked_frame_size bytearraybufferended frame_sizerrbrcheaders_recv_stateheaders_send_statepush_id session_idr stream_typereceiving_ended sending_endedrrs rQrzH3Stream.__init__Osz .2kk  &*&*0<0D0<0D#' &*"'+$"rPboolc.|jo|jo|j Sr)rrrrs rQis_endedzH3Stream.is_ended_s!Od&:O4!"<== =!rPN)rrrr)rrrr)r7r8r9rrrrOrPrQrrNsT#### PPPP""""""rPrceZdZdZd@dAd Z d@dBd ZdCdZdDdZdEdZdEdZ dFdZ dGdZ dHdZ d@dId Z edJd"ZedJd#ZdKdLd(ZdMd+ZdNd,ZdOd.ZdPd0ZdQd2ZdRd4ZdSd6ZdTd7Z dKdUd8ZdVd9ZdWd;ZdXd<ZdXd=ZdYd?Zd$S)Z H3Connectionzu A low-level HTTP/3 connection object. :param quic: A :class:`~qh3.connection.QuicConnection` instance. Fquicrenable_webtransportrrrcd|_d|_||_|jj|_d|_||_|j|_t|j|j|_ d|_ d|_ t|_d|_d|_d|_i|_|jrdnd|_d|_d|_d|_d|_d|_d|_d|_d|_d|_i|_|dS)NidFrri)_max_table_capacity_blocked_streams_enable_webtransport configuration is_client _is_client_is_done_quic _quic_loggerr _decoder_decoder_bytes_received_decoder_bytes_sentr_encoder_encoder_bytes_received_encoder_bytes_sent_settings_received_stream _max_push_id _next_push_id_local_control_stream_id_local_decoder_stream_id_local_encoder_stream_id_peer_control_stream_id_peer_decoder_stream_id_peer_encoder_stream_id_received_settings_sent_settings_blocked_stream_map_init_connection)rrrs rQrzH3Connection.__init__ps #( #$7!,6  484E$T%=t?TUU '($#$ $ '($#$ "',. -1_(F$"#48%48%48%37$37$37$9=598:  rPrris_unidirectionalc|rH|tj}|j|t |n||j}||tj|j|t tj t |z|S)z Create a WebTransport stream and return the stream ID. :param session_id: The WebTransport session identifier. :param is_unidirectional: Whether to create a unidirectional stream. rr) _create_uni_streamrtrzrsend_stream_datarget_next_available_stream_id_log_stream_typerSr`)rrr%rs rQcreate_webtransport_streamz'H3Connection.create_webtransport_streams  // 0GHHI J ' ' ?:3N3N O O O O ??AAI  ! !#1H "    J ' ' =>>!*--.    rPeventr list[H3Event]c(|js t|tr||St|tr||jSt|tr ||j |j St|tr | |j |j SnD#t$r7}d|_|j|j |jYd}~nd}~wwxYwgS)zx Handle a QUIC event and return a list of HTTP events. :param event: The QUIC event to handle. T)rr~N)r isinstancer_receive_stream_datar_receive_datagramrr_receive_stream_resetrrr_receive_stop_sendingr|rcloser~)rr-excs rQ handle_eventzH3Connection.handle_events7}  e%788Y44U;;;'<==Y11%*==={33Y55eouGWXXX':;;Y55eouGWXXXY     $    "~S=N!   s()C.C#4C4C D-D  DrcR||j|j|j|j|j|jfvS)z RFC 9114 6.2: control, QPACK encoder, and QPACK decoder streams are critical streams. Closure of any critical stream MUST be treated as a connection error of type H3_CLOSED_CRITICAL_STREAM. )rrr rrrrs rQ_is_critical_streamz H3Connection._is_critical_streams:   (  (  (  )  )  )    rPrct||rtd|d|j|}|t ||gSd|_|r|j|d|j|dt ||gS)NCritical stream z reset by peerrrT) r9rrget H3StreamResetrrpopr#rrrstreams rQr3z"H3Connection._receive_stream_resets  # #I . . U&'S)'S'S'STT T!!),, >!I*MMMN N "& ??   . L  Y - - -  $$Y555 jIIIJJrPcP||rtd|d|j|}|6d|_|r|j|d|j|dt||gS)Nr;z stop-sending by peerTr<) r9rrr=rrr?r# H3StopSendingr@s rQr4z"H3Connection._receive_stop_sendings  # #I . . &C9CCC !!),,  #'F    2   D111  $$Y555 jIIIJJrPflow_idrrcZ|jt||zdS)z Send a datagram for the specified flow. :param flow_id: The flow ID. :param data: The HTTP/3 datagram payload. N)rsend_datagram_framer)rrDrs rQ send_datagramzH3Connection.send_datagrams- &&w'?'?$'FGGGGGrPrrc |jr Jd|j|j|jkrt|j}|xjdz c_|j|t tjt|| ||z| tj |}|j|t||S)a Send a push promise related to the specified stream. Returns the stream ID on which headers and data can be sent. :param stream_id: The stream ID on which to send the data. :param headers: The HTTP request headers for this push. z%Only servers may send a push promise.Nr)r)r rrr$rr)rrSr\r_encode_headersr(rtrw)rrrrpush_stream_ids rQsend_push_promisezH3Connection.send_push_promises?KK$KKK"   $(:d>O(O(O( ($ a ##  &((4+?+? 7+S+SS     00'0RR ##NOG4L4LMMMrP end_streamc ||}|jtjkrt d|r||||jD|jdd|j t|||j |ttj||dS)a Send data on the given stream. To retrieve datagram which need to be sent over the network call the QUIC connection's :meth:`~qh3.connection.QuicConnection.datagrams_to_send` method. :param stream_id: The stream ID on which to send the data. :param data: The data to send. :param end_stream: Whether to end the stream. 'DATA frame is not allowed in this stateNhttp frame_createdlengthrcategoryr-r)_get_or_create_streamrrbrdrr_maybe_cleanup_streamr log_eventencode_http3_data_framerrr)rrSrW)rrrrLrAs rQ send_datazH3Connection.send_data$s++I66  $ (B B B!"KLL L  $  ! ! # # # ""6***   (   ' '%&>>t99 ? (    ## |IND99:     rPc ||}|jtjkrt d|r||||}|jE|jdd|j t||||jtj kr\d}|j s?|s=|D]:\}}|dkrt|d krd }n#|d sn;|stj|_ntj|_|j|t%t&j||||dS) a Send headers on the given stream. To retrieve datagram which need to be sent over the network call the QUIC connection's :meth:`~qh3.connection.QuicConnection.datagrams_to_send` method. :param stream_id: The stream ID on which to send the headers. :param headers: The HTTP headers to send. :param end_stream: Whether to end the stream. *HEADERS frame is not allowed in this stateNrOrPrRrrrSFr*T:)rUrrbrerrrIrrWencode_http3_headers_framerrcr r startswithrdrr)rrSrXrV) rrrrLrAris_informational_headerskvs rQ send_headerszH3Connection.send_headersHs++I66  $ (C C C!"NOO O  $  ! ! # # #)))W==    (   ' '%&AAz??GyB (     $ (< < <', $? : #DAqJq66C<<7;4!E(\\$//, G,8,F)(4(CF % ## |I$5zBBJ    ""6*****rPdict[int, int] | Nonec|jS)z> Return the received SETTINGS frame, or None. )r!rs rQreceived_settingszH3Connection.received_settingss &&rPc|jS)z: Return the sent SETTINGS frame, or None. )r"rs rQ sent_settingszH3Connection.sent_settingss ""rPNrrrc|jd}|||||j|t ||S)zD Create an unidirectional stream of the given type. T)r%rrr)rr*r+r)r)rrrrs rQr(zH3Connection._create_uni_streamshJ;;d;SS  yk     ##I{/K/KLLLrPrrcl |#|j|j\}}|j|`n.|st|j||\}}|xjt |z c_|j|j |n!#t$r}t|d}~wwxYw|S)z Decode a HEADERS block and send decoder updates on the decoder stream. This is called with frame_data=None when a stream becomes unblocked. N) r#_pendingr r feed_headerrrrr)rr)rrrdecoderrr6s rQ_decode_headerszH3Connection._decode_headerss 6!#'#;I#F#O ,Y7@@"0-///#'=#<#i((F&,DL # rPrAc|rB|j|jd|j|jddSdSr)rrr?rr#)rrAs rQrVz"H3Connection._maybe_cleanup_streams` ??   A L  V-t 4 4 4  $ ( ()94 @ @ @ @ @  A ArPrc tj|jtjdtj|jtjdtjdi}|jrd|tj <|S)z3 Return the local HTTP/3 settings. ir) rgrkrrlrmr rorrr rq)rrs rQ_get_local_settingsz H3Connection._get_local_settingssW  ,d.F  *F  )4+@   M1 $   $ 645HW0 1rPrc|tjkr|jst|tjkr|jrt dt |}||||_|j | tj d| tj d| tj d}|j|j|d|_n|tjkrXt%|}|}|st+dt-|gS|tjkr+|jrt dt3||_n?|tjtjtjtjfvrt d gS) zG Handle a frame received on the peer's control stream. z#SETTINGS have already been receivedr)max_table_capacitydyn_table_capacityblocked_streamsTrz%GOAWAY frame has extra trailing bytes)rz!Servers must not send MAX_PUSH_IDz$Invalid frame type on control stream)rSr[rrrr_validate_settingsr!rapply_settingsr=rgrkrmrr)rr]rrrrrr^r rrrWrXr\r_)rrrrrsr goaway_ids rQ_handle_control_framez"H3Connection._handle_control_frames + + +D4K +& & + + +& M%&KLLL%j11H  # #H - - -&.D #m22#+<<0PRS#T#T#+<<0PRS#T#T ( W-JA N N3G J ' '(Ew O O O&*D # # 9+ + +j)))C))++I7799 J !HIII"Y7778 8 90 0 0 K%&IJJJ 1* = =D    N    "  $    ""HII I rP stream_endedc |tjkrF|jtjurt d|s|rt ||j||jgSgSg}|tj kr|jtj urt d| |j|}d}|jtj ur'|j rt|}nt|nt!||jS|jdd|j||jnt+|||j|jtj ur||d ks|rtj|_ntj |_|jrd }|jtj ur3|1|d kr+|t1||j n|t3||j|j| n||tjkr|j|j st d t7|}|} | |j||d}t=||jK|jdd|jt+||| |j|tA|| |jni|tj!tj"tj#tjtj$tj%tj&fvrt |jdnd|S)zF Handle a frame received on a request or push stream. rN)rrrrr[NrO frame_parsedr\rSr]T)rr)rrrrz"Clients must not send PUSH_PROMISEr)rRrrr)rrrz$Invalid frame type on request streamz!Invalid frame type on push stream)'rSrWrrbrdrrrrrXrerprcr rrrrrWr_rrrappendr rr\rrtellrencode_http3_push_promise_framer!rYrZr[r]r^r_) rrrrAr http_eventsrr frame_bufrs rQ_handle_request_or_push_framez*H3Connection._handle_request_or_push_frames  ' '( 0JJJ%&OPPP z  ' &%1"("2 I%' * * *(L,GGG%&RSSS**6+;ZHHG&*K(L,@@@?6";G"D"DKK,W5555!'*** ,!++#(*EE *1#55!$Z '"("2F,   (L,@@@&+*<*< *<0<0JF-,8,G))(#'L)\-AAA+#%%""0 '"("2""# ' &"("2%1 91 1 1fn6L? L%&JKKKJ///I--//G** *Y^^-=-=-?-?"@G *' 2 2 2 ,!++#(*JJ": ' '"("2 K,      ##W@P         !    "    !  $   ">)768  rPc T|tj|_||_|j|jttj t|j|j rQ|j J|j|jttjt|j |tj|_|tj|_dSr)r(rtrvrrwr"rr)rrSr[rr rr^rrxrryrrs rQr$zH3Connection._init_connections(,(?(? @R(S(S%"6688 ##  ) +_T=P-Q-Q R R    ? t0< J ' '-Y2ODDU4V4VWW    )-(?(?  $) ) %)-(?(?  $) ) %%%rPc|jGdddddd|d}||d}|||d <|jd d | dSdS) Ncontrolpush qpack_encoder qpack_decoder webtransport)rrrr'ruunknown)newrassociated_push_idrOstream_type_setrS)rr=rW)rrrr type_namers rQr+zH3Connection._log_stream_types   (""$  c+y)) %9==D"-4)*   ' '' (      ) (rPct|} |}n#t$rtdwxYwt ||d|gS)z$ Handle a datagram. rzCould not parse flow IDN)rrD)rrr r|rr)rrrrDs rQr2zH3Connection._receive_datagrams}$ ;''))GG ; ; ; 9:: : ; d388::<<&8'JJJKKs 'Arc |j}||}t|r"|||j|j}n!|||j|j}|||Sr)rrUr_receive_stream_data_unirrL_receive_request_or_push_datarV)rr-rrAresults rQr1z!H3Connection._receive_stream_datasO ++I66 #I . . 2265:uGWXXFF77 E$4F ""6*** rPc  g}|j}|rd|_|jr|||S|j}|jt jkr|j|rb||| tt||j||| n+| t||j|||S|jt j kr|j |sit|}||jkrN|rt!d| t#||j|d|xj|zc_|Sn||t|}||jkro|rt!d| t#t||j|d|xj|zc_| |Sd}|r2|s0|s.|jt(jurt#d|j|dgSgS|r||t-t|} d } | j} | j} | j} | j}|j}| sS|j8 | |_| |_n#t8$rYnwxYw| } |jt jkr|j|_d|_t|| d}| ||t<j |s|r+| t||j|||S|j Q|jt j kr<|j !d d |j "|j| |j}tG|| j$| z }|jt j kr||krn||}|j}| } ||z |_|jsd|_d|_ ||||||jo | n5#tJ$r(d|_t||_&||j'|<Yn9wxYw|jt(j(ur|jrt|} n | S| r|d| =|r`|s^|jsW|jt(j)urD|rtU|ddds+| t#d|j|d|S)zC Handle data received on a request or push stream. TN)rrrrz"DATA frame truncated by stream endF)rrrrrPrrr'rOrrQrSrrrArr)+rrrextendrrrSr`rrr"rclearrWrrrrrrrbrcrrrr pull_bytesrr r+rtrzrrWrXminrrrr#rerdgetattr)rrArrrs_buffer s_stream_iddata_lenbuf_lenrconsumedbuf_tellbuf_eofbuf_pull_uint_varbuf_pull_bytes handle_framer s_frame_size chunk_sizers rQrz*H3Connection._receive_request_or_push_datas &( =  *%)F " >  OOD ! ! ! &   !> > >!- %%%""2"8__#)#4"-%1     ""2!#)#4"-%1      . .63D3P" t99f///#O()MNNN&&$!%$*N&1). %%1%%&&0%%%h--V...#O()MNNN&&$!&x$*N&1). %%0%%NN$$$&&    ( 0DDD  &"-%) I  " OOD ! ! !%//***8'-9 '))U  ((9(9(;(;F%(9(9(;(;F%%&E#8::$ (EEE(.(9F%(,F%!&x ':!;!;JNN$$$))"-:;R*"\#**:%/+1+<*5-9 '&%1)Y^;;%//!',!.FF#)#4 G0",L\3<(+BCCJ IN22zL7P7P( 33J*JxzzH!-z 9F $ )$(!$(! "" L#-#-%%+%;%I !   !%,/ OO)8>(5  )\-HHH*Ix==k'))U p  $(#    (L,FFF" 'O^U++  &&$!$$*N&1)- s$/K KK1R/SSc  g}|j||rd|_tt |j}d}t }|jtjtj tj fvs| s|j | |_n#t$rYn[wxYw|}|jtj kr#|jt!d|j|_no|jtjkr#|jt!d|j|_n7|jtjkr"|jt!d|j|_|jtjkr!||j|j|jtj kr|rt/d | }| } || } n#t$rYnwxYw|}|||| nq|jtjkr|jg | |_n#t$rYnmwxYw|}||j|j|j |jd|=||d |S|jtj kr|j@ | |_n#t$rYnwxYw|}t |j|d} |j| s|r5|t?| |j|j|j |S|jtjkr||j |z }|} |j!"|n!#tF$r} tI| d} ~ wwxYw|xj%tM|z c_%nM|jtjkr ||j |z }|} |j'(|n!#tR$r} tU| d} ~ wwxYw|j+,D]Q\} } |j'-| \}}||f| _.|/| B#t`$rYNwxYw|xj1tM|z c_1n.|2|j |}|jtjtj tj fvv| |r |jd|=|D]}|j3|}||4tjj6d||jo|j d |_7d|_8|j+|=|jr/|||d |j|S)NTrrz"Only one control stream is allowedz(Only one QPACK decoder stream is allowedz(Only one QPACK encoder stream is allowedr'z%Closing control stream is not allowedrkrP)rrrrrF)9rrrrrrrrtrwrvrzrrr rrrrryrrxr r+rrrrrrrrr"rr feed_decoderr rrrr feed_encoderr rr#r resume_headerrmrrrseekrrrSrXrr)rrArrrrrunblocked_streamsrrrr6 blocked_idblocked_stream stream_datarrs rQrz%H3Connection._receive_stream_data_unisF&(  T"""  *%)F "% ..///&)ee  !3Z5LM N N7799 N !)),):):)<))),):):)<)<*"xxzzH)) &"("2$*$6*M)8),99&#|TTT#z'>>>$,,/,=,=,?,?))*"xxzzH"6=#;<<  ##%%%&&6!+'-'8)/)?&,&6 #"#z'???~~clSXXZZ&?@@88::=M..t4444)===133<=,,D 9,,,#z'???~~clSXXZZ&?@@88::=M..t4444)===133<=372J2P2P2R2R ! !.J!/3}/J/J:/V/V, W'#3/*--j9999(!!! !,,D 9,,,&&&88::y  !3Z5LM N N7799 N~  ) ixi(+  I\),F   22(0#!!'!7!M N>N JKK K : 9>N>NrP)F)rrrrrr)rrr%rrr)r-rrr.)rrrr)rrrrrr.)rDrrrrr)rrrrrr)rrrrrLrrr)rrrrrLrrr)rrer)rrrrrr)rrrrrr)rrrrrr)rrrr)rArrr)rr)rrrrrr.) rrrrrArrrrr.r)rrrrrrrr)rrrr.)r-rrr.)rArrrrrrr.)rrrr) r7r8r9rrr,r7r9r3r4rGrKrYrdpropertyrgrir(rprIrUrVrwrrr$r+r2r1rrr|rOrPrQrris " " " " " J:?02     KKKK*KKKK(HHHH<" " " " JDI7+7+7+7+7+r'''X' ###X#     .    AAAA    ''''ROOOOb    .GK, L L L L    XXXXtkkkkZLLLLLLrPr)rrrrrr)rrrr)rrrr)rrrrr) rrrr/rr/rrrr)rrrr)rrrr)X __future__rloggingenumrr_compatr_hazmatrr r r r r rrrquic.connectionrr quic.eventsrrrrr quic.loggerreventsrrrrrrr r!r"r#rCr> exceptionsr$ getLoggerloggerH3_ALPNr frozensetrrrrrr0__annotations__rrrange_ir5rSrbrgrt Exceptionr|rrrrrrrrrrrrrrrrrrrrrrOrPrQrs"""""""''''''                      GFFFFFFF*)))))                      /.....  7 # # &-%9]33%Im44#)C%9%@AA y!RSS%.Y[[00003 %B--BN2''''''''0        4 g( + + + + +I + + +66666}66666666m66666666m66655555=555********/////m///,,,,,=,,,/////=///-----M---44444-444    $$( :":":":":"zOOOO"""""""""6NLNLNLNLNLNLNLNLNLNLrP