Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/test/__pycache__/test_iutils.cpython-39.pyc
Ðазад
a k�h@5 � @ s� d Z ddlZddlZddlZddlZddlZddlmZ ddlm Z m Z m Z m Z ddl mZ ddlmZ ddlmZ ddlmZmZ G d d � d e�ZG d d � d e�ZG d d� de�ZdS )zD Test running processes with the APIs in L{twisted.internet.utils}. � N)�skipIf)�error� interfaces�reactor�utils)�Deferred)�platform)�SuppressedWarningsTests)�SynchronousTestCase�TestCasec @ s� e Zd ZdZe�ed�du r dZdZdZ e j Z dd� Z dd� Zdd � Zd d � Zd d � Zdd� Zee�� d�dd� �Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Z d d � Z d!d"� Z d#d$� Z dS )%�ProcessUtilsTestszt Test running a process using L{getProcessOutput}, L{getProcessValue}, and L{getProcessOutputAndValue}. Nz)reactor doesn't implement IReactorProcessc C sV | � � }t|d��(}|�tj�|�tj � W d � n1 s@0 Y tj�|�S )zj Write the given list of lines to a text file and return the absolute path to it. ZwtN)�mktemp�open�write�os�linesep�join�path�abspath)�selfZ sourceLines�script� scriptFile� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/test/test_iutils.py�makeSourceFile$ s 6z ProcessUtilsTests.makeSourceFilec C s. | � g d��}t�| jd|g�}|�| jd�S )z� L{getProcessOutput} returns a L{Deferred} which fires with the complete output of the process it runs after that process exits. )� import syszfor s in b'hello world\n':z s = bytes([s])z sys.stdout.buffer.write(s)z sys.stdout.flush()�-us hello world �r r �getProcessOutput�exe� addCallback� assertEqual�r r �dr r r � test_output. s � z ProcessUtilsTests.test_outputc sF � � ddg�}t�� jd|g�}� �|t�}� fdd�}|�|� |S )z� The L{Deferred} returned by L{getProcessOutput} is fired with an L{IOError} L{Failure} if the child process writes to stderr. r z!sys.stderr.write("hello world\n")r c s � � | jtj�S �N)� assertFailureZ processEndedr Z ProcessDone)�err�r r r �cbFailedL s z?ProcessUtilsTests.test_outputWithErrorIgnored.<locals>.cbFailed)r r r r r& �IOErrorr )r r r# r) r r( r �test_outputWithErrorIgnored? s � z-ProcessUtilsTests.test_outputWithErrorIgnoredc C s2 | � g d��}tj| jd|gdd�}|�| jd�S )z� If a C{True} value is supplied for the C{errortoo} parameter to L{getProcessOutput}, the returned L{Deferred} fires with the child's stderr output as well as its stdout output. )r zsys.stdout.write("foo")�sys.stdout.flush()zsys.stderr.write("foo")�sys.stderr.flush()r T)Zerrortoos foofoor r" r r r � test_outputWithErrorCollectedR s � z/ProcessUtilsTests.test_outputWithErrorCollectedc C s, | � dg�}t�| jd|g�}|�| jd�S )z| The L{Deferred} returned by L{getProcessValue} is fired with the exit status of the child process. zraise SystemExit(1)r � )r r �getProcessValuer r r! r" r r r � test_valueg s z ProcessUtilsTests.test_valuec s6 � � g d��}� fdd�}t�� jd|g�}|�|�S )a The L{Deferred} returned by L{getProcessOutputAndValue} fires with a three-tuple, the elements of which give the data written to the child's stdout, the data written to the child's stderr, and the exit status of the child. )r z*sys.stdout.buffer.write(b'hello world!\n')z,sys.stderr.buffer.write(b'goodbye world!\n')z sys.exit(1)c s2 | \}}}� � |d� � � |d� � � |d� d S )Ns hello world! s goodbye world! r/ �r! �Z out_err_code�outr' �coder( r r �gotOutputAndValue� s z@ProcessUtilsTests.test_outputAndValue.<locals>.gotOutputAndValuer �r r �getProcessOutputAndValuer r �r r r6 r# r r( r �test_outputAndValueq s � z%ProcessUtilsTests.test_outputAndValuez"Windows doesn't have real signals.c sB � � g d��}� fdd�}t�� jd|g�}� �|t�}|�|�S )z� If the child process exits because of a signal, the L{Deferred} returned by L{getProcessOutputAndValue} fires a L{Failure} of a tuple containing the child's stdout, stderr, and the signal which caused it to exit. )zimport sys, os, signalz"sys.stdout.write('stdout bytes\n')z"sys.stderr.write('stderr bytes\n')r, r- z$os.kill(os.getpid(), signal.SIGKILL)c s4 | \}}}� � |d� � � |d� � � |tj� d S )Ns stdout bytes s stderr bytes )r! �signal�SIGKILL)Z out_err_sigr4 r' �sigr( r r r6 � s z>ProcessUtilsTests.test_outputSignal.<locals>.gotOutputAndValuer )r r r8 r r& �tupler r9 r r( r �test_outputSignal� s � z#ProcessUtilsTests.test_outputSignalc C sV t j�| �� �}t �|� | �ddg�}|| jd|g|d�}|�||�t � � �� |S )N�import os, sysz sys.stdout.write(os.getcwd())r )r ) r r r r �makedirsr r r �encode�sys�getfilesystemencoding)r �utilFunc�check�dirr r# r r r � _pathTest� s �zProcessUtilsTests._pathTestc C s | � tj| j�S )z L{getProcessOutput} runs the given command with the working directory given by the C{path} parameter. )rH r r r! r( r r r �test_getProcessOutputPath� s z+ProcessUtilsTests.test_getProcessOutputPathc s � fdd�}� � tj|�S )z~ L{getProcessValue} runs the given command with the working directory given by the C{path} parameter. c s � � | d� d S �Nr r2 ��resultZignoredr( r r rF � s z9ProcessUtilsTests.test_getProcessValuePath.<locals>.check)rH r r0 �r rF r r( r �test_getProcessValuePath� s z*ProcessUtilsTests.test_getProcessValuePathc s � fdd�}� � tj|�S )z� L{getProcessOutputAndValue} runs the given command with the working directory given by the C{path} parameter. c s& | \}}}� � ||� � � |d� d S rJ r2 �Zout_err_statusrG r4 r' �statusr( r r rF � s zBProcessUtilsTests.test_getProcessOutputAndValuePath.<locals>.check)rH r r8 rM r r( r �!test_getProcessOutputAndValuePath� s z3ProcessUtilsTests.test_getProcessOutputAndValuePathc C s� t j�| �� �}t �|� | �g d��}| �t jt �� � t �|� t � t � d�j �}t � |t j t jB � | �t j ||� || jd|g�}|�||�t�� �� |S )N)r@ zcdir = os.getcwd()zsys.stdout.write(cdir)�.r )r r r r rA r Z addCleanup�chdir�getcwd�stat�S_IMODE�st_mode�chmod�S_IXUSR�S_IRUSRr r rB rC rD )r rE rF rG r Z originalModer# r r r �_defaultPathTest� s � z"ProcessUtilsTests._defaultPathTestc C s | � tj| j�S )a If no value is supplied for the C{path} parameter, L{getProcessOutput} runs the given command in the same working directory as the parent process and succeeds even if the current working directory is not accessible. )r[ r r r! r( r r r � test_getProcessOutputDefaultPath� s z2ProcessUtilsTests.test_getProcessOutputDefaultPathc s � fdd�}� � tj|�S )a If no value is supplied for the C{path} parameter, L{getProcessValue} runs the given command in the same working directory as the parent process and succeeds even if the current working directory is not accessible. c s � � | d� d S rJ r2 rK r( r r rF s z@ProcessUtilsTests.test_getProcessValueDefaultPath.<locals>.check)r[ r r0 rM r r( r � test_getProcessValueDefaultPath� s z1ProcessUtilsTests.test_getProcessValueDefaultPathc s � fdd�}� � tj|�S )a If no value is supplied for the C{path} parameter, L{getProcessOutputAndValue} runs the given command in the same working directory as the parent process and succeeds even if the current working directory is not accessible. c s& | \}}}� � ||� � � |d� d S rJ r2 rO r( r r rF s zIProcessUtilsTests.test_getProcessOutputAndValueDefaultPath.<locals>.check)r[ r r8 rM r r( r �(test_getProcessOutputAndValueDefaultPath s z:ProcessUtilsTests.test_getProcessOutputAndValueDefaultPathc sD � � ddg�}d�tj� jd|g�d�}� �fdd�}|�|� |S )z� Standard input can be made available to the child process by passing bytes for the `stdinBytes` parameter. r z"sys.stdout.write(sys.stdin.read())s These are the bytes to see.r )� stdinBytesc s& | \}}}� � �|� � �d|� d S rJ )ZassertInr! r3 �r r_ r r r6 ( s zPProcessUtilsTests.test_get_processOutputAndValueStdin.<locals>.gotOutputAndValuer7 )r r r# r6 r r` r �#test_get_processOutputAndValueStdin s ��� z5ProcessUtilsTests.test_get_processOutputAndValueStdin) �__name__� __module__� __qualname__�__doc__r ZIReactorProcessr �skip�output�valuerC � executabler r r$ r+ r. r1 r: r r Z isWindowsr? rH rI rN rQ r[ r\ r] r^ ra r r r r r s. r c @ s e Zd ZdZdd� ZdS )�SuppressWarningsTestsz. Tests for L{utils.suppressWarnings}. c s� g � � fdd�}| � td|� dd� }t�|dtdd�f�}|d � | �t� �d � |d� | �t� �d � |d � | �t� �d � d S )zs L{utils.suppressWarnings} decorates a function so that the given warnings are suppressed. c s � � ||f� d S r% )�append)r �a�kw�rL r r � showwarning@ s z@SuppressWarningsTests.test_suppressWarnings.<locals>.showwarningro c S s t �| � d S r% )�warnings�warn)�msgr r r �fE s z6SuppressWarningsTests.test_suppressWarnings.<locals>.f)�ignorezThis is message��messagezSanity check messager/ zUnignored message� N)�patchrp r ZsuppressWarnings�dictr! �len)r ro rs �gr rn r �test_suppressWarnings9 s z+SuppressWarningsTests.test_suppressWarningsN)rb rc rd re r| r r r r rj 4 s rj c @ s* e Zd ZdZeej�Zdd� Zdd� ZdS )� DeferredSuppressedWarningsTestsz` Tests for L{utils.runWithWarningsSuppressed}, the version that supports Deferreds. c sh di fdi fg}t � � | �|� fdd�� t�d� � �d� t�d� | �dgdd � | �� D �� d S ) z� If the function called by L{utils.runWithWarningsSuppressed} returns a C{Deferred}, the warning filters aren't removed until the Deferred fires. �rt z.*foo.*�rt z.*bar.*c s � S r% r r rn r r �<lambda>l � zGDeferredSuppressedWarningsTests.test_deferredCallback.<locals>.<lambda>� ignore foo� � ignore foo 2c S s g | ] }|d �qS ru r ��.0�wr r r � <listcomp>p r� zIDeferredSuppressedWarningsTests.test_deferredCallback.<locals>.<listcomp>N)r �runWithWarningsSuppressedrp rq �callbackr! � flushWarnings)r �filtersr rn r �test_deferredCallbackd s z5DeferredSuppressedWarningsTests.test_deferredCallbackc sx di fdi fg}t � � | �|� fdd��}t�d� � �t� � |�dd� � t�d� | �dgdd � | �� D �� d S ) z� If the function called by L{utils.runWithWarningsSuppressed} returns a C{Deferred}, the warning filters aren't removed until the Deferred fires with an errback. r~ r c s � S r% r r rn r r r� z r� zFDeferredSuppressedWarningsTests.test_deferredErrback.<locals>.<lambda>r� c S s | � t�S r% )Ztrap�ZeroDivisionError)rs r r r r� } r� r� c S s g | ] }|d �qS ru r r� r r r r� r� zHDeferredSuppressedWarningsTests.test_deferredErrback.<locals>.<listcomp>N) r r� rp rq Zerrbackr� Z addErrbackr! r� )r r� r# r rn r �test_deferredErrbackr s z4DeferredSuppressedWarningsTests.test_deferredErrbackN) rb rc rd re � staticmethodr r� r� r� r r r r r} Z s r} )re r r; rU rC rp Zunittestr Ztwisted.internetr r r r Ztwisted.internet.deferr Ztwisted.python.runtimer Z twisted.python.test.test_utilr Ztwisted.trial.unittestr r r rj r} r r r r �<module> s &
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка