Файловый менеджер - Редактировать - /usr/lib/python3/dist-packages/twisted/internet/test/__pycache__/test_posixbase.cpython-310.pyc
Ðазад
o �b�% � @ s� d Z ddlmZ ddlmZmZ ddlmZ ddlm Z dZ zddl m Z ddl mZ W n ey7 d Z Y nw 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 �F/usr/lib/python3/dist-packages/twisted/internet/test/test_posixbase.pyr s zTrivialReactor.__init__c C � d| j |< d S �NT�r �r �readerr r r � addReader � zTrivialReactor.addReaderc C � | j |= d S r r r r r r � removeReader" � zTrivialReactor.removeReaderc C r r �r �r �writerr r r � addWriter% r zTrivialReactor.addWriterc C r r r r r r r � removeWriter( r 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 )�assertIsInstance�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" r1 r r � assertEqual�set� assertNotIn)r r r r! �removedr r r �'test_removeAllReturnsRemovedDescriptorsL s z=PosixReactorBaseTests.test_removeAllReturnsRemovedDescriptorsN)r$ r% r& �__doc__r- r. r3 r8 r r r r r' , s r' c @ s& e Zd ZdZeee�s dZdd� 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�connectionLost� assertFailure� stopListening�ZeroDivisionError)r �portr r r �test_connectionLostFailedd s z&TCPPortTests.test_connectionLostFailedN) r$ r% r& r9 � isinstancer r �skiprE r r r r r: \ s r: 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 { � 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. )rK r r r r �seconds� s z TimeoutReportReactor.secondsc C s& | j }|d urd | _ |�|� d S d S r )rJ �callback)r �timeout�dr r r � doIteration� s �z TimeoutReportReactor.doIterationN) r$ r% r& r9 r r rM rN rR r r r r rH o s rH 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)�ignoredr r r r= � r> z>IterationTimeoutTests._checkIterationTimeout.<locals>.<lambda>r )rJ � addCallback�append�run�r r rP 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)rH rZ � assertIsNonerY 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. rI c S � d S r r r r r r r= � rL z8IterationTimeoutTests.test_delayedCall.<locals>.<lambda>N�rH � callLaterrZ r4 rY 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. rI c S r] r r r r r r r= � rL z7IterationTimeoutTests.test_timePasses.<locals>.<lambda>� �K N)rH r_ rK rZ r4 rY 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 r] r r r r r r r= � rL zAIterationTimeoutTests.test_multipleDelayedCalls.<locals>.<lambda>� c S r] r r r r r r r= � rL rI c S r] r r r r r r r= � rL Nr^ rY 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. rd c S r] r r r r r r r= � rL z=IterationTimeoutTests.test_resetDelayedCall.<locals>.<lambda>ra � N)rH r_ rK �resetrZ r4 �r r �callrP 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. rd c S r] r r r r r r r= � rL z=IterationTimeoutTests.test_delayDelayedCall.<locals>.<lambda>re � �< N)rH r_ rK �delayrZ r4 ri 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}. rd c S r] r r r r r r r= � rL z>IterationTimeoutTests.test_cancelDelayedCall.<locals>.<lambda>N)rH r_ �cancelrZ r[ ri r r r �test_cancelDelayedCall� s z,IterationTimeoutTests.test_cancelDelayedCallN) r$ r% r& r9 rZ r\ r` rc rf rk ro rq r r r r rS � s rS c @ s, e Zd ZdZedur eZdd� 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)�failr r r r �loseConnection s z`ConnectedDatagramPortTests.test_connectionFailedDoesntCallLoseConnection.<locals>.loseConnectionN�goodbye)r �ConnectedDatagramPortr rt �connectionFailed)r rt rD 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 rB s zYConnectedDatagramPortTests.test_connectionFailedCallsStopListening.<locals>.stopListeningNru )ry r rv r rB rw � assertTrue)r rB rD r r r �'test_connectionFailedCallsStopListening s zBConnectedDatagramPortTests.test_connectionFailedCallsStopListening)r$ r% r& r9 � skipSocketsrG rx r{ r r r r rr � s rr c @ s e Zd Zdd� ZdS )� WakerTestsc C s0 t d d�}| �� }|�d � | �t|�d� d S )Nr r )r � flushWarningsr@ r4 �len)r r) �warningsr r r � test_noWakerConstructionWarnings' s z+WakerTests.test_noWakerConstructionWarningsN)r$ r% r& r� r r r r r} & s r} )r9 �twisted.internet.deferr �twisted.internet.posixbaser r �twisted.internet.protocolr �twisted.trial.unittestr r| �twisted.internetr �twisted.test.test_unixr � ImportErrorr �twisted.internet.tcpr r r' r: rH rS rr r} r r r r �<module> s* � 0(b-
| ver. 1.1 | |
.
| PHP 8.4.18 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка