Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/test/__pycache__/test_tcp_internals.cpython-39.pyc
Ðазад
a k�h�2 � @ s d Z ddlZddlZddlZz ddlZW n ey> dZY n0 ddlmZ ddlm Z m Z ddl m Z m Z ddlmZmZ ddlmZmZmZmZmZmZmZmZmZmZm Z ddl m Z dd l m Z dd l!m"Z" ee j#�$e � d �G d d � d e"��Z%ee j#�$e � d �G dd� de"��Z&dS )z Whitebox tests for TCP APIs. � N)�skipIf)� interfaces�reactor)� gatherResults� maybeDeferred)�Protocol� ServerFactory) �_ACCEPT_ERRORS�EAGAIN� ECONNABORTED� EINPROGRESS�EMFILE�ENFILE�ENOBUFS�ENOMEM�EPERM� EWOULDBLOCK�Port)�log)�platform)�TestCasez?This test only applies to reactors that implement IReactorFDsetc @ sF e Zd ZdZdZdd� Zdd� Zdd� Zee � � d kd �d d � �Z d S )�PlatformAssumptionsTestsz4 Test assumptions about platform behaviors. i c C s\ g | _ td urXddlm} t|� �d }t�tj�| _t�tj|| jd f� |d | _ d S )Nr )� _listOpenFDs� � �d ) � openSockets�resourceZtwisted.internet.processr �len� getrlimit� RLIMIT_NOFILE�originalFileLimit� setrlimit� socketLimit)�selfr ZnewLimit� 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_tcp_internals.py�setUp4 s �z PlatformAssumptionsTests.setUpc C sT | j r| j �� �� q td urPt�tj�d }t| jd |�}t�tj||f� d S )Nr r ) r �pop�closer r r �minr! r" )r$ ZcurrentHardLimitZ newSoftLimitr% r% r& �tearDownF s z!PlatformAssumptionsTests.tearDownc C s t � � }| j�|� |S )z| Create and return a new socket object, also tracking it so it can be closed in the test tear down. )�socketr �append)r$ �sr% r% r& r, R s z PlatformAssumptionsTests.socket�win32zhWindows requires an unacceptably large amount of resources to provoke this behavior in the naive manner.c C s� | � � }|�d� |�� d }|�d� | � � }|�d� t| j�D ]Z}z | � � W qD ty� } z0|jd t t fv r�W Y d}~ q�n� W Y d}~qDd}~0 0 qD| � d� | � |� d|f�dtf� | �t j|j�}| � |jd t t f� dS ) z� Test that the platform accept(2) call fails with either L{EMFILE} or L{ENOBUFS} when there are too many file descriptors open. )� 127.0.0.1r r � Fr Nz7Could provoke neither EMFILE nor ENOBUFS from platform.r0 )r, �bind� getsockname�listen� setblocking�ranger# �OSError�argsr r �failZassertIn� connect_exr � assertRaises�error�accept)r$ �portZserverPortNumber�client�i�e�excr% r% r& �test_acceptOutOfFiles[ s& �z.PlatformAssumptionsTests.test_acceptOutOfFilesN) �__name__� __module__� __qualname__�__doc__r# r' r+ r, r r �getTyperC r% r% r% r& r ) s �r c @ s� e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z e e � � dkd�dd� �Ze e � � dkd�dd� �Ze ej�d�dkd�dd� �Ze e � � dkd �d d � �Zd d � Zd!S )"�SelectReactorTestsz7 Tests for select-specific failure conditions. c C s g | _ g | _t�| jj� d S �N)�ports�messagesr Z addObserverr- �r$ r% r% r& r' � s zSelectReactorTests.setUpc C s" t �| jj� tdd� | jD ��S )Nc S s g | ]}t |j��qS r% )r � stopListening)�.0�pr% r% r& � <listcomp>� � z/SelectReactorTests.tearDown.<locals>.<listcomp>)r ZremoveObserverrL r- r rK rM r% r% r& r+ � s zSelectReactorTests.tearDownc C s& t |||d�}|�� | j�|� |S )z Create, start, and return a new L{Port}, also tracking it so it can be stopped in the test tear down. �� interface)r ZstartListeningrK r- )r$ Z portNumber�factoryrT rP r% r% r& r> � s zSelectReactorTests.portc s� G �fdd�d�}t � }| jd|dd�}| �|d|� � |�� d�tj� � � �fdd �| jD �}| �t|�dd | jf � d S ) a� Test behavior in the face of an exception from C{accept(2)}. On any exception which indicates the platform is unable or unwilling to allocate further resources to us, the existing port should remain listening, a message should be logged, and the exception should not propagate outward from doRead. @param socketErrorNumber: The errno to simulate from accept. c s e Zd ZdZ� fdd�ZdS )z9SelectReactorTests._acceptFailureTest.<locals>.FakeSocketzI Pretend to be a socket in an overloaded system. c s t � t�� ���d S rJ )r7 �os�strerrorrM ��socketErrorNumberr% r& r= � s z@SelectReactorTests._acceptFailureTest.<locals>.FakeSocket.acceptN�rD rE rF rG r= r% rX r% r& � FakeSocket� s r[ r r0 rS r, z/Could not accept new connection ({acceptError})c s( g | ] }|� d ��ko"|� d�� k�qS )Z log_formatZ acceptError)�get)rO �msg)�expectedErrorCode�expectedFormatr% r& rQ � s �z9SelectReactorTests._acceptFailureTest.<locals>.<listcomp>z+Log event for failed accept not found in %rN) r r> �patch�doRead�errno� errorcoderL � assertGreaterr )r$ rY r[ rU r> ZmatchingMessagesr% )r^ r_ rY r& �_acceptFailureTest� s � �z%SelectReactorTests._acceptFailureTestc C s | � t�S )a* C{accept(2)} can fail with C{EMFILE} when there are too many open file descriptors in the process. Test that this doesn't negatively impact any other existing connections. C{EMFILE} mainly occurs on Linux when the open file rlimit is encountered. )re r rM r% r% r& �test_tooManyFilesFromAccept� s z.SelectReactorTests.test_tooManyFilesFromAcceptc C s | � t�S )z� Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ENOBUFS}. This mainly occurs on Windows and FreeBSD, but may be possible on Linux and other platforms as well. )re r rM r% r% r& � test_noBufferSpaceFromAccept� s z/SelectReactorTests.test_noBufferSpaceFromAcceptc C s | � t�S )z� Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ECONNABORTED}. It is not clear whether this is actually possible for TCP connections on modern versions of Linux. )re r rM r% r% r& � test_connectionAbortedFromAccept� s z3SelectReactorTests.test_connectionAbortedFromAcceptr/ z(Windows accept(2) cannot generate ENFILEc C s | � t�S )z� Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ENFILE}. This can occur on Linux when the system has exhausted (!) its supply of inodes. )re r rM r% r% r& �test_noFilesFromAccept� s z)SelectReactorTests.test_noFilesFromAcceptz(Windows accept(2) cannot generate ENOMEMc C s | � t�S )a� Similar to L{test_tooManyFilesFromAccept}, but test the case where C{accept(2)} fails with C{ENOMEM}. On Linux at least, this can sensibly occur, even in a Python program (which eats memory like no ones business), when memory has become fragmented or low memory has been filled (d_alloc calls kmem_cache_alloc calls kmalloc - kmalloc only allocates out of low memory). )re r rM r% r% r& �test_noMemoryFromAccept� s z*SelectReactorTests.test_noMemoryFromAcceptZINFRASTRUCTUREZAZUREPIPELINESz(Hangs on Azure Pipelines due to firewallc s� t � }t|_| jd|dd��| ��j� g � � fdd�}| �|� �fdd�}� �|� � d�_��� | � �jd� � �|� � ��� | � �jd� ��� | � �jd� d S ) z� L{tcp.Port.doRead} increases the number of consecutive C{accept} calls it performs if all of the previous C{accept} calls succeed; otherwise, it reduces the number to the amount of successful calls. r r0 rS c s � D ] } | � � qd S rJ )r) �r? )�clientsr% r& �closeAll s z7SelectReactorTests.test_acceptScaling.<locals>.closeAllc s( t � t jt j�} | �d� �� jf� | S )Nr0 )r, �AF_INET� SOCK_STREAM�connectZgetHostr> rk )r> r% r& rp s z6SelectReactorTests.test_acceptScaling.<locals>.connectr N) r r �protocolr> Z addCleanuprN r- � numberAcceptsra rd � assertEqual)r$ rU rm rp r% )rl r> r& �test_acceptScaling s" z%SelectReactorTests.test_acceptScalingz'Windows accept(2) cannot generate EPERMc s� d�dg� G � ��fdd�d�}t ��D ]}��tj|� j� q(���j|� j� dg� t� }�jd|dd�}d|_�� |d|� � |� � �� |jd� d S ) z� C{accept(2)} returning C{EPERM} is treated as a transient failure and the call retried no more than the maximum number of consecutive C{accept(2)} calls. �{ r c s e Zd ZdZ� ��fdd�ZdS )zLSelectReactorTests.test_permissionFailure.<locals>.FakeSocketWithAcceptLimit�� Pretend to be a socket in an overloaded system whose C{accept} method can only be called C{maximumNumberOfAccepts} times. c s: � d d7 < � d �kr&�� d� ttt�t���d S )Nr r z(Maximum number of accept calls exceeded.)r9 r7 r rV rW �Zoself�Z acceptCallsZmaximumNumberOfAcceptsr$ r% r& r= C s zSSelectReactorTests.test_permissionFailure.<locals>.FakeSocketWithAcceptLimit.acceptNrZ r% rx r% r& �FakeSocketWithAcceptLimit< s ry r0 rS r, r N) r6 r; r, r< r= ZfailureExceptionr r> rr r` ra Z assertEquals)r$ ry �_rU r> r% rx r& �test_permissionFailure2 s z)SelectReactorTests.test_permissionFailurec s� t t�}|�tttg� tdd� |D ��d � G � fdd�d�}t� }| jd|dd�}| � |d |� � |� � | � t j �}| �dt|�� | �|d jjd � � d S ) z} A C{socket.error} raised by C{accept(2)} whose C{errno} is unknown to the recovery logic is logged. c s s | ]}t |t�r|V qd S rJ )� isinstance�int)rO r< r% r% r& � <genexpr>g rR zBSelectReactorTests.test_unknownSocketErrorRaise.<locals>.<genexpr>r c s e Zd ZdZ� fdd�ZdS )zYSelectReactorTests.test_unknownSocketErrorRaise.<locals>.FakeSocketWithUnknownAcceptErrorrv c s t � d��d S )Nz unknown socket error message)r7 rw �ZunknownAcceptErrorr% r& r= q s z`SelectReactorTests.test_unknownSocketErrorRaise.<locals>.FakeSocketWithUnknownAcceptError.acceptNrZ r% r r% r& � FakeSocketWithUnknownAcceptErrorj s r� r r0 rS r, N)�listr �extendr r r �maxr r> r` ra ZflushLoggedErrorsr, r< rs r �valuer8 )r$ Z knownErrorsr� rU r> Zfailuresr% r r& � test_unknownSocketErrorRaise^ s � z/SelectReactorTests.test_unknownSocketErrorRaiseN)rD rE rF rG r' r+ r> re rf rg rh r r rH ri rj rV �environr\ rt r{ r� r% r% r% r& rI � s( ) � ) +rI )'rG rb rV r, r � ImportErrorZunittestr Ztwisted.internetr r Ztwisted.internet.deferr r Ztwisted.internet.protocolr r Ztwisted.internet.tcpr r r r r r r r r r r Ztwisted.pythonr Ztwisted.python.runtimer Ztwisted.trial.unittestr Z IReactorFDSetZ providedByr rI r% r% r% r& �<module> s2 4 �[ �
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка