zcdZddlZddlZddlmZddlmZmZddlm Z m Z m Z m Z ddl mZmZmZmZmZmZmZmZGdde ZGd d e ZGd 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) DirMovedEventDirDeletedEventDirCreatedEventDirModifiedEventFileMovedEventFileDeletedEventFileCreatedEventFileModifiedEventc@eZdZdZeejejfdZdZ dZ dS)PollingEmitterz` Platform-independent emitter that polls a directory to detect file system changes. ctj|||d_tj_fd_dS)NcRtjjjjS)Nstatlistdir)rwatchpath is_recursive)rselfrs:lib/python3.11/site-packages/watchdog/observers/polling.pyz)PollingEmitter.__init__..Hs,&7 JOTZ44'R'R'R)r__init__ _snapshot threadingLock_lock_take_snapshot)r event_queuertimeoutrrs` ``rr zPollingEmitter.__init__CsadK@@@^%% RRRRRRrc8||_dSN)r%r!)rs ron_thread_startzPollingEmitter.on_thread_startKs,,..rc|j|rdS|j5|s ddddS |}n\#t $rO|t|jj | YddddSwxYwt|j |}||_ |j D]$}|t|%|jD]$}|t!|%|jD]$}|t%|%|jD](\}}|t)||)|jD]$}|t|%|jD]$}|t/|%|jD]$}|t3|%|jD](\}}|t7||) ddddS#1swxYwYdSr)) 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_paths r queue_eventszPollingEmitter.queue_eventsNs?   " "7 + +  F Z" E" E++-- " E" E" E" E" E" E" E" E  #2244      !A!ABBB " E" E" E" E" E" E" E" E  +4><HHF)DN#0 = =  !1(!;!;<<<<"1 > >  !28!rrrr=sh 4KgrzRRRR///(E(E(E(E(ErrceZdZdZefdZdS)PollingObserverza Platform-independent observer that polls a directory to detect file system changes. c>tj|t|dS)N emitter_classr')rr r)rr's rr zPollingObserver.__init__s d.'RRRRRRrN)r?r@rArBrr rErrrGrGys= 8SSSSSSrrGceZdZdZddZdS)PollingObserverVFSzT File system independent observer that polls a directory to detect changes. cbtt||}tj|||dS)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. rrIN)rrrr )rrrpolling_interval emitter_clss rr zPollingObserverVFS.__init__s7n4III d+GWXXXXXXrN)rM)r?r@rArBr rErrrLrLs8YYYYYYrrL)rBrCr" functoolsrwatchdog.utils.dirsnapshotrrwatchdog.observers.apirrrr watchdog.eventsr r r r rrrrrrGrLrErrrUs&$ OOOOOOOO                    9E9E9E9E9E\9E9E9ExSSSSSlSSS Y Y Y Y Y Y Y Y Y Yr