Файловый менеджер - Редактировать - /home/digitalm/venv/lib/python3.7/site-packages/watchdog/observers/__pycache__/inotify_buffer.cpython-37.pyc
Назад
B �P�g� � @ sr d dl mZ d dlZd dlmZmZmZmZ d dlm Z m Z d dl m Z d dl mZ e�e�ZG dd� de �ZdS ) � )� annotationsN)� TYPE_CHECKING�List�Tuple�Union)�Inotify� InotifyEvent)� BaseThread)� DelayedQueuec sN e Zd ZdZdZd� fdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z � Z S )� InotifyBufferz�A wrapper for `Inotify` that holds events for `delay` seconds. During this time, IN_MOVED_FROM and IN_MOVED_TO events are paired. g �?Fc s2 t � �� tt | j�| _t||�| _| �� d S )N) �super�__init__r r �delay�_queuer �_inotify�start)�self�path� recursive)� __class__� �W/home/digitalm-up/venv/lib/python3.7/site-packages/watchdog/observers/inotify_buffer.pyr " s zInotifyBuffer.__init__c C s | j �� S )z�Returns a single event or a tuple of from/to events in case of a paired move event. If this buffer has been closed, immediately return None. )r �get)r r r r � read_event( s zInotifyBuffer.read_eventc C s | j �� | j�� d S )N)r �closer )r r r r �on_thread_stop/ s z InotifyBuffer.on_thread_stopc C s | � � | �� d S )N)�stop�join)r r r r r 3 s zInotifyBuffer.closec s� g }x�|D ]�� t �d� � � fdd�}� jr�x�t|�D ]0\}}||�r6trXt|t�rXt�|� f||< P q6W | j� |�}|dk r�|� |� f� q�t �d� |� � � q |� � � q W |S )z Group any matching move eventsz in-event %sc s t | t� o | jo | j� jkS )N)� isinstance�tuple� is_moved_from�cookie)�event)� inotify_eventr r �matching_from_event= s z8InotifyBuffer._group_events.<locals>.matching_from_eventNz'could not find matching move_from event) �logger�debugZ is_moved_to� enumerater r r �AssertionErrorr �remove�append)r � event_list�groupedr$ �indexr" Z from_eventr )r# r � _group_events7 s$ zInotifyBuffer._group_eventsc C s� d}x�| � � r�|s�| j�� }| �|�}xr|D ]j}t|t�sT|jrT|j| jjkr,d}q,t|t� od|j }| j � ||� t|t�s,|j r,|j| jjkr,d}q,W qW dS )z�Read event from `inotify` and add them to `queue`. When reading a IN_MOVE_TO event, remove the previous added matching IN_MOVE_FROM event and add them back to the queue as a tuple. FTN) Zshould_keep_runningr Z read_eventsr. r r Z is_ignoredZsrc_pathr r r �putZis_delete_self)r Z deleted_selfZinotify_eventsZgrouped_eventsr# r r r r �runY s zInotifyBuffer.run)F) �__name__� __module__� __qualname__�__doc__r r r r r r. r0 � __classcell__r r )r r r s "r )� __future__r �logging�typingr r r r Z watchdog.observers.inotify_cr r Zwatchdog.utilsr Z watchdog.utils.delayed_queuer � getLoggerr1 r% r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.3.23 | Генерация страницы: 0.05 |
proxy
|
phpinfo
|
Настройка