U ꥡ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)rwatchpathZ is_recursiverselfrr>/tmp/pip-unpacked-wheel-thtqfo2i/watchdog/observers/polling.pyHs z)PollingEmitter.__init__..)super__init__ _snapshot threadingLock_lock_take_snapshot)rZ event_queuertimeoutrr __class__rrrCs zPollingEmitter.__init__cCs||_dSN)r"r)rrrron_thread_startKszPollingEmitter.on_thread_startc Cs||j|rdS|jZ|s0W5QRdSz |}Wn:tk rv|t|jj | YW5QRdSXt |j |}||_ |j D]}|t|q|jD]}|t|q|jD]}|t|q|jD]\}}|t||q|jD]}|t|q|jD]}|t|q|jD]}|t|q6|jD]\}}|t||qRW5QRXdSr&)Z stopped_eventwaitr!Zshould_keep_runningr"OSErrorZ queue_eventr rrstoprrZ files_deletedrZfiles_modifiedrZ files_createdrZ files_movedr Z dirs_deletedZ dirs_modifiedr dirs_createdr Z dirs_movedr )rr#Z new_snapshoteventsZsrc_path dest_pathrrr queue_eventsNs:          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)NZ emitter_classr#)rrr)rr#r$rrrszPollingObserver.__init__)r/r0r1r2rrr5rrr$rr6ysr6cs"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. rr7N)rrrr)rrrZpolling_intervalZ emitter_clsr$rrrszPollingObserverVFS.__init__)r9)r/r0r1r2rr5rrr$rr8sr8)r2r3r functoolsrZwatchdog.utils.dirsnapshotrrZwatchdog.observers.apirrrrZwatchdog.eventsr r r r r rrrrr6r8rrrrs ( <