"e1dZddlZddlZddlmZddlmZddlmZ ddl m Z ddl Z d Z d Zd ZGd d e ZGdde ZGdde ZGdde Zy#Gdde Z YFxYw)a~ Sample usage to track changes in a thread. import threading import time watcher = fsnotify.Watcher() watcher.accepted_file_extensions = {'.py', '.pyw'} # Configure target values to compute throttling. # Note: internal sleep times will be updated based on # profiling the actual application runtime to match # those values. watcher.target_time_for_single_scan = 2. watcher.target_time_for_notification = 4. watcher.set_tracked_paths([target_dir]) def start_watching(): # Called from thread for change_enum, change_path in watcher.iter_changes(): if change_enum == fsnotify.Change.added: print('Added: ', change_path) elif change_enum == fsnotify.Change.modified: print('Modified: ', change_path) elif change_enum == fsnotify.Change.deleted: print('Deleted: ', change_path) t = threading.Thread(target=start_watching) t.daemon = True t.start() try: ... finally: watcher.dispose() Note: changes are only reported for files (added/modified/deleted), not directories. N)basename) pydev_log)scandir)IntEnumc eZdZy)rN)__name__ __module__ __qualname__A/usr/lib/python3/dist-packages/_pydev_bundle/fsnotify/__init__.pyrr2s r rzFabio Zadroznyzfabiofz@gmail.comz0.1.5ceZdZdZdZdZy)ChangeN)rr r addedmodifieddeletedr r r rr<s EHGr rceZdZdZy)_SingleVisitInfocpd|_t|_i|_t j|_yNr)countset visited_dirs file_to_mtimetimelast_sleep_timeselfs r __init__z_SingleVisitInfo.__init__Ds) E#yy{r N)rr r r"r r r rrBs+r rc6eZdZdZd dZdZdZdZdZdZ y) _PathWatcherz( Helper to watch a single path. c||_||_||_||_||_d|_i}|j |d|y)z :type root_path: str :type accept_directory: Callback[str, bool] :type accept_file: Callback[str, bool] :type max_recursion_level: int :type sleep_time: float g?cyNr )_changes r z'_PathWatcher.__init__..fsr N)accept_directory accept_file_max_recursion_level _root_path sleep_timesleep_at_elapsed_check)r! root_pathr*r+single_visit_infomax_recursion_levelr.old_file_to_mtimes r r"z_PathWatcher.__init__PsO!1&$7!#% ( %';=NOr cVt|tr|j|jk(Sy)NF) isinstancer$r-r!os r __eq__z_PathWatcher.__eq__hs" a &??all2 2r c||k( Sr'r r7s r __ne__z_PathWatcher.__ne__ns19}r c,t|jSr')hashr-r s r __hash__z_PathWatcher.__hash__qsDOO$$r c ||jvs||jkDry|jj| t|tr$ |j t j}|j}t|D]}|xjdz c_ |jdzdk(ry|jdkDrjtj}||jz } | |jkDr8tj |jtj|_|j#r?|j%|j&s|j)|j&||||dz|j+|j&s|j-} | j.| j0f} |j&} | || <|j3| d} | s|t4j6| fw| | k7s~|t4j8| fy#t$r' |j d}n#t$rYYywxYwYwxYw#t:$rYywxYw)Nzutf-8ri,r)rr,addr6bytesdecodesysgetfilesystemencodingUnicodeDecodeErrorrrrr.rrr/sleepis_dirr*path _check_dirr+stat st_mtime_nsst_sizepoprrrOSError)r!dir_pathr2 append_changer4level new_filesentrytdiffrJmtimerH old_mtimes r rIz_PathWatcher._check_dirts  (55 5AZAZ9Z &&**84* (E*'s/H/H/JKH*77I * ?!''1,'%**S0A5* IIK #4#D#DD$"7"77 JJt7@D -=<<>,,UZZ8 4E}Vginqrirs%%ejj1 ::7 ?*#+??7#;-!J   ssI #H /C&I>IA,II I*H<;I< I III  I III IIcB|j|j|||dyr)rIr-)r!r2rPr4s r r0z_PathWatcher._checks ):MK\^_`r N)) rr r __doc__r"r9r;r>rIr0r r r r$r$Ks(P0 %/bar r$ceZdZhdZdZdZdZdZdZddZ e d Z e jd Z e d Z e jd Z d Ze dZdZdZy)Watcher>.git.idea .metadata __pycache__ node_modulesr @g@F Nct_tj_|fd}|fd}|_|_t_y)a :param Callable[str, bool] accept_directory: Callable that returns whether a directory should be watched. Note: if passed it'll override the `ignored_dirs` :param Callable[str, bool] accept_file: Callable that returns whether a file should be watched. Note: if passed it'll override the `accepted_file_extensions`. Nc2t|jvSr')r ignored_dirs)rOr!s r r)z"Watcher.__init__..s0B$J[J[0[r cXj xs|jjSr')accepted_file_extensionsendswith) path_namer!s r r)z"Watcher.__init__..s*111fY5G5GHeHe5fr ) r_path_watchers threadingEvent _disposedr+r*r_single_visit_info)r!r*r+s` r r"zWatcher.__init__sR"e"*  #[   gK& 0"2"4r c|jSr')_accept_directoryr s r r*zWatcher.accept_directorys%%%r cB||_|jD] }||_ yr')rqrkr*)r!r* path_watchers r r*zWatcher.accept_directorys'!1 // =L,.s CI:r )keyrY)r3r.z,Tracking the following paths for changes: %szTime to track: %.2fszFolders found: %szFiles found: %sN)r6listrzrsortedrrorr$r*r+r3r@rdebugr~rrrk)r!pathsr{ initial_timerHr.rs actual_times r set_tracked_pathszWatcher.set_tracked_pathss%$s!34HE s5z'=> "2"4yy{  ,DJ'%%  ''$($<$<% L   l + ,yy{\1 FN. <+S1H1H1U1U-VW)3t/F/F/T/T+UV+r c#XK|jjs tj}|j}|j}g}|j }t x|_}|jD]}|j||||D]}|tj|f|D]} | tj|z } |jrtd| z| dkDr|jdkr|jD] }d|_ n|j| z } | dkDrd} n| dkrd} |jD]}|jdkrd|_|j| z} | |jz } |xj| dt|jzz z c_| dkDr|jj!| |jdksd|_|j"| z }|dkDr|jj!||jjs yyw) z Continuously provides changes (until dispose() is called). Changes provided are tuples with the Change enum and filesystem path. :rtype: Iterable[Tuple[Change, str]] z--- Total poll time: %.3fsrrYrbg?gMbP?g@N)rnis_setrrorappendrrkr0rrprint_poll_timeprinttarget_time_for_single_scanr.r~waittarget_time_for_notification)r!rold_visit_infor4changesrPr2rsrSchangerpercnew_sleep_timediff_sleep_timerUs r iter_changeszWatcher.iter_changess'..'')99;L!44N . < < G#NNM:J:L LD #&7 $ 3 3 Y ##$5}FWX Y+ 7v~~u56 7"    99;5K##2[@AQ33s:(,(;(;6 25 /6 ;;kID by!"(,(;(;< '22c96;L3)5)@)@4)G +9<;R;R*R$//OsSQUQdQdMeGe4fg/&? NN// <'22U:6;L3!<(44{BDby##D){..''))sGH*AH*(H*)NN)rr r rfrhrrrr3r"propertyr*setterr+rxr{rrr r r r\r\sVL " #& $' O5,&&== !!33 **#,JE*r r\)rZrlrCos.pathr _pydev_bundlerosrenumrobjectr __author__ __email__ __version__rrr$r\r r r rs&N #      W +v+[a6[a|w*fw*s  & s A A*