o *ήcCK @sjddlZddlZddlZddlZddlZddlZddlmZddlmZm Z m Z ddl m Z e dZeedrBeedrBeedsIe dejejeee e d d defZejeee d d defZejed d defZGd d d Zed dejejejejejejejejejg ZGdddej Z!e"e!Z#dZ$e$e#dZ%GdddZ&GdddZ'dS)N)reduce)c_intc_char_pc_uint32)UnsupportedLibc inotify_initinotify_add_watchinotify_rm_watchz"Unsupported libc version found: %sT) use_errnoc@seZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d ZeeBZe e BZd ZdZdZdZdZdZdZdZdZeddeeeeeee e e e e eg ZdZdZdS)InotifyConstants @iii i@iiiii i@lcC||BSNxyrrC/tmp/pip-target-vg8gfxp4/lib/python/watchdog/observers/inotify_c.pyOzInotifyConstants.N)__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_CLOSEIN_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_NONBLOCKrrrrr -sTr cCrrrrrrrrerrc@s2eZdZdZdefdefdefdefdefgZdS)inotify_event_structa Structure 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)rr r!__doc__rrr_fields_rrrrr<rs r<rrc@seZdZdZdefddZeddZeddZed d Z ed d Z d dZ ddZ ddZ ddZddZddZefddZddZddZedd Zed!d"Zd#S)$Inotifya  Linux 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. FcCs|t}|dkr t||_t|_t|_t|_ ||_ ||_ ||_ t j|r2||||n|||t|_dS)N)rrD _raise_error _inotify_fd threadingLock_lockdict _wd_for_path _path_for_wd_path _event_mask _is_recursiveospathisdir_add_dir_watch _add_watch_moved_from_events)selfrR recursive event_mask inotify_fdrrr__init__s    zInotify.__init__cC|jS)z)The event mask for this inotify instance.)rOrWrrrrYzInotify.event_maskcCr\)z.The path associated with the inotify instance.)rNr]rrrrRr^z Inotify.pathcCr\)z0Whether we are watching directories recursively.)rPr]rrr is_recursiver^zInotify.is_recursivecCr\)z9The file descriptor associated with the inotify instance.)rGr]rrrfdr^z Inotify.fdcCs t|_dS)z)Clear cached records of MOVED_FROM eventsN)rKrVr]rrrclear_move_recordss zInotify.clear_move_recordscCs|j|jvr |j|jjSdS)z The source path corresponding to the given MOVED_TO event. If the source path is outside the monitored directories, None is returned instead. N)r?rVsrc_path)rWdestination_eventrrrsource_for_moves zInotify.source_for_movecCs||j|j<dS)zf Save this event as the source event for future MOVED_TO events to reference. N)rVr?)rWeventrrrremember_move_from_eventsz Inotify.remember_move_from_eventcCs:|j|||jWddS1swYdS)zn Adds a watch for the given path. :param path: Path to begin monitoring. N)rJrUrO)rWrRrrr add_watchs"zInotify.add_watchcCsh|j'|j|}|j|=t|j|dkr"tWddSWddS1s-wYdS)z Removes a watch for the given path. :param path: Path string for which the watch will be removed. rEN)rJrLpoprMr rGrDrF)rWrRr=rrr remove_watchs  "zInotify.remove_watchc Cs|j5|j|jvr|j|j}t|j|zt|jWn ty'Yn wWddSWddS1s;wYdS)zQ Closes the inotify instance and removes all associated watches. N)rJrNrLr rGrQcloseOSError)rWr=rrrrjs     "z Inotify.closec sPfdd}d} z tj|}Wn'ty9}z|jtjkr&WYd}~q|jtjkr4gWYd}~Sd}~ww jg}t |D]\}}}} |dkrQqFj |} | r_tj | | n| } t |||| | } | jrr| nb| jrԈ| } | jvrňj| }j| =|j| j<| jj |<jrňjD]&\}}|| tj jrĈj|}|| | j}|j|<|j |<qtj | | } t |||| | } | jrj |}j||krj|=|| jr| jr| jrz | j!Wn ty YqFw|"|| qFWd|S1s!wY|S)z< Reads events from inotify and yields them. c sg}t|D]W\}}}|D],}z!tj||}|j}t|tjtj Bd||}| |Wqt y:Yqw|D] } tj|| }j tj |} t| tjd| |}| |q=q|SNr)rQwalkrRjoinrUrO InotifyEventr r*r7appendrkrLdirname) rbeventsrootdirnames filenamesrq full_pathwd_direfilename wd_parent_dirr]rr_recursive_simulates,   z0Inotify.read_events.._recursive_simulateNTrE)#rQreadrGrkerrnoEINTREBADFrJrD_parse_event_bufferrMrRrnro is_moved_fromrf is_moved_tordrLrbr_copyitems startswithsepencoderhreplace is_ignoredrp is_directory is_createrUrOextend)rWevent_buffer_sizer{ event_bufferrx event_listr=r>r?rAwd_pathrb inotify_event move_src_pathmoved_wdrN_wd _move_to_pathrRrr]r read_eventssz                  55zInotify.read_eventsc Cstj|sttjttj|||||r=t|D] \}}}|D]}tj ||}tj |r5q%|||q%qdSdS)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) rQrRrSrkr}ENOTDIRstrerrorrUrmrnislink) rWrRrXr>rsrt_rqrvrrrrT_s   zInotify._add_dir_watchcCs6t|j||}|dkrt||j|<||j|<|S)z Adds a watch for the given path to monitor events specified by the mask. :param path: Path to monitor :param mask: Event bit mask. rE)rrGrDrFrLrM)rWrRr>r=rrrrUvs    zInotify._add_watchcCsRt}|tjkrttjd|tjkrttjd|tjkr!dSt|t|)z5 Raises errors for inotify failures. zinotify watch limit reachedzinotify instance limit reachedN) ctypes get_errnor}ENOSPCrkEMFILEEACCESrQr)errrrrrFs     zInotify._raise_errorccs|d}|dt|krr?lengthrArrrrs zInotify._parse_event_bufferN)rr r!rBWATCHDOG_ALL_EVENTSr[propertyrYrRr_r`rardrfrgrirjDEFAULT_EVENT_BUFFER_SIZErrTrU staticmethodrFrrrrrrDs0        b rDc@s4eZdZdZddZeddZeddZedd Zed d Z ed d Z eddZ eddZ eddZ eddZeddZeddZeddZeddZeddZed d!Zed"d#Zed$d%Zed&d'Zed(d)Zed*d+Zd,d-Zd.d/Zd0d1Zed2d3Zd4d5Zd6S)7roa 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. cCs"||_||_||_||_||_dSr)r_mask_cookie_name _src_path)rWr=r>r?rArbrrrr[s  zInotifyEvent.__init__cCr\r)rr]rrrrbzInotifyEvent.src_pathcCr\r)rr]rrrr=rzInotifyEvent.wdcCr\r)rr]rrrr>rzInotifyEvent.maskcCr\r)rr]rrrr?rzInotifyEvent.cookiecCr\r)rr]rrrrArzInotifyEvent.namecC|jtj@dkSrl)rr r#r]rrr is_modifyzInotifyEvent.is_modifycCrrl)rr r%r]rrris_close_writerzInotifyEvent.is_close_writecCrrl)rr r&r]rrris_close_nowriterzInotifyEvent.is_close_nowritecCrrl)rr r"r]rrr is_accessrzInotifyEvent.is_accesscCrrl)rr r+r]rrr is_deleterzInotifyEvent.is_deletecCrrl)rr r,r]rrris_delete_selfrzInotifyEvent.is_delete_selfcCrrl)rr r*r]rrrrrzInotifyEvent.is_createcCrrl)rr r(r]rrrrrzInotifyEvent.is_moved_fromcCrrl)rr r)r]rrrrrzInotifyEvent.is_moved_tocCrrl)rr r/r]rrris_moverzInotifyEvent.is_movecCrrl)rr r-r]rrr is_move_selfrzInotifyEvent.is_move_selfcCrrl)rr r$r]rrr is_attrib rzInotifyEvent.is_attribcCrrl)rr r2r]rrrr rzInotifyEvent.is_ignoredcCs|jp |jp |jtj@dkSrl)rrrr r7r]rrrrs zInotifyEvent.is_directorycCs|j|j|j|j|jfSr)rrrrrr]rrrkeyszInotifyEvent.keycCs |j|jkSrrrWrrrr__eq__ zInotifyEvent.__eq__cCs |j|jkSrrrrrr__ne__ rzInotifyEvent.__ne__cCs t|jSr)hashrr]rrr__hash__#s zInotifyEvent.__hash__cCsNg}ttD]}|dr|dvrtt|}||@r||qd|}|S)NIN_)r9r.r/|)dirr rgetattrrprn)r>maskscc_val mask_stringrrr_get_mask_string&s    zInotifyEvent._get_mask_stringc Cs8||j}d}|t|j|j|j||jt|j fS)Nz5<%s: src_path=%r, wd=%d, mask=%s, cookie=%d, name=%s>) rr>typerrbr=r?rQfsdecoderA)rWrsrrr__repr__1s zInotifyEvent.__repr__N) rr r!rBr[rrbr=r>r?rArrrrrrrrrrrrrrrrrrrrrrrrrrosb                      ro)(rQr}rrHr ctypes.util functoolsrrrrwatchdog.utilsrCDLLlibchasattrr CFUNCTYPErr rr r#r$r(r)r*r+r,r4r%r Structurer<sizeof EVENT_SIZEDEFAULT_NUM_EVENTSrrDrorrrrs^     7  )