h;YSSKrSSKrSSKrSSKrSSKrSSKrSSKJrJrJrJ r J r J r J r J r SSKJrJrJrJrJrJrJr SSKJr SSKJrJrJr \R8"\5r\R>(a$\R@"S5r!\RD"S5r#"S S \5r$"S S \5r%"S S\5r&"SS\&\RN5r("SS\&5r)"SS\&5r*g)N)BinaryIOCallableClassVar Collection GeneratorMappingSequenceType) JsonError JsonObject JsonValue create_objectget_boolget_enumget_str)CockpitProblem)EndpointRouter RoutingRule_T_Pc|^\rSrSr%S\S'S\SS4U4SjjrS\4S jrS S S \S\ 4S jr S \SS4Sjr Sr Sr U=r$)ChannelRoutingRule&zdict[str, list[Type[Channel]]]tablerouter channel_typeszCollection[Type[Channel]]c>[TU]U5 0UlUH:nURRUR/5nUR U5 M< URR 5HnURSSS9 M g)Nc,[UR5$N)len restrictions)clss 1/usr/lib/python3/dist-packages/cockpit/channel.py-ChannelRoutingRule.__init__..5ss3+;+;'<T)keyreverse)super__init__r setdefaultpayloadappendvaluessort)selfrrr$entry __class__s r%r,ChannelRoutingRule.__init__)ss   !CJJ))#++r:E LL ! ZZ&&(E JJ>'2.C&&s'7'7AA4;;''/r(cgr!r2s r%shutdownChannelRoutingRule.shutdown_ r()r)__name__ __module__ __qualname____firstlineno____annotations__rr,r r:boolrErJrO__static_attributes__ __classcell__)r4s@r%rr&sg ++ Lv L6Q Lj/OZdim" * 1A   r(rc\rSrSrSrg) ChannelErrorcrMN)rRrSrTrUrXrMr(r%r[r[csr(r[c\rSrSr%SrSrSr\\S'Sr \ \S'\r \ \S'\\S 'S \S 'S r S \S'S\S'Sr S\S'SrS\S'SrSr\\S'S\S'S\S\SS 4SjrS\S\S\SS 4SjrS S!S"S!S#\SS 4S$jrS%\SS 4S&jrSJS'jrSJS(jrSJS)jrS\SS 4S*jrS\SS 4S+jrS,\SS 4S-jrS\S,\SS 4S.jrS,\SS/4S0jrS1\ SS 4S2jr!SS3.S,\S4\S\4S5jjr"SJS6jr#S\4S7jr$SJS8jr%S9r&SKS:jr'SKSLS;jjr(S,\S\4S<jr)S,\S\4S=jr*S,\S\4S>jr+SKS?S S1\ S\4S@jjr,SAr-SJSBjr.\/R`"SCSD9r1SE\SF'S\S1\ SS 4SGjr2S\SS 4SHjr3SIr4g )MChannelgi@i F _send_pingsr _out_sequence _out_window _ack_byteszset[asyncio.Task]_tasksNJsonObject | None _close_argsz ClassVar[str]r.rMz&ClassVar[Sequence[tuple[str, object]]]r#zClassVar[Sequence[str]]r: is_binaryz codecs.IncrementalDecoder | Nonedecodercommandmessager6cfUS:Xa[5Ul[US5Ul[ USSS9(aSUl[ USS/S5SLUl[US S 5Ul[ US S /S5SLUl SUl UR5 URU5 gUS :XaUR5 gUS:XaUR5 gUS:XaUR5 gUS:XaUR!U5 gUS:XaUR#U5 gUS:XaUR%U5 gg)Nopenchannelz flow-controlF)defaultTz send-acksbytesgrouprobinaryrawreadydoneclosepingpongr@)setrdrrnrr`rrcrqrhrifreeze_endpointdo_opendo_readydo_donedo_closedo_pingdo_pong do_options)r2rjrks r% do_controlChannel.do_controls  f %DK"7I6DL?#' &w gYMUYYDO '9=DJ%gx%$GtSDNDL  " LL !   MMO   LLN   MMO   LL !   LL !  ! OOG $"r(rncURbgURX#5 g![an[S[ U5S9UeSnAff=f![a)nUR UR 55 SnAgSnAff=f)Nprotocol-errorrk)rfrr r[rIrv get_attrs)r2rnrjrkexcs r%do_channel_controlChannel.do_channel_controlsr    '  ( P1 P"#3SXFCO P ( JJs}} ' ' (s,# AAAA A<A77A<hostz str | Nonerq_messagecpURbgUbgUbURU:wagUR5 gr!)rfrqr~)r2rrqrs r%do_killChannel.do_kills7    '      u!4  r(r@c[er!NotImplementedErrorr2r@s r%r{Channel.do_open!!r(cgr!rMrNs r%r|Channel.do_readyrQr(cgr!rMrNs r%r}Channel.do_donerQr(c$UR5 gr!rvrNs r%r~Channel.do_closes  r(c[SSS9e)Nz not-supportedz)This channel does not implement "options"r)r[r2rks r%rChannel.do_optionss?4_``r(c&URU5 gr!) send_pongrs r%rChannel.do_pings wr(datacZUR(aURS[U5S9 gg)Nack)rp)rc send_controlr"r2rs r%send_ackChannel.send_acks% ??   e3t9  5 r(cURbgURU5(dURU5 gg![a)nUR UR 55 SnAgSnAff=fr!)rfdo_datarr[rvr)r2rnrrs r%do_channel_dataChannel.do_channel_datas[    '  (<<%% d#& ( JJs}} ' ' (s'9 A,A''A,z bool | Nonec&AUR5 g)zHandles incoming data to the channel. Return value is True if the channel takes care of send acks on its own, in which case it should call self.send_ack() on `data` at some point. None or False means that the acknowledgement is sent automatically.Trrs r%rChannel.do_datas  r(kwargsc LUR5 UR"SSS0UD6 g)NrjrtrM) thaw_endpointr)r2rs r%rt Channel.readys$  4'4V4r(finalrcURceURRXS9$![an[S[ U5S9UeSnAff=f)Nrrr)ridecodeUnicodeDecodeErrorr[rI)r2rrrs r%__decode_frameChannel.__decode_framesV||''' L<<&&t&9 9! L/SB K Ls* A AA c\URbURSSS9 URSS9 g)Nr(Trru)rj)ri_Channel__decode_framerrNs r%ru Channel.dones0 << #   4  0 &)r(cURSL$r!)rfrNs r% is_closingChannel.is_closingst++r(c:URUR5 gr!)shutdown_endpointrfrNs r% _close_nowChannel._close_nows t//0r(cURRU5 URb#UR(dUR5 gggr!)rdremoverfr)r2tasks r% _task_doneChannel._task_dones: 4    ' OO 1< 'r(cURbe[R"U5nURR U5 UR UR 5 U$)zCreate a task associated with the channel. All tasks must exit before the channel can close. You may not create new tasks after calling .close(). )rfasyncio create_taskrdaddadd_done_callbackr)r2 coroutinenamers r%rChannel.create_task sM '''""9-  t/ r(cURbgU=(d 0UlUR(dUR5 gg)zRequests the channel to be closed. After you call this method, you won't get anymore `.do_*()` calls. This will wait for any running tasks to complete before sending the close message. N)rfrdr)r2 close_argss r%rv Channel.closes6    ' %+{{ OO r(cNURURU5 UR(a`UR[ U5-nUR[ R -U[ R -:waURSUS9 X lURUR:$)a[Send binary data and handle book-keeping for flow control. The flow control is "advisory". The data is sent immediately, even if it's larger than the window. In general you should try to send packets which are approximately Channel.BLOCK_SIZE in size. Returns True if there is still room in the window, or False if you should stop writing for now. In that case, `.do_resume_send()` will be called later when there is more room. Be careful with text channels (i.e. without binary="raw"): you are responsible for ensuring that @data is valid UTF-8. This isn't validated here for efficiency reasons. rw)rjsequence) send_channel_datarnr`rar"r^ BLOCK_SIZErrb)r2r out_sequences r% send_bytesChannel.send_bytes$s t||T2   --D 9L!!W%7%77<7K]K];]]!!&<!H!- !!D$4$444r(cUR(aURU5$URc[R"S5"SS9UlUR UR U55$)aSend data and transparently handle UTF-8 for text channels Use this for channels which can be text, but are not guaranteed to get valid UTF-8 frames -- i.e. multi-byte characters may be split across frames. This is expensive, so prefer send_text() or send_bytes() wherever possible. zutf-8strict)errors)rhrricodecsgetincrementaldecoder send_textrrs r% send_dataChannel.send_data=sW >>??4( ( << !77@QDL~~d11$788r(c@URUR55$)zSend UTF-8 string data and handle book-keeping for flow control. Similar to `send_bytes`, but for text data. The data is sent as UTF-8 encoded bytes. )rencoders r%rChannel.send_textNs t{{}--r(msgc rURR[X55S-nURU5$)N ) json_encoderrrr)r2rrprettys r% send_jsonChannel.send_jsonUs1""))-*DEL~~f%%r(cUR(d![RSUR5 gUS[R -UlURUR :aUR5 gg)NzGot wild pong on channel %sr) r`loggerwarningrnr^ SEND_WINDOWrbrado_resume_sendrs r%rChannel.do_pongYs^ NN8$,, G ":.1D1DD    0 0 0    ! 1r(cg)zURURSU5 g)Nrxrrs r%rChannel.send_pongks !!$,,@r() rcrfrarbr`rdrnrirqrhr6Nr!)rrer6N)5rRrSrTrUrrr`rWrVraintrbrfr#r:rnrqrIr rrrr{r|r}r~rrrprrrrrtrrurrrrrvrrrrrrjson JSONEncoderrrrrXrMr(r%r^r^gskJ!KKM3"K" '+K$+=?L:?.0L+0G EO //%#% %t%8 (# ( (j (UY ( L   X\ "z"d"  a*aa z d 6U6t6 (s (% (D ( E m 5i5D5>$''--/( ( JJs}} ' ' (s0A A6 A11A6cVURceURR5 gr!)rresume_readingrNs r%rProtocolChannel.do_resume_sends"*** &&(r(cSUlUR(a*URceURR5 gg)a|Mark the channel to be closed on EOF. Normally, ProtocolChannel tries to keep the channel half-open after receiving EOF from the transport. This instructs that the channel should be closed on EOF. If EOF was already received, then calling this function will close the channel immediately. If you don't call this function, you are responsible for closing the channel yourself. TN)r r rrvrNs r% close_on_eofProtocolChannel.close_on_eofs8" 99??. .. OO ! ! # r(cRSUlUR5 UR(+$NT)r rur rNs r% eof_receivedProtocolChannel.eof_receiveds!  %%%%r(cVUR(aURU5 gXlgr!)rrrrs r%rProtocolChannel.do_pings    NN7 #&Or(cSUlg)NF)rrNs r% pause_writingProtocolChannel.pause_writings  r(crSUlURb#URUR5 SUlggr5)rrrrNs r%resume_writingProtocolChannel.resume_writings0 ?? & NN4?? +"DO 'r()r rr rrr)rzasyncio.Task[asyncio.Transport]r6N)rzException | Noner6Nr)%rRrSrTrU__doc__rrVrrWrrrr r rAbstractEventLoopr rr r{r BaseTransportrrrrprr}r~r,rr2r6rr;r>rXrMr(r%rros .2J*1K&*J#*GKDK'+K$+ M4D$"7+D+D"z"^e^o^o"RzRdR $)>)>$4$+$E$d$( $(%(D()$$&d& &!#r(rc\rSrSr%SrS\S'\R\S'SrS\ SS 4S jr S\ SS4S jr SS jr S \ SS4SjrSSjrS\SS4SjrSSjrS\ SS4SjrSSjrSSjrS\ SS4SjrS \ S\4SjrSrg) AsyncChanneliaA subclass for async/await-style implementation of channels, with flow control This subclass provides asynchronous `read()` and `write()` calls for subclasses, with familiar semantics. `write()` doesn't buffer, so the `done()` method on the base channel class can be used in a way similar to `shutdown()`. A high-level `sendfile()` method is available to send the entire contents of a binary-mode file-like object. The subclass must provide an async `run()` function, which will be spawned as a task. The task is cancelled when the channel is closed. On the receiving side, the channel will respond to flow control pings to indicate that it has received the data, but only after it has been consumed by `read()`. On the sending side, write() will block if the channel backs up. z(asyncio.Queue[bytes | JsonObject | None] receive_queuer Nr@r6rec# [e7fr!rrs r%runAsyncChannel.run s !!rc # [R"5UlURUR U5IShvN 5 gN ![R a UR5 g[ a)nURUR55 SnAgSnAf[a'nURS[U5S.5 SnAgSnAf[a) URS[R"5S.5 ef=f7f)Nr)problemrkzinternal-error)rJcause) rrr rvrGCancelledErrorr[rr rI BaseException traceback format_exc)r2r@rs r% run_wrapperAsyncChannel.run_wrappers 002DI JJTXXg.. /.%%  JJL ( JJs}} ' ' K JJ#3CI J J  JJ#3i>R>R>TU V  s\D9A AA DA $D-D/ D8BD D)C D 6DDc# URR5IShvN nUcg[U[5(aUR U5 OUR U5 U$MbND7fr!)rErBrHrrr)r2items r%readAsyncChannel.reads[ ++//11D|$((t$ d# 1sA(A&AA(rc# URU5(d4URR5UlURIShvN ggN7fr!)rr  create_future write_waiterrs r%r"AsyncChannel.write-s@~~d## $ 7 7 9D ## # #$ #sAAAAc`# URR"SU/UQ70UD6IShvN $N7fr!)r run_in_executor)r2fnargsrs r% in_threadAsyncChannel.in_thread2s,YY..tRI$I&IIIIs %.,.streamc,# U URRSUR[R5IShvN nUS:XaOUR U5IShvN M_UR 5 SSS5 gN?N!!,(df  g=f7f)Nr()r r[rTr^rr"ru)r2r`rs r%sendfileAsyncChannel.sendfile5sr !YY66tV[['J\J\]]3;jj&&&  IIKV]' Vs?B:BA?BB B6 B?BB B BcdURb#URRS5 SUlggr!)rX set_resultrNs r%rAsyncChannel.do_resume_send?s/    (    ( ( . $D  )r(c[R"5UlURUR U5UR R SUS3S9Ulg)Nz .run_wrapper())r)rQueuerErrPr4rR _run_taskrs r%r{AsyncChannel.do_openDsS$]]_))$*:*:7*C26..2I2I1J-X_W``a/b*dr(c:URRS5 gr!rE put_nowaitrNs r%r}AsyncChannel.do_doneIs %%d+r(c8URR5 gr!)rjcancelrNs r%r~AsyncChannel.do_closeLs r(rkc:URRU5 gr!rmrs r%rAsyncChannel.do_pingOs %%g.r(c:URRU5 gr5rmrs r%rAsyncChannel.do_dataRs %%d+r()rjr rErX)r6z bytes | None)r\zCallable[_P, _T]r]z_P.argsrz _P.kwargsr6rr)rRrSrTrUr@rVrrArXr rGrPrTrpr"r^rrbrr{r}r~rrWrrXrMr(r%rDrDs*>=  # ##L""0C"    $$$$ JX$% dzddd , /z/d/Edr(rDcR\rSrSr%SrS\S'S\SS4SjrS\SS4S jrS S jr S r g) GeneratorChanneliWa A trivial Channel subclass for sending data from a generator with flow control. Calls the .do_yield_data() generator with the options from the open message and sends the data which it yields. If the generator returns a value it will be used for the close message. z"Generator[bytes, None, JsonObject]_GeneratorChannel__generatorr@r6c[er!rrs r% do_yield_dataGeneratorChannel.do_yield_data`rr(NcPURU5UlUR5 gr!)r{ryrrs r%r{GeneratorChannel.do_opencs!--g6 r(c6UR[UR55(a-UR[UR55(aM,gg![a5nUR 5 UR UR 5 SnAgSnAff=fr!)rnextry StopIterationrurvvalue)r2stops r%rGeneratorChannel.do_resume_sendgsl #..d&6&6!788..d&6&6!788 # IIK JJtzz " " #sAA B#+BB) __generatorr) rRrSrTrUr@rVr r{r{rrXrMr(r%rxrxWs; 65"Z"4X"zd#r(rx)+rrrloggingrNtypingrrrrrrr r jsonutilr r rrrrrprotocolrrrrr getLoggerrRr TYPE_CHECKINGTypeVarr ParamSpecrrr[r^ProtocolrrDrxrMr(r%rs$  ___bbb$11   8 $   B   $ B: : z > EAhEAP#gw//#Dc7cL#w#r(