zc!.ddlZddlZddlmZddlmZddlmZdZdZ GddeZ Gdd Z Gd d eZ Gd d eZ Gdde ZdS)N)Path) BaseThread)SkipRepeatsQueueceZdZdZdS) 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__6lib/python3.11/site-packages/watchdog/observers/api.pyrrsrrcreZdZdZdZedZedZedZdZ dZ dZ d Z d S) ObservedWatchzAn scheduled watch. :param path: Path string. :param recursive: ``True`` if watch is recursive; ``False`` otherwise. cvt|trt||_n||_||_dSN) isinstancerstr_path _is_recursive)selfpath recursives r__init__zObservedWatch.__init__0s8 dD ! ! TDJJDJ&rc|jS)z"The path that this watch monitors.)rrs rrzObservedWatch.path7s zrc|jS)z;Determines whether subdirectories are watched for the path.)rrs r is_recursivezObservedWatch.is_recursive<s !!rc|j|jfSr)rrrs rkeyzObservedWatch.keyAsy$+++rc"|j|jkSrr!rwatchs r__eq__zObservedWatch.__eq__Ex59$$rc"|j|jkSrr#r$s r__ne__zObservedWatch.__ne__Hr'rc*t|jSr)hashr!rs r__hash__zObservedWatch.__hash__KsDH~~rcRdt|jd|jd|jdS)N)typer rrrs r__repr__zObservedWatch.__repr__Ns3 JJ   D,=,=,=? ?rN) r r r r rpropertyrrr!r&r)r,r1r rrrr's'''X""X",,X,%%%%%%?????rrcZeZdZdZefdZedZedZdZ dZ dZ dS) 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`` cXtj|||_||_||_dSr)rr _event_queue_watch_timeout)r event_queuer%timeouts rrzEventEmitter.__init__gs-D!!!'  rc|jS)z6 Blocking timeout for reading events. r8rs rr:zEventEmitter.timeoutms }rc|jS)z9 The watch associated with this emitter. )r7rs rr%zEventEmitter.watchts {rcH|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)r6putr%)revents r queue_eventzEventEmitter.queue_event{s( udj122222rcdS)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:s r queue_eventszEventEmitter.queue_eventsrc|r0||j|.dSdSr)should_keep_runningrDr:rs rrunzEventEmitter.runsV&&(( ,   dl + + +&&(( , , , , ,rN) r r r r DEFAULT_EMITTER_TIMEOUTrr2r:r%rArDrHr rrr4r4Ts$4K    X X 3 3 3    ,,,,,rr4cTeZdZdZefdZedZedZdZ dZ dS)EventDispatchera Consumer thread base class subclassed by event observer threads that dispatch events from an event queue to appropriate event handlers. :param timeout: Event queue blocking timeout (in seconds). :type timeout: ``float`` cbtj|t|_||_dSr)rrrr6r8rCs rrzEventDispatcher.__init__s*D!!!&LL rc|jS)zEvent queue block timeout.r<rs rr:zEventDispatcher.timeouts }rc|jS)zThe event queue which is populated with file system events by emitters and from which events are dispatched by a dispatcher thread.)r6rs rr9zEventDispatcher.event_queues   rcdS)aOverride 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` :param timeout: Interval period (in seconds) to wait before timing out on the event queue. :type timeout: ``float`` :raises: :class:`queue.Empty` Nr )rr9r:s rdispatch_eventszEventDispatcher.dispatch_eventsrErc|rM ||j|jn#tj$rYGwxYw|KdSdSr)rGrPr9r:queueEmptyrs rrHzEventDispatcher.runs&&((  $$T%5t|DDDD;    &&((     s 7A A N) r r r r DEFAULT_OBSERVER_TIMEOUTrr2r:r9rPrHr rrrKrKs 8    X!!X!    "rrKceZdZdZefdZdZdZdZdZ dZ e dZ fd Z dd Zd Zd ZdZdZdZdZxZS) BaseObserverzBase observer.ct||||_tj|_t |_t|_ t |_ t|_ dSr) rKr_emitter_class threadingRLock_lockset_watchesdict _handlers _emitters_emitter_for_watch)r emitter_classr:s rrzBaseObserver.__init__sb  w///+_&&  "&&&rcX||j|j<|j|dSr)rar%r`addremitters r _add_emitterzBaseObserver._add_emitters-18 . 7#####rc|j|j=|j|| |dS#t $rYdSwxYwr)rar%r`removestopjoin RuntimeErrorres r_remove_emitterzBaseObserver._remove_emittersj  #GM 2 g&&&   LLNNNNN    DD sA A! A!c|jD]}||jD]'} |#t$rY$wxYw|j|jdSr)r`rjrkrlclearrares r_clear_emitterszBaseObserver._clear_emitterss~  G LLNNNN~  G        %%'''''s> A  A c||jvrt|j|<|j||dSr)r_r\rdr event_handlerr%s r_add_handler_for_watchz#BaseObserver._add_handler_for_watchsB  & *$'EEDN5 ! u!!-00000rc|j|=dSr)r_r$s r_remove_handlers_for_watchz'BaseObserver._remove_handlers_for_watchs N5 ! ! !rc|jS)z/Returns event emitter created by this observer.)r`rs remitterszBaseObserver.emitterss ~rc|jD];} |#t$r||wxYwt dSr)r`copystart Exceptionrmsuper)rrf __class__s rr{zBaseObserver.starts}~**,,  G     $$W---   s 3!AFc|j5t||}||||j|_||j||j}||| r| |j |dddn #1swxYwY|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)r9r%r:) r[rrtragetrXr9r:rgis_aliver{r]rd)rrsrrr%rfs rschedulezBaseObserver.schedules0Z % %!$ 22E  ' ' u = = =&**511 $--$:J496:l.DD!!'***==??$MMOOO M  e $ $ $ % % % % % % % % % % % % % % % sB:CCCcr|j5|||ddddS#1swxYwYdS)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)r[rtrrs radd_handler_for_watchz"BaseObserver.add_handler_for_watch-sZ > >  ' ' u = = = > > > > > > > > > > > > > > > > > >s ,00c|j5|j||ddddS#1swxYwYdS)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)r[r_rirrs rremove_handler_for_watchz%BaseObserver.remove_handler_for_watch?sZ 8 8 N5 ! ( ( 7 7 7 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8s !6::c|j5|j|}|j|=|||j|ddddS#1swxYwYdS)zUnschedules a watch. :param watch: The watch to unschedule. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)r[rar_rmr]ri)rr%rfs r unschedulezBaseObserver.unscheduleQsZ ( (-e4Gu%   ) ) ) M  ' ' '  ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (sAAA!Ac|j5|j||jddddS#1swxYwYdS)zKUnschedules all watches and detaches all associated event handlers.N)r[r_rorpr]rs runschedule_allzBaseObserver.unschedule_all`sZ " " N " " "  " " " M   ! ! ! " " " " " " " " " " " " " " " " " "sAAA #A c.|dSr)rrs ron_thread_stopzBaseObserver.on_thread_stophs rc\|d|\}}|j5t|j|gD]4}||j|gvr||5 dddn #1swxYwY|dS)NT)blockr:)rr[listr_dispatch task_done)rr9r:r@r%handlers rrPzBaseObserver.dispatch_eventsks"T7CC u Z , ,  2 25" = =>> , ,dn00;;;,$$U+++ ,  , , , , , , , , , , , , , , , sAB  BB)F)r r r r rTrrgrmrprtrvr2rxr{rrrrrrrP __classcell__)r~s@rrVrVs*.F))))$$$ ( ( (111 """X%%%%N>>>$888$ ( ( ("""        rrV)rRrYpathlibrwatchdog.utilsrwatchdog.utils.bricksrrIrTrrr4rKrVr rrrsN$ %%%%%%222222!)?)?)?)?)?)?)?)?Z@,@,@,@,@,:@,@,@,F22222j222ji i i i i ?i i i i i r