+ OiCRt^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_intc(V^8dQhR\RR/#)argsreturnNint)formats"4/usr/lib/python3/dist-packages/cockpit/transports.py __annotate__rs((((c8\V!^8wd \R4hR#)zprctl() failedN) sys_prctlOSError)r s*rprctlrs $1&''ricaa]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 ^<V^8dQhRS[PRS[PRS[RS[RR/#)r loopprotocolin_fdout_fdextrazdict[str, object] | NoneasyncioAbstractEventLoopProtocolr )r __classdict__s"rr_Transport.__annotate__9sG00"+++.3 rcz<\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_blockingconnection_maderesume_reading)selfrrrrr __class__s&&&&&&rr'_Transport.__init__9s  ! FX]f       u% ? OOFE * &&t, rc<V^8dQhRR/#r r N)rr#s"rrr$TsTrc\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)r0r2readr BLOCK_SIZEBlockingIOErrorr _eio_is_eoferrnoEIOabortlen data_received _close_reader eof_receivedclose)r6dataexc keep_opens& r _read_ready_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[/#r r bool)rr#s"rrr$ms  D rcVP#N)r-r6s&r is_reading_Transport.is_readingmrc<V^8dQhRR/#r:r;)rr#s"rrr$pstrc4VP4RVnR#N) pause_readingr0rTs&rrF_Transport._close_readerps  rc<V^8dQhRR/#r:r;)rr#s"rrr$ts%%t%rcVP'd/VPPVP4RVnR#R#)FN)r-r( remove_readerr0rTs&rr]_Transport.pause_readingts1     JJ $ $T[[ 1$D  rc<V^8dQhRR/#r:r;)rr#s"rrr$ys$$$rcVP'gMVPR8wd:VPPVPVP4RVnR#R#R#)r[TNr\)r-r0r( add_readerrLrTs&rr5_Transport.resume_readingysIDKK2$5 JJ ! !$++t/?/? @#D %6rc<V^8dQhRR/#r:r;)rr#s"rrr$s   rcR#rSr;rTs&r_close_Transport._closes rc"<V^8dQhRRRR/#)r rJzException | Noner Nr;)rr#s"rrr$s+trcRVnVP4VP4VPP VP P V4VP4R#)TN)r/rF_remove_write_queuer( call_soonr)connection_lostri)r6rJs&&rrC_Transport.abortsH     " T^^;;SA rc <V^8dQhRS[/#rOrP)rr#s"rrr$s""t"rc\hrSNotImplementedErrorrTs&r can_write_eof_Transport.can_write_eof!!rc<V^8dQhRR/#r:r;)rr#s"rrr$sOO4OrcVP'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_nowrTs&r write_eof_Transport.write_eofsK999} ;;  LL8$ ?    ! LLG Nrc <V^8dQhRS[/#rOr )rr#s"rrr$s88s8rcZVPf^#\RVP44#)Nc38"TFp\V4xK R#5irS)rD).0blocks& r 3_Transport.get_write_buffer_size..s7;%3u::;s)r,sumrTs&rget_write_buffer_size _Transport.get_write_buffer_sizes$ ;; 74;;777rc<V^8dQhRR/#)r r ztuple[int, int]r;)rr#s"rrr$s):rcR#)r)rrr;rTs&rget_write_buffer_limits"_Transport.get_write_buffer_limitss rc&<V^8dQhRRRRRR/#)r high int | Nonelowr Nr;)rr#s"rrr$s#''L'l'^b'rc>Ve V^8XgQhVe V^8XgQhR#R#rSr;)r6rrs&&&rset_write_buffer_limits"_Transport.set_write_buffer_limitss(|tqy(({cQh&&h{rc<V^8dQhRR/#r:r;)rr#s"rrr$s"""rc\hrSrsrTs&rrz_Transport._write_eof_nowrwrc<V^8dQhRR/#r:r;)rr#s"rrr$sdrc\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,r2writevr1r?rrCpopleftrD appendleftrmr.rzr/)r6n_bytesrJrs& r _write_ready_Transport._write_readys@ &-{{&&& ii dkk:G  CWMKK'')E5zG# 9: &&uX7 s5z !G LLA7 K{{{ LL, -  $ $ &yyy FG##%}}}  % G  JJsO  s#+F GG'G(F??Gc<V^8dQhRR/#r:r;)rr#s"rrr$sTrcVPeIVPP4VPP VP 4RVnR#R#rS)r,r)resume_writingr( remove_writerr1rTs&rrm_Transport._remove_write_queues> ;; " NN ) ) + JJ $ $T\\ 2DK #rc$<V^8dQhRS[RR/#r rIr Nbytes)rr#s"rrr$s'''$'rc2\PRWP4VPeQhVPP VPVP 4\P!V34VnVPP4R#)z!%s creating write queue for fd %sN) r*r+r1r,r( add_writerr collectionsdequer) pause_writingr6rIs&&r_create_write_queue_Transport._create_write_queuesg 8$ M{{""" dllD,=,=>!''0  $$&rc$<V^8dQhRS[RR/#rr)rr#s"rrr$s55%5D5rcVP'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+r1r.r,appendrDIOV_MAXjoinclearr2writer?rrCr)r6rIall_datarrJs&& rr_Transport.writes === LLF U 999} ;; " KK  t $4;;')88DKK0 !!# ""8,  hht||T2G c$i   $ $T(^ 4  G  JJsO  s$#!D++ E :E E EE c<V^8dQhRR/#r:r;)rr#s"rrr$s  t rcVP'dR#RVnVP4VPeR#VP4R#)NT)r/rFr,rCrTs&rrH_Transport.closes7 ===    ;; "  rc4<V^8dQhRS[P/#rOr BaseProtocol)rr#s"rrr$sg22rcVP#rS)r)rTs&r get_protocol_Transport.get_protocols ~~rc <V^8dQhRS[/#rOrP)rr#s"rrr$sDrcVP#rS)r/rTs&r is_closing_Transport.is_closings }}rc8<V^8dQhRS[PRR/#)r rr Nr)rr#s"rrr$s!""W%9%9"d"rc\hrSrs)r6rs&&r set_protocol_Transport.set_protocolrwrc<V^8dQhRR/#r:r;)rr#s"rrr$ src&VP4R#rS)rirTs&r__del___Transport.__del__ s  rc<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 &#) r r>r(r)zcollections.deque[bytes] | Noner,r0r1r/r-r.r@)rr r r!r"rQ)rr#s"rrr$*s +  $ $$    .- KLN Jr)r/r.r0r-r(r1r)r,i)r\r\NrS)NN)!__name__ __module__ __qualname____firstlineno__r>r@r'rLrUrFr]r5rirCrur{rrrrzrrmrrrHrrrr__annotate_func____static_attributes____classdictcell__ __classcell__r7r#s@@rrr*s +JK62  %% $$  ""OO88 ''""B ''55@  ""Arrc6a]tRtRtoRtV3RlRltRtVtR#)SubprocessProtocolizBAn extension to asyncio.Protocol for use with SubprocessTransport.c<V^8dQhRR/#r:r;)rr#s"rrSubprocessProtocol.__annotate__s"""rc \h)z"Called when subprocess has exited.rsrTs&rprocess_exited!SubprocessProtocol.process_exiteds!!rr;N)rrrr__doc__rrrr#s@rrrsL""rrc2a]tRtRtoV3RlRltRtVtR#) WindowSizeic <V^8dQhRS[/#)r value)r)rr#s"rrWindowSize.__annotate__s++j+rcJ\VR4Vn\VR4VnR#)rowscolsN)rrr)r6rs&&rr'WindowSize.__init__sE6* E6* r)rrN)rrrrr'rrrs@rrrs++rrcFaa]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[/#r rr )rQstr)rr#s"rr SubprocessTransport.__annotate__0s4CrczVPe-VPPVR7PRR7#R#)N)rreplace)errors)_stderrgetdecode)r6rs&$r get_stderrSubprocessTransport.get_stderr0s5 << #<<##%#077y7I Irc"<V^8dQhRRRR/#)r processzsubprocess.Popen[bytes]r Nr;)rr#s"rrr6s ff";ffrcLaaaaRVV3RlloRVVVV3RllpRVVV3Rllp\P!SP4oSPP SV4R # \ \ 3d.\RSP 2TRR7P4R #i;i) c4V^8dQhR\R\RR/#)r pidstatusr Nr )rs"rr4SubprocessTransport.watch_exit..__annotate__7s! 0 0c 03 04 0rcv<VSP8XgQh\SP\4'gQh\P !V4Sn\PRSP 4SP'gSPP4R#R# \d TSnLdi;i)zProcess exited with status %dN) r isinstancer)rr2waitstatus_to_exitcode _returncode ValueErrorr*r+r/r)rrrr6s&&r child_exited4SubprocessTransport.watch_exit..child_exited7s'++% %%dnn.@AA AA *#%#<#.pidfd_readyDs>**W[[!4KC JJ $ $U + HHUO  %rcV^8dQhRR/#r:r;)rs"rrrJs G G Grc<\P!SP^4wrSPP SW4R#r)r2r rr(call_soon_threadsafe)rrrrr6s rwaitpid_thread6SubprocessTransport.watch_exit..waitpid_threadJs-**W[[!4KC JJ + +L# Frzcockpit-waitpid-T)nametargetdaemonN) r2 pidfd_openrr(reAttributeErrorrrstart)r6rr rrr sff @@r watch_exitSubprocessTransport.watch_exit6s 0 0 & &  G G  fMM'++.E JJ ! !% 5( f *7;;-8X\ ] c c e fs.__annotate__`s 5 5D 5rc<\\\P4S'd)\P !^\ P^4R#R#r)r SET_PDEATHSIGsignalSIGTERMfcntlioctltermios TIOCSCTTY)rsr preexec_fn0SubprocessTransport.__init__..preexec_fn`s/ - 0 Aw00!4rNstderrstdinstdoutr)start_new_sessionT)r2openpty_pty_fdset_window_size subprocessPopen_processrHr@PIPEr,r-filenor+Spoolerrr&r'r) r6rrr rrrr) session_fdrrr7s &&&&d$, rr'SubprocessTransport.__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  &rc$<V^8dQhRS[RR/#)r sizer N)r)rr#s"rrrsWWJW4Wrc 0VPfQh\^\VPR44p\^\VPR44p\ P !VP\P\P!RW#44R#)N2H4xi) r0maxminrrr%r&r' TIOCSWINSZstructpack)r6r;rrs&& rr1#SubprocessTransport.set_window_sizese||'''1c$))Y/01c$))Y/0 DLL'"4"4fkk&$6UVrc <V^8dQhRS[/#rOrP)rr#s"rrrs//t/rcRVPfQhVPPRJ#rS)r4r,rTs&rru!SubprocessTransport.can_write_eofs'}}(((}}""$..rc<V^8dQhRR/#r:r;)rr#s"rrrsrcVPfQhVPPfQhVPPP4RVnR#)Nr\)r4r,rHr1rTs&rrz"SubprocessTransport._write_eof_nowsE}}(((}}""... !!# rc <V^8dQhRS[/#rOr )rr#s"rrrs!!!rcNVPfQhVPP#rS)r4rrTs&rget_pidSubprocessTransport.get_pids"}}(((}}   rc<V^8dQhRR/#)r r rr;)rr#s"rrrs   rcVP#rS)rrTs&rget_returncode"SubprocessTransport.get_returncoderWrc:<V^8dQhRS[RS[P/#)r fdr )r r Transport)rr#s"rrrs!""S"W->->"rc\hrSrs)r6rSs&&rget_pipe_transport&SubprocessTransport.get_pipe_transportrwrc8<V^8dQhRS[PRR/#)r sigr N)r#Signals)rr#s"rrrs#hhv~~h$hrcVPfQhVPe-\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.)r4rr*r+rr2killProcessLookupError)r6rYs&&r send_signalSubprocessTransport.send_signals}}(((    ' LLNPSUbUbUfUf g  h GGDMM%%s + LL0#}}7H7H I! h LLNPSUbUbUfUf g hs AB##5CCc<V^8dQhRR/#r:r;)rr#s"rrrs))4)rcDVP\P4R#rS)r^r#r$rTs&r terminateSubprocessTransport.terminate (rc<V^8dQhRR/#r:r;)rr#s"rrrs))d)rcDVP\P4R#rS)r^r#SIGKILLrTs&rr\SubprocessTransport.killrdrc<V^8dQhRR/#r:r;)rr#s"rrrs N N NrcVPe(\P!VP4RVnVPeaVPPe6VPPP4RVPnVP 4R#R# \ d/\PRTPP4R#i;i)Nzcan't kill %i due to EPERM) r0r2rHr4r,rbPermissionErrorr*r+rrTs&rriSubprocessTransport._closes << # HHT\\ "DL == $}}"". ##))+&* # N % # N 94==;L;LM NsB&&5CCcB<V^8dQh/R;R&R;R&R;R&R;R&#)r rr0zsubprocess.Popen[bytes] | Noner4rzSpooler | Nonerr;)rr#s"rrrs9  !"/5#$$%&'r)r@r1r4r0rr)rrrrrr0r4rrrr'r1rurzrLrPrVr^rbr\rirrrrrs@@rrrs !G15H $K% ff@,' # ,' 04 ,','\WW // !!  ""hh0)))) N NCrrcjaa]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 cZ<V^8dQhRS[PRS[PRS[RS[/#)r rrr,r-r)rr#s"rrStdioTransport.__annotate__s788W668'BRBR8[^8lo8rc(<\SV`WW44R#rS)r&r')r6rrr,r-r7s&&&&&rr'StdioTransport.__init__s 7rc <V^8dQhRS[/#rOrP)rr#s"rrrqstrcR#)Fr;rTs&rruStdioTransport.can_write_eofsrc<V^8dQhRR/#r:r;)rr#s"rrrqs888rc\R4h)zCan't write EOF to stdout) RuntimeErrorrTs&rrzStdioTransport._write_eof_nows677rr;)rr[) rrrrrr'rurzrrrrs@@rroros-88888rroca]tRtRtoRtV3RlRltV3RlRltV3RlRltR R /V3R lR lltV3R lRlt V3RlRlt V3Rlt Rt Vt R#)r7izConsumes 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. c:<V^8dQhRS[PRS[/#)r rrSr r!r )rr#s"rrSpooler.__annotate__s!44W664C4rcWnRVn.Vn\P!V4Vn\P !VPR4VP VPVP4R#)r[FNr\)r(_fd _contentsr2dupr3rerL)r6rrSs&&&rr'Spooler.__init__sN 66": %( $"2"23rc<V^8dQhRR/#r:r;)rr#s"rrr~s  T rc\P!VPR4pTR8wdTP P T4R#TP4R# \dR#\dRpLRi;i)i Nr)r2r=rr?rrrrHrs& rrLSpooler._read_readys` 77488T*D 3; NN ! !$ ' JJL   D s!A A6'A60A65A6c <V^8dQhRS[/#rOrP)rr#s"rrr~sDD4Drc|VPR8XdR#\P!VP...^4...38g#)r[Fr\)rselectrTs&r _is_readySpooler._is_readys6 88r>}}dhhZR3B|CCrrFc&<V^8dQhRS[RS[/#r)rQr)rr#s"rrr~sDUrcVP4'dVP4K(RPVP4pV'd.VnV#)r)rrLrr)r6rresults&$ rr Spooler.gets<nn    $..) DN rc<V^8dQhRR/#r:r;)rr#s"rrr~strcVPR8wdOVPPVP4\P!VP4RVnR#R#rZ)rr(rar2rHrTs&rrH Spooler.closes? 88r> JJ $ $TXX . HHTXX DH rc<V^8dQhRR/#r:r;)rr#s"rrr~src&VP4R#rS)rHrTs&rrSpooler.__del__s  rcP<V^8dQh/S[P;R&S[;R&R;R&#)r r(rz list[bytes]rr})rr#s"rrr~s1  $ $$ Hr)rrr(N)rrrrrr'rLrrrHrrrrrs@rr7r7sW44  DD 5 orr7)&rr rctypesrAr%loggingr2rr#rAr2r' threadingrtypingrrrjsonutilrrCDLLrrr" getLoggerrr*rrTrr"rrrror7r;rrrs R  **) KK  # # (     8 $ a""aH"))"++ mN*g&A&AmN`8Z8(88r