"ddZddlmZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z mZmZddlmZmZmZmZddlmZmZGdd eZGd d eZGd d eZy)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: ) annotationsN)partial)DirCreatedEventDirDeletedEventDirModifiedEvent DirMovedEventFileCreatedEventFileDeletedEventFileModifiedEventFileMovedEvent)DEFAULT_EMITTER_TIMEOUTDEFAULT_OBSERVER_TIMEOUT BaseObserver EventEmitter)DirectorySnapshotDirectorySnapshotDiffc^eZdZdZeej ejffd ZdZ dZ xZ S)PollingEmitterz` Platform-independent emitter that polls a directory to detect file system changes. ct|||d_tj_fd_y)NcrtjjjjS)Nstatlistdir)rwatchpath is_recursive)rselfrsz)PollingEmitter.__init__..Hs(&7 JJOOTZZ444' )super__init__ _snapshot threadingLock_lock_take_snapshot)r event_queuertimeoutrr __class__s` ``rr"zPollingEmitter.__init__=s5 eW5^^%  r c.|j|_yN)r'r#)rs ron_thread_startzPollingEmitter.on_thread_startLs,,.r cz|jj|ry|j5|js dddy |j }t|j|}||_ |jD]}|j t||jD]}|j t!||j"D]}|j t%||j&D] \}}|j t)||"|j*D]}|j t||j,D]}|j t/||j0D]}|j t3||j4D] \}}|j t7||" dddy#t $rI|j t|jj|jYdddywxYw#1swYyxYwr,) stopped_eventwaitr&should_keep_runningr'OSError queue_eventrrrstoprr# files_deletedr files_modifiedr files_createdr files_movedr dirs_deleted dirs_modifiedr dirs_createdr dirs_movedr)rr) new_snapshoteventssrc_path dest_paths r queue_eventszPollingEmitter.queue_eventsOs'    " "7 +  ZZ" E++-" E" E  #224 +4>><HF)DN#00 =  !1(!;< ="11 >  !28!<= >"00 =  !1(!;< ='-'9'9 F#)  )!DE F#// <  !:; <"00 =  !1(!;< ="// <  !:; <'-'8'8 E#)  x!CD EC" E" E   !AB " E" E " E" Es1H1GE=H1AH.#H1-H..H11H:) __name__ __module__ __qualname____doc__r osrscandirr"r-rA __classcell__r*s@rrr7s+( WW  /(Er rc&eZdZdZeffd ZxZS)PollingObserverza Platform-independent observer that polls a directory to detect file system changes. c0t|t|y)N emitter_classr))r!r"r)rr)r*s rr"zPollingObserver.__init__s ~wGr )rBrCrDrErr"rHrIs@rrKrKzs 8HHr rKc$eZdZdZdfd ZxZS)PollingObserverVFSzT File system independent observer that polls a directory to detect changes. cLtt||}t| ||y)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. rrMN)rrr!r")rrrpolling_interval emitter_clsr*s rr"zPollingObserverVFS.__init__s&n4I  {r[s`"$#    qpO@E\@EFHlH N Nr