"d*/ddlmZddlZddlZddlmZddlmZmZddl m Z dZ dZ Gdde Z Gd d ZGd d eZGd deZGddeZGddeZy)) annotationsN)Path) BaseThreadProtocol)SkipRepeatsQueueceZdZdZy) 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__8/usr/lib/python3/dist-packages/watchdog/observers/api.pyr r srr c^eZdZdZdZedZedZedZdZ dZ dZ d Z y ) ObservedWatchzAn scheduled watch. :param path: Path string. :param recursive: ``True`` if watch is recursive; ``False`` otherwise. cpt|trt||_||_y||_||_yN) isinstancerstr_path _is_recursive)selfpath recursives r__init__zObservedWatch.__init__0s2 dD !TDJ'DJ&rc|jS)z"The path that this watch monitors.)rrs rrzObservedWatch.path7szzrc|jS)z;Determines whether subdirectories are watched for the path.)rrs r is_recursivezObservedWatch.is_recursive<s!!!rc2|j|jfSr)rr!rs rkeyzObservedWatch.keyAsyy$++++rc4|j|jk(Srr#rwatchs r__eq__zObservedWatch.__eq__Exx599$$rc4|j|jk7Srr%r&s r__ne__zObservedWatch.__ne__Hr)rc,t|jSr)hashr#rs r__hash__zObservedWatch.__hash__KsDHH~rchdt|jd|jd|jdS)N)typer rr!rs r__repr__zObservedWatch.__repr__Ns44:&&'wtyym?4K\K\J]]^__rN) r r r rrpropertyrr!r#r(r+r.r3rrrrr's]'"",,%%`rrcXeZdZdZeffd ZedZedZdZ dZ dZ xZ 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`` cLt|||_||_||_yr)superr _event_queue_watch_timeout)r event_queuer'timeout __class__s rrzEventEmitter.__init__fs$ '  rc|jS)z6 Blocking timeout for reading events. r;rs rr=zEventEmitter.timeoutls }}rc|jS)z9 The watch associated with this emitter. )r:rs rr'zEventEmitter.watchss {{rcR|jj||jfy)z Queues a single event. :param event: Event to be queued. :type event: An instance of :class:`watchdog.events.FileSystemEvent` or a subclass. N)r9putr')revents r queue_eventzEventEmitter.queue_eventzs! udjj12rcy)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`` Nrrr=s r queue_eventszEventEmitter.queue_eventsrc~|jr-|j|j|jr,yyr)should_keep_runningrHr=rs rrunzEventEmitter.runs.&&(   dll +&&(r) r r r rDEFAULT_EMITTER_TIMEOUTrr4r=r'rErHrL __classcell__r>s@rr6r6SsJ$4K   3  ,rr6cheZdZdZeZ effd ZedZ dZ edZ dZ dZ xZS)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`` cNt|t|_||_yr)r8rr r9r;)rr=r>s rrzEventDispatcher.__init__s &L rc|jS)z)Timeout value to construct emitters with.r@rs rr=zEventDispatcher.timeouts}}rctj| |jjtj y#t j$rYywxYwr)rstopr< put_nowaitrQ _stop_eventqueueFullrs rrUzEventDispatcher.stopsC     ' '(C(C Dzz   s)AAAc|jS)zThe event queue which is populated with file system events by emitters and from which events are dispatched by a dispatcher thread.)r9rs rr<zEventDispatcher.event_queues    rcy)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<s rdispatch_eventszEventDispatcher.dispatch_eventsrIrc|jr. |j|j|jr-yy#tj$rYTwxYwr)rKr\r<rXEmptyrs rrLzEventDispatcher.runsM&&( $$T%5%56&&(;;  sAAA)r r r robjectrWDEFAULT_OBSERVER_TIMEOUTrr4r=rUr<r\rLrNrOs@rrQrQsS (KC7 !!  rrQceZdZdZeffd ZdZdZdZdZ dZ e dZ fd Z dd Zd Zd Zd ZdZdZdZxZS) BaseObserverzBase observer.ct||||_tj|_t |_t|_ t |_ t|_ yr) r8r_emitter_class threadingRLock_lockset_watchesdict _handlers _emitters_emitter_for_watch)r emitter_classr=r>s rrzBaseObserver.__init__sK !+__&  "&&rcl||j|j<|jj|yr)rmr'rladdremitters r _add_emitterzBaseObserver._add_emitters(18 . 7#rc|j|j=|jj||j  |j y#t $rYywxYwr)rmr'rlremoverUjoin RuntimeErrorrqs r_remove_emitterzBaseObserver._remove_emittersO  # #GMM 2 g&   LLN   sA A! A!c|jD]}|j|jD]} |j|jj |j j y#t$rYVwxYwr)rlrUrvrwclearrmrqs r_clear_emitterszBaseObserver._clear_emitterssw~~ G LLN ~~ G     %%'   sA99 BBc||jvrt|j|<|j|j|yr)rkrhrpr event_handlerr's r_add_handler_for_watchz#BaseObserver._add_handler_for_watchs5  &$'EDNN5 ! u!!-0rc|j|=yr)rkr&s r_remove_handlers_for_watchz'BaseObserver._remove_handlers_for_watchs NN5 !rc|jS)z/Returns event emitter created by this observer.)rlrs remitterszBaseObserver.emitterss~~rc|jjD]} |jt | y#t$r|j |wxYwr)rlcopystart Exceptionrxr8)rrrr>s rrzBaseObserver.startsZ~~**, G      $$W- s AAc|j5t||}|j|||jj |Y|j |j ||j}|jr|j|j||jj|ddd|S#1swYSxYw)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=) rgrrrmgetrdr<r=is_aliverrsrirp)rr~rrr'rrs rschedulezBaseObserver.schedule s0ZZ %!$ 2E  ' ' u =&&**519-- $ 0 0t||.==?MMO!!'* MM  e $ %  % s B.CCcj|j5|j||dddy#1swYyxYw)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)rgrr}s radd_handler_for_watchz"BaseObserver.add_handler_for_watch2s0ZZ >  ' ' u = > > >s)2c|j5|j|j|dddy#1swYyxYw)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)rgrkrur}s rremove_handler_for_watchz%BaseObserver.remove_handler_for_watchDs7ZZ 8 NN5 ! ( ( 7 8 8 8s5>c|j5|j|}|j|=|j||jj |dddy#1swYyxYw)zUnschedules a watch. :param watch: The watch to unschedule. :type watch: An instance of :class:`ObservedWatch` or a subclass of :class:`ObservedWatch` N)rgrmrkrxriru)rr'rrs r unschedulezBaseObserver.unscheduleVs\ZZ (--e4Gu%   ) MM  '  ( ( (s A AA(c|j5|jj|j|jjdddy#1swYyxYw)zKUnschedules all watches and detaches all associated event handlers.N)rgrkrzr{rirs runschedule_allzBaseObserver.unschedule_allesLZZ " NN "  " MM   ! " " "s AAA$c$|jyr)rrs ron_thread_stopzBaseObserver.on_thread_stopms rcp|jd}|tjury|\}}|j5t |j j|gD]2}||j j|gvs"|j |4 ddd|jy#1swYxYw)NT)block)rrQrWrglistrkdispatch task_done)rr<entryrDr'handlers rr\zBaseObserver.dispatch_eventspsd+ O// /  u ZZ ,  2 25" => ,dnn00;;$$U+ ,  ,  , ,sAB,?B,,B5)F)r r r rr`rrsrxr{rrr4rrrrrrrrr\rNrOs@rrbrbsd.F)$ (1 "%N>$8$ ("  rrbceZdZdddZy)BaseObserverSubclassCallablecyrrrGs r__call__z%BaseObserverSubclassCallable.__call__s rN).)r=floatreturnrb)r r r rrrrrrs rr) __future__rrXrepathlibrwatchdog.utilsrrwatchdog.utils.bricksrrMr`r rr6rQrbrrrrrsv # /2!(`(`X@,:@,F8j8vl ?l ^ 8 r