o *ή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-target-vg8gfxp4/lib/python/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|tr t||_n||_||_dSN) isinstancerstr_path _is_recursive)selfpath recursiver r r __init__0s   zObservedWatch.__init__cC|jS)z"The path that this watch monitors.)rrr r r r7zObservedWatch.pathcCr)z;Determines whether subdirectories are watched for the path.)rrr r r is_recursive<rzObservedWatch.is_recursivecCs |j|jfSr)rrrr r r keyAs zObservedWatch.keycCs |j|jkSrrrwatchr r r __eq__E zObservedWatch.__eq__cCs |j|jkSrrrr r r __ne__Hr zObservedWatch.__ne__cCs t|jSr)hashrrr r r __hash__Ks zObservedWatch.__hash__cCsdt|j|j|jfS)Nz<%s: path=%s, is_recursive=%s>)typerrrrr r r __repr__NszObservedWatch.__repr__N) rrr r rpropertyrrrrr!r#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__cCr)z6 Blocking timeout for reading events. r+rr r r r-mzEventEmitter.timeoutcCr)z9 The watch associated with this emitter. )r*rr r r rtr1zEventEmitter.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_eventcCdS)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_eventszEventEmitter.queue_eventscCs$|r||j|sdSdSr)should_keep_runningr7r-rr r r runs zEventEmitter.run) rrr r DEFAULT_EMITTER_TIMEOUTrr&r-rr4r7r: __classcell__r r r.r r'Ts    r'cs\eZdZdZeZ effdd 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+r6r.r r rs  zEventDispatcher.__init__cCr)z)Timeout value to construct emitters with.r0rr r r r-rzEventDispatcher.timeoutcCs6t|z |jtjWdStjyYdSwr)rstopr, put_nowaitr= _stop_eventqueueFullrr r r r>s zEventDispatcher.stopcCr)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,r1zEventDispatcher.event_queuecCr5)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_eventsr8zEventDispatcher.dispatch_eventscCs>|rz||jWn tjyYqw|sdSdSr)r9rCr,rAEmptyrr r r r:szEventDispatcher.run)rrr r objectr@DEFAULT_OBSERVER_TIMEOUTrr&r-r>r,rCr:r<r r r.r r=s    r=cseZdZdZeffdd 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)r emitter_classr-r.r r rs   zBaseObserver.__init__cCs||j|j<|j|dSr)rQrrPaddremitterr r r _add_emitters zBaseObserver._add_emittercCsB|j|j=|j||z|WdSty YdSwr)rQrrPremover>join RuntimeErrorrTr r r _remove_emitters   zBaseObserver._remove_emitterc CsV|jD]}|q|jD]}z|Wq tyYq w|j|jdSr)rPr>rXrYclearrQrTr r r _clear_emitterss      zBaseObserver._clear_emitterscCs*||jvr t|j|<|j||dSr)rOrLrSr event_handlerrr r r _add_handler_for_watchs  z#BaseObserver._add_handler_for_watchcCs |j|=dSr)rOrr r r _remove_handlers_for_watchr z'BaseObserver._remove_handlers_for_watchcCr)z/Returns event emitter created by this observer.)rPrr r r emittersrzBaseObserver.emittersc sD|jD]}z|Wqty||wtdSr)rPcopystart ExceptionrZr(rTr.r r rcs   zBaseObserver.startFcCs|j9t||}||||j|dur.|j|j||jd}|r)| | ||j |Wd|S1s?wY|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-) rKr r_rQgetrHr,r-is_alivercrVrMrS)rr^rrrrUr r r schedule s       zBaseObserver.schedulecCs8|j|||WddS1swYdS)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)rKr_r]r r r add_handler_for_watch3s"z"BaseObserver.add_handler_for_watchcCs<|j|j||WddS1swYdS)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)rKrOrWr]r r r remove_handler_for_watchEs"z%BaseObserver.remove_handler_for_watchcCsT|j|j|}|j|=|||j|WddS1s#wYdS)zUnschedules a watch. :param watch: The watch to unschedule. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)rKrQrOrZrMrW)rrrUr r r unscheduleWs   "zBaseObserver.unschedulecCsH|j|j||jWddS1swYdS)zKUnschedules all watches and detaches all associated event handlers.N)rKrOr[r\rMrr r r unschedule_allfs   "zBaseObserver.unschedule_allcCs |dSr)rkrr r r on_thread_stopnr zBaseObserver.on_thread_stopcCs|jdd}|tjur dS|\}}|j"t|j|gD]}||j|gvr.||qWdn1s9wY|dS)NT)block)rer=r@rKlistrOdispatch task_done)rr,entryr3rhandlerr r r rCqs    zBaseObserver.dispatch_events)F)rrr r rFrrVrZr\r_r`r&rarcrgrhrirjrkrlrCr<r r r.r rGs$      'rG)rArIpathlibrwatchdog.utilsrwatchdog.utils.bricksrr;rFrr r'r=rGr r r r s    -C;