Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/__pycache__/test_posixbase.cpython-39.pyc
Ðазад
a k�h�% � @ s� d Z ddlmZ ddlmZmZ ddlmZ ddlm Z dZ z ddl m Z ddl mZ W n eyn d Z Y n0 dd l mZ dd lmZ G d d � d e�ZG dd� de �ZG dd� de �ZG dd� de�ZG dd� de �ZG dd� de �ZG dd� de �ZdS )z> Tests for L{twisted.internet.posixbase} and supporting code. � )�Deferred)�PosixReactorBase�_Waker)� ServerFactory)�TestCaseN)�unix)� ClientProtoz)Platform does not support AF_UNIX sockets��reactor)�Portc @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �TrivialReactorc C s i | _ i | _t�| � d S �N)�_readers�_writersr �__init__��self� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/test_posixbase.pyr s zTrivialReactor.__init__c C s d| j |< d S �NT�r �r �readerr r r � addReader s zTrivialReactor.addReaderc C s | j |= d S r r r r r r � removeReader" s zTrivialReactor.removeReaderc C s d| j |< d S r �r �r �writerr r r � addWriter% s zTrivialReactor.addWriterc C s | j |= d S r r r r r r � removeWriter( s zTrivialReactor.removeWriterN)�__name__� __module__� __qualname__r r r r r r r r r r s r c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) �PosixReactorBaseTestsz( Tests for L{PosixReactorBase}. c C s2 | � |jt� | �|j|j� | �|j|j� d S r )ZassertIsInstance�wakerr �assertIn�_internalReadersr �r r r r r � _checkWaker1 s z!PosixReactorBaseTests._checkWakerc C s t � }| �|� dS )z When L{PosixReactorBase} is instantiated, it creates a waker and adds it to its internal readers set. N)r r( r' r r r �test_wakerIsInternalReader6 s z0PosixReactorBaseTests.test_wakerIsInternalReaderc C s\ t � }t� }|j�|� |�|� |�|j|j� | �|� | � ||j� | � ||j� dS )z� Any L{IReadDescriptors} in L{PosixReactorBase._internalReaders} are left alone by L{PosixReactorBase._removeAll}. N) r �objectr& �addr � _removeAllr r r( r% )r r �extrar r r �"test_removeAllSkipsInternalReaders> s z8PosixReactorBaseTests.test_removeAllSkipsInternalReadersc C sj t � }t� }t� }|�|� |�|� |�|j|j�}| �t|�||h� | � ||j� | � ||j� dS )z� L{PosixReactorBase._removeAll} returns a list of removed L{IReadDescriptor} and L{IWriteDescriptor} objects. N) r r* r r r, r r � assertEqual�setZ assertNotIn)r r r r Zremovedr r r �'test_removeAllReturnsRemovedDescriptorsL s z=PosixReactorBaseTests.test_removeAllReturnsRemovedDescriptorsN)r r! r" �__doc__r( r) r. r1 r r r r r# , s r# c @ s& e Zd ZdZeee�sdZdd� ZdS )� TCPPortTestsz1 Tests for L{twisted.internet.tcp.Port}. zNon-posixbase reactorc C s, t dt� �}d|_dd� |_| �|�� t�S )z� L{Port.stopListening} returns a L{Deferred} which errbacks if L{Port.connectionLost} raises an exception. i90 Tc S s dd S )N� r r )�reasonr r r �<lambda>k � z8TCPPortTests.test_connectionLostFailed.<locals>.<lambda>)r r � connected�connectionLostZ assertFailure� stopListening�ZeroDivisionError)r �portr r r �test_connectionLostFailedd s z&TCPPortTests.test_connectionLostFailedN) r r! r" r2 � isinstancer r �skipr= r r r r r3 \ s r3 c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �TimeoutReportReactorz� A reactor which is just barely runnable and which cannot monitor any readers or writers, and which fires a L{Deferred} with the timeout passed to its C{doIteration} method as soon as that method is invoked. c C s t �| � t� | _d| _d S )N�d )r r r �iterationTimeout�nowr r r r r v s z TimeoutReportReactor.__init__c C s dS )z� Ignore the reader. This is necessary because the waker will be added. However, we won't actually monitor it for any events. Nr r r r r r { s z TimeoutReportReactor.addReaderc C s g S )z� There are no readers or writers, so there is nothing to remove. This will be called when the reactor stops, though, so it must be implemented. r r r r r � removeAll� s z TimeoutReportReactor.removeAllc C s | j S )zx Override the real clock with a deterministic one that can be easily controlled in a unit test. )rC r r r r �seconds� s z TimeoutReportReactor.secondsc C s" | j }|d ur d | _ |�|� d S r )rB �callback)r �timeout�dr r r � doIteration� s z TimeoutReportReactor.doIterationN) r r! r" r2 r r rD rE rI r r r r r@ o s r@ c @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dS )�IterationTimeoutTestsz� Tests for the timeout argument L{PosixReactorBase.run} calls L{PosixReactorBase.doIteration} with in the presence of various delayed calls. c s6 g }� j �|j� � j �� fdd�� � �� |d S )Nc s � � � S r )�stop)Zignoredr r r r6 � r7 z>IterationTimeoutTests._checkIterationTimeout.<locals>.<lambda>r )rB Z addCallback�append�run�r r rG r r r �_checkIterationTimeout� s z,IterationTimeoutTests._checkIterationTimeoutc C s t � }| �|�}| �|� dS )zl If there are no delayed calls, C{doIteration} is called with a timeout of L{None}. N)r@ rO � assertIsNonerN r r r � test_noCalls� s z"IterationTimeoutTests.test_noCallsc C s0 t � }|�ddd� � | �|�}| �|d� dS )z� If there is a delayed call, C{doIteration} is called with a timeout which is the difference between the current time and the time at which that call is to run. rA c S s d S r r r r r r r6 � r7 z8IterationTimeoutTests.test_delayedCall.<locals>.<lambda>N�r@ � callLaterrO r/ rN r r r �test_delayedCall� s z&IterationTimeoutTests.test_delayedCallc C s> t � }|�ddd� � | jd7 _| �|�}| �|d� dS )z� If a delayed call is scheduled and then some time passes, the timeout passed to C{doIteration} is reduced by the amount of time which passed. rA c S s d S r r r r r r r6 � r7 z7IterationTimeoutTests.test_timePasses.<locals>.<lambda>� �K N)r@ rS rC rO r/ rN r r r �test_timePasses� s z%IterationTimeoutTests.test_timePassesc C sP t � }|�ddd� � |�ddd� � |�ddd� � | �|�}| �|d� dS ) z� If there are several delayed calls, C{doIteration} is called with a timeout which is the difference between the current time and the time at which the earlier of the two calls is to run. �2 c S s d S r r r r r r r6 � r7 zAIterationTimeoutTests.test_multipleDelayedCalls.<locals>.<lambda>� c S s d S r r r r r r r6 � r7 rA c S s d S r r r r r r r6 � r7 NrR rN r r r �test_multipleDelayedCalls� s z/IterationTimeoutTests.test_multipleDelayedCallsc C sH t � }|�ddd� �}| jd7 _|�d� | �|�}| �|d� dS )z� If a delayed call is reset, the timeout passed to C{doIteration} is based on the interval between the time when reset is called and the new delay of the call. rX c S s d S r r r r r r r6 � r7 z=IterationTimeoutTests.test_resetDelayedCall.<locals>.<lambda>rU � N)r@ rS rC �resetrO r/ �r r �callrG r r r �test_resetDelayedCall� s z+IterationTimeoutTests.test_resetDelayedCallc C sH t � }|�ddd� �}| jd7 _|�d� | �|�}| �|d� dS )z� If a delayed call is re-delayed, the timeout passed to C{doIteration} is based on the remaining time before the call would have been made and the additional amount of time passed to the delay method. rX c S s d S r r r r r r r6 � r7 z=IterationTimeoutTests.test_delayDelayedCall.<locals>.<lambda>rY � �< N)r@ rS rC �delayrO r/ r] r r r �test_delayDelayedCall� s z+IterationTimeoutTests.test_delayDelayedCallc C s6 t � }|�ddd� �}|�� | �|�}| �|� dS )zp If the only delayed call is canceled, L{None} is the timeout passed to C{doIteration}. rX c S s d S r r r r r r r6 � r7 z>IterationTimeoutTests.test_cancelDelayedCall.<locals>.<lambda>N)r@ rS �cancelrO rP r] r r r �test_cancelDelayedCall� s z,IterationTimeoutTests.test_cancelDelayedCallN) r r! r" r2 rO rQ rT rW rZ r_ rc re r r r r rJ � s rJ c @ s, e Zd ZdZedureZdd� Zdd� ZdS )�ConnectedDatagramPortTestsz/ Test connected datagram UNIX sockets. Nc s. � fdd�}t �dt� �}||_|�d� dS )z� L{ConnectedDatagramPort} does not call the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. c s � � d� dS )z� Dummy C{loseConnection} method. C{loseConnection} is deprecated and should not get called. z7loseConnection is deprecated and should not get called.N)Zfailr r r r �loseConnection s z`ConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnection.<locals>.loseConnectionN�goodbye)r �ConnectedDatagramPortr rg �connectionFailed)r rg r< r r r �-test_connectionFailedDoesntCallLoseConnection s zHConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnectionc s@ d� _ � fdd�}t�dt� �}||_|�d� � �� j � dS )z� L{ConnectedDatagramPort} calls L{ConnectedDatagramPort.stopListening} instead of the deprecated C{loseConnection} in L{ConnectedDatagramPort.connectionFailed}. Fc s d� _ dS )z8 Dummy C{stopListening} method. TN)�calledr r r r r: s zYConnectedDatagramPortTests.test_connectionFailedCallsStopListening.<locals>.stopListeningNrh )rl r ri r r: rj Z assertTrue)r r: r< r r r �'test_connectionFailedCallsStopListening s zBConnectedDatagramPortTests.test_connectionFailedCallsStopListening)r r! r" r2 � skipSocketsr? rk rm r r r r rf � s rf c @ s e Zd Zdd� ZdS )� WakerTestsc C s0 t d d�}| �� }|�d � | �t|�d� d S )Nr r )r Z flushWarningsr9 r/ �len)r r$ �warningsr r r � test_noWakerConstructionWarnings' s z+WakerTests.test_noWakerConstructionWarningsN)r r! r" rr r r r r ro & s ro )r2 Ztwisted.internet.deferr Ztwisted.internet.posixbaser r Ztwisted.internet.protocolr Ztwisted.trial.unittestr rn Ztwisted.internetr Ztwisted.test.test_unixr � ImportErrorr Ztwisted.internet.tcpr r r# r3 r@ rJ rf ro r r r r �<module> s& 0(b-
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка