+ iCcsRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI Ht^RIHtHtHt^RIHtHt]P,!R4P.tRRlt^t]P4!]4tRt!RR ]P<4t!R R ]P@4t!!R R 4t"!RR]]PF4t#!RR]4t$!RR4t%R#)zKBi-directional asyncio.Transport implementations based on file descriptors.N)Thread)AnyClassVarSequence) JsonObjectget_intcs(V^8dQhR\RR/#)argsreturnNintformat"7/usr/lib/python3.14/site-packages/cockpit/transports.py __annotate__rs((((cs8\V!^8wd \R4hR#)zprctl() failedN) sys_prctlOSError)rs*rprctlrs $1&''ricsaa]tRt^*toR2tRtR3V3RlV3RllltV3RlRltV3RlRltV3RlR lt V3R lR lt V3R lR lt V3RlRlt R4V3RlRllt V3RlRltV3RlRltV3RlRltV3RlRltR5V3RlRlltV3RlRltV3RlRltV3R lR!ltV3R"lR#ltV3R$lR%ltV3R&lR'ltV3R(lR)ltV3R*lR+ltV3R,lR-ltV3R.lR/ltV3R0ltR1tVtV;t #)6 _TransportFc s^<V^8dQhRS[PRS[PRS[RS[RR/#)rloopprotocolin_fdout_fdextrazdict[str, object] | NoneasyncioAbstractEventLoopProtocolr r __classdict__"rr_Transport.__annotate__9sG00"+++.3 rcsz<\SV`V4WnW n\P RWW44RVnRVnRVnRVn W0n W@n \P!VR4WC8wd\P!VR4VPPV4VP4R#)z/Created transport %s for protocol %s, fds %d %dNF)super__init___loop _protocolloggerdebug_queue _is_reading_eof_closing_in_fd_out_fdos set_blockingZconnection_maderesume_reading)selfrrrrr __class__s&&&&&&rr$Z_Transport.__init__9s  ! FX]f       u% ? OOFE * &&t, rc<V^8dQhRR/#rrNrr!rrr"TsTrcs\PRWPVP4\P !VP\ P4pTR8wd=\PR\T44TPPT4R#\PR4TP!4TPP#4pT'gTP%4R#R# \dR#\dUpTP'd'TP\P8XdRpRp?LTPT4Rp?R#Rp?ii;i)zRead ready on %s %s %dNrz read %d bytesz got EOF)r'r(r&r-r/readr BLOCK_SIZEBlockingIOErrorr _eio_is_eoferrnoZEIOabortlenZ data_received _close_readerZ eof_receivedclose)r2dataexcZ keep_open& r _read_readyZ_Transport._read_readyTs -t^^T[[Q 774;; (=(=>D 3; LL*CI 6 NN ( ( . LL %    335I %   CII$: 3 s)/C:: E&E&E&3E! E!!E&c <V^8dQhRS[/#rrboolrr!rrr"ms  D rcVP#N)r*r2&r is_readingZ_Transport.is_readingmrcr4r5r6rr!rrr"pstrcs4VP4RVnR#N) pause_readingr-rJrKrr>Z_Transport._close_readerps  rcr4r5r6rr!rrr"ts%%t%rcsVP'd/VPPVP4RVnR#R#)FN)r*r% remove_readerr-rJrKrrQZ_Transport.pause_readingts1     JJ $ $T[[ 1$D  rcr4r5r6rr!rrr"ys$$$rcsVP'gMVPR8wd:VPPVPVP4RVnR#R#R#)rOTNrP)r*r-r% add_readerrCrJrKrr1Z_Transport.resume_readingysIDKK2$5 JJ ! !$++t/?/? @#D %6rcr4r5r6rr!rrr"s   rcR#rIr6rJrKr_closeZ_Transport._closes rc"<V^8dQhRRRR/#)rrAzException | NonerNr6rr!rrr"s+trcsRVnVP4VP4VPP VP P V4VP4R#)TN)r,r>_remove_write_queuer%Z call_soonr&Zconnection_lostrU)r2rA&&rr<Z_Transport.abortsH     " T^^;;SA rcrDrErFrr!rrr"s""t"rc\hrIZNotImplementedErrorrJrKr can_write_eofZ_Transport.can_write_eof!!rcr4r5r6rr!rrr"sOO4OrcsVP'dQhRVnVPf)\PRV4VP 4R#\PRV4R#)TNz%s got EOF. closing backend.z,%s got EOF. bytes in queue, deferring close)r+r)r'r(_write_eof_nowrJrKr write_eofZ_Transport.write_eofsK999} ;;  LL8$ ?    ! LLG NrcrDrEr rr!rrr"s88s8rcsZVPf^#\RVP44#)Nc3s8"TFp\V4xK R#5irI)r=)Z.0block& rZ Z3_Transport.get_write_buffer_size..s7;%3u::;s)r)ZsumrJrKrget_write_buffer_sizeZ _Transport.get_write_buffer_sizes$ ;; 74;;777rcr4)rrztuple[int, int]r6rr!rrr"s):rcsR#)r)rrr6rJrKrget_write_buffer_limitsZ"_Transport.get_write_buffer_limitss rcs&<V^8dQhRRRRRR/#)rhigh int | NonelowrNr6rr!rrr"s#''L'l'^b'rcs>Ve V^8XgQhVe V^8XgQhR#R#rIr6)r2rcre&&&rset_write_buffer_limitsZ"_Transport.set_write_buffer_limitss(|tqy(({cQh&&h{rcr4r5r6rr!rrr"s"""rcrYrIrZrJrKrr]Z_Transport._write_eof_nowr\rcr4r5r6rr!rrr"sdrcs\PRV4VPfQh\P!VP VP4p\PRT4T'dTPP4p\T4T8d4\PR4TPPY1R4M*T\T4,p\PRT4KTP'g\PR4TP4TP'd&\PR4TP4TP'dTP4R#R#R# \ d^pELK\dpTPT4Rp?R#Rp?ii;i)z%s _write_readyNz, successfully wrote %d bytes from the queuez incomplete block. Stop.z& removed complete block. %d remains.z%s queue drained.z'%s queue drained. closing backend now.)r'r(r)r/Zwritevr.r9rr<Zpopleftr=Z appendleftrWr+r]r,)r2n_bytesrAr_rBr _write_readyZ_Transport._write_readys@ &-{{&&& ii dkk:G  CWMKK'')E5zG# 9: &&uX7 s5z !G LLA7 K{{{ LL, -  $ $ &yyy FG##%}}}  % G  JJsO  s#+F GG'G(F??Gcr4r5r6rr!rrr"sTrcsVPeIVPP4VPP VP 4RVnR#R#rI)r)r&Zresume_writingr%Z remove_writerr.rJrKrrWZ_Transport._remove_write_queues> ;; " NN ) ) + JJ $ $T\\ 2DK #rc$<V^8dQhRS[RR/#rr@rNbytesrr!rrr"s'''$'rcs2\PRWP4VPeQhVPP VPVP 4\P!V34VnVPP4R#)z!%s creating write queue for fd %sN) r'r(r.r)r%Z add_writerri collectionsZdequer&Z pause_writingr2r@rXr_create_write_queueZ_Transport._create_write_queuesg 8$ M{{""" dllD,=,=>!''0  $$&rcrjrkrlrr!rrr"s55%5D5rcsVP'd#\PRVP4R#VP'dQhVP eVP P V4\VP 4\8dQRPVP 4pVP P4VP P V4R#\P!VPV4pT\T48wdTP!YR4R#R# \d^pL6\dpTPT4Rp?R#Rp?ii;i)z+ignoring write() to closing transport fd %iNr)r,r'r(r.r+r)appendr=IOV_MAXjoinZclearr/writer9rr<rp)r2r@Zall_datarhrAs&& rrtZ_Transport.writes === LLF U 999} ;; " KK  t $4;;')88DKK0 !!# ""8,  hht||T2G c$i   $ $T(^ 4  G  JJsO  s$#!D++ E :E E EE cr4r5r6rr!rrr"s  t rcsVP'dR#RVnVP4VPeR#VP4R#)NT)r,r>r)r<rJrKrr?Z_Transport.closes7 ===    ;; "  rcs4<V^8dQhRS[P/#rErZ BaseProtocolrr!rrr"sg22rcrHrI)r&rJrKr get_protocolZ_Transport.get_protocols ~~rcrDrErFrr!rrr"sDrcrHrI)r,rJrKr is_closingZ_Transport.is_closings }}rc8<V^8dQhRS[PRR/#)rrrNrurr!rrr"s!""W%9%9"d"rcrYrIrZ)r2rrXr set_protocolZ_Transport.set_protocolr\rcr4r5r6rr!rrr" src&VP4R#rI)rUrJrKr__del__Z_Transport.__del__ s  rcs<V^8dQh/S[S[,;R&S[P;R&S[P;R&R;R&S[;R&S[;R&S[;R&S[;R &S[;R &S[;R &#) rr8r%r&zcollections.deque[bytes] | Noner)r-r.r,r*r+r:)rr rrrrGrr!rrr"*s +  $ $$    .- KLN Jr)r,r+r-r*r%r.r&r)i)rPrPNrI)NN)!__name__ __module__ __qualname____firstlineno__r8r:r$rCrLr>rQr1rUr<r[r^rarbrgr]rirWrprtr?rvrwryr{__annotate_func____static_attributes____classdictcell__ __classcell__r3r @@rrr*s +JK62  %% $$  ""OO88 ''""B ''55@  ""Arrcs6a]tRtRtoRtV3RlRltRtVtR#)SubprocessProtocolizBAn extension to asyncio.Protocol for use with SubprocessTransport.cr4r5r6rr!rrZSubprocessProtocol.__annotate__s"""rc rY)z"Called when subprocess has exited.rZrJrKrprocess_exitedZ!SubprocessProtocol.process_exiteds!!rr6N)r|r}r~r__doc__rrrr @rrrsL""rrcs2a]tRtRtoV3RlRltRtVtR#) WindowSizeicrD)rvalue)rrr!rrZWindowSize.__annotate__s++j+rcsJ\VR4Vn\VR4VnR#)rowscolsN)rrr)r2rrXrr$ZWindowSize.__init__sE6* E6* r)rrN)r|r}r~rr$rrrrrrrs++rrcsFaa]tRtRtoRtRtRtRtRR/V3RlRlltV3RlR lt R RR R/V3R lV3R lllt V3RlRlt V3RlRlt V3RlRlt V3RlRltV3RlRltV3RlRltV3RlRltV3RlRltV3RlRltV3R lR!ltV3R"ltR#tVtV;t#)$SubprocessTransportiaA bi-directional transport speaking with stdin/out of a subprocess. Note: this is not really a normal SubprocessTransport. Although it implements the entire API of asyncio.SubprocessTransport, it is not designed to be used with asyncio.SubprocessProtocol objects. Instead, it pair with normal Protocol objects which also implement the SubprocessProtocol defined in this module (which only has a process_exited() method). Whatever the protocol writes is sent to stdin, and whatever comes from stdout is given to the Protocol via the .data_received() function. If stderr is configured as a pipe, the transport will separately collect data from it, making it available via the .get_stderr() method. NresetFc&<V^8dQhRS[RS[/#rrr)rGstrrr!rr SubprocessTransport.__annotate__0s4CrcszVPe-VPPVR7PRR7#R#)N)rZreplace)ZerrorsZ)_stderrgetZdecode)r2rs&$r get_stderrZSubprocessTransport.get_stderr0s5 << #<<##%#077y7I IrcrV)rprocesszsubprocess.Popen[bytes]rNr6rr!rrr6s ff";ffrcsLaaaaRVV3RlloRVVVV3RllpRVVV3Rllp\P!SP4oSPP SV4R # \ \ 3d.\RSP 2TRR7P4R #i;i) cs4V^8dQhR\R\RR/#)rpidstatusrNr r r rr4SubprocessTransport.watch_exit..__annotate__7s! 0 0c 03 04 0rcsv<VSP8XgQh\SP\4'gQh\P !V4Sn\PRSP 4SP'gSPP4R#R# \d TSnLdi;i)zProcess exited with status %dN) rZ isinstancer&rr/Zwaitstatus_to_exitcode _returncodeZ ValueErrorr'r(r,r)rrrr2s&&r child_exitedZ4SubprocessTransport.watch_exit..child_exited7s'++% %%dnn.@AA AA *#%#<#.pidfd_readyDs>**W[[!4KC JJ $ $U + HHUO  %rcrr5r6r r rrrJs G G Grcs<\P!SP^4wrSPP SW4R#r)r/rrr%Zcall_soon_threadsafe)rrrrr2s rwaitpid_threadZ6SubprocessTransport.watch_exit..waitpid_threadJs-**W[[!4KC JJ + +L# Frzcockpit-waitpid-T)ZnameZtargetZdaemonN) r/Z pidfd_openrr%rSZAttributeErrorrrZstart)r2rrrrrsff @@r watch_exitZSubprocessTransport.watch_exit6s 0 0 & &  G G  fMM'++.E JJ ! !% 5( f *7;;-8X\ ] c c e fs.__annotate__`s 5 5D 5rcs<\\\P4S'd)\P !^\ P^4R#R#r)r SET_PDEATHSIGsignalSIGTERMfcntlioctltermiosZ TIOCSCTTY)rsr preexec_fnZ0SubprocessTransport.__init__..preexec_fn`s/ - 0 Aw00!4rNstderrstdinstdoutrZstart_new_sessionT)r/Zopenpty_pty_fdset_window_size subprocessZPopen_processr?r:ZPIPErrZfilenorSpoolerrr#r$r) r2rrrrrrrZ session_fdrrr3s &&&&d$, rr$ZSubprocessTransport.__init__Vs 5 5 ')zz| $DL*!$$V,)8 &,,Tf3=fFPf8BfVZf^dfDM HHZ  LL$,,6#D ',,TNNQ[Q`Q`N8BNFLNDM==&&& &&==''' ''MM((//1E]]((//1F ==   +"4)=)=)D)D)FGDLDL 7  &rcrj)rsizerN)rrr!rrrsWWJW4Wrc s0VPfQh\^\VPR44p\^\VPR44p\ P !VP\P\P!RW#44R#)NZ2H4xi) rZmaxZminrrrrrZ TIOCSWINSZstructZpack)r2rrrs&& rrZ#SubprocessTransport.set_window_sizese||'''1c$))Y/01c$))Y/0 DLL'"4"4fkk&$6UVrcrDrErFrr!rrrs//t/rcsRVPfQhVPPRJ#rI)rrrJrKrr[Z!SubprocessTransport.can_write_eofs'}}(((}}""$..rcr4r5r6rr!rrrsrcsVPfQhVPPfQhVPPP4RVnR#)NrP)rrr?r.rJrKrr]Z"SubprocessTransport._write_eof_nowsE}}(((}}""... !!# rcrDrEr rr!rrrs!!!rcsNVPfQhVPP#rI)rrrJrKrget_pidZSubprocessTransport.get_pids"}}(((}}   rcr4)rrrdr6rr!rrrs   rcrHrI)rrJrKrget_returncodeZ"SubprocessTransport.get_returncoderMrcs:<V^8dQhRS[RS[P/#)rfdr)r r Transportrr!rrrs!""S"W->->"rcrYrIrZ)r2rrXrget_pipe_transportZ&SubprocessTransport.get_pipe_transportr\rcrx)rsigrN)rZSignalsrr!rrrs#hhv~~h$hrcsVPfQhVPe-\PRWPP4R#\ P !VPPV4\PRWPP4R# \d/\PRYPP4R#i;i)Nz3won't attempt %s to process %i. It exited already.zsent %s to process %iz3can't send %s to process %i. It's exited just now.)rrr'r(rr/killZProcessLookupError)r2rrXr send_signalZSubprocessTransport.send_signals}}(((    ' LLNPSUbUbUfUf g  h GGDMM%%s + LL0#}}7H7H I! h LLNPSUbUbUfUf g hs AB##5CCcr4r5r6rr!rrrs))4)rcDVP\P4R#rI)rrrrJrKr terminateZSubprocessTransport.terminate (rcr4r5r6rr!rrrs))d)rcrrI)rrZSIGKILLrJrKrrZSubprocessTransport.killrrcr4r5r6rr!rrrs N N NrcsVPe(\P!VP4RVnVPeaVPPe6VPPP4RVPnVP 4R#R# \ d/\PRTPP4R#i;i)Nzcan't kill %i due to EPERM) rr/r?rrrZPermissionErrorr'r(rrJrKrrUZSubprocessTransport._closes << # HHT\\ "DL == $}}"". ##))+&* # N % # N 94==;L;LM NsB&&5CCcsB<V^8dQh/R;R&R;R&R;R&R;R&#)rrdrzsubprocess.Popen[bytes] | NonerrzSpooler | Nonerr6rr!rrrs9  !"/5#$$%&'r)r:r.rrrr)r|r}r~rrrrrrrr$rr[r]rrrrrrrUrrrrrrrrrs !G15H $K% ff@,' # ,' 04 ,','\WW // !!  ""hh0)))) N NCrrcsjaa]tRtRtoRtR V3RlV3RllltV3RlRltV3RlRltR tVt V;t #) StdioTransportizA bi-directional transport that corresponds to stdin/out. Can talk to just about anything: - files - pipes - character devices (including terminals) - sockets csZ<V^8dQhRS[PRS[PRS[RS[/#)rrrrrrrr!rrStdioTransport.__annotate__s788W668'BRBR8[^8lo8rcs(<\SV`WW44R#rI)r#r$)r2rrrrr3s&&&&&rr$ZStdioTransport.__init__s 7rcrDrErFrr!rrrstrcrT)Fr6rJrKrr[ZStdioTransport.can_write_eofsrcr4r5r6rr!rrrs888rcs\R4h)zCan't write EOF to stdout)Z RuntimeErrorrJrKrr]ZStdioTransport._write_eof_nows677rr6)rrO) r|r}r~rrr$r[r]rrrrrrrrs-88888rrcsa]tRtRtoRtV3RlRltV3RlRltV3RlRltR R /V3R lR lltV3R lRlt V3RlRlt V3Rlt Rt Vt R#)rizConsumes data from an fd, storing it in a buffer. This makes a copy of the fd, so you don't have to worry about holding it open. cs:<V^8dQhRS[PRS[/#)rrrrrr rr!rrSpooler.__annotate__s!44W664C4rcsWnRVn.Vn\P!V4Vn\P !VPR4VP VPVP4R#)rOFNrP)r%_fd _contentsr/Zdupr0rSrC)r2rrrfrr$ZSpooler.__init__sN 66": %( $"2"23rcr4r5r6rr!rrrs  T rcs\P!VPR4pTR8wdTP P T4R#TP4R# \dR#\dRpLRi;i)i Nr)r/r7rr9rrrqr?ror`rrCZSpooler._read_readys` 77488T*D 3; NN ! !$ ' JJL   D s!A A6'A60A65A6crDrErFrr!rrrsDD4Drcs|VPR8XdR#\P!VP...^4...38g#)rOFrP)rselectrJrKr _is_readyZSpooler._is_readys6 88r>}}dhhZR3B|CCrrFcrr)rGrmrr!rrrsDUrcsVP4'dVP4K(RPVP4pV'd.VnV#)r)rrCrsr)r2rZresults&$ rrZ Spooler.gets<nn    $..) DN rcr4r5r6rr!rrrstrcsVPR8wdOVPPVP4\P!VP4RVnR#R#rN)rr%rRr/r?rJrKrr?Z Spooler.closes? 88r> JJ $ $TXX . HHTXX DH rcr4r5r6rr!rrrsrcrzrI)r?rJrKrr{ZSpooler.__del__s  rcsP<V^8dQh/S[P;R&S[;R&R;R&#)rr%rz list[bytes]rrrr!rrrs1  $ $$ Hr)rrr%N)r|r}r~rrr$rCrrr?r{rrrrrrrrsW44  DD 5 orr)&rrrnZctypesr;rZloggingr/rrrrrZ threadingrZtypingrrrZjsonutilrrZCDLLrrrZ getLoggerr|r'rrrrrrrrrrr6rrrs R  **) KK  # # (     8 $ a""aH"))"++ mN*g&A&AmN`8Z8(88r