U ꥡc.@sddlZddlZddlmZddlmZddlmZdZdZ GdddeZ Gdd d Z Gd d d eZ Gd d d eZ Gddde ZdS)N)Path) BaseThread)SkipRepeatsQueuec@seZdZdZdS) 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 :/tmp/pip-unpacked-wheel-thtqfo2i/watchdog/observers/api.pyrsrc@s\eZdZdZddZeddZeddZedd Zd d Z d d Z ddZ ddZ dS) ObservedWatchzAn scheduled watch. :param path: Path string. :param recursive: ``True`` if watch is recursive; ``False`` otherwise. cCs&t|trt||_n||_||_dSN) isinstancerstr_path _is_recursive)selfpath recursiver r r __init__0s  zObservedWatch.__init__cCs|jS)z"The path that this watch monitors.)rrr r r r7szObservedWatch.pathcCs|jS)z;Determines whether subdirectories are watched for the path.)rrr r r is_recursive<szObservedWatch.is_recursivecCs |j|jfSr)rrrr r r keyAszObservedWatch.keycCs |j|jkSrrrwatchr r r __eq__EszObservedWatch.__eq__cCs |j|jkSrrrr r r __ne__HszObservedWatch.__ne__cCs t|jSr)hashrrr r r __hash__KszObservedWatch.__hash__cCsdt|j|j|jfS)Nz<%s: path=%s, is_recursive=%s>)typerrrrr r r __repr__Ns zObservedWatch.__repr__N) rrr r rpropertyrrrrrr r"r r r r r 's   r csTeZdZdZeffdd ZeddZeddZdd 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`` cs t||_||_||_dSr)superr _event_queue_watch_timeout)r event_queuertimeout __class__r r rgs zEventEmitter.__init__cCs|jS)z6 Blocking timeout for reading events. r(rr r r r*mszEventEmitter.timeoutcCs|jS)z9 The watch associated with this emitter. )r'rr r r rtszEventEmitter.watchcCs|j||jfdS)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)reventr r r queue_event{s zEventEmitter.queue_eventcCsdS)aOverride 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 rr*r r r queue_eventsszEventEmitter.queue_eventscCs|r||jqdSr)should_keep_runningr2r*rr r r runszEventEmitter.run) rrr r DEFAULT_EMITTER_TIMEOUTrr#r*rr0r2r4 __classcell__r r r+r r$Ts    r$csZeZdZdZeZeffdd ZeddZ ddZ 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`` cstt|_||_dSr)r%rrr&r(r1r+r r rs zEventDispatcher.__init__cCs|jS)z)Timeout value to construct emitters with.r-rr r r r*szEventDispatcher.timeoutcCs8t|z|jtjWntjk r2YnXdSr)rstopr) put_nowaitr7 _stop_eventqueueFullrr r r r8s  zEventDispatcher.stopcCs|jS)zThe event queue which is populated with file system events by emitters and from which events are dispatched by a dispatcher thread.)r&rr r r r)szEventDispatcher.event_queuecCsdS)agOverride 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 )rr)r r r dispatch_eventsszEventDispatcher.dispatch_eventscCs:|r6z||jWqtjk r2YqYqXqdSr)r3r=r)r;Emptyrr r r r4s zEventDispatcher.run)rrr r objectr:DEFAULT_OBSERVER_TIMEOUTrr#r*r8r)r=r4r6r r r+r r7s    r7cseZdZdZeffdd ZddZddZdd Zd d Z d d Z e ddZ fddZ d!ddZddZddZddZddZddZdd ZZS)" BaseObserverzBase observer.cs@t|||_t|_t|_t|_ t|_ t|_ dSr) r%r_emitter_class threadingRLock_lockset_watchesdict _handlers _emitters_emitter_for_watch)rZ emitter_classr*r+r r rs  zBaseObserver.__init__cCs||j|j<|j|dSr)rKrrJaddremitterr r r _add_emitters zBaseObserver._add_emittercCsD|j|j=|j||z |Wntk r>YnXdSr)rKrrJremover8join RuntimeErrorrMr r r _remove_emitters   zBaseObserver._remove_emitterc CsZ|jD] }|q|jD]&}z |Wqtk r>YqXq|j|jdSr)rJr8rQrRclearrKrMr r r _clear_emitterss     zBaseObserver._clear_emitterscCs*||jkrt|j|<|j||dSr)rIrFrLr event_handlerrr r r _add_handler_for_watchs  z#BaseObserver._add_handler_for_watchcCs |j|=dSr)rIrr r r _remove_handlers_for_watchsz'BaseObserver._remove_handlers_for_watchcCs|jS)z/Returns event emitter created by this observer.)rJrr r r emittersszBaseObserver.emittersc sL|jD]2}z |Wq tk r:||Yq Xq tdSr)rJcopystart ExceptionrSr%rMr+r r r\s   zBaseObserver.startFc Csv|jft||}||||j|dkr\|j|j||jd}|rR| | ||j |W5QRX|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)rr*) rEr rXrKgetrBr)r*is_aliver\rOrGrL)rrWrrrrNr r r schedule s   zBaseObserver.schedulec Cs"|j|||W5QRXdS)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)rErXrVr r r add_handler_for_watch3sz"BaseObserver.add_handler_for_watchc Cs&|j|j||W5QRXdS)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)rErIrPrVr r r remove_handler_for_watchEsz%BaseObserver.remove_handler_for_watchc Cs>|j.|j|}|j|=|||j|W5QRXdS)zUnschedules a watch. :param watch: The watch to unschedule. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)rErKrIrSrGrP)rrrNr r r unscheduleWs   zBaseObserver.unschedulec Cs2|j"|j||jW5QRXdS)zKUnschedules all watches and detaches all associated event handlers.N)rErIrTrUrGrr r r unschedule_allfs zBaseObserver.unschedule_allcCs |dSr)rdrr r r on_thread_stopnszBaseObserver.on_thread_stopc Cst|jdd}|tjkrdS|\}}|j:t|j|gD] }||j|gkr<||qs    -C;