Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/__pycache__/test_fdset.cpython-39.pyc
Ðазад
a k�h�4 � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddlm Z ddl m Z m Z ddl mZmZ ddlmZ dd lmZ dd lmZ d d � ZG d d� de�Zee �G dd� d��Ze� �e�� � dS )z0 Tests for implementations of L{IReactorFDSet}. � N)�skipIf)� implementer)�FileDescriptor)� IReactorFDSet�IReadDescriptor)� EINPROGRESS� EWOULDBLOCK)�ReactorBuilder)�platform)�SkipTestc C s� t � � } | �d� | �d� z�t � � }zn|�d� z|�d| �� d f� W n8 ty� } z |jd tt fvrp� W Y d }~n d }~0 0 | � � \}}W n t y� |� � � Y n0 W | � � n | � � 0 ||fS )N)� 127.0.0.1r � Fr r ) �socket�bind�listen� setblocking�connect� getsockname�OSError�argsr r �accept� BaseException�close)Z serverSocket�client�e�server�addr� 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_fdset.py� socketpair s$ r c @ s� e Zd ZdZegZdd� Zdd� Zdd� Zdd � Z d d � Z d d � Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zee�� d�dd � �Zd d � Zd S ) �ReactorFDSetTestsBuilderz> Builder defining tests relating to L{IReactorFDSet}. c C s* t � \}}| �|j� | �|j� ||fS )zL Return the two sockets which make up a new TCP connection. )r Z addCleanupr )�selfr r r r r �_connectedPair8 s z'ReactorFDSetTestsBuilder._connectedPairc C s. | � � }| �� \}}t|�}|j|_|||fS �N)� buildReactorr" r �fileno)r! �reactorr r �fdr r r � _simpleSetupA s z%ReactorFDSetTestsBuilder._simpleSetupc sD | � � \�� }� �fdd�}|� _��� � |�d� | ��� dS )z� C{reactor.addReader()} accepts an L{IReadDescriptor} provider and calls its C{doRead} method when there may be data available on its C{fileno}. c s �� � � ��� d S r# )� removeReader�stopr �r' r& r r � removeAndStopR s z>ReactorFDSetTestsBuilder.test_addReader.<locals>.removeAndStop� xN)r( �doRead� addReader�sendall� runReactor�r! r r, r r+ r �test_addReaderK s z'ReactorFDSetTestsBuilder.test_addReaderc s` � � � \}}}� fdd�}||_|�|� |�|� |�d� |�d|jd|j� � �|� dS )z� L{reactor.removeReader()} accepts an L{IReadDescriptor} provider previously passed to C{reactor.addReader()} and causes it to no longer be monitored for input events. c s � � d� d S �NzdoRead should not be called��failr �r! r r r6 f s z8ReactorFDSetTestsBuilder.test_removeReader.<locals>.failr- r N)r( r. r/ r) r0 � callLaterr* r1 �r! r& r' r r6 r r7 r �test_removeReader^ s z*ReactorFDSetTestsBuilder.test_removeReaderc s: | � � \�� }� �fdd�}|� _��� � | ��� dS )z� C{reactor.addWriter()} accepts an L{IWriteDescriptor} provider and calls its C{doWrite} method when it may be possible to write to its C{fileno}. c s �� � � ��� d S r# )� removeWriterr* r r+ r r r, ~ s z>ReactorFDSetTestsBuilder.test_addWriter.<locals>.removeAndStopN)r( �doWrite� addWriterr1 r2 r r+ r �test_addWriterv s z'ReactorFDSetTestsBuilder.test_addWriterc C s� | � � }t|d| d �}t|d| �}t|d| �}| �� \}}| �||� � | �||� � ||� | �||� � | �||� � ||� | �||� � | �||� � dS )z= Helper for getReaders and getWriters tests. �get�s�add�removeN)r$ �getattrr" Z assertNotInZassertIn)r! �kindr& r? rA rB r r r r r � _getFDTest� s z#ReactorFDSetTestsBuilder._getFDTestc C s | � d� dS )z� L{IReactorFDSet.getReaders} reflects the additions and removals made with L{IReactorFDSet.addReader} and L{IReactorFDSet.removeReader}. �ReaderN�rE r7 r r r �test_getReaders� s z(ReactorFDSetTestsBuilder.test_getReadersc sV � � � \}}}� fdd�}||_|�|� |�|� |�d|jd|j� � �|� dS )z� L{reactor.removeWriter()} accepts an L{IWriteDescriptor} provider previously passed to C{reactor.addWriter()} and causes it to no longer be monitored for outputability. c s � � d� d S �Nz doWrite should not be calledr5 r r7 r r r6 � s z8ReactorFDSetTestsBuilder.test_removeWriter.<locals>.failr N)r( r< r= r; r8 r* r1 r9 r r7 r �test_removeWriter� s z*ReactorFDSetTestsBuilder.test_removeWriterc C s | � d� dS )z� L{IReactorFDSet.getWriters} reflects the additions and removals made with L{IReactorFDSet.addWriter} and L{IReactorFDSet.removeWriter}. �WriterNrG r7 r r r �test_getWriters� s z(ReactorFDSetTestsBuilder.test_getWritersc s� � � � }� �� \}}}� fdd�|_� fdd�|_|�d� |�|� |�|� |�� }|�d|jd|j � � � |� � � ||g� dS )z� C{reactor.removeAll()} removes all registered L{IReadDescriptor} providers and all registered L{IWriteDescriptor} providers and returns them. c s � � d�S r4 r5 r r7 r r �<lambda>� � z9ReactorFDSetTestsBuilder.test_removeAll.<locals>.<lambda>c s � � d�S rI r5 r r7 r r rM � rN r- r N) r$ r( r. r< r0 r/ r= Z removeAllr8 r* r1 � assertEqual)r! r& r' r Zremovedr r7 r �test_removeAll� s z'ReactorFDSetTestsBuilder.test_removeAllc C s8 | � � }t|�}|�|j� | �|� | �|jg � dS )z� A descriptor's C{fileno} method should not be called after the descriptor has been removed from the reactor. N)r$ �RemovingDescriptor�callWhenRunning�startr1 rO �calls)r! r& � descriptorr r r �test_removedFromReactor� s z0ReactorFDSetTestsBuilder.test_removedFromReactorc sd | � � �| �� \� �G � ��fdd�dt�}|��}��|� � �d� | ��� | �|jd� dS )zp If L{FileDescriptor.fileno} returns C{-1}, the descriptor is removed from the reactor. c s: e Zd Z��� ZdZdd� Z� �fdd�Z�fdd�ZdS ) zWReactorFDSetTestsBuilder.test_negativeOneFileDescriptor.<locals>.DisappearingDescriptorrN c S s | j S r# )�_filenor7 r r r r% � s z^ReactorFDSetTestsBuilder.test_negativeOneFileDescriptor.<locals>.DisappearingDescriptor.filenoc s( d| _ | j��d�7 _� �d� d S )N���r � y)rW � _received�recv�sendr7 )r r r r r. � s z^ReactorFDSetTestsBuilder.test_negativeOneFileDescriptor.<locals>.DisappearingDescriptor.doReadc s � � � d S r# �r* �r! �reason�r& r r �connectionLost s zfReactorFDSetTestsBuilder.test_negativeOneFileDescriptor.<locals>.DisappearingDescriptor.connectionLostN)�__name__� __module__� __qualname__r% rW rZ r. ra r �r r& r r r �DisappearingDescriptor� s rf r- N)r$ r" r r/ r\ r1 rO rZ )r! rf rU r re r � test_negativeOneFileDescriptor� s z7ReactorFDSetTestsBuilder.test_negativeOneFileDescriptorz*Cannot duplicate socket filenos on Windowsc s� �� � � � jj}|dv r&t|�d������ \}�G � �fdd�dt�}� �|� � ��fdd�}� �d|� ��� � �� t j � dS ) a The file descriptor underlying a FileDescriptor may be closed and replaced by another at some point. Bytes which arrive on the new descriptor must not be delivered to the FileDescriptor which was originally registered with the original descriptor of the same number. Practically speaking, this is difficult or impossible to detect. The implementation relies on C{fileno} raising an exception if the original descriptor has gone away. If C{fileno} continues to return the original file descriptor value, the reactor may deliver events from that descriptor. This is a best effort attempt to ease certain debugging situations. Applications should not rely on it intentionally. )Z EPollReactorZ KQueueReactorZ CFReactorZAsyncioSelectorReactorz$ cannot detect lost file descriptorsc s0 e Zd ZdZ�fdd�Zdd� Z� fdd�ZdS ) z@ReactorFDSetTestsBuilder.test_lostFileDescriptor.<locals>.Victima� This L{FileDescriptor} will have its socket closed out from under it and another socket will take its place. It will raise a socket.error from C{fileno} after this happens (because socket objects remember whether they have been closed), so as long as the reactor calls the C{fileno} method the problem will be detected. c s � � � S r# )r% r7 )r r r r% 3 s zGReactorFDSetTestsBuilder.test_lostFileDescriptor.<locals>.Victim.filenoc S s t d��d S )Nz$Victim.doRead should never be called)� Exceptionr7 r r r r. 6 s zGReactorFDSetTestsBuilder.test_lostFileDescriptor.<locals>.Victim.doReadc s � � � dS )z� When the problem is detected, the reactor should disconnect this file descriptor. When that happens, stop the reactor so the test ends. Nr] r^ r` r r ra 9 s zOReactorFDSetTestsBuilder.test_lostFileDescriptor.<locals>.Victim.connectionLostN)rb rc rd �__doc__r% r. ra r )r& r r r �Victim* s rj c s: � � � \} }��� }��� t�|�� |� | �d� d S )Nr- )r" r% r �os�dup2r\ )ZnewCZnewSr% )r! r r r �messItUpH s zBReactorFDSetTestsBuilder.test_lostFileDescriptor.<locals>.messItUpr N) r$ � __class__rb r r" r r/ r8 r1 ZflushLoggedErrorsr �error)r! �namer rj rm r )r& r! r r �test_lostFileDescriptor s z0ReactorFDSetTestsBuilder.test_lostFileDescriptorc C s� | � � }G dd� dt�}| �� \}}||�}|j|_||�}|j|_|�|� |�|� |�|j� | �|� | � |j � | � |j � dS )z� Any file descriptors added to the reactor have their C{connectionLost} called when C{reactor.stop} is called. c @ s e Zd Zdd� Zdd� ZdS )zSReactorFDSetTestsBuilder.test_connectionLostOnShutdown.<locals>.DoNothingDescriptorc S s d S r# r r7 r r r r. _ s zZReactorFDSetTestsBuilder.test_connectionLostOnShutdown.<locals>.DoNothingDescriptor.doReadc S s d S r# r r7 r r r r< b s z[ReactorFDSetTestsBuilder.test_connectionLostOnShutdown.<locals>.DoNothingDescriptor.doWriteN)rb rc rd r. r< r r r r �DoNothingDescriptor^ s rr N) r$ r r" r% r/ r= rR r* r1 Z assertTrueZ disconnected)r! r& rr r r Zfd1�fd2r r r � test_connectionLostOnShutdownW s z6ReactorFDSetTestsBuilder.test_connectionLostOnShutdownN)rb rc rd ri r ZrequiredInterfacesr" r( r3 r: r> rE rH rJ rL rP rV rg r r Z isWindowsrq rt r r r r r 1 s" Lr c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )rQ a� A read descriptor which removes itself from the reactor as soon as it gets a chance to do a read and keeps track of when its own C{fileno} method is called. @ivar insideReactor: A flag which is true as long as the reactor has this descriptor as a reader. @ivar calls: A list of the bottom of the call stack for any call to C{fileno} when C{insideReactor} is false. c C s$ || _ d| _g | _t� \| _| _d S �NF)r& � insideReactorrT r �read�write)r! r& r r r �__init__� s zRemovingDescriptor.__init__c C s" d| _ | j�| � | j�d� d S )NT� a)rv r& r/ rx r\ r7 r r r rS � s zRemovingDescriptor.startc C s dS )NZfoor r7 r r r � logPrefix� s z RemovingDescriptor.logPrefixc C s4 | j �| � d| _| j �� | j�� | j�� d S ru )r& r) rv r* rw r rx r7 r r r r. � s zRemovingDescriptor.doReadc C s, | j s"| j�tjdd�d d� � | j�� S )N� )�limitrX )rv rT �append� traceback� extract_stackrw r% r7 r r r r% � s zRemovingDescriptor.filenoc C s d S r# r r^ r r r ra � s z!RemovingDescriptor.connectionLostN) rb rc rd ri ry rS r{ r. r% ra r r r r rQ t s rQ ) ri rk r r Zunittestr Zzope.interfacer Ztwisted.internet.abstractr Ztwisted.internet.interfacesr r Ztwisted.internet.tcpr r Z#twisted.internet.test.reactormixinsr Ztwisted.python.runtimer Ztwisted.trial.unittestr r r rQ �globals�updateZmakeTestCaseClassesr r r r �<module> s$ E.
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка