Файловый менеджер - Редактировать - /home/digitalm/venv/lib/python3.7/site-packages/watchdog/observers/__pycache__/api.cpython-37.pyc
Назад
B �P�g*/ � @ s� d dl mZ d dlZd dlZd dlmZ d dlmZmZ d dl m Z dZ dZ G dd� de �Z G d d � d �ZG d d � d e�ZG d d� de�ZG dd� de�ZG dd� de�ZdS )� )� annotationsN)�Path)� BaseThread�Protocol)�SkipRepeatsQueue� c @ s e Zd ZdZdS )� EventQueuea. Thread-safe event queue based on a special queue that skips adding the same event (:class:`FileSystemEvent`) multiple times consecutively. Thus avoiding dispatching multiple event handling calls when multiple identical events are produced quicker than an observer can consume them. N)�__name__� __module__� __qualname__�__doc__� r r �L/home/digitalm-up/venv/lib/python3.7/site-packages/watchdog/observers/api.pyr s r c @ s\ e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zd d � Z d d � Z dd� Z dd� Z dS )� ObservedWatchz�An scheduled watch. :param path: Path string. :param recursive: ``True`` if watch is recursive; ``False`` otherwise. c C s& t |t�rt|�| _n|| _|| _d S )N)� isinstancer �str�_path� _is_recursive)�self�path� recursiver r r �__init__0 s zObservedWatch.__init__c C s | j S )z"The path that this watch monitors.)r )r r r r r 7 s zObservedWatch.pathc C s | j S )z;Determines whether subdirectories are watched for the path.)r )r r r r � is_recursive< s zObservedWatch.is_recursivec C s | j | jfS )N)r r )r r r r �keyA s zObservedWatch.keyc C s | j |j kS )N)r )r �watchr r r �__eq__E s zObservedWatch.__eq__c C s | j |j kS )N)r )r r r r r �__ne__H s zObservedWatch.__ne__c C s t | j�S )N)�hashr )r r r r �__hash__K s zObservedWatch.__hash__c C s" dt | �j� d| j�d| j� d�S )N�<z: path=z, is_recursive=�>)�typer r r )r r r r �__repr__N s zObservedWatch.__repr__N) r r r r r �propertyr r r r r r r" r r r r r ' s r c sT e Zd ZdZef� fdd� Zedd� �Zedd� �Zdd � Z d d � Z d d � Z � Z S )� EventEmittera Producer thread base class subclassed by event emitters that generate events and populate a queue with them. :param event_queue: The event queue to populate with generated events. :type event_queue: :class:`watchdog.events.EventQueue` :param watch: The watch to observe and produce events for. :type watch: :class:`ObservedWatch` :param timeout: Timeout (in seconds) between successive attempts at reading events. :type timeout: ``float`` c s t � �� || _|| _|| _d S )N)�superr � _event_queue�_watch�_timeout)r � event_queuer �timeout)� __class__r r r f s zEventEmitter.__init__c C s | j S )z6 Blocking timeout for reading events. )r( )r r r r r* l s zEventEmitter.timeoutc C s | j S )z9 The watch associated with this emitter. )r' )r r r r r s s zEventEmitter.watchc C s | j �|| jf� dS )z� Queues a single event. :param event: Event to be queued. :type event: An instance of :class:`watchdog.events.FileSystemEvent` or a subclass. N)r& �putr )r �eventr r r � queue_eventz s zEventEmitter.queue_eventc C s dS )a Override this method to populate the event queue with events per interval period. :param timeout: Timeout (in seconds) between successive attempts at reading events. :type timeout: ``float`` Nr )r r* r r r � queue_events� s zEventEmitter.queue_eventsc C s x| � � r| �| j� qW d S )N)�should_keep_runningr/ r* )r r r r �run� s zEventEmitter.run) r r r r �DEFAULT_EMITTER_TIMEOUTr r# r* r r. r/ r1 � __classcell__r r )r+ r r$ S s r$ c sZ e Zd ZdZe� Zef� fdd� Zedd� �Z dd� Z edd � �Z d d � Z d d � Z � ZS )�EventDispatchera< Consumer thread base class subclassed by event observer threads that dispatch events from an event queue to appropriate event handlers. :param timeout: Timeout value (in seconds) passed to emitters constructions in the child class BaseObserver. :type timeout: ``float`` c s t � �� t� | _|| _d S )N)r% r r r& r( )r r* )r+ r r r � s zEventDispatcher.__init__c C s | j S )z)Timeout value to construct emitters with.)r( )r r r r r* � s zEventDispatcher.timeoutc C s8 t �| � y| j�tj� W n tjk r2 Y nX d S )N)r �stopr) � put_nowaitr4 � _stop_event�queue�Full)r r r r r5 � s zEventDispatcher.stopc C s | j S )z�The event queue which is populated with file system events by emitters and from which events are dispatched by a dispatcher thread.)r& )r r r r r) � s zEventDispatcher.event_queuec C s dS )ag Override this method to consume events from an event queue, blocking on the queue for the specified timeout before raising :class:`queue.Empty`. :param event_queue: Event queue to populate with one set of events. :type event_queue: :class:`EventQueue` :raises: :class:`queue.Empty` Nr )r r) r r r �dispatch_events� s z EventDispatcher.dispatch_eventsc C s< x6| � � r6y| �| j� W q tjk r2 wY qX qW d S )N)r0 r: r) r8 �Empty)r r r r r1 � s zEventDispatcher.run)r r r r �objectr7 �DEFAULT_OBSERVER_TIMEOUTr r# r* r5 r) r: r1 r3 r r )r+ r r4 � s r4 c s� e Zd ZdZef� fdd� Zdd� Zdd� Zdd � Zd d � Z d d � Z e dd� �Z � fdd�Z d!dd�Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z� ZS )"� BaseObserverzBase observer.c s@ t � �|� || _t�� | _t� | _t� | _ t� | _ t� | _ d S )N) r% r �_emitter_class� threading�RLock�_lock�set�_watches�dict� _handlers� _emitters�_emitter_for_watch)r Z emitter_classr* )r+ r r r � s zBaseObserver.__init__c C s || j |j< | j�|� d S )N)rH r rG �add)r �emitterr r r � _add_emitter� s zBaseObserver._add_emitterc C sD | j |j= | j�|� |�� y |�� W n tk r> Y nX d S )N)rH r rG �remover5 �join� RuntimeError)r rJ r r r �_remove_emitter� s z BaseObserver._remove_emitterc C sb x| j D ] }|�� qW x0| j D ]&}y |�� W q tk rD Y q X q W | j �� | j�� d S )N)rG r5 rM rN �clearrH )r rJ r r r �_clear_emitters� s z BaseObserver._clear_emittersc C s* || j krt� | j |< | j | �|� d S )N)rF rC rI )r � event_handlerr r r r �_add_handler_for_watch� s z#BaseObserver._add_handler_for_watchc C s | j |= d S )N)rF )r r r r r �_remove_handlers_for_watch� s z'BaseObserver._remove_handlers_for_watchc C s | j S )z/Returns event emitter created by this observer.)rG )r r r r �emitters� s zBaseObserver.emittersc sP x@| j �� D ]2}y |�� W q tk r< | �|� � Y q X q W t� �� d S )N)rG �copy�start� ExceptionrO r% )r rJ )r+ r r rW s zBaseObserver.startFc C sv | j �f t||�}| �||� | j�|�dkr\| j| j|| jd�}| �� rR|� � | � |� | j � |� W dQ R X |S )am Schedules watching a path and calls appropriate methods specified in the given event handler in response to file system events. :param event_handler: An event handler instance that has appropriate event handling methods which will be called by the observer in response to file system events. :type event_handler: :class:`watchdog.events.FileSystemEventHandler` or a subclass :param path: Directory path that will be monitored. :type path: ``str`` :param recursive: ``True`` if events will be emitted for sub-directories traversed recursively; ``False`` otherwise. :type recursive: ``bool`` :return: An :class:`ObservedWatch` object instance representing a watch. N)r) r r* ) rB r rS rH �getr? r) r* �is_aliverW rK rD rI )r rR r r r rJ r r r �schedule s zBaseObserver.schedulec C s" | j � | �||� W dQ R X dS )a! Adds a handler for the given watch. :param event_handler: An event handler instance that has appropriate event handling methods which will be called by the observer in response to file system events. :type event_handler: :class:`watchdog.events.FileSystemEventHandler` or a subclass :param watch: The watch to add a handler for. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)rB rS )r rR r r r r �add_handler_for_watch2 s z"BaseObserver.add_handler_for_watchc C s& | j � | j| �|� W dQ R X dS )a' Removes a handler for the given watch. :param event_handler: An event handler instance that has appropriate event handling methods which will be called by the observer in response to file system events. :type event_handler: :class:`watchdog.events.FileSystemEventHandler` or a subclass :param watch: The watch to remove a handler for. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)rB rF rL )r rR r r r r �remove_handler_for_watchD s z%BaseObserver.remove_handler_for_watchc C s> | j �. | j| }| j|= | �|� | j�|� W dQ R X dS )z�Unschedules a watch. :param watch: The watch to unschedule. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)rB rH rF rO rD rL )r r rJ r r r � unscheduleV s zBaseObserver.unschedulec C s2 | j �" | j�� | �� | j�� W dQ R X dS )zKUnschedules all watches and detaches all associated event handlers.N)rB rF rP rQ rD )r r r r �unschedule_alle s zBaseObserver.unschedule_allc C s | � � d S )N)r_ )r r r r �on_thread_stopm s zBaseObserver.on_thread_stopc C sx |j dd�}|tjkrd S |\}}| j�> x6t| j� |g ��D ] }|| j� |g �kr>|�|� q>W W d Q R X |�� d S )NT)�block)rY r4 r7 rB �listrF �dispatch� task_done)r r) �entryr- r �handlerr r r r: p s z BaseObserver.dispatch_events)F)r r r r r= r rK rO rQ rS rT r# rU rW r[ r\ r] r^ r_ r` r: r3 r r )r+ r r> � s 'r> c @ s e Zd Zdddd�dd�ZdS ) � BaseObserverSubclassCallable.�floatr> )r* �returnc C s d S )Nr )r r* r r r �__call__� s z%BaseObserverSubclassCallable.__call__N).)r r r rj r r r r rg � s rg )� __future__r r8 r@ �pathlibr Zwatchdog.utilsr r Zwatchdog.utils.bricksr r2 r= r r r$ r4 r> rg r r r r �<module> s ,C; 0
| ver. 1.4 |
Github
|
.
| PHP 8.3.23 | Генерация страницы: 0.04 |
proxy
|
phpinfo
|
Настройка