⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.24
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.9
/
site-packages
/
cockpit
/
__pycache__
/
View File Name :
transports.cpython-39.pyc
a gOG @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZmZ ddlmZmZ edjZeddddZdZeeZd Z G d d d ej Z G d d d ej Z G dd dZ!G dd de ej"Z"G dd de Z#G dd dZ$dS )zKBi-directional asyncio.Transport implementations based on file descriptors. N)AnyClassVarSequence ) JsonObjectget_int)argsreturnc G s t | dkrtdd S )Nr zprctl() failed) sys_prctlOSError)r r 6/usr/lib/python3.9/site-packages/cockpit/transports.pyprctl' s r i c s e Zd ZU dZee ed< ejed< ej ed< ded< eed< eed< e ed < e ed < e ed < d Z e ed < dHejej eedd fdd Z ddddZ e dddZddddZdddd Zddd d Zddd d ZdId!dd"d#d$Ze dd%d&Zddd'd(Zedd)d*Zd+dd,d-ZdJd.d.dd/d0d1Zddd2d3Zddd4d5Zddd6d7Ze dd8d9d:Z e dd8d;d<Z ddd=d>Z ej dd?d@Z!e ddAdBZ"ej ddCdDdEZ#dddFdGZ$ Z%S )K _Transporti BLOCK_SIZE_loop _protocolz collections.deque[bytes] | None_queue_in_fd_out_fd_closing _is_reading_eofF _eio_is_eofNzdict[str, object] | None)loopprotocolin_fdout_fdextrac s t | || _|| _td| ||| d | _d| _d| _d| _ || _ || _ t |d ||krnt |d | j| | d S )Nz/Created transport %s for protocol %s, fds %d %dF)super__init__r r loggerdebugr r r r r r os set_blockingZconnection_maderesume_reading)selfr r r r r __class__r r r! B s z_Transport.__init__r c C s t d| | j| j zt| jtj}W nf ty< Y d S t y } z<| j rb|j t j krbd}n| | W Y d }~d S W Y d }~n d }~0 0 |dkrt dt| | j| n(t d | | j }|s| d S )NzRead ready on %s %s %d z read %d bytesz got EOF)r" r# r r r$ readr r BlockingIOErrorr r errnoZEIOabortlenZ data_received _close_readerZ eof_receivedclose)r' dataexcZ keep_openr r r _read_ready] s$ $ z_Transport._read_readyc C s | j S N)r r' r r r is_readingv s z_Transport.is_readingc C s | d| _d S Nr ) pause_readingr r7 r r r r1 y s z_Transport._close_readerc C s | j r| j| j d| _ d S NF)r r remove_readerr r7 r r r r: } s z_Transport.pause_readingc C s, | j s(| jdkr(| j| j| j d| _ d S )Nr T)r r r add_readerr5 r7 r r r r& s z_Transport.resume_readingc C s d S r6 r r7 r r r _close s z_Transport._closezException | None)r4 r c C s4 d| _ | | | j| jj| | d S NT)r r1 _remove_write_queuer Z call_soonr Zconnection_lostr> )r' r4 r r r r/ s z_Transport.abortc C s t d S r6 NotImplementedErrorr7 r r r can_write_eof s z_Transport.can_write_eofc C s@ | j r J d| _ | jd u r0td| | n td| d S )NTz %s got EOF. closing backend.z,%s got EOF. bytes in queue, deferring close)r r r" r# _write_eof_nowr7 r r r write_eof s z_Transport.write_eofc C s" | j d u rdS tdd | j D S )Nr c s s | ]}t |V qd S r6 )r0 ).0blockr r r <genexpr> r+ z3_Transport.get_write_buffer_size.<locals>.<genexpr>)r sumr7 r r r get_write_buffer_size s z _Transport.get_write_buffer_sizeztuple[int, int]c C s dS )N)r r r r7 r r r get_write_buffer_limits s z"_Transport.get_write_buffer_limits int | None)highlowr c C s, |d u s|dksJ |d u s(|dks(J d S Nr r )r' rM rN r r r set_write_buffer_limits s z"_Transport.set_write_buffer_limitsc C s t d S r6 rA r7 r r r rD s z_Transport._write_eof_nowc C s t d| | jd usJ zt| j| j}W nD tyD d}Y n0 tyr } z| | W Y d }~d S d }~0 0 t d| |r| j }t ||krt d | j ||d q|t |8 }t d| q| jst d | | j rt d | | jr| d S )Nz%s _write_readyr z, 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$ writevr r- r r/ popleftr0 appendleftr@ r rD r )r' n_bytesr4 rG r r r _write_ready s4 z_Transport._write_readyc C s, | j d ur(| j | j| j d | _ d S r6 )r r Zresume_writingr Z remove_writerr r7 r r r r@ s z _Transport._remove_write_queue)r3 r c C sL t d| | j | jd u s J | j| j| j t|f| _| j d S )Nz!%s creating write queue for fd %s) r" r# r r r Z add_writerrU collectionsdequer Z pause_writingr' r3 r r r _create_write_queue s z _Transport._create_write_queuec C s | j rtd| j d S | jr"J | jd url| j| t| jtkrhd | j}| j | j| d S zt | j|}W nD t y d}Y n0 ty } z| | W Y d }~d S d }~0 0 |t|kr| ||d d S )Nz+ignoring write() to closing transport fd %ir+ r )r r" r# r r r appendr0 IOV_MAXjoinclearr$ writer- r r/ rY )r' r3 Zall_datarT r4 r r r r^ s( z_Transport.writec C s2 | j r d S d| _ | | jd ur&d S | d S r? )r r1 r r/ r7 r r r r2 s z_Transport.closec C s | j S r6 )r r7 r r r get_protocol s z_Transport.get_protocolc C s | j S r6 )r r7 r r r is_closing s z_Transport.is_closing)r r c C s t d S r6 rA )r' r r r r set_protocol s z_Transport.set_protocolc C s | d S r6 )r> r7 r r r __del__ s z_Transport.__del__)r r N)N)NN)&__name__ __module__ __qualname__r r int__annotations__asyncioAbstractEventLoopProtocolboolr r! r5 r8 r1 r: r& r> r/ rC rE rJ rK rP rD rU r@ bytesrY r^ r2 Z BaseProtocolr_ r` ra rb __classcell__r r r( r r 3 sP ! r c @ s e Zd ZdZddddZdS )SubprocessProtocolzBAn extension to asyncio.Protocol for use with SubprocessTransport.Nr* c C s t dS )z"Called when subprocess has exited.NrA r7 r r r process_exited s z!SubprocessProtocol.process_exited)rc rd re __doc__ro r r r r rn s rn c @ s e Zd ZedddZdS ) WindowSize)valuec C s t |d| _t |d| _d S )Nrowscols)r rs rt )r' rr r r r r! s zWindowSize.__init__N)rc rd re r r! r r r r rq s rq c sV e Zd ZU dZdZded< dZded< dZded< ded < ee j d d d Z ee j e j d ddZ ddeedddZeeddddZddde j eee eded fdd Zedd d d Zed d d!Zdd d"d#Zed d$d%Zdd d&d'Z ee j d(d)d*Z e j dd+d,d-Z!dd d.d/Z"dd d0d1Z#dd d2d3Z$ Z%S )4SubprocessTransporta A 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. NrL _returncode_pty_fdz subprocess.Popen[bytes] | None_processzSpooler | None_stderrr* c C s@ z t t t d t W S ttfy6 Y n0 t S rO ) r$ r2 pidfd_opengetpidrh ZPidfdChildWatcherAttributeErrorr ZSafeChildWatcherr r r r _create_watcher: s z#SubprocessTransport._create_watcher)r r c C s: d}t | |d }|d u r6t }|| t| || |S )NZ!_cockpit_transports_child_watcher)getattrru r} Z attach_loopsetattr)r ZquarkZwatcherr r r _get_watcherD s z SubprocessTransport._get_watcherFresetr r c C s( | j d ur | j j|djddS dS d S )Nr replace)errors )ry getdecode)r' r r r r get_stderrP s z SubprocessTransport.get_stderr)pidcoder c C sV t | jtsJ | jd us J | jj|ks.J || _td| j | jsR| j d S )Nz Process exited with status %d) isinstancer rn rx r rv r" r# r ro )r' r r r r r _exitedV s zSubprocessTransport._exited)ptywindowzWindowSize | None)r r r r r kwargsc s" d d fdd } r|t \| _}|d ur6| | ||d< tj|f|||dd|| _t | | j| j } } d| _nPtj|ftj tj |d|| _| jj sJ | jj sJ | jj } | jj } | jj d urt|| jj | _nd | _t ||| | | || jj| j d S )Nr* c s$ t ttj r tdtjd d S rO )r SET_PDEATHSIGsignalSIGTERMfcntlioctltermiosZ TIOCSCTTYr r r r preexec_fnr s z0SubprocessTransport.__init__.<locals>.preexec_fnstderrT)stdinstdoutr Zstart_new_session)r r r )r$ openptyrw set_window_size subprocessPopenrx r2 r PIPEr r filenor Spoolerry r r! r Zadd_child_handlerr r ) r' r r r r r r r Z session_fdr r r( r r r! h s: z SubprocessTransport.__init__)sizer c C s2 | j d usJ t| j tjtd|j|j d S )NZ2H4x) rw r r r Z TIOCSWINSZstructpackrs rt )r' r r r r r s z#SubprocessTransport.set_window_sizec C s | j d usJ | j jd uS r6 )rx r r7 r r r rC s z!SubprocessTransport.can_write_eofc C s4 | j d usJ | j jd us J | j j d| _d S r9 )rx r r2 r r7 r r r rD s z"SubprocessTransport._write_eof_nowc C s | j d usJ | j jS r6 )rx r r7 r r r get_pid s zSubprocessTransport.get_pidc C s | j S r6 )rv r7 r r r get_returncode s z"SubprocessTransport.get_returncode)fdr c C s t d S r6 rA )r' r r r r get_pipe_transport s z&SubprocessTransport.get_pipe_transport)sigr c C s~ | j d usJ | jd ur.td|| j j d S z&t| j j| td|| j j W n$ tyx td|| j j Y n0 d S )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.)rx rv r" r# r r$ killProcessLookupError)r' r r r r send_signal s z SubprocessTransport.send_signalc C s | tj d S r6 )r r r r7 r r r terminate s z SubprocessTransport.terminatec C s | tj d S r6 )r r SIGKILLr7 r r r r s zSubprocessTransport.killc C sz | j d ur t| j d | _ | jd urv| jjd urF| jj d | j_z | W n" tyt td| jj Y n0 d S )Nzcan't kill %i due to EPERM) rw r$ r2 rx r r PermissionErrorr" r# r r7 r r r r> s zSubprocessTransport._close)&rc rd re rp rv rg rw rx staticmethodrh ZAbstractChildWatcherr} ri r rk strr rf r rn r r r! rq r rC rD r r Transportr r ZSignalsr r r r> rm r r r( r ru $ s> /ru c sN e Zd ZdZd ejejeed fdd Ze ddd Z d dd d Z Z S )StdioTransportzA bi-directional transport that corresponds to stdin/out. Can talk to just about anything: - files - pipes - character devices (including terminals) - sockets r r )r r r r c s t |||| d S r6 )r r! )r' r r r r r( r r r! s zStdioTransport.__init__r* c C s dS r; r r7 r r r rC s z StdioTransport.can_write_eofNc C s t dd S )NzCan't write EOF to stdout) RuntimeErrorr7 r r r rD s z StdioTransport._write_eof_now)r r ) rc rd re rp rh ri rj rf r! rk rC rD rm r r r( r r s r c @ s e Zd ZU dZejed< eed< ded< ejedddZd d d d Z e d d dZ dde e dddZ d d ddZd d ddZd S )r zConsumes 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] _contents)r r c C s@ || _ d| _g | _t|| _t| jd || j| j d S )Nr F)r r r r$ dupr% r= r5 )r' r r r r r r! s zSpooler.__init__Nr* c C s^ zt | jd}W n( ty& Y d S ty: d}Y n0 |dkrR| j| n| d S )Ni r+ )r$ r, r r- r r rZ r2 rX r r r r5 s zSpooler._read_readyc C s, | j dkrdS t| j gg g dg g g fkS )Nr Fr )r selectr7 r r r _is_ready s zSpooler._is_readyFr r c C s, | r| q d| j}|r(g | _|S )Nr+ )r r5 r\ r )r' r resultr r r r s z Spooler.getc C s. | j dkr*| j| j t| j d| _ d S r9 )r r r< r$ r2 r7 r r r r2 ! s z Spooler.closec C s | d S r6 )r2 r7 r r r rb ' s zSpooler.__del__)rc rd re rp rh ri rg rf r! r5 rk r rl r r2 rb r r r r r s r )%rp rh rV Zctypesr. r Zloggingr$ r r r r r typingr r r Zjsonutilr r ZCDLLr r rf r Z getLoggerrc r" r[ r r rj rn rq ru r r r r r r <module> s6 e 9