Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/test/__pycache__/test_stdio.cpython-39.pyc
Ðазад
a k�h�1 � @ s� d Z ddlZddlZddlZddlmZ ddlmZmZm Z m Z m Z ddl m Z mZ ddlmZ ddlmZ ddlmZ dd lmZmZ d Zeej�Zej � ej �ed < G d d � d e j �Z G dd� de�Z!dS )z� Tests for L{twisted.internet.stdio}. @var properEnv: A copy of L{os.environ} which has L{bytes} keys/values on POSIX platforms and native L{str} keys/values on Windows. � N)�skipIf)�defer�error�protocol�reactor�stdio)�filepath�log)� requireModule)�platform)� ConnectionLostNotifyingProtocol)�SkipTest�TestCases xyz123abc Twisted is great!� PYTHONPATHc @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d � ZdS ) � StandardIOTestProcessProtocola� Test helper for collecting output from a child process and notifying something when it exits. @ivar onConnection: A L{defer.Deferred} which will be called back with L{None} when the connection to the child process is established. @ivar onCompletion: A L{defer.Deferred} which will be errbacked with the failure associated with the child process exiting when it exits. @ivar onDataReceived: A L{defer.Deferred} which will be called back with this instance whenever C{childDataReceived} is called, or L{None} to suppress these callbacks. @ivar data: A C{dict} mapping file descriptors to strings containing all bytes received from the child process on each file descriptor. Nc C s t �� | _t �� | _i | _d S �N)r �Deferred� onConnection� onCompletion�data��self� 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_stdio.py�__init__8 s z&StandardIOTestProcessProtocol.__init__c C s | j �d � d S r )r �callbackr r r r �connectionMade= s z,StandardIOTestProcessProtocol.connectionMadec C s> | j �|d�| | j |< | jdur:| jd }| _|�| � dS )z� Record all bytes received from the child process in the C{data} dictionary. Fire C{onDataReceived} if it is not L{None}. � N)r �get�onDataReceivedr )r �name�bytes�dr r r �childDataReceived@ s z/StandardIOTestProcessProtocol.childDataReceivedc C s | j �|� d S r )r r )r �reasonr r r � processEndedJ s z*StandardIOTestProcessProtocol.processEnded) �__name__� __module__� __qualname__�__doc__r r r r# r% r r r r r # s r c @ s� e Zd Ze�� r ed�du r dZdd� Zdd� Zdd � Z d d � Z d d � Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zee�� d�dd � �ZdS ) �StandardInputOutputTestsZ win32processNzIOn windows, spawnProcess is not available in the absence of win32process.c O s: t jdd| tjjgt|� }tj|t j|fdti|��S )a_ Launch a child Python process and communicate with it using the given ProcessProtocol. @param proto: A L{ProcessProtocol} instance which will be connected to the child process. @param sibling: The basename of a file containing the Python program to run in the child process. @param *args: strings which will be passed to the child process on the command line as C{argv[2:]}. @param **kw: additional arguments to pass to L{reactor.spawnProcess}. @return: The L{IProcessTransport} provider for the spawned process. s -ms twisted.test.�env)�sys� executabler � __class__r' �listZ spawnProcess� properEnv)r �protoZsibling�args�kwr r r � _spawnProcessV s ��z&StandardInputOutputTests._spawnProcessc s$ �fdd�}� fdd�}|� ||�S )Nc s � � d| ��� d S )Nz%Process terminated with non-Failure: )Zfail)�resultr r r �cbq s z4StandardInputOutputTests._requireFailure.<locals>.cbc s � | �S r r )�err)r r r �ebt s z4StandardInputOutputTests._requireFailure.<locals>.eb)Z addCallbacks)r r" r r6 r8 r )r r r �_requireFailurep s z(StandardInputOutputTests._requireFailurec sL �� � � t�d� � t� ��j}���d� � � ��fdd�}��||�S )z� Verify that a protocol connected to L{StandardIO} can disconnect itself using C{transport.loseConnection}. �Child process logging to s stdio_test_loseconnc sb t � ��,}|D ]}t�d|�� � qW d � n1 s:0 Y ��d�j� | �tj� d S )NzChild logged: � ) �openr �msg�rstripZfailIfInr �trapr � ProcessDone)r$ �f�line�� errorLogFile�pr r r r% � s 2zBStandardInputOutputTests.test_loseConnection.<locals>.processEnded)�mktempr r= r r r4 r9 �r r" r% r rC r �test_loseConnectiony s z,StandardInputOutputTests.test_loseConnectionc sf | � � }t�d| � t� � t�� � _� fdd�}� j�|� dd� }| �� j|�}| � � d|� |S )z� When stdin is closed and the protocol connected to it implements L{IHalfCloseableProtocol}, the protocol's C{readConnectionLost} method is called. r: c s � j }� j�� |S r )r � transportZ closeStdin)Zignoredr" �rE r r �cbBytes� s zAStandardInputOutputTests.test_readConnectionLost.<locals>.cbBytesc S s | � tj� d S r )r? r r@ �r$ r r r r% � s zFStandardInputOutputTests.test_readConnectionLost.<locals>.processEndeds stdio_test_halfclose) rF r r= r r r r � addCallbackr9 r4 )r rD rK r% r" r rJ r �test_readConnectionLost� s z0StandardInputOutputTests.test_readConnectionLostc sj t � � z�j� dtdd� W n0 tyL } ztt|���W Y d}~n d}~0 0 � �fdd�}��� j|�S )z� Verify that a write made directly to stdout using L{os.write} after StandardIO has finished is reliably received by the process reading that stdout. s stdio_test_lastwriteT)ZusePTYNc s2 �� � jd �t�d� j�d�� | �tj� dS )z� Asserts that the parent received the bytes written by the child immediately after the child starts. r; z Received z) from child, did not find expected bytes.N)� assertTruer �endswith�UNIQUE_LAST_WRITE_STRINGr? r r@ rL �rE r r r r% � s �zEStandardInputOutputTests.test_lastWriteReceived.<locals>.processEnded)r r4 rQ � ValueErrorr �strr9 r )r �er% r rR r �test_lastWriteReceived� s � " z/StandardInputOutputTests.test_lastWriteReceivedc s2 t � � � j}��� d� � �fdd�}��||�S )z� Verify that the transport of a protocol connected to L{StandardIO} has C{getHost} and C{getPeer} methods. s stdio_test_hostpeerc s6 � j d �� \}}��|� ��|� | �tj� d S )Nr; )r � splitlinesrO r? r r@ )r$ �hostZpeerrR r r r% � s z?StandardInputOutputTests.test_hostAndPeer.<locals>.processEnded�r r r4 r9 rG r rR r �test_hostAndPeer� s z)StandardInputOutputTests.test_hostAndPeerc s2 t � � � j}��� d� � �fdd�}��||�S )z� Verify that the C{write} method of the transport of a protocol connected to L{StandardIO} sends bytes to standard out. s stdio_test_writec s" �� � jd d� | �tj� d S �Nr; s ok!�� assertEqualr r? r r@ rL rR r r r% � s z9StandardInputOutputTests.test_write.<locals>.processEndedrY rG r rR r � test_write� s z#StandardInputOutputTests.test_writec s2 t � � � j}��� d� � �fdd�}��||�S )z� Verify that the C{writeSequence} method of the transport of a protocol connected to L{StandardIO} sends bytes to standard out. s stdio_test_writeseqc s" �� � jd d� | �tj� d S r[ r\ rL rR r r r% � s zAStandardInputOutputTests.test_writeSequence.<locals>.processEndedrY rG r rR r �test_writeSequence� s z+StandardInputOutputTests.test_writeSequencec C sT | � � }t|d��.}td�D ]}|�d|f � q W d � n1 sF0 Y |S )N�wbi � %d )rF r< �range�write)r �junkPathZjunkFile�ir r r � _junkPath s 0z"StandardInputOutputTests._junkPathc sd t � ��j}g �ttd���� ���fdd�� ���d���j�� � ����fdd�}��||�S )z� Verify that the transport of a protocol connected to L{StandardIO} is a working L{IProducer} provider. �d c s8 �r4�� d��� f � ���d � t�d� d � d S )Nra ���g{�G�z�?)�append�poprc r � callLater)Zign)r �proc�toWrite�writtenr r r s z>StandardInputOutputTests.test_producer.<locals>.connectionMades stdio_test_producerc s> �� � jd d���� ���dt��f � | �tj� d S )Nr; r z*Connection lost with %d writes left to go.)r] r �joinZ assertFalse�lenr? r r@ rL )rE r rm rn r r r% s �z<StandardInputOutputTests.test_producer.<locals>.processEnded)r r r/ rb r4 r rM r9 rG r )r rE rl r rm rn r � test_producer s z&StandardInputOutputTests.test_producerc s> t � ��j}��� � ���d� � � ��fdd�}��||�S )z� Verify that the transport of a protocol connected to L{StandardIO} is a working L{IConsumer} provider. s stdio_test_consumerc sP t � d��&}���jd |�� � W d � n1 s60 Y | �tj� d S )N�rbr; )r< r] r �readr? r r@ )r$ rA �rd rE r r r r% 2 s 4z<StandardInputOutputTests.test_consumer.<locals>.processEnded)r r rf r4 r9 rG r rt r � test_consumer& s z&StandardInputOutputTests.test_consumerzpStandardIO does not accept stdout as an argument to Windows. Testing redirection to a file is therefore harder.c s� t �� }t|�}t���� ����d� �_}��|j � t |� � d�}t � � s�t�� \}}��tj |� ��tj |� ||d< tj|fi |��� d�t�� �� ���fdd��t�d�� ����fdd �}|�|� |S ) aE If L{StandardIO} is created with a file descriptor which refers to a normal file (ie, a file from the filesystem), L{StandardIO.write} writes bytes to that file. In particular, it does not immediately consider the file closed or call its protocol's C{connectionLost} method. r` )�stdout�stdin� c sD �D ].} | �kr � � � d S � �d| f � q4qt�d�� d S )N� %dr )ZloseConnectionrc r rk )�value)� connection�count�howMany�spinr r r~ ] s zAStandardInputOutputTests.test_normalFileStandardOut.<locals>.spinr c s< �� t� ��d � �� ��� d�dd� t��D ��� d S )Nr; r c s s | ]}d |f V qdS )ry Nr )�.0re r r r � <genexpr>m r zVStandardInputOutputTests.test_normalFileStandardOut.<locals>.cbLost.<locals>.<genexpr>)r] �nextZ getContentro rb rL )r| r} �pathr r r �cbLostj s �zCStandardInputOutputTests.test_normalFileStandardOut.<locals>.cbLost)r r r r ZFilePathrF r< �normalZ addCleanup�close�dict�filenor � isWindows�os�piper Z StandardIO� itertoolsr| r rk rM )r Z onConnLostr1 r� �kwargs�r�wr� r )r{ r| r} r� r r~ r �test_normalFileStandardOut9 s& z3StandardInputOutputTests.test_normalFileStandardOut)r& r' r( r r� r �skipr4 r9 rH rN rV rZ r^ r_ rf rq ru r r� r r r r r* N s& � ' �r* )"r) r� r� r, Zunittestr Ztwisted.internetr r r r r Ztwisted.pythonr r Ztwisted.python.reflectr Ztwisted.python.runtimer Ztwisted.test.test_tcpr Ztwisted.trial.unittestr r rQ r� �environr0 �pathsepro r� ZProcessProtocolr r* r r r r �<module> s +
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка