Файловый менеджер - Редактировать - /home/digitalm/venv/lib/python3.7/site-packages/watchdog/observers/__pycache__/fsevents.cpython-37.pyc
Назад
B �P�g7 � @ s� d Z ddlmZ ddlZddlZddlZddlZddlZddlZ ddl m Z m Z m Z mZmZmZmZmZmZmZ ddlmZmZmZmZ ddlmZ e� d�Z G dd � d e�Z G d d � d e�Z dS ) u� :module: watchdog.observers.fsevents :synopsis: FSEvents based emitter implementation. :author: yesudeep@google.com (Yesudeep Mangalapilly) :author: contact@tiger-222.fr (Mickaël Schoentgen) :platforms: macOS � )� annotationsN) �DirCreatedEvent�DirDeletedEvent�DirModifiedEvent� DirMovedEvent�FileCreatedEvent�FileDeletedEvent�FileModifiedEvent�FileMovedEvent�generate_sub_created_events�generate_sub_moved_events)�DEFAULT_EMITTER_TIMEOUT�DEFAULT_OBSERVER_TIMEOUT� BaseObserver� EventEmitter)�DirectorySnapshotZfseventsc s� e Zd ZdZedf� fdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z edd� �Zdd� Zdd� Zdd � Zd d � Zd d � Z� ZS )!�FSEventsEmittera5 macOS FSEvents Emitter class. :param event_queue: The event queue to fill with events. :param watch: A watch object representing the directory to monitor. :type watch: :class:`watchdog.observers.api.ObservedWatch` :param timeout: Read events blocking timeout (in seconds). :param suppress_history: The FSEvents API may emit historic events up to 30 sec before the watch was started. When ``suppress_history`` is ``True``, those events will be suppressed by creating a directory snapshot of the watched path before starting the stream as a reference to suppress old events. Warning: This may result in significant memory usage in case of a large number of items in the watched path. :type timeout: ``float`` Fc sZ t � �|||� t� | _|| _d| _d | _t�� | _ t j � t j � t j �| jj ���| _d S )Ng )�super�__init__�set�_fs_view�suppress_history� _start_time�_starting_state� threading�Lock�_lock�os�path�realpath�abspath� expanduser�watch�_absolute_watch_path)�selfZ event_queuer" �timeoutr )� __class__� �Q/home/digitalm-up/venv/lib/python3.7/site-packages/watchdog/observers/fsevents.pyr K s zFSEventsEmitter.__init__c C s t �| j� t �| � d S )N)� _fseventsZ remove_watchr" �stop)r$ r' r' r( �on_thread_stop\ s z FSEventsEmitter.on_thread_stopc C sV | j jr"t�d|� t�| |� n0| �|�sFt�d|� t�| |� n t�d|� d S )Nzqueue_event %sz drop event %s)Z_watchZ is_recursive�logger�debugr � queue_event�_is_recursive_event)r$ �eventr' r' r( r. ` s zFSEventsEmitter.queue_eventc C sV |j r |jn tj�|j�}|| jkr(dS t|ttf�rRtj�|j �}|| jkrRdS dS )NFT) � is_directory�src_pathr r �dirnamer# � isinstancer r � dest_path)r$ r0 r2 r5 r' r' r( r/ m s z#FSEventsEmitter._is_recursive_eventc C s. |j r tnt}| �||�� | �t|�� d S )N)r1 r r r. r )r$ r0 r2 r3 �clsr' r' r( �_queue_created_event} s z$FSEventsEmitter._queue_created_eventc C s. |j r tnt}| �||�� | �t|�� d S )N)r1 r r r. r )r$ r0 r2 r3 r6 r' r' r( �_queue_deleted_event� s z$FSEventsEmitter._queue_deleted_eventc C s |j r tnt}| �||�� d S )N)r1 r r r. )r$ r0 r2 r3 r6 r' r' r( �_queue_modified_event� s z%FSEventsEmitter._queue_modified_eventc C sH |j r tnt}| �|�}| �|||�� | �t|�� | �t|�� d S )N)r1 r r � _encode_pathr. r )r$ Z src_eventr2 �dst_path� src_dirname� dst_dirnamer6 r' r' r( �_queue_renamed_event� s z$FSEventsEmitter._queue_renamed_eventc C sZ |j | jk}| jrNy | j� |j�d }||j k}W qR tk rJ d}Y qRX nd}|pX|S )Nr F)�inoder r r �KeyError)r$ r0 Z in_historyZ old_inodeZ before_startr' r' r( �_is_historic_created_event� s z*FSEventsEmitter._is_historic_created_eventc C s | j p| jp| jS )z9Returns True if the event indicates a change in metadata.)Zis_inode_meta_modZ is_xattr_modZis_owner_change)r0 r' r' r( � _is_meta_mod� s z FSEventsEmitter._is_meta_modc s2 t �� tjkrLx<|D ]4� d�� fdd�t� �D ��}t �� � d|� �� qW t�� | j dkrdd | _ �x�|�r,|� d�� | � � j �}tj �|�}yt�|�}W n tk r� d }Y nX |o�|j� jk}� j�r@� j�r@| �� �s�| �� ||� | j�� j� � j�s| �� ��r | � � ||� | � � ||� | j� � j� �n�� j�rb| �� ��sb| �� ||� | j�� j� � j�s�| �� ��r�| � � ||� � j �r�t t!� fdd�|D ��d �}|�rrt �d|� | � |j �} tj �| �} | �"� || || � | j�� j� x t#|| �D ]} | �$| � �q W |�%|� |j�s>| �|��rL| � || | � |j�r�| � || | � | j� |j� n`|�r�| �� ||� | j�� j� x<t&|�D ]} | �$| � �q�W n | � � ||� | j� � j� qh� j�r�| � � ||� | j� � j� � j'rh| �$t(| j)j �� t �d � | �*� | j�+� qhW d S ) Nz, c 3 s | ]}t � |�d kr|V qdS )TN)�getattr)�.0�attr)r0 r' r( � <genexpr>� s z/FSEventsEmitter.queue_events.<locals>.<genexpr>z: �< r c 3 s$ | ] }|j r|j� jkr|V qd S )N)� is_renamedr? )rD �e)r0 r' r( rF � s z"Destination event for rename is %sz&Stopping because root path was changed),r, �getEffectiveLevel�logging�DEBUG�join�dirr- �time� monotonicr r �popr: r r r3 �stat�OSError�st_inor? Z is_createdZ is_removedrA r7 r �addZ is_modifiedrB r9 r8 �discardrH �next�iterr> r r. �remover Zis_root_changedr r" r* �clear) r$ r% �events�flagsr2 r< rR �existsZ dst_eventr; r= Z sub_eventr' )r0 r( � queue_events� s� z FSEventsEmitter.queue_eventsc sj t j� y@� fdd�t||||�D �}| j� | �| j|� W dQ R X W n tk rd t�d� Y nX dS )zhCallback passed to FSEventStreamCreate(), it will receive all FS events and queue them. c s" g | ]\}}}}� ||||��qS r' r' )rD r r? Z event_flagsZevent_id)r6 r' r( � <listcomp>8 s z3FSEventsEmitter.events_callback.<locals>.<listcomp>Nz(Unhandled exception in fsevents callback) r) Z NativeEvent�zipr r^ r% � Exceptionr, � exception)r$ �paths�inodesr\ Zidsr[ r' )r6 r( �events_callback1 s z FSEventsEmitter.events_callbackc C s^ | j jg| _t�� | _y$t�| | j | j| j� t� | � W n t k rX t � d� Y nX d S )Nz&Unhandled exception in FSEventsEmitter) r" r Z pathnamesrO rP r r) Z add_watchre Z read_eventsra r, rb )r$ r' r' r( �run@ s zFSEventsEmitter.runc C s: | j r6t| jjt�r$t�| jj�}n| jj}t|�| _d S )N) r r4 r" r �bytesr �fsdecoder r )r$ Z watch_pathr' r' r( �on_thread_startI s z FSEventsEmitter.on_thread_startc C s t | jjt�rt�|�S |S )z6Encode path only if bytes were passed to this emitter.)r4 r" r rg r �fsencode)r$ r r' r' r( r: R s z FSEventsEmitter._encode_path)�__name__� __module__� __qualname__�__doc__r r r+ r. r/ r7 r8 r9 r> rA � staticmethodrB r^ re rf ri r: � __classcell__r' r' )r& r( r 4 s$ r c s* e Zd Zef� fdd� Zddd�Z� ZS )�FSEventsObserverc s t � jt|d� d S )N)Z emitter_classr% )r r r )r$ r% )r& r' r( r Z s zFSEventsObserver.__init__Fc C s& t |t�rt�d|�}t�| |||�S )N�NFC)r4 �str� unicodedata� normalizer �schedule)r$ Z event_handlerr � recursiver' r' r( rv ] s zFSEventsObserver.schedule)F)rk rl rm r r rv rp r' r' )r& r( rq Y s rq ) rn � __future__r rK r r rO rt Z_watchdog_fseventsr) Zwatchdog.eventsr r r r r r r r r r Zwatchdog.observers.apir r r r Zwatchdog.utils.dirsnapshotr � getLoggerr, r rq r' r' r' r( �<module> s 0 '
| ver. 1.4 |
Github
|
.
| PHP 8.3.23 | Генерация страницы: 0.06 |
proxy
|
phpinfo
|
Настройка