"d]ddlmZ ddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZddlmZmZmZmZddlmZddlmZdZd Z ejBre Z"nejFejHzZ"ejJZ&ejNejPzejRzZ*ejVejXzejZzej\zej^zej`zejbzZ2d Z3d Z4d Z5d Z6dZ7GddZ8GddZ9GddeZ:GddeZ;y)) annotationsN)S_ISDIR) EVENT_TYPE_CREATEDEVENT_TYPE_DELETEDEVENT_TYPE_MOVEDDirCreatedEventDirDeletedEventDirModifiedEvent DirMovedEventFileCreatedEventFileDeletedEventFileModifiedEventFileMovedEventgenerate_sub_moved_events)DEFAULT_EMITTER_TIMEOUTDEFAULT_OBSERVER_TIMEOUT BaseObserver EventEmitter)platform)DirectorySnapshotiicztjjtjj|SN)ospathabspathnormpath)rs ;/usr/lib/python3/dist-packages/watchdog/observers/kqueue.py absolute_pathr~s$ 77??277++D1 22c<|jtjzS)z8Determines whether the given kevent represents deletion.)fflagsselectKQ_NOTE_DELETEkevs r is_deletedr& ::-- --rcj|j}|tjzxs|tjzS)zr;r?s rkeventszKeventDescriptorSet.keventss' ZZ !== ! ! !s #,c|j5t|jjcdddS#1swYyxYw)zD List of paths for which kevents have been created. N)r>r:r8keysr?s rpathszKeventDescriptorSet.pathss7 ZZ :116689 : : :s #:Acd|j5|j|cdddS#1swYyxYw)z Given a file descriptor, returns the kevent descriptor object for it. :param fd: OS file descriptor. :type fd: ``int`` :returns: A :class:`KeventDescriptor` object. N)r>r9)r@fds r get_for_fdzKeventDescriptorSet.get_for_fds.ZZ /**2. / / /s&/c~|j5t|}|j|cdddS#1swYyxYw)z Obtains a :class:`KeventDescriptor` object for the specified path. :param path: Path for which the descriptor will be obtained. N)r>r_getr@rs rgetzKeventDescriptorSet.gets5ZZ # &D99T? # # #3<c~|j5t|}|j|cdddS#1swYyxYw)z Determines whether a :class:`KeventDescriptor has been registered for the specified path. :param path: Path for which the descriptor will be obtained. N)r>r _has_pathrLs r __contains__z KeventDescriptorSet.__contains__s6ZZ ( &D>>$' ( ( (rNc|j5t|}|j|s|jt ||dddy#1swYyxYw)an Adds a :class:`KeventDescriptor` to the collection for the given path. :param path: The path for which a :class:`KeventDescriptor` object will be added. :param is_directory: ``True`` if the path refers to a directory; ``False`` otherwise. :type is_directory: ``bool`` N)r>rrP_add_descriptorKeventDescriptorr@r is_directorys raddzKeventDescriptorSet.addsPZZ K &D>>$'$$%5dL%IJ K K Ks 8AAc|j5t|}|j|r |j|j |dddy#1swYyxYw)z Removes the :class:`KeventDescriptor` object for the given path if it already exists. :param path: Path for which the :class:`KeventDescriptor` object will be removed. N)r>rrP_remove_descriptorrKrLs rremovezKeventDescriptorSet.removesLZZ 9 &D~~d#'' $8 9 9 9s =AAc2|j5|jD]}|j|jj|jj|j jg|_dddy#1swYyxYw)zH Clears the collection and closes all open descriptors. N)r>r6closeclearr9r8r;r@ descriptors rr]zKeventDescriptorSet.clears~ZZ "// #   " #    # # %  # # ) ) +  % % + + -DM    s A7B  Bc |j|S)z-Returns a kevent descriptor for a given path.r8rLs rrKzKeventDescriptorSet._gets((..rc||jvS)zoDetermines whether a :class:`KeventDescriptor` for the specified path exists already in the collection.rarLs rrPzKeventDescriptorSet._has_pathst0000rc|jj||jj|j||j |j <||j|j<y)z Adds a descriptor to the collection. :param descriptor: An instance of :class:`KeventDescriptor` to be added. N) r6rWr;appendkeventr8rr9rHr^s rrSz#KeventDescriptorSet._add_descriptorsX j) Z../5?!!*//21; .rc|jj||j|j=|j|j =|j j|j|jy)z Removes a descriptor from the collection. :param descriptor: An instance of :class:`KeventDescriptor` to be removed. N) r6rZr9rHr8rr;rer\r^s rrYz&KeventDescriptorSet._remove_descriptor's`   ,  # #JMM 2  % %joo 6 Z../rN)__name__ __module__ __qualname____doc__rApropertyrCrFrIrMrQrWrZr]rKrPrSrYrrr3r3sg &!!:: / # (K$ 9 /1 < rr3ceZdZdZdZedZedZedZedZ dZ edZ d Z d Z d Zd Zy )rTa A kevent descriptor convenience data structure to keep together: * kevent * directory status * path * file descriptor :param path: Path string for which a kevent descriptor will be created. :param is_directory: ``True`` if the path refers to a directory; ``False`` otherwise. :type is_directory: ``bool`` ct||_||_tj|t |_tj|j ttt|_ y)N)filterflagsr!) r_path _is_directoryropenWATCHDOG_OS_OPEN_FLAGS_fdr"reWATCHDOG_KQ_FILTERWATCHDOG_KQ_EV_FLAGSWATCHDOG_KQ_FFLAGS_kevrUs rrAzKeventDescriptor.__init__GsI"4( )774!78MM HH%&%   rc|jS)z-OS file descriptor for the kevent descriptor.)rur?s rrHzKeventDescriptor.fdRs xxrc|jS)z/The path associated with the kevent descriptor.)rqr?s rrzKeventDescriptor.pathWszzrc|jS)z8The kevent object associated with the kevent descriptor.)ryr?s rrezKeventDescriptor.kevent\syyrc|jS)z}Determines whether the kevent descriptor refers to a directory. :returns: ``True`` or ``False`` )rrr?s rrVzKeventDescriptor.is_directoryas!!!rcb tj|jy#t$rYywxYw)zQ Closes the file descriptor associated with a kevent descriptor. N)rr\rHOSErrorr?s rr\zKeventDescriptor.closejs)  HHTWW    s " ..c2|j|jfSr)rrVr?s rkeyzKeventDescriptor.keyss 4,,--rc4|j|jk(Srrr^s r__eq__zKeventDescriptor.__eq__wxx:>>))rc4|j|jk7Srrr^s r__ne__zKeventDescriptor.__ne__zrrc,t|jSr)hashrr?s r__hash__zKeventDescriptor.__hash__}sDHH~rchdt|jd|jd|jdS)N)typergrrVr?s r__repr__zKeventDescriptor.__repr__s44:&&'wtyym?4K\K\J]]^__rN)rgrhrirjrArkrHrrerVr\rrrrrrlrrrTrT5s  ""..**`rrTcteZdZdZeej ffd ZdZdZ dZ dZ dZ dZ d d Zd Zd ZxZS) KqueueEmittera kqueue(2)-based event emitter. .. ADMONITION:: About ``kqueue(2)`` behavior and this implementation ``kqueue(2)`` monitors file system events only for open descriptors, which means, this emitter does a lot of book-keeping behind the scenes to keep track of open descriptors for every entry in the monitored directory tree. This also means the number of maximum open file descriptors on your system must be increased **manually**. Usually, issuing a call to ``ulimit`` should suffice:: ulimit -n 1024 Ensure that you pick a number that is larger than the number of files you expect to be monitored. ``kqueue(2)`` does not provide enough information about the following things: * The destination path of a file or directory that is renamed. * Creation of a file or directory within a directory; in this case, ``kqueue(2)`` only indicates a modified event on the parent directory. Therefore, this emitter takes a snapshot of the directory tree when ``kqueue(2)`` detects a change on the file system to be able to determine the above information. :param event_queue: The event queue to fill with events. :param watch: A watch object representing the directory to monitor. :type watch: :class:`watchdog.observers.api.ObservedWatch` :param timeout: Read events blocking timeout (in seconds). :type timeout: ``float`` :param stat: stat function. See ``os.stat`` for details. ct||||tj|_t j |_t|_ |ffd }t|j|j||_ y)Ncb|}|j|t|j|Sr)_register_keventrst_mode)rr@ stat_infostats r custom_statz+KqueueEmitter.__init__..custom_stats-T I  ! !$ 0A0A(B C r) recursiver)superrAr"kqueue_kqr<RLockr>r3r6rr is_recursive _snapshot)r@ event_queuewatchtimeoutrr __class__s ` rrAzKqueueEmitter.__init__se eW5==?__& 01#'  + JJ%"4"4; rc |jj||y#t$rL}|jtjk(rn$|jtj k(rnYd}~yYd}~yd}~wwxYw)a4 Registers a kevent descriptor for the given path. :param path: Path for which a kevent descriptor will be created. :param is_directory: ``True`` if the path refers to a directory; ``False`` otherwise. :type is_directory: ``bool`` N)r6rWrerrnoENOENT EOPNOTSUPP)r@rrVes rrzKqueueEmitter._register_keventsh     ! !$ 5 ww%,,&$E,,,  ' s A4=A//A4c:|jj|y)z Convenience function to close the kevent descriptor for a specified kqueue-monitored path. :param path: Path for which the kevent descriptor will be closed. N)r6rZrLs r_unregister_keventz KqueueEmitter._unregister_kevents   &rctj|||jtk(r'|j |j |j y|jtk(rB|j|j |j |j|j y|jtk(r|j|j yy)z Handles queueing a single event object. :param event: An instance of :class:`watchdog.events.FileSystemEvent` or a subclass. N) r queue_event event_typerrsrc_pathrVrr dest_pathr)r@events rrzKqueueEmitter.queue_events   u-   1 1  ! !%..%2D2D E   !1 1  # #ENN 3  ! !%//53E3E F   !3 3  # #ENN 34rc#fK|jj|j}|j}t |r(|j ||j ||D]}|yt|r(|j rt|yt|yt|rX|j r=|jjs|jj|k(rt|yt|yyt|r(|j rt|yt|yyw)a Generate events from the kevent list returned from the call to :meth:`select.kqueue.control`. .. NOTE:: kqueue only tells us about deletions, file modifications, attribute modifications. The other events, namely, file creation, directory modification, file rename, directory rename, directory creation, etc. are determined by comparing directory snapshots. N)r6rIidentrr1_gen_renamed_eventsrVr.r rr+rrr&r r )r@r% ref_snapshot new_snapshotr_rrs r_gen_kqueue_eventsz KqueueEmitter._gen_kqueue_eventss&&11#))< ?? c?11*11<     $&&&x00'11  &&::**djjoo.I +844'11/J_&&%h//&x00 sD/D1cRttjj|S)zR Helper to generate a DirModifiedEvent on the parent of src_path. )r rrdirname)r@rs r_parent_dir_modifiedz"KqueueEmitter._parent_dir_modified;s  9::rc#HK |j|}|j |}|t|}|rt||}|nt|||j||j||r-|jjrt||D]}|yyy|rt|n t ||j|y#t$r;|rt|t|Yyt |t |YywxYww)a Compares information from two directory snapshots (one taken before the rename operation and another taken right after) to determine the destination path of the file system object renamed, and yields the appropriate events to be queued. N)inodeKeyErrorrr r r rrr rrrrr) r@rrVrrf_inoderr sub_events rrz!KqueueEmitter._gen_renamed_eventsAs1 "((2G!%%g.  %i0I%h : $Xy99++H5 5++I6 6 ::**%>x%S( '(+ %h//&x00++H5 5S %h//%h//  'x00&x00  s4D"CCD"%DD"DD"DD"cl|jj|jjt|S)z Reads events from a call to the blocking :meth:`select.kqueue.control()` method. :param timeout: Blocking timeout for reading events. :type timeout: ``float`` (seconds) )rcontrolr6rC MAX_EVENTS)r@rs r _read_eventszKqueueEmitter._read_eventsus)xx 1 1 9 9:wOOrc|j5 |j|}|jt|jj |jj }|j}||_||z }|jD]}|jt||jD]}|jt||jD]}|jt||D]+} |j| ||D]} |j| - dddy#t $r(} | j"t"j$k7rYd} ~ 5d} ~ wwxYw#1swYyxYw)z Queues events by reading them from a call to the blocking :meth:`select.kqueue.control()` method. :param timeout: Blocking timeout for reading events. :type timeout: ``float`` (seconds) N)r>rreverserrrrr dirs_createdrr files_createdr files_modifiedrrrrEBADF) r@r event_listrr diff_eventsdirectory_created file_created file_modifiedr%rrs r queue_eventszKqueueEmitter.queue_eventssuZZ  !..w7 ""$ 1JJOOTZZ%<%<   $~~ !-*\9 *5)A)AI%$$_5F%GHI$/$=$=EL$$%5l%CDE%0%?%?GM$$%6}%EFG&0C!%!8!8\<"0((/00/  : 77ekk)* ;  s5E+DD7-E+7 E(E#E+#E((E++E4c|j5|jj|jj dddy#1swYyxYwr)r>r6r]rr\r?s ron_thread_stopzKqueueEmitter.on_thread_stops> ZZ     # # % HHNN    s 5A  Ar)rgrhrirjrrrrArrrrrrrrr __classcell__rs@rrrsL*Z+B ()V'4*)1V; 26h P)Vrrc&eZdZdZeffd ZxZS)KqueueObserverzi Observer thread that schedules watching directories and dispatches calls to event handlers. c0t|t|y)N) emitter_classr)rrAr)r@rrs rrAzKqueueObserver.__init__s }gFr)rgrhrirjrrArrs@rrrs 8GGrr)< __future__rrros.pathr"r<rrwatchdog.eventsrrrrr r r r r rrrwatchdog.observers.apirrrrwatchdog.utilsrwatchdog.utils.dirsnapshotrr O_EVTONLY is_darwinrtO_RDONLY O_NONBLOCKKQ_FILTER_VNODErv KQ_EV_ADD KQ_EV_ENABLE KQ_EV_CLEARrwr#r*r)r- KQ_NOTE_LINKr0KQ_NOTE_REVOKErxrr&r+r.r1r3rTrrrlrrrsi #2h      qp#8   8&[[2==8++''&*=*==@R@RR            3. O . . XXvL`L`^lLl^ G\Gr