Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/__pycache__/test_epollreactor.cpython-39.pyc
Ðазад
a k�h� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z zddl m Z W n e yf dZ Y n0 G d d � d �Zee d �G d d � d e ��ZdS )z- Tests for L{twisted.internet.epollreactor}. � )�skipIf��ConnectionDone)�_ContinuousPolling)�Clock)�TestCase)� epollreactorNc @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � DescriptorzF Records reads and writes, as if it were a C{FileDescriptor}. c C s g | _ d S �N)�events��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_epollreactor.py�__init__ s zDescriptor.__init__c C s dS )N� r r r r r �fileno s zDescriptor.filenoc C s | j �d� d S )N�read�r �appendr r r r �doRead s zDescriptor.doReadc C s | j �d� d S )N�writer r r r r �doWrite# s zDescriptor.doWritec C s |� t� | j�d� d S )N�lost)Ztrapr r r )r �reasonr r r �connectionLost& s zDescriptor.connectionLostN) �__name__� __module__� __qualname__�__doc__r r r r r r r r r r s r z(epoll not supported in this environment.c @ sx e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd S ) �ContinuousPollingTestsza L{_ContinuousPolling} can be used to read and write from C{FileDescriptor} objects. c C sv t t� �}| �|j� t� }| �|�|�� |�|� | �|j� | � |jj � | � |jj |j � | � |�|�� dS )zi Adding a reader when there was previously no reader starts up a C{LoopingCall}. N)r r � assertIsNone�_loop�object� assertFalse� isReading� addReader�assertIsNotNone� assertTrue�running�assertIs�clock�_reactor�r �poller�readerr r r �test_addReader2 s z%ContinuousPollingTests.test_addReaderc C sv t t� �}| �|j� t� }| �|�|�� |�|� | �|j� | � |jj � | � |jj |j � | � |�|�� dS )zi Adding a writer when there was previously no writer starts up a C{LoopingCall}. N)r r r! r" r# r$ � isWriting� addWriterr' r( r) r* r+ r, �r r. �writerr r r �test_addWriterA s z%ContinuousPollingTests.test_addWriterc C sV t t� �}t� }|�|� |�|� | �|j� | �|j� � g � | � |� |�� dS )z= Removing a reader stops the C{LoopingCall}. N) r r r# r& � removeReaderr! r" � assertEqualr, �getDelayedCallsr$ r% r- r r r �test_removeReaderP s z(ContinuousPollingTests.test_removeReaderc C sV t t� �}t� }|�|� |�|� | �|j� | �|j� � g � | � |� |�� dS )z= Removing a writer stops the C{LoopingCall}. N) r r r# r2 � removeWriterr! r" r7 r, r8 r$ r1 r3 r r r �test_removeWriter\ s z(ContinuousPollingTests.test_removeWriterc C s& t t� �}|�t� � |�t� � dS )zM Removing unknown readers and writers silently does nothing. N)r r r: r# r6 )r r. r r r �test_removeUnknownh s z)ContinuousPollingTests.test_removeUnknownc C s� t t� �}t� }|�|� | �|j� |�t� � | �|j� |�t� � | �|j� |�t� � |�|� | �|j� | �|jj � | � t |j � � �d� dS )za Adding multiple readers and writers results in a single C{LoopingCall}. r N)r r r# r2 r' r" r& r: r( r) r7 �lenr, r8 r3 r r r � test_multipleReadersAndWritersp s z5ContinuousPollingTests.test_multipleReadersAndWritersc C s� t � }t|�}t� }|�|� | �|jg � |�d� | �|jdg� |�d� | �|jddg� |�d� | �|jg d�� dS )za Adding a reader causes its C{doRead} to be called every 1 milliseconds. g�h㈵��>r )r r r N)r r r r& r7 r �advance�r Zreactorr. �descr r r �test_readerPolling� s z)ContinuousPollingTests.test_readerPollingc C s� t � }t|�}t� }|�|� | �|jg � |�d� | �|jdg� |�d� | �|jddg� |�d� | �|jg d�� dS )zb Adding a writer causes its C{doWrite} to be called every 1 milliseconds. ���MbP?r )r r r N)r r r r2 r7 r r? r@ r r r �test_writerPolling� s z)ContinuousPollingTests.test_writerPollingc C sT t � }t|�}t� }dd� |_|�|� | �|jg � |�d� | �|jdg� dS )zu If a C{doRead} returns a value indicating disconnection, C{connectionLost} is called on it. c S s t � S r r r r r r �<lambda>� � zBContinuousPollingTests.test_connectionLostOnRead.<locals>.<lambda>rC r N)r r r r r& r7 r r? r@ r r r �test_connectionLostOnRead� s z0ContinuousPollingTests.test_connectionLostOnReadc C sT t � }t|�}t� }dd� |_|�|� | �|jg � |�d� | �|jdg� dS )zv If a C{doWrite} returns a value indicating disconnection, C{connectionLost} is called on it. c S s t � S r r r r r r rE � rF zCContinuousPollingTests.test_connectionLostOnWrite.<locals>.<lambda>rC r N)r r r r r2 r7 r r? r@ r r r �test_connectionLostOnWrite� s z1ContinuousPollingTests.test_connectionLostOnWritec C s� t t� �}t� }t� }t� }|�|� |�|� |�|� |�|� |�� }| �|�� g � | �|�� g � | �t |�d� | �t |�|||h� dS )zv L{_ContinuousPolling.removeAll} removes all descriptors and returns the readers and writers. � N) r r r# r& r2 Z removeAllr7 � getReaders� getWritersr= �set)r r. r/ r4 ZbothZremovedr r r �test_removeAll� s z%ContinuousPollingTests.test_removeAllc C s. t t� �}t� }|�|� | �||�� � dS )zb L{_ContinuousPolling.getReaders} returns a list of the read descriptors. N)r r r# r& �assertInrJ r- r r r �test_getReaders� s z&ContinuousPollingTests.test_getReadersc C s. t t� �}t� }|�|� | �||�� � dS )zc L{_ContinuousPolling.getWriters} returns a list of the write descriptors. N)r r r# r2 rN rK r3 r r r �test_getWriters� s z&ContinuousPollingTests.test_getWritersN)r r r r r0 r5 r9 r; r< r> rB rD rG rH rM rO rP r r r r r + s r )r Zunittestr Ztwisted.internet.errorr Ztwisted.internet.posixbaser Ztwisted.internet.taskr Ztwisted.trial.unittestr Ztwisted.internetr � ImportErrorr r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка