o *ήc@sdZddlZddlZddlmZddlmZmZddlm Z m Z m Z m Z ddl mZmZmZmZmZmZmZmZGddde ZGd d d e ZGd d d e ZdS) ug :module: watchdog.observers.polling :synopsis: Polling emitter implementation. :author: yesudeep@google.com (Yesudeep Mangalapilly) :author: contact@tiger-222.fr (Mickaël Schoentgen) Classes ------- .. autoclass:: PollingObserver :members: :show-inheritance: .. autoclass:: PollingObserverVFS :members: :show-inheritance: :special-members: N)partial)DirectorySnapshotDirectorySnapshotDiff) EventEmitter BaseObserverDEFAULT_OBSERVER_TIMEOUTDEFAULT_EMITTER_TIMEOUT) DirMovedEventDirDeletedEventDirCreatedEventDirModifiedEventFileMovedEventFileDeletedEventFileCreatedEventFileModifiedEventcs<eZdZdZeejejffdd ZddZ ddZ Z S)PollingEmitterz` Platform-independent emitter that polls a directory to detect file system changes. cs6t|||d_t_fdd_dS)NcstjjjjdS)Nstatlistdir)rwatchpath is_recursiverselfrrA/tmp/pip-target-vg8gfxp4/lib/python/watchdog/observers/polling.pyHsz)PollingEmitter.__init__..)super__init__ _snapshot threadingLock_lock_take_snapshot)r event_queuertimeoutrr __class__rrrCs zPollingEmitter.__init__cCs||_dSN)r#r)rrrron_thread_startKszPollingEmitter.on_thread_startc Cs|j|rdS|j|s WddSz|}Wnty<|t|jj | YWddSwt |j |}||_ |j D] }|t|qI|jD] }|t|qV|jD] }|t|qc|jD] \}}|t||qp|jD] }|t|q|jD] }|t|q|jD] }|t|q|jD] \}}|t||qWddS1swYdSr() stopped_eventwaitr"should_keep_runningr#OSError queue_eventr rrstoprr files_deletedrfiles_modifiedr files_createdr files_movedr dirs_deleted dirs_modifiedr dirs_createdr dirs_movedr )rr% new_snapshoteventssrc_path dest_pathrrr queue_eventsNsD          "zPollingEmitter.queue_events) __name__ __module__ __qualname____doc__rosrscandirrr)r< __classcell__rrr&rr=srcs$eZdZdZeffdd ZZS)PollingObserverza Platform-independent observer that polls a directory to detect file system changes. cstjt|ddS)N emitter_classr%)rrr)rr%r&rrrszPollingObserver.__init__)r=r>r?r@rrrCrrr&rrDysrDcs"eZdZdZdfdd ZZS)PollingObserverVFSzT File system independent observer that polls a directory to detect changes. cs"tt||d}tj||ddS)a :param stat: stat function. See ``os.stat`` for details. :param listdir: listdir function. See ``os.scandir`` for details. :type polling_interval: float :param polling_interval: interval in seconds between polling the file system. rrEN)rrrr)rrrpolling_interval emitter_clsr&rrrszPollingObserverVFS.__init__)rH)r=r>r?r@rrCrrr&rrGsrG)r@rAr functoolsrwatchdog.utils.dirsnapshotrrwatchdog.observers.apirrrrwatchdog.eventsr r r r r rrrrrDrGrrrrs ( <