7jGSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK JrJrJr SSKJrJr \R("S5R*rS\SS4SjrSr\R2"\5rS r"S S \R:5r"S S \R>5r "SS5r!"SS\\RD5r""SS\5r#"SS5r$g)zKBi-directional asyncio.Transport implementations based on file descriptors.N)AnyClassVarSequence) JsonObjectget_intargsreturnc2[U6S:wa [S5eg)Nrzprctl() failed) sys_prctlOSError)r s 4/usr/lib/python3/dist-packages/cockpit/transports.pyprctlr's $1&''ic D^\rSrSr%Sr\\\S'\R\S'\R\S'S\S'\\S'\\S '\ \S '\ \S '\ \S 'S r \ \S'S0S\RS\RS\S\SS4 U4Sjjjr S1SjrS\ 4SjrS1SjrS1SjrS1SjrS1SjrS2S3SjjrS\ 4SjrS1S jrS\4S!jrS4S"jrS5S6S#jjrS1S$jrS1S%jrS1S&jrS'\SS4S(jrS'\SS4S)jrS1S*jr S\RB4S+jr"S\ 4S,jr#S\RBSS4S-jr$S1S.jr%S/r&U=r'$)7 _Transport3i BLOCK_SIZE_loop _protocolzcollections.deque[bytes] | None_queue_in_fd_out_fd_closing _is_reading_eofF _eio_is_eofNloopprotocolin_fdout_fdextrazdict[str, object] | Nonecv>[TU]U5 XlX l[R SXX45 SUlSUlSUlSUl X0l X@l [R"US5 XC:wa[R"US5 URRU5 UR5 g)Nz/Created transport %s for protocol %s, fds %d %dF)super__init__rrloggerdebugrrrrrros set_blockingconnection_maderesume_reading)selfrrr r!r" __class__s rr%_Transport.__init__Bs  ! FX]f       u% ? OOFE * &&t, rr c[RSXRUR5 [R "UR[ R5nUS:wa;[RS[U55 URRU5 g[RS5 UR!5 URR#5nU(dUR%5 gg![a g[aQnUR(a%UR[R:XaSnSnANURU5 SnAgSnAff=f)NzRead ready on %s %s %drz read %d bytesz got EOF)r&r'rrr(readrrBlockingIOErrorr rerrnoEIOabortlen data_received _close_reader eof_receivedclose)r,dataexc keep_opens r _read_ready_Transport._read_ready]s -t^^T[[Q 774;; (=(=>D 3; LL*CI 6 NN ( ( . LL %    335I %   CII$: 3 s#/C55 E E 1EEEcUR$N)rr,s r is_reading_Transport.is_readingvrc2UR5 SUlgN) pause_readingrrAs rr7_Transport._close_readerys  rcUR(a-URRUR5 SUlggNF)rr remove_readerrrAs rrH_Transport.pause_reading}s.    JJ $ $T[[ 1$D  rcUR(dIURS:wa8URRURUR5 SUlggg)NrGT)rrr add_readerr=rAs rr+_Transport.resume_readingsFDKK2$5 JJ ! !$++t/?/? @#D %6rcgr@rAs r_close_Transport._closes rcSUlUR5 UR5 URR UR R U5 UR5 gNT)rr7_remove_write_queuer call_soonrconnection_lostrS)r,r;s rr4_Transport.abortsH     " T^^;;SA rc[er@NotImplementedErrorrAs r can_write_eof_Transport.can_write_eof!!rcUR(aeSUlURc'[RSU5 UR 5 g[RSU5 g)NTz%s got EOF. closing backend.z,%s got EOF. bytes in queue, deferring close)rrr&r'_write_eof_nowrAs r write_eof_Transport.write_eofsI99} ;;  LL8$ ?    ! LLG NrcVURcg[SUR55$)Nrc38# UHn[U5v M g7fr@)r5).0blocks r 3_Transport.get_write_buffer_size..s7;%3u::;s)rsumrAs rget_write_buffer_size _Transport.get_write_buffer_sizes$ ;; 74;;777rcg)N)rrrRrAs rget_write_buffer_limits"_Transport.get_write_buffer_limitssrc2UbUS:XdeUb US:XdeggNrrR)r,highlows rset_write_buffer_limits"_Transport.set_write_buffer_limitss(|tqy(({cQh&&h{rc[er@r\rAs rrb_Transport._write_eof_nowr`rc|[RSU5 URce[R"UR UR5n[RSU5 U(aURR5n[U5U:a3[RS5 URRX1S5 O-U[U5-n[RSU5 U(aMUR(d~[RS5 UR5 UR(a%[RS5 UR5 UR(aUR5 ggg![ a SnGNE[anURU5 SnAgSnAff=f)Nz%s _write_readyrz, 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'rr(writevrr1r r4popleftr5 appendleftrWrrbr)r,n_bytesr;rhs r _write_ready_Transport._write_readysC &-{{&&& ii dkk:G  CWMKK'')E5zG# 9: &&uX7 s5z !G LLA7 Kg{{ LL, -  $ $ &yy FG##%}}  % G  JJsO  s+F F; F; F66F;cURbGURR5 URR UR 5 SUlggr@)rrresume_writingr remove_writerrrAs rrW_Transport._remove_write_queues> ;; " NN ) ) + JJ $ $T\\ 2DK #rr:c.[RSXR5 URbeURR URUR 5 [R"U45UlURR5 g)Nz!%s creating write queue for fd %s) r&r'rrr add_writerr~ collectionsdequer pause_writingr,r:s r_create_write_queue_Transport._create_write_queuesg 8$ M{{""" dllD,=,=>!''0  $$&rcUR(a![RSUR5 gUR(aeUR bUR R U5 [UR 5[:aPSRUR 5nUR R5 UR R U5 g[R"URU5nU[U5:waUR!XS5 gg![a SnN2[anURU5 SnAgSnAff=f)Nz+ignoring write() to closing transport fd %irr)rr&r'rrrappendr5IOV_MAXjoinclearr(writer1r r4r)r,r:all_datar}r;s rr_Transport.writes == LLF U 99} ;; " KK  t $4;;')88DKK0 !!# ""8,  hht||T2G c$i   $ $T(^ 4  G  JJsO  s!D"" E0 E9EEcUR(agSUlUR5 URbgUR5 grV)rr7rr4rAs rr9_Transport.closes5 ==    ;; "  rcUR$r@)rrAs r get_protocol_Transport.get_protocol s ~~rcUR$r@)rrAs r is_closing_Transport.is_closing s }}rc[er@r\)r,rs r set_protocol_Transport.set_protocolr`rc$UR5 gr@)rSrAs r__del___Transport.__del__s  r)rrrrrrrr)rGrGNr Nr@)r;zException | Noner N)r ztuple[int, int])NN)rs int | Nonertrr N)(__name__ __module__ __qualname____firstlineno__rrint__annotations__asyncioAbstractEventLoopProtocolboolrr%r=rBr7rHr+rSr4r^rcrlrorurbr~rWbytesrrr9 BaseProtocolrrrr__static_attributes__ __classcell__r-s@rrr3sp +J +  $ $$ -- K LN JK 1359 00"+++.3 62 D % $ "t"O8s8 '"B ''$'5%5D5@ g22D"W%9%9"d"rrc"\rSrSrSrSSjrSrg)SubprocessProtocolizBAn extension to asyncio.Protocol for use with SubprocessTransport.Nc[e)z"Called when subprocess has exited.r\rAs rprocess_exited!SubprocessProtocol.process_exiteds!!rrRr)rrrr__doc__rrrRrrrrs L"rrc"\rSrSrS\4SjrSrg) WindowSizeivaluecH[US5Ul[US5Ulg)Nrowscols)rrr)r,rs rr%WindowSize.__init__sE6* E6* r)rrN)rrrrrr%rrRrrrrs+j+rrc r^\rSrSr%SrSrS\S'SrS\S'SrS\S'S \S 'S S .S \ S\ 4Sjjr S(Sjr S SS.S\ RS\S\\ S\ SSS\4 U4SjjjrS\SS4SjrS\ 4SjrS)SjrS\4SjrS*SjrS \S\ R44S!jrS"\R:SS4S#jrS)S$jrS)S%jr S)S&jr!S'r"U=r#$)+SubprocessTransporti$aA 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. Nr_pty_fdzsubprocess.Popen[bytes] | None_process _returncodezSpooler | None_stderrFresetrr cjURb&URRUS9RSS9$g)Nrreplace)errors)rgetdecode)r,rs r get_stderrSubprocessTransport.get_stderr9s5 << #<<##%#077y7I Irc^^^^SU4SjjmSUUUU4SjjnS[S[SS4UUU4Sjjn[R"TR5mTRR TU5 g![ [4a Sn[TRUS5nUcF[R"5nURTR5 [TRXE5 URTRU5 gf=f) Nr c>[TR[5(de[R STR 5 TR (dTRR5 gg)NzProcess exited with status %d) isinstancerrr&r'rrrrAsr flag_exit1SubprocessTransport.watch_exit..flag_exit@sLdnn.@AA AA LL8$:J:J K==--/!rcF>[R"TRS5upUTR:Xde[R"U5TlTR RT5 [R"T5 T"5 g![ a UTlNLf=frr) r(waitpidpidwaitstatus_to_exitcoder ValueErrorrrLr9)rstatusrpidfdprocessr,s r pidfd_ready3SubprocessTransport.watch_exit..pidfd_readyFs**W[[!4KC'++% %% *#%#<#TRU:XdeUTlT"5 gr@)rr)rrrrr,s rchild_watch_fired9SubprocessTransport.watch_exit..child_watch_firedQs";;#% %%#D  Kr!_cockpit_transports_child_watcherr)rr( pidfd_openrrrOAttributeErrorr getattrrSafeChildWatcher attach_loopsetattradd_child_handler)r,rrrquarkwatcherrrs`` @@r watch_exitSubprocessTransport.watch_exit?s 0   3 c d   FMM'++.E JJ ! !% 5( F7Edjj%6G!224##DJJ/ E3  % %gkk3D E FsC?)ptywindowrrr rrzWindowSize | Nonekwargsc >^SU4SjjnT(a[R"5uUlnUbURU5 XS'[R "U4XUSS.UD6Ul[R"U5 URURpSUlO[R "U4[R[RUS.UD6UlUR R(deUR R(deUR RR5n UR RR5n UR Rb3[XR RR55UlOSUl[ T U]EXX5 UR%UR 5 g)Nc>[[[R5 T(a'[R "S[ RS5 ggrr)r SET_PDEATHSIGsignalSIGTERMfcntlioctltermios TIOCSCTTY)rsr preexec_fn0SubprocessTransport.__init__..preexec_fnts/ - 0 Aw00!4rstderrT)stdinstdoutrstart_new_session)rrrr)r(openptyrset_window_size subprocessPopenrr9rPIPErrfilenorSpoolerrr$r%r) r,rrr rrrr session_fdr r!r-s ` rr%SubprocessTransport.__init__jsp 5 ')zz| $DL*!$$V,)8 &,,Tf3=8BVZf^dfDM HHZ  LL$,,6#D ',,TNQ[Q`Q`8BNFLNDM==&& &&=='' ''MM((//1E]]((//1F ==   +"4)=)=)D)D)FGDLDL 7  &rsizec URce[R"UR[R[ R "SURUR55 g)N2H4x) rrrr TIOCSWINSZstructpackrr)r,r s rr#SubprocessTransport.set_window_sizesD||''' DLL'"4"4fkk&$))UYU^U^6_`rcPURceURRSL$r@)rrrAs rr^!SubprocessTransport.can_write_eofs'}}(((}}""$..rcURceURRceURRR5 SUlgrF)rrr9rrAs rrb"SubprocessTransport._write_eof_nowsE}}(((}}""... !!# rcLURceURR$r@)rrrAs rget_pidSubprocessTransport.get_pids"}}(((}}   rcUR$r@)rrAs rget_returncode"SubprocessTransport.get_returncoderDrfdc[er@r\)r,rs rget_pipe_transport&SubprocessTransport.get_pipe_transportr`rsigcURceURb+[RSXRR5 g[ R "URRU5 [RSXRR5 g![a- [RSXRR5 gf=f)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(killProcessLookupError)r,rs r send_signalSubprocessTransport.send_signals}}(((    ' LLNPSUbUbUfUf g  h GGDMM%%s + LL0#}}7H7H I! h LLNPSUbUbUfUf g hs AB4CCcBUR[R5 gr@)r#rrrAs r terminateSubprocessTransport.terminate (rcBUR[R5 gr@)r#rSIGKILLrAs rr!SubprocessTransport.killr(rcURb'[R"UR5 SUlURb^URRb5URRR5 SURlUR 5 gg![ a- [RSURR5 gf=f)Nzcan't kill %i due to EPERM) rr(r9rrr&PermissionErrorr&r'rrAs rrSSubprocessTransport._closes << # HHT\\ "DL == $}}"". ##))+&* # N % # N 94==;L;LM NsB!!4CC)rrrrrr)rzsubprocess.Popen[bytes]r Nr)r r)$rrrrrrrrrrstrrrrrrrrr%rrr^rbrrr TransportrrSignalsr#r&r!rSrrrs@rrr$s" !G\ 15H.5 $K$ */4C )F`#/3 ,'00,'-,' },'  ,' - ,',','\aJa4a/t/ !! "S"W->->"hv~~h$h0)) N Nrrc ^\rSrSrSrS S\R S\RS\S\4U4Sjjjr S\ 4S jr S S jr S r U=r$)StdioTransportizA bi-directional transport that corresponds to stdin/out. Can talk to just about anything: - files - pipes - character devices (including terminals) - sockets rrrrc&>[TU]XX45 gr@)r$r%)r,rrrrr-s rr%StdioTransport.__init__s 7rr cgrKrRrAs rr^StdioTransport.can_write_eofsrc[S5e)NzCan't write EOF to stdout) RuntimeErrorrAs rrbStdioTransport._write_eof_nows677rrR)rrr)rrrrrrrrrr%rr^rbrrrs@rr3r3sR8W668'BRBR8[^8lo88t88rr3c\rSrSr%Sr\R \S'\\S'S\S'S\R S\4S jr SS jr S \ 4S jr SS.S\ S \ 4SjjrSSjrSSjrSrg )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. r_fdz list[bytes] _contentsrrcXlSUl/Ul[R"U5Ul[R "URS5 UR URUR5 g)NrGF)rr<r=r(dupr)rOr=)r,rrs rr%Spooler.__init__sN 66": %( $"2"23rr Nc[R"URS5nUS:waUR R U5 gUR5 g![a g[a SnNLf=f)Ni r)r(r0r<r1r r=rr9rs rr=Spooler._read_readys` 77488T*D 3; NN ! !$ ' JJL   D s!A A0" A0/A0cxURS:Xag[R"UR///S5///4:g$)NrGFr)r<selectrAs r _is_readySpooler._is_readys6 88r>}}dhhZR3B|CCrFrrcUR5(a'UR5 UR5(aM'SRUR5nU(a/UlU$)Nr)rEr=rr=)r,rresults rr Spooler.getsMnn    nn$..) DN rcURS:waMURRUR5 [R"UR5 SUlggrF)r<rrLr(r9rAs rr9 Spooler.close"s? 88r> JJ $ $TXX . HHTXX DH rc$UR5 gr@)r9rAs rrSpooler.__del__(s  r)r=r<rr)rrrrrrrrrr%r=rrErrr9rrrRrrrrsn  $ $$ H4W664C4 D4D $)DU rr)%rrrctypesr2rloggingr(rDrrrrtypingrrrjsonutilrrCDLLrr rr getLoggerrr&rr0rrrrrr3rrRrrrTs$R  **) KK  # # (((     8 $ a""aH"))"++ vN*g&A&AvNr8Z8(88r