| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
o
�b�! � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZm Z ddl
m Z d dd �Z G d
d � d e
�ZG d d
� d
e j�Zdi dddfdd�ZG dd� de j�Zdi ddfdd�ZG dd� de j�Zdi dddfdd�Zdd� Zdd� Zd d � Zg d �ZdS ) z
Utility methods.
� N��wraps)�BytesIO)�defer�protocol)�failure� c C sL |d u r
ddl m} t�� }| |g|�R � }|�|||ft|� ||� |S )Nr )�reactor)�twisted.internetr r �Deferred� spawnProcess�tuple) r �
executable�args�env�pathr � protoArgs�d�pr r �8/usr/lib/python3/dist-packages/twisted/internet/utils.py�_callProtocolWithDeferred s r c @ s e Zd ZdZdd� ZdS )�_UnexpectedErrorOutputay
Standard error data was received where it was not expected. This is a
subclass of L{IOError} to preserve backward compatibility with the previous
error behavior of L{getProcessOutput}.
@ivar processEnded: A L{Deferred} which will fire when the process which
produced the data on stderr has ended (exited and all file descriptors
closed).
c C s t �| d|��� || _d S )Nz got stderr: )�IOError�__init__� processEnded)�self�textr r r r r * s
z _UnexpectedErrorOutput.__init__N)�__name__�
__module__� __qualname__�__doc__r r r r r r s
r c @ s: e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
S )�
_BackRelaya�
Trivial protocol for communicating with a process and turning its output
into the result of a L{Deferred}.
@ivar deferred: A L{Deferred} which will be called back with all of stdout
and, if C{errortoo} is true, all of stderr as well (mixed together in
one string). If C{errortoo} is false and any bytes are received over
stderr, this will fire with an L{_UnexpectedErrorOutput} instance and
the attribute will be set to L{None}.
@ivar onProcessEnded: If C{errortoo} is false and bytes are received over
stderr, this attribute will refer to a L{Deferred} which will be called
back when the process ends. This C{Deferred} is also associated with
the L{_UnexpectedErrorOutput} which C{deferred} fires with earlier in
this case so that users can determine when the process has actually
ended, in addition to knowing when bytes have been received via stderr.
r c C s* || _ t� | _|r| j| _d S | j| _d S �N)�deferredr �s�errReceivedIsGood� errReceived�errReceivedIsBad)r r# �errortoor r r r B s
z_BackRelay.__init__c C sJ | j d ur#t�� | _t|| j�}| j �t�|�� d | _ | j� � d S d S r" )
r# r r �onProcessEndedr �errbackr �Failure� transport�loseConnection)r r �errr r r r' J s
�z_BackRelay.errReceivedIsBadc C � | j �|� d S r" �r$ �write�r r r r r r% R � z _BackRelay.errReceivedIsGoodc C r/ r" r0 r2 r r r � outReceivedU r3 z_BackRelay.outReceivedc C s> | j d ur| j �| j�� � d S | jd ur | j�|� d S d S r" )r# �callbackr$ �getvaluer) r* �r �reasonr r r r X s
�z_BackRelay.processEndedN)r ) r r r r r r' r% r4 r r r r r r! / s
r! c s t � fdd�| ||||�S )a�
Spawn a process and return its output as a deferred returning a L{bytes}.
@param executable: The file name to run and get the output of - the
full path should be used.
@param args: the command line arguments to pass to the process; a
sequence of strings. The first string should B{NOT} be the
executable's name.
@param env: the environment variables to pass to the process; a
dictionary of strings.
@param path: the path to run the subprocess in - defaults to the
current directory.
@param reactor: the reactor to use - defaults to the default reactor
@param errortoo: If true, include stderr in the result. If false, if
stderr is received the returned L{Deferred} will errback with an
L{IOError} instance with a C{processEnded} attribute. The
C{processEnded} attribute refers to a L{Deferred} which fires when the
executed process ends.
c s t | � d�S )N�r( )r! )r r9 r r �<lambda>y s z"getProcessOutput.<locals>.<lambda>)r )r r r r r r( r r9 r �getProcessOutput_ s �r; c @ s e Zd Zdd� Zdd� ZdS )� _ValueGetterc C s
|| _ d S r" )r# )r r# r r r r ~ s
z_ValueGetter.__init__c C s | j �|jj� d S r" )r# r5 �value�exitCoder7 r r r r � s z_ValueGetter.processEndedN)r r r r r r r r r r< } s r< c C s t t| ||||�S )z7Spawn a process and return its exit code as a Deferred.)r r< )r r r r r r r r �getProcessValue� s r? c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) �_EverythingGetterNc C s4 || _ t� | _t� | _| jj| _| jj| _|| _d S r" )r# r �outBuf�errBufr1 r4 r& �
stdinBytes)r r# rC r r r r � s
z_EverythingGetter.__init__c C s, | j d ur| j�d| j � | j�� d S d S )Nr )rC r, � writeToChild�
closeStdin)r r r r �connectionMade� s
�z _EverythingGetter.connectionMadec C sT | j �� }| j�� }|j}|j}|jr | j�|||jf� d S | j�|||f� d S r" ) rA r6 rB r= r> �signalr# r* r5 )r r8 �outr. �e�coder r r r � s
z _EverythingGetter.processEndedr" )r r r r rF r r r r r r@ � s
r@ c C s t t| |||||fd�S )a. Spawn a process and returns a Deferred that will be called back with
its output (from stdout and stderr) and it's exit code as (out, err, code)
If a signal is raised, the Deferred will errback with the stdout and
stderr up to that point, along with the signal, as (out, err, signalNum)
)r )r r@ )r r r r r rC r r r �getProcessOutputAndValue� s �rK c C s0 |D ]}zt j�|� W q ty Y qw | S r" )�warnings�filters�remove�
ValueError)� passthrough� addedFilters�fr r r �_resetWarningFilters� s �rS c O s� | D ] \}}t j|i |�� qt jdt| �� }z ||i |��}W n ty: t�� }td|� |d �|d ��w t |t
j �rI|� t|� |S td|� |S )a}
Run the function I{f}, but with some warnings suppressed.
This calls L{warnings.filterwarnings} to add warning filters before
invoking I{f}. If I{f} returns a L{Deferred} then the added filters are
removed once the deferred fires. Otherwise they are removed immediately.
Note that the list of warning filters is a process-wide resource, so
calling this function will affect all threads.
@param suppressedWarnings:
A list of arguments to pass to L{warnings.filterwarnings}, a sequence
of (args, kwargs) 2-tuples.
@param f: A callable, which may return a L{Deferred}.
@param a: Positional arguments passed to I{f}
@param kw: Keyword arguments passed to I{f}
@return: The result of C{f(*a, **kw)}
@seealso: L{twisted.python.util.runWithWarningsSuppressed}
functions similarly, but doesn't handled L{Deferred}s.
N� � )
rL �filterwarningsrM �len�
BaseException�sys�exc_inforS �with_traceback�
isinstancer r �addBoth) �suppressedWarningsrR �a�kwr �kwargsrQ �resultrZ r r r �runWithWarningsSuppressed� s
�
�rc c s t � �� �fdd��}|S )z�
Wrap C{f} in a callable which suppresses the indicated warnings before
invoking C{f} and unsuppresses them afterwards. If f returns a Deferred,
warnings will remain suppressed until the Deferred fires.
c s t �� g| �R i |��S r" )rc )r_ r` �rR r^ r r �warningSuppressingWrapper� s z3suppressWarnings.<locals>.warningSuppressingWrapperr )rR r^ re r rd r �suppressWarnings� s rf )rc rf r; r? rK )Nr )r rY rL � functoolsr �ior r
r r �twisted.pythonr r r r �ProcessProtocolr! r; r< r? r@ rK rS rc rf �__all__r r r r �<module> s*
� 0
� +