xjR*ddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z m Z m Z ddl mZddlmZddlmZerddlmZejdZeedreed r eed sd ejZeeeje e e e d d efZeje e e d d efZeje d defZGddZedejej ej!ej"ej#ej$ej%ej&ej'ej(ej)g Z*Gddej+Z,ej-e,Z.dZ/e/e.dzzZ0GddZ1GddZ2dS)) annotationsN)c_char_pc_intc_uint32)reduce) TYPE_CHECKING)UnsupportedLibcError) Generator inotify_initinotify_add_watchinotify_rm_watchz Unsupported libc version found: T) use_errnoceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Ze e zZd ZdZdZdZdZdZdZdZdZedeeeeeee e e e e eg ZdZdZdS)InotifyConstants @iii i@iiiii i@lc ||zSNxys MC:\Projects\Historical\venv\Lib\site-packages\watchdog/observers/inotify_c.pyzInotifyConstants.Bs QUN)__name__ __module__ __qualname__ IN_ACCESS IN_MODIFY IN_ATTRIBIN_CLOSE_WRITEIN_CLOSE_NOWRITEIN_OPEN IN_MOVED_FROM IN_MOVED_TO IN_CREATE IN_DELETEIN_DELETE_SELF IN_MOVE_SELFIN_MOVE IN_UNMOUNT IN_Q_OVERFLOW IN_IGNORED IN_ONLYDIRIN_DONT_FOLLOWIN_EXCL_UNLINK IN_MASK_ADDIN_ISDIR IN_ONESHOTr IN_ALL_EVENTS IN_CLOEXEC IN_NONBLOCKrr#r!rr!sIIIN!GMKIINLk)GJMJJNNKHJF             M&JKKKr#rc ||zSrrrs r!r"r"Zs Qr#c4eZdZdZdefdefdefdefdeffZdS)InotifyEventStructaStructure representation of the inotify_event structure (used in buffer size calculations):: struct inotify_event { __s32 wd; /* watch descriptor */ __u32 mask; /* watch mask */ __u32 cookie; /* cookie to synchronize two events */ __u32 len; /* length (including nulls) of name */ char name[0]; /* stub for possible name */ }; wdmaskcookielennameN)r$r%r&__doc__rrr_fields_rr#r!rBrBksH   u  8   HHHr#rBrrceZdZdZdddd)d Zed*dZed+dZed,dZed*dZ d-dZ d.dZ d/dZ d0dZ d0dZd-dZedd1d Zd-d!Zd2d#Zd3d$Zed-d%Zed4d(ZdS)5InotifyaLinux inotify(7) API wrapper class. :param path: The directory path for which we want an inotify object. :type path: :class:`bytes` :param recursive: ``True`` if subdirectories should be monitored; ``False`` otherwise. FN) recursive event_maskpathbytesrLboolrM int | NonereturnNonec6t}|dkrt|_t j_d_d_tj \_ _ ttdrztj_jjtjjj tjd fd }|_n d fd }|_i_i_|_|t.}|_|_tj|r||| n||i_dS) NFTpollrRrPchtfdjDS)Nc34K|]\}}|jkVdSr _inotify_fd).0fd_selfs r! z4Inotify.__init__..do_poll..s/SSeb!2!11SSSSSSr#)any_pollerrVr^sr!do_pollz!Inotify.__init__..do_polls4SSSSt|?P?P?R?RSSSSSSr#cftjjjggg}j|dvSNr)selectrZ_kill_r)resultr^s r! do_selectz#Inotify.__init__..do_selects2(8$,'GRPP'6!944r#)rLrRrP)r rK _raise_errorrZ threadingLock_lock_closed _is_readingospiperg_kill_whasattrrfrVraregisterPOLLIN_check_inotify_fd _wd_for_path _path_for_wd_pathWATCHDOG_ALL_EVENTS _event_mask _is_recursiverNisdir_add_dir_watch _add_watch_moved_from_events)r^rNrLrM inotify_fdrcris` r!__init__zInotify.__init__s!^^     " " "%^%%  %'WYY" dl 66 " " /!;==DL L ! !$"2FM B B B L ! !$, > > > T T T T T T&-D " " 5 5 5 5 5 5&/D "/1.0  ,J%& 7==   .   jI  F F F F OOD* - - -;=r#intc|jS)z)The event mask for this inotify instance.)r|rbs r!rMzInotify.event_mask r#c|jS)z.The path associated with the inotify instance.)rzrbs r!rNz Inotify.paths zr#c|jS)z0Whether we are watching directories recursively.)r}rbs r! is_recursivezInotify.is_recursives !!r#c|jS)z9The file descriptor associated with the inotify instance.rYrbs r!r\z Inotify.fdrr#ci|_dS)z)Clear cached records of MOVED_FROM eventsN)rrbs r!clear_move_recordszInotify.clear_move_recordss"$r#destination_event InotifyEvent bytes | NonecP|j|jvr|j|jjSdS)zThe source path corresponding to the given MOVED_TO event. If the source path is outside the monitored directories, None is returned instead. N)rErsrc_path)r^rs r!source_for_movezInotify.source_for_moves/  #t'> > >*+<+CDM Mtr#eventc$||j|j<dS)z]Save this event as the source event for future MOVED_TO events to reference. N)rrE)r^rs r!remember_move_from_eventz Inotify.remember_move_from_events16 ---r#c||j5|||jddddS#1swxYwYdS)zeAdds a watch for the given path. :param path: Path to begin monitoring. N)rnrr|)r^rNs r! add_watchzInotify.add_watchs Z 4 4 OOD$"2 3 3 3 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s 155c|j5|j|}|j|=t |j|dkrt ddddS#1swxYwYdS)zRemoves a watch for the given path. :param path: Path string for which the watch will be removed. rUN)rnrxpopryr rZrKrk)r^rNrCs r! remove_watchzInotify.remove_watchs Z ' '"&&t,,B!"% 0"55;;$$&&&  ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 'sAA**A.1A.c8|j5|jsrd|_|j|jvr'|j|j}t |j||jrtj|j dn| ddddS#1swxYwYdS)z?Closes the inotify instance and removes all associated watches.T!N) rnrorzrxr rZrprqwriters_close_resources)r^rCs r!closez Inotify.closes Z , ,< ,# :!222*4:6B$T%5r:::#,HT\40000))+++ , , , , , , , , , , , , , , , , , ,sA:BBB)event_buffer_sizerlist[InotifyEvent]c Dd fd }d} j5jrgcdddSd_dddn #1swxYwYrt jj|}j5d _jr"gcdddS dddn #1swxYwYnI#t$r<}|j tj krYd}~|j tj krgcYd}~Sd}~wwxYw j5g}t |D]R\}}}} |d krj|} | r tj| | n| } t#|||| | } | jr| n1| jr)| } | jvr؉j| }j| =|j| j<| jj|<jrjD]}|| tjjzrIj|}|| | j}|j|<|j|<tj| | } t#|||| | } | jr3j|}j||krj|=| | jrZ| j!rS| j"rL #| j$n#t$rY0wxYw|%|| T dddn #1swxYwY|S) z*Reads events from inotify and yields them.rrOrRrc g}tj|D]8\}}}|D]}tjt5tj||} | j}t|tj tj zd||}| |dddn #1swxYwY|D]~} tj|| } jtj|} t| tj d| |}| |:|Sre)rqwalk contextlibsuppressOSErrorrNjoinrr|rrr/r;appendrxdirname) reventsrootdirnames filenamesr full_pathwd_direfilename wd_parent_dirr^s r!_recursive_simulatez0Inotify.read_events.._recursive_simulatesF-/WX->-> % %)h ' ) )G#,W55 ) )$&GLLw$?$? !%DK27<<666G ,RvtX N N  .S11-@@@@".S$($8$8$G$GM$(999#'#4]#C -m>CB>C D D*DD DD H#N;MN M%!N$M%%#NNNctj|jtj|jtj|jdSr)rqrrZrgrsrbs r!rzInotify._close_resourcess? !"""  r#rDctj|s7ttjtjtj|||||rvtj|D]c\}}}|D]X}tj ||}tj |rB|||YbdSdS)a&Adds a watch (optionally recursively) for the given directory path to monitor events specified by the mask. :param path: Path to monitor :param recursive: ``True`` to monitor recursively. :param mask: Event bit mask. N) rqrNr~rrENOTDIRstrerrorrrrislink) r^rNrDrLrrr]rrs r!rzInotify._add_dir_watchsw}}T"" K%-U])C)CTJJ J d###  5%'WT]] 5 5!h'55G " T7 ; ;Iw~~i00! OOIt4444 5 5 5 5 5r#ct|j||}|dkrt||j|<||j|<|S)zAdds a watch for the given path to monitor events specified by the mask. :param path: Path to monitor :param mask: Event bit mask. rU)r rZrKrkrxry)r^rNrDrCs r!rzInotify._add_watchsRt/t < < 88  " " ""$$ $" r#c8tj}|tjkrt tjd|tjkrt tjd|tjkr"t |tj|dS)z#Raises errors for inotify failures.zinotify watch limit reachedzinotify instance limit reachedN) ctypes get_errnorENOSPCrEMFILEEACCESrqr)errs r!rkzInotify._raise_errors   %,  %,(EFF F %,  %,(HII I %,  #r{3//00 0  r#r&Generator[tuple[int, int, int, bytes]]c# Kd}|dzt|kritjd||\}}}}||dz|dz|zd}|d|zz }||||fV|dzt|kgdSdS)aParses an event buffer of ``inotify_event`` structs returned by inotify:: struct inotify_event { __s32 wd; /* watch descriptor */ __u32 mask; /* watch mask */ __u32 cookie; /* cookie to synchronize two events */ __u32 len; /* length (including nulls) of name */ char name[0]; /* stub for possible name */ }; The ``cookie`` member of this struct is used to pair two related events, for example, it pairs an IN_MOVED_FROM event with an IN_MOVED_TO event. rriIIIN)rFstruct unpack_fromrstrip)rirCrDrElengthrGs r!rzInotify._parse_event_buffers" "fL))))'-'9&,PQ'R'R $BffBR& 89@@GGD f AdFD( ( ( ( "fL))))))))r#)rNrOrLrPrMrQrRrSrRrrRrOrj)rRrS)rrrRr)rrrRrS)rNrOrRrS)rrrRr)rNrOrDrrLrPrRrS)rNrOrDrrRr)rrOrRr)r$r%r&rHrpropertyrMrNrr\rrrrrrDEFAULT_EVENT_BUFFER_SIZErrrr staticmethodrkrrr#r!rKrKs:?Y]+>+>+>+>+>+>Z   X X"""X"   X %%%%    6666 4444 ' ' ' ',,,,"7Prrrrrrh 5555,  1 1 1\ 1)))\)))r#rKcJeZdZdZd,d Zed-d Zed.d Zed.dZed.dZ ed-dZ ed/dZ ed/dZ ed/dZ ed/dZed/dZed/dZed/dZed/dZed/dZed/dZed/dZed/dZed/dZed/dZed/d Zed0d"Zd1d%Zd1d&Zd.d'Zed2d)Zd3d*Z d+S)4ra Inotify event struct wrapper. :param wd: Watch descriptor :param mask: Event mask :param cookie: Event cookie :param name: Base name of the event source path. :param src_path: Full event source path. rCrrDrErGrOrrRrScL||_||_||_||_||_dSr)_wd_mask_cookie_name _src_path)r^rCrDrErGrs r!rzInotifyEvent.__init__s)   !r#c|jSr)rrbs r!rzInotifyEvent.src_paths ~r#c|jSr)rrbs r!rCzInotifyEvent.wds xr#c|jSr)rrbs r!rDzInotifyEvent.mask zr#c|jSr)rrbs r!rEzInotifyEvent.cookies |r#c|jSr)rrbs r!rGzInotifyEvent.namerr#rPc2|jtjzdkSre)rrr(rbs r! is_modifyzInotifyEvent.is_modifyz,66::r#c2|jtjzdkSre)rrr*rbs r!is_close_writezInotifyEvent.is_close_writez,;;a??r#c2|jtjzdkSre)rrr+rbs r!is_close_nowritezInotifyEvent.is_close_nowritesz,==AAr#c2|jtjzdkSre)rrr,rbs r!is_openzInotifyEvent.is_open z,44q88r#c2|jtjzdkSre)rrr'rbs r! is_accesszInotifyEvent.is_accessrr#c2|jtjzdkSre)rrr0rbs r! is_deletezInotifyEvent.is_deleterr#c2|jtjzdkSre)rrr1rbs r!is_delete_selfzInotifyEvent.is_delete_selfrr#c2|jtjzdkSre)rrr/rbs r!rzInotifyEvent.is_createrr#c2|jtjzdkSre)rrr-rbs r!rzInotifyEvent.is_moved_fromsz,::Q>>r#c2|jtjzdkSre)rrr.rbs r!rzInotifyEvent.is_moved_to"sz,881<r3r=|)dirrrgetattrrr)rDmaskscc_vals r!_get_mask_stringzInotifyEvent._get_mask_stringNsz%&& $ $A||E"" $q0L'L'L 0!44%<$LLOOOxxr#cdt|jd|jd|jd||jd|jdtj|j d S)N) typer$rrCr*rDrErqfsdecoderGrbs r!__repr__zInotifyEvent.__repr__Xs 1T # 1 1  1 1dg 1 1**4955 1 1@D  1 1[++ 1 1 1 r#N) rCrrDrrErrGrOrrOrRrSrrrj)rRr)rrrRrP)rDrrRr!)rRr!)!r$r%r&rHrrrrCrDrErGrrrrrrrrrrr r rrrrrrr rr*r0rr#r!rrsV  """"XXXXX;;;X;@@@X@BBBXB999X9;;;X;;;;X;@@@X@;;;X;???X?===X=999X9>>>X>;;;X;<<<X<fffXf NNNXN---- ---- \      r#r)3 __future__rrr ctypes.utilrrqrfrrlrrr functoolsrtypingrwatchdog.utilsr collections.abcr CDLLlibcrtrerror CFUNCTYPEr r r rr(r)r-r.r/r0r1r8r*r+r,r{ StructurerBsizeof EVENT_SIZEDEFAULT_NUM_EVENTSrrKrrr#r!r?s""""""  ,,,,,,,,,, //////*))))))v{4wt^$$&GGD:M,N,N&V]V]^bdvVwVw& ;tz ; ;E  u % %%V$F$UE8XQUVVVXkmqWrssK#6#E5(dKKKM_aeLfgg6v6667MNN 44444444pf""&$""''')  $),V]- . . .*r/BK)K)K)K)K)K)K)K)\ I I I I I I I I I I r#