| Server IP : 138.197.176.125 / Your IP : 216.73.217.55 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
U
��W[� � @ s d Z ddlmZmZ ddlZddlZddlmZ ddlm Z m
Z
ddl m Z ddl
mZ ddlmZ d d d
�ZG d d � d e�ZG d
d� de j�Zdi dddfdd�ZG dd� de j�Zdi ddfdd�ZG dd� de j�Zdi ddfdd�Zdd� Zd d � Z d d � Z d d dddgZ dS )!z
Utility methods.
� )�division�absolute_importN��wraps)�protocol�defer)�failure)�reraise)�BytesIOc C sD |d krddl m} t�� }| |�}|�|||ft|� ||� |S )Nr )�reactor)�twisted.internetr r �DeferredZ spawnProcess�tuple)r �
executable�args�env�pathr �d�p� 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|f � || _d S )Nzgot stderr: %r)�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| _n| j| _d S �N)�deferredr
�s�errReceivedIsGood� errReceived�errReceivedIsBad)r r$ �errortoor r r r E s
z_BackRelay.__init__c C sF | j d k rBt�� | _t|| j�}| j �t�|�� d | _ | j� � d S r# )
r$ r r
�onProcessEndedr �errbackr ZFailureZ transportZloseConnection)r r �errr r r r( M s
z_BackRelay.errReceivedIsBadc C s | j �|� d S r# �r% �write�r r r r r r& U s z _BackRelay.errReceivedIsGoodc C s | j �|� d S r# r- r/ r r r � outReceivedX s z_BackRelay.outReceivedc C s8 | j d k r | j �| j�� � n| jd k r4| j�|� d S r# )r$ �callbackr% �getvaluer* r+ �r �reasonr r r r [ s
z_BackRelay.processEndedN)r ) r r r r! r r( r& r0 r r r r r r" 2 s
r" 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 r5 r r �<lambda>} s z"getProcessOutput.<locals>.<lambda>)r )r r r r r r) r r5 r �getProcessOutputc s �r7 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$ r1 �value�exitCoder3 r r r r � s z_ValueGetter.processEndedN�r r r r r r r r r r8 � s r8 c C s t t| ||||�S )z7Spawn a process and return its exit code as a Deferred.)r r8 �r r r r r r r r �getProcessValue� s �r> c @ s e Zd Zdd� Zdd� ZdS )�_EverythingGetterc C s. || _ t� | _t� | _| jj| _| jj| _d S r# )r$ r
�outBuf�errBufr. r0 r' r9 r r r r � s
z_EverythingGetter.__init__c C sR | j �� }| j�� }|j}|j}|jr<| j�|||jf� n| j�|||f� d S r# ) r@ r2 rA r: r; �signalr$ r+ r1 )r r4 �outr, �e�coder r r r � s
z _EverythingGetter.processEndedNr< r r r r r? � s r? c C s t t| ||||�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 �getProcessOutputAndValue� s �rF c C s4 |D ]*}zt j�|� W q tk
r, Y qX q| S r# )�warnings�filters�remove�
ValueError)Z passthrough� addedFilters�fr r r �_resetWarningFilters� s rM c O s� | D ]\}}t j||� qt jdt| �� }z|||�}W n0 t�� }td|� t|d |d � Y n*X t|t j
�r�|� t|� n
td|� |S dS )a% Run the function C{f}, but with some warnings suppressed.
@param suppressedWarnings: A list of arguments to pass to filterwarnings.
Must be a sequence of 2-tuples (args, kwargs).
@param f: A callable, followed by its arguments and keyword arguments
N� � ) rG �filterwarningsrH �len�sys�exc_inforM r �
isinstancer r
ZaddBoth) �suppressedWarningsrL �a�kwr �kwargsrK �resultrS r r r �runWithWarningsSuppressed� s
rZ 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 �� f| �|�S r# )rZ )rV rW �rL rU r r �warningSuppressingWrapper� s z3suppressWarnings.<locals>.warningSuppressingWrapperr )rL rU r\ r r[ r �suppressWarnings� s r] )N) r! Z
__future__r r rR rG � functoolsr r r r Ztwisted.pythonr Ztwisted.python.compatr �ior
r r r ZProcessProtocolr" r7 r8 r> r? rF rM rZ r] �__all__r r r r �<module> s8
1�
�
�