Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/internet/test/__pycache__/test_inotify.cpython-39.pyc
Ðазад
a k�h�H � @ sx d Z ddlZddlmZmZ ddlmZmZ ddlm Z ddl m Z e d�dur^ddlm Z ndZ G d d � d e j �ZdS ) z? Tests for the inotify wrapper in L{twisted.internet.inotify}. � N)�defer�reactor)�filepath�runtime)� requireModule)�unittestztwisted.python._inotify)�inotifyc @ s e Zd ZdZej�� sdZdd� Zdd� Z d<dd �Z d d � Z d d � Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Z d.d/� Z d0d1� Z d2d3� Z d4d5� Z d6d7� Z!d8d9� Z"d:d;� Z#dS )=� INotifyTestsz] Define all the tests for the basic functionality exposed by L{inotify.INotify}. z&This platform doesn't support INotify.c C s@ t �| �� �| _| j�� t�� | _| j�� | �| jj � d S �N) r �FilePath�mktemp�dirname�createDirectoryr �INotifyZ startReadingZ addCleanup�loseConnection��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_inotify.py�setUp s zINotifyTests.setUpc C s4 G dd� d�}| � tjd|� � | �tjtj� dS )a L{inotify.INotify} emits a C{RuntimeError} when initialized in an environment that doesn't support inotify as we expect it. We just try to raise an exception for every possible case in the for loop in L{inotify.INotify._inotify__init__}. c @ s e Zd Zdd� ZdS )z;INotifyTests.test_initializationErrors.<locals>.FakeINotifyc S s t �� �d S r )r � INotifyErrorr r r r �init. s z@INotifyTests.test_initializationErrors.<locals>.FakeINotify.initN)�__name__� __module__� __qualname__r r r r r � FakeINotify- s r Z_inotifyN)�patchr r � assertRaisesr )r r r r r �test_initializationErrors$ s z&INotifyTests.test_initializationErrorsNc s` � du r�j �d�� t�� �� ��fdd�}��|� �jj�j ��fdd�gd� |� � �S )a� Test notification from some filesystem operation. @param mask: The event mask to use when setting up the watch. @param operation: A function which will be called with the name of a file in the watched directory and which should trigger the event. @param expectedPath: Optionally, the name of the path which is expected to come back in the notification event; this will also be passed to C{operation} (primarily useful when the operation is being done to the directory itself, not a file in it). @return: A L{Deferred} which fires successfully when the expected event has been received or fails otherwise. Nzfoo.barc s0 | \}}}�� |�� � �� � ��|�@ � d S r )� assertEqual� asBytesMode� assertTrue��result�watch�filename�events)� expectedPath�maskr r r � cbNotifiedK s z2INotifyTests._notificationTest.<locals>.cbNotifiedc s � � | �S r ��callback��args��notifiedr r �<lambda>S � z0INotifyTests._notificationTest.<locals>.<lambda>�r( � callbacks)r �childr �Deferred� addCallbackr r$ )r r( � operationr' r) r )r' r( r/ r r �_notificationTest4 s �z INotifyTests._notificationTestc C s dd� }| � tj|�S )z{ Reading from a file in a monitored directory sends an C{inotify.IN_ACCESS} event to the callback. c S s | � d� | �� d S )N� foo)� setContentZ getContent��pathr r r r7 ^ s z+INotifyTests.test_access.<locals>.operation)r8 r � IN_ACCESS�r r7 r r r � test_accessX s zINotifyTests.test_accessc C s dd� }| � tj|�S )zy Writing to a file in a monitored directory sends an C{inotify.IN_MODIFY} event to the callback. c S s8 | � d��}|�d� W d � n1 s*0 Y d S )N�wr9 )�open�write)r< ZfObjr r r r7 j s z+INotifyTests.test_modify.<locals>.operation)r8 r Z IN_MODIFYr> r r r � test_modifyd s zINotifyTests.test_modifyc C s dd� }| � tj|�S )z� Changing the metadata of a file in a monitored directory sends an C{inotify.IN_ATTRIB} event to the callback. c S s | � � | � � d S r )�touchr; r r r r7 v s z+INotifyTests.test_attrib.<locals>.operation)r8 r Z IN_ATTRIBr> r r r � test_attribp s zINotifyTests.test_attribc C s dd� }| � tj|�S )z� Closing a file which was open for writing in a monitored directory sends an C{inotify.IN_CLOSE_WRITE} event to the callback. c S s | � d��� d S �Nr@ �rA �closer; r r r r7 � s z/INotifyTests.test_closeWrite.<locals>.operation)r8 r �IN_CLOSE_WRITEr> r r r �test_closeWrite| s z INotifyTests.test_closeWritec C s dd� }| � tj|�S )z� Closing a file which was open for reading but not writing in a monitored directory sends an C{inotify.IN_CLOSE_NOWRITE} event to the callback. c S s | � � | �d��� d S )N�r)rD rA rH r; r r r r7 � s z1INotifyTests.test_closeNoWrite.<locals>.operation)r8 r ZIN_CLOSE_NOWRITEr> r r r �test_closeNoWrite� s z INotifyTests.test_closeNoWritec C s dd� }| � tj|�S )zt Opening a file in a monitored directory sends an C{inotify.IN_OPEN} event to the callback. c S s | � d��� d S rF rG r; r r r r7 � s z)INotifyTests.test_open.<locals>.operation)r8 r �IN_OPENr> r r r � test_open� s zINotifyTests.test_openc s � fdd�}� � tj|�S )z} Moving a file out of a monitored directory sends an C{inotify.IN_MOVED_FROM} event to the callback. c s& | � d��� | �t�� �� �� d S rF )rA rH �moveTor r r r; r r r r7 � s z.INotifyTests.test_movedFrom.<locals>.operation)r8 r Z IN_MOVED_FROMr> r r r �test_movedFrom� s zINotifyTests.test_movedFromc s � fdd�}� � tj|�S )zy Moving a file into a monitored directory sends an C{inotify.IN_MOVED_TO} event to the callback. c s$ t �� �� �}|�� |�| � d S r )r r r rD rO )r< �pr r r r7 � s z,INotifyTests.test_movedTo.<locals>.operation)r8 r Z IN_MOVED_TOr> r r r � test_movedTo� s zINotifyTests.test_movedToc C s dd� }| � tj|�S )zw Creating a file in a monitored directory sends an C{inotify.IN_CREATE} event to the callback. c S s | � d��� d S rF rG r; r r r r7 � s z+INotifyTests.test_create.<locals>.operation)r8 r � IN_CREATEr> r r r � test_create� s zINotifyTests.test_createc C s dd� }| � tj|�S )zw Deleting a file in a monitored directory sends an C{inotify.IN_DELETE} event to the callback. c S s | � � | �� d S r )rD �remover; r r r r7 � s z+INotifyTests.test_delete.<locals>.operation)r8 r Z IN_DELETEr> r r r � test_delete� s zINotifyTests.test_deletec C s dd� }| j tj|| jd�S )z{ Deleting the monitored directory itself sends an C{inotify.IN_DELETE_SELF} event to the callback. c S s | � � d S r )rU r; r r r r7 � s z/INotifyTests.test_deleteSelf.<locals>.operation�r' )r8 r �IN_DELETE_SELFr r> r r r �test_deleteSelf� s �z INotifyTests.test_deleteSelfc sJ �fdd�}�j j�jd� fdd�gd� t�� � � �|� �j�� � S )z� Deleting the monitored directory itself sends an C{inotify.IN_DELETE_SELF} event to the callback even if the mask isn't specified by the call to watch(). c s4 | \}}}� � |�� � j�� � � �|tj@ � d S r )r r r r! r rX r" r r r r) � s z6INotifyTests.test_deleteSelfForced.<locals>.cbNotifiedr c s � � | �S r r* r, )�dr r r0 � r1 z4INotifyTests.test_deleteSelfForced.<locals>.<lambda>r2 )r r$ r r r5 r6 rU �r r) r �rZ r r �test_deleteSelfForced� s � z"INotifyTests.test_deleteSelfForcedc s � fdd�}� j tj|� jd�S )zy Renaming the monitored directory itself sends an C{inotify.IN_MOVE_SELF} event to the callback. c s | � t�� �� �� d S r )rO r r r r; r r r r7 � s z-INotifyTests.test_moveSelf.<locals>.operationrW )r8 r Z IN_MOVE_SELFr r> r r r � test_moveSelf� s �zINotifyTests.test_moveSelfc sT � ��fdd�}t jt jB }�j j�j|d|gd� �j�d��t�� � ��� � S )z� L{inotify.INotify} when initialized with autoAdd==True adds also adds the created subdirectories to the watchlist. c s � ��fdd�}t �d|� d S )Nc s@ z �� �j���� � �d � W n ty: � �� Y n0 d S r )r! r � _isWatchedr+ � Exception�errbackr �rZ r �subdirr r �_ s zIINotifyTests.test_simpleSubdirectoryAutoAdd.<locals>._callback.<locals>._r �r � callLater)�wpr% r( rd rb r r � _callback s z>INotifyTests.test_simpleSubdirectoryAutoAdd.<locals>._callbackT�r( �autoAddr3 �test� r �IN_ISDIRrS r$ r r4 r r5 r �r rh � checkMaskr rb r � test_simpleSubdirectoryAutoAdd s � z+INotifyTests.test_simpleSubdirectoryAutoAddc sZ g � � ���fdd�}t jt jB }�j j�j|d|gd� �j�d��t�� ���� �S )zz L{inotify.INotify} removes a directory from the watchlist when it's removed from the filesystem. c sL ���fdd�}���fdd�}� s<� � |� t�d|� n t�d|� d S )Nc s> z �� �j���� ��� W n ty8 � �� Y n0 d S r )r! r r_ rU r` ra r rb r r rd % s zEINotifyTests.test_simpleDeleteDirectory.<locals>._callback.<locals>._c s@ z �� �j���� � �d � W n ty: � �� Y n0 d S r �� assertFalser r_ r+ r` ra r rb r r �_eb, s zGINotifyTests.test_simpleDeleteDirectory.<locals>._callback.<locals>._ebr )�appendr rf )rg r% r( rd rs ��callsrZ r rc r r rh " s z:INotifyTests.test_simpleDeleteDirectory.<locals>._callbackTri rk rl rn r ru r �test_simpleDeleteDirectory s � z'INotifyTests.test_simpleDeleteDirectoryc s\ � �fdd�}�� �jj�jtj�fdd�gd�� t�� ���|� �j�� t�� � � S )z� L{inotify.INotify} closes the file descriptor after removing a directory from the filesystem (and therefore from the watchlist). c sN � �fdd�}| \}}}�� |�� �j�� � ��|tj@ � t�d|� d S )Nc sP z0�� �j��j�� �� �jj� � �d � W n tyJ � �� Y n0 d S r )rr r r_ r � connectedr+ r` ra r r\ r r rd L s zIINotifyTests.test_deleteSelfLoseConnection.<locals>.cbNotified.<locals>._r )r r r r! r rX r rf )r# rd �ignoredr% r& r\ r r r) K s z>INotifyTests.test_deleteSelfLoseConnection.<locals>.cbNotifiedc s � � | �S r r* r, r. r r r0 ] r1 z<INotifyTests.test_deleteSelfLoseConnection.<locals>.<lambda>r2 ) r! r r$ r rX r r5 r6 rU r[ r )rZ r/ r r � test_deleteSelfLoseConnectionE s �� z*INotifyTests.test_deleteSelfLoseConnectionc C sL | j j| jdd� | �| j �| j�� | j �| j� | �| j �| j�� dS )zR L{inotify.INotify.ignore} removes a directory from the watchlist T)rj N)r r$ r r! r_ �ignorerr r r r r �test_ignoreDirectoryh s z!INotifyTests.test_ignoreDirectoryc C sV t jD ] \}}| �t �|�d |� qt jt jB t jB }| �tt �|��h d�� dS )zy L{inotify.humaReadableMask} translates all the possible event masks to a human readable string. r > Z close_writerA �accessN)r Z_FLAG_TO_HUMANr ZhumanReadableMaskrI r= rM �set)r r( �valuero r r r �test_humanReadableMaskq s �z#INotifyTests.test_humanReadableMaskc C sv | j �d�}|�d�}|�d�}|�� |||g}| jj| j dd� | jj| j dd� |D ]}| �| j�|�� qZdS )z� L{inotify.INotify.watch} with recursive==True will add all the subdirectories under the given path to the watchlist. rk �test2�test3T)� recursiveN)r r4 �makedirsr r$ r! r_ )r rc �subdir2�subdir3�dirsrZ r r r �test_recursiveWatch s z INotifyTests.test_recursiveWatchc C s0 ddl }t�� }|�|j� |�� | �� dS )z� L{inotify.INotify.connectionLost} if there's a problem while closing the fd shouldn't raise the exception but should log the error r N)�osr r rH Z_fdr ZflushLoggedErrors)r r� �in_r r r �test_connectionLostError� s z%INotifyTests.test_connectionLostErrorc sT � ��fdd�}t jt jB }�j j�j|d|gd� �j�d��t�� � ��� � S )z� L{inotify.INotify.watch} with autoAdd==False will stop inotify from watching subdirectories created under the watched one. c s � ��fdd�}t �d|� d S )Nc s@ z �� �j���� � �d � W n ty: � �� Y n0 d S r rq r rb r r rd � s zEINotifyTests.test_noAutoAddSubdirectory.<locals>._callback.<locals>._r re )rg �fpr( rd rb r r rh � s z:INotifyTests.test_noAutoAddSubdirectory.<locals>._callbackFri rk rl rn r rb r �test_noAutoAddSubdirectory� s � z'INotifyTests.test_noAutoAddSubdirectoryc s� �j �d�� � �� t�� �� �fdd�}�fdd�}���jj� |gd�� �j�� � ���jj� tj |gd�� �� |� � � � �S )z� L{inotify.INotify} will watch a filepath for events even if the same path is repeatedly added/removed/re-added to the watchpoints. �foo.bar2c s2 | \}}}�� |�� � �� � ��|tj@ � d S r �r r r! r rX �r# ry r% r& )r' r r r r) � s z<INotifyTests.test_seriesOfWatchAndIgnore.<locals>.cbNotifiedc s � � | � d S r r* r, r. r r �callIt� s z8INotifyTests.test_seriesOfWatchAndIgnore.<locals>.callIt�r3 r2 ) r r4 rD r r5 r! r r$ r{ rX r6 rU )r r) r� r )r' r/ r r �test_seriesOfWatchAndIgnore� s �� z(INotifyTests.test_seriesOfWatchAndIgnorec s� �j �d�}|�� �j �d�� � �� t�� �� �fdd�}�fdd�}���jj|tj|gd�� �� |� ���jj� tj|gd�� �j� |� |� � � � � �S )zr L{inotify.INotify} will ignore a filepath after it has been removed from the watch list. r� zfoo.bar3c s2 | \}}}�� |�� � �� � ��|tj@ � d S r r� r� )� expectedPath2r r r r) � s z4INotifyTests.test_ignoreFilePath.<locals>.cbNotifiedc s � � | � d S r r* r, r. r r r� � s z0INotifyTests.test_ignoreFilePath.<locals>.callItr� ) r r4 rD r r5 r! r r$ rX r6 r{ rU )r r' r) r� r )r� r/ r r �test_ignoreFilePath� s( � �� z INotifyTests.test_ignoreFilePathc C s* | j �d�}|�� | �t| jj|� dS )zf L{inotify.INotify} will raise KeyError if a non-watched filepath is ignored. z foo.ignoredN)r r4 rD r �KeyErrorr r{ )r r' r r r �test_ignoreNonWatchedFile s z&INotifyTests.test_ignoreNonWatchedFilec s� t � � � ������fdd�}tjtjB }�jj�j|d|gd� �j�d����d����d��t�� ��� � ��d���d ���d �g�t ��D ] \}}|� |j � t�� �� q��S ) aB L{inotify.INotify} with autoAdd==True for a watched path generates events for every file or directory already present in a newly created subdirectory under the watched one. This tests that we solve a race condition in inotify even though we may generate duplicate events. c s� � � |� t� �dkr�zv���j���� ���j���� ���j���� ����g }dd� |D �}��t� �t|�� ��� |� W n ty� ��� Y n 0 ��d � d S )N� c S s h | ] }|� � �qS r )r )�.0�fr r r � <setcomp> r1 zRINotifyTests.test_complexSubdirectoryAutoAdd.<locals>._callback.<locals>.<setcomp>) �add�lenr! r r_ r r` ra r+ )rg r% r( �created�rv rZ r Z someFilesrc r� r� r r rh s z?INotifyTests.test_complexSubdirectoryAutoAdd.<locals>._callbackTri rk r� r� z file1.datz file2.datz file3.dat)r~ r rm rS r$ r r4 r r5 r� � enumerater: r< �encode�sys�getfilesystemencoding)r rh ro �ir% r r� r � test_complexSubdirectoryAutoAdd s$ � �z,INotifyTests.test_complexSubdirectoryAutoAdd)N)$r r r �__doc__r �platformZsupportsINotify�skipr r r8 r? rC rE rJ rL rN rP rR rT rV rY r] r^ rp rw rz r| r� r� r� r� r� r� r� r� r r r r r s> $ *# %& r )r� r� Ztwisted.internetr r Ztwisted.pythonr r Ztwisted.python.reflectr Z twisted.trialr r ZTestCaser r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка