+ i&cs^RIt^RIt^RIt^RIHtHtHt^RIHtH t ^RI H t H t H t ]P!]4t!RR4t!RR4t!R R ] 4t!R R 4t!R R] 4tR#)iN)DictListOptional) JsonObject JsonValue)CockpitProblemCockpitProtocolErrorCockpitProtocolServercsBa]tRt^toRtRtRtV3RlRltRtVt R#)ExecutionQueuea_Temporarily delay calls to a given set of class methods. Functions by replacing the named function at the instance __dict__ level, effectively providing an override for exactly one instance of `method`'s object. Queues the invocations. Run them later with .run(), which also reverses the redirection by deleting the named methods from the instance. cs\P!4VnWnVPFpVP V4K R#N) collectionsZdequequeuemethods_wrap)selfr method&& 3/usr/lib/python3.14/site-packages/cockpit/router.py__init__ZExecutionQueue.__init__s1 &&(  llF JJv #csjaa\SPSPPVV3Rl4R#)cs><SPPSV34#r )r Zappend)argsrrs*rZZ&ExecutionQueue._wrap..%sIZIZ\bdh[iIjrN)Zsetattr__self____func____name__)rrsffrr ZExecutionQueue._wrap!s  !9!9;jkrc<V^8dQhRR/#returnNZformat __classdict__"r __annotate__ZExecutionQueue.__annotate__'s??T?rcs\PR\VP44VPF wrV!V!K VPF-p\ VP VPP4K/ R#)z.ExecutionQueue: Running %d queued method callsN) loggerdebuglenr r Zdelattrrrr)rrr& rrunZExecutionQueue.run'sX Es4::W JJLF DM'llF FOOV__%=%= >#r)r r N) r __module__ __qualname____firstlineno__Z__doc__rr r%__static_attributes____classdictcell__r@rrrsl ??rrcsa]tRt^0toRtV3RlRltV3RlRltV3RlRltV3RlR ltV3R lR lt V3R lR lt V3RlRlt V3RlRlt V3RlRlt RV3RlRlltV3RltRtVtR#)EndpointNcrrrouterRouterrrrrr Endpoint.__annotate__4sxrcs4VPV4WnR#r ) add_endpointr/rr/&&rrZEndpoint.__init__4sD! rcrrrrrrr r18suuurcs\PRV4\VPVPVP 04VnR#)zFreezing endpoint %sN)r!r"rdo_channel_controldo_channel_datado_kill _Endpoint__endpoint_frozen_queuer&rfreeze_endpointZEndpoint.freeze_endpoint8s9 +T2'5t7N7NPTPdPdfjfrfr6s't$rcrrrrrrr r1=s,,t,rcst\PRV4VPP4RVnR#)zThawing endpoint %sN)r!r"r8r%r9r:r thaw_endpointZEndpoint.thaw_endpoint=s+ *D1 $$((*'+$rcrrrrrrr r1D""$"rc\hr ZNotImplementedErrorr9r:rdo_closeZEndpoint.do_closeD!!rc0<V^8dQhRS[RS[RS[RR/#rchannelcommandmessagerNstrrrrrr r1Gs*""#""j"UY"rcr>r r?)rrDrErF&&&&rr5ZEndpoint.do_channel_controlGrArc*<V^8dQhRS[RS[RR/#rrDdatarNrHZbytesrrrr r1Js"""s"%"D"rcr>r r?rrDrL&&&rr6ZEndpoint.do_channel_dataJrArc,<V^8dQhRRRRRS[RR/#rhostz str | NonegrouprFrNrrrrr r1Ms*""L"" "W["rcr>r r?)rrRrSrFrIrr7ZEndpoint.do_killMrArcrJrKrMrrrr r1Qs"666E6d6rcs<VPPW4R#r )r/Zwrite_channel_datarNrOrsend_channel_dataZEndpoint.send_channel_dataQs &&w5rc s4<V^8dQhRS[RS[RRRS[RR/#)rrDrEmsgJsonObject | NonekwargsrN)rHrrrrr r1Ts5...%(./B.NW. .rc sVPP!V3RVRV/VBVR8XdJVPPV,PV4VPP V4R#R#)rDrEcloseN)r/ write_control endpointsZremove drop_channel)rrDrErVrXs&&&&,rsend_channel_controlZEndpoint.send_channel_controlTsa !!#RwRR6R g  KK ! !$ ' . .w 7 KK $ $W - rcs(<V^8dQhRRRS[RR/#)rrVrWrXrN)rrrrr r1\s$;;%8;9;Y];rc s@VPP!W3/VBR#r )r/shutdown_endpoint)rrVrXs&&,rr^ZEndpoint.shutdown_endpoint\s %%d:6:rcs@<V^8dQh/R;R&S[S[,;R&#)rr0r/r8)rrrrrr r10s %n5<r)Z__endpoint_frozen_queuer/r )rr&r'r(r8rr;r<r@r5r6r7rUr]r^__annotate_func__r)r*r+r,rr-r-0sy8<uu ,,""""""""66..;;Yrr-cs]tRt^`tRtR#) RoutingErrorrN)rr&r'r(r)rrrr`r``srr`csba]tRt^dtoV3RlRltV3RlRltV3RlRltV3RltRtVt R #) RoutingRulecrr.rrrrr RoutingRule.__annotate__gsxrcsWnR#r r/r3r4rrZRoutingRule.__init__gs rcs6<V^8dQhRS[RS[S[,/#roptionsr)rrr-rrrr rbjs " "* "(1C "rc r>)a5Check if a routing rule applies to a given 'open' message. This should inspect the options dictionary and do one of the following three things: - return an Endpoint to handle this channel - raise a RoutingError to indicate that the open should be rejected - return None to let the next rule run r?)rrer4r apply_ruleZRoutingRule.apply_rulejs "!rcrrrrrrr rbur=rcr>r r?r9r:rshutdownZRoutingRule.shutdownurArcs$<V^8dQh/R;R&#)rr0r/rrrrr rbds rrcN) rr&r'r(rrfrgr_r)r*r+r,rrarads* " """#rracsa]tRt^ytoRtV3RlRltV3RlRltV3RlRltV3RlR ltV3R lR lt RV3R lRllt V3RlRlt V3RlRlt V3RlRlt V3RlRltR tV3RlRltV3RlRltV3RltRtVtR #)r0Fcs0<V^8dQhRS[S[,/#)r routing_rules)rrarrrr Router.__annotate__s  d;&7 rcsVF pWnK Wn/Vn/Vn\P !4VnVP P4R#r )r/rh open_channelsr[asyncioEvent no_endpointsset)rrhrulerrrZRouter.__init__sF!DK"*#MMO rc <V^8dQhRS[/#rrrTrrrr risjrc s/#)z7Used by the 'info' channel. Gets overridden in Bridge.rr9r:rinfoZ Router.infos rcs&<V^8dQhRS[RS[/#rd)rr-rrrr ris 0 0: 0( 0rcsVPFHp\PRV4VPV4pVfK0\PRV4Vu# \PR4\ R4h)z applying rule %sz resulting endpoint is %sz No rules matchedz not-supported)rhr!r"rfr`)rreroendpoints&& r check_rulesZRouter.check_rulessc&&D LL-t 4w/H# ;XF ' LL- ./ /rc$<V^8dQhRS[RR/#)rrDrN)rHrrrr rishhChDhrcsVPPV4\PRV4R# \d%\P RYP4R#i;i)zrouter dropped channel %sz.trying to drop non-existent channel %s from %sN)rjpopr!r"KeyErrorZerror)rrDr4rr\ZRouter.drop_channelsQ h    " "7 + LL4g > h LLI7TfTf g hs15+A$#A$cru)rrsrN)r-rrrr ris""X"$"rcsh\4VPV&VPP4R#r )rnr[rmZclear)rrsr4rr2ZRouter.add_endpoints$#&5x  !rNcs.<V^8dQhRS[RRRS[RR/#)rrsrVrWrXrN)r-rrrrr ris,''('9L'_h'mq'rc s:VPPV4p\PRWV4VF+pVP!V3RRRV/VBVP V4K- VP'gVP P4VP'dz\PRVP4VP'gFVP'd2\PR4VPP4R#R#R#R#)z'shutdown_endpoint(%s, %s) will close %srErYrD endpoints remaining: %rz close transportN) r[rvr!r"rZr\rmrn_eofZ transportrY)rrsrVrXZchannelsrDs&&&, rr^ZRouter.shutdown_endpoints>>%%h/ >RZ[G   s OG OW O O   g & ~~~    ! ! # 999 LL4dnn E>>>dnnn 01$$&'5> rcrPrQrTrrrr ris*33L33 3W[3rcs\VP4p\PRW\ V44VFpVP WV4K R#)z+do_kill(%s, %s). Considering %d endpoints.N)rnr[r!r"r#r7)rrRrSrFr[rs&&&& rr7ZRouter.do_killsB'  BDQTU^Q_`!H   T' 2"rcrBrCrGrrrr ris*???c?J?[_?rcs2VPf \R4hVR8XdWP9d \R4h\P RWP R44VP V4pY@PT&TPT,PT4MVPV,pTPYT4R# \d.pTPTP4RTR7Rp?R#Rp?ii;i \dR#i;i)Nz,channel control message received before initZopenzchannel is already openz5Trying to find endpoint for new channel %s payload=%sZpayloadrY)rErD) init_hostrrjr!r"Zgetrtr`rZZ get_attrsr[Zaddrwr5)rrDrErFrsexcrzrchannel_control_receivedZRouter.channel_control_receiveds >> !&'UV V f ,,,*+DEE  TV]_j_jkt_uv++G4 +3  w ' NN8 $ ( ( 1 --g6 ##Gg>  ""3==?GW"U   s)6C %D D"C??D DDcrJrKrMrrrr ris" 0 0S 0 0$ 0rcsVPf \R4hVPV,pTP Y4R# \dR#i;i)Nz)channel data message received before init)r{rrjrwr6)rrDrLrss&&& rchannel_data_receivedZRouter.channel_data_receivedsQ >> !&'RS S ))'2H   /   sA AAcrprq)boolrrrr ris $ $d $rcs\PRV4\VP4pVFpVP 4K RVn\PRVP4\ VP4#)zeof_received(%r)Trx)r!r"rnr[r@ryr)rr[rsr$r eof_receivedZRouter.eof_receiveds` '.' !H    "  0$..ADNN##rcs4<V^8dQhRS[S[,RR/#)rr|rN)rZ Exceptionrrrr ris < BBBB5%B2+B.,B22B5cs<V^8dQh/S[S[,;R&S[S[S[3,;R&R;R&S[P ;R&S[;R&S[S[P,;R&#)rrhrjzdict[Endpoint, set[str]]r[rmryr) rrarrHr-rkrlrrZFuturerrrr riysl $$X &&*)--   j"'..18kr)rryr[rmrjrhr )rr&r'r(ryrrrrtr\r2r^r7r}r~rrrrr_r)r*r+r,rr0r0ys D   0 0hh""''"33 ??< 0 0 $ $59 < < + +Err0)rkr ZloggingZtypingrrrZjsonutilrrZprotocolrrrZ getLoggerrr!rr-r`rar0rrrrsi ''+QQ   8 $??>-;-;` > ""*O+ "O+r