"dM 0ddlmZddlZddlZddlZddlZddlZddlZddlmZm Z m Z ddl m Z ddl mZejdZeedreedr eedsed ej$ej&e e ee d defZej&e e e d defZej&e d defZGd d Ze dej0ej2ej4ej6ej8ej:ej<ej>ej@ejBg Z"GddejFZ$ejJe$Z&dZ'e'e&dzzZ(GddZ)GddZ*y)) annotationsN)c_char_pc_intc_uint32)reduce)UnsupportedLibc inotify_initinotify_add_watchinotify_rm_watchz Unsupported libc version found: T) use_errnoceZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d ZeezZe e zZd ZdZdZdZdZdZdZdZdZedeeeeeee e e e e eg ZdZdZy)InotifyConstants @iii i@iiiii i@lc ||zSNxys >/usr/lib/python3/dist-packages/watchdog/observers/inotify_c.pyzInotifyConstants.Ss 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_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_NONBLOCKrr!rrr1sIIIN!GMKIINL 00Hk)GJMJJNNKHJ             M&JKr!rc ||zSrrrs rr r ks Qr!c2eZdZdZdefdefdefdefdefgZy)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)r"r#r$__doc__rrr_fields_rr!rrArA{s7  u  8   Hr!rArrceZdZdZdefdZedZedZedZ edZ dZ d Z d Z d Zd Zd ZefdZdZdZedZedZy)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. Fcvt}|dk(rtj||_t j |_i|_i|_||_ ||_ ||_ tjj|r|j|||i|_y|j!||i|_y)N)r rJ _raise_error _inotify_fd threadingLock_lock _wd_for_path _path_for_wd_path _event_mask _is_recursiveospathisdir_add_dir_watch _add_watch_moved_from_events)selfrX recursive event_mask inotify_fds r__init__zInotify.__init__s!^    "%^^%  %& 77==    i <#% OOD* -"$r!c|jS)z)The event mask for this inotify instance.)rUr]s rr_zInotify.event_maskr!c|jS)z.The path associated with the inotify instance.)rTrcs rrXz Inotify.pathszzr!c|jS)z0Whether we are watching directories recursively.)rVrcs r is_recursivezInotify.is_recursives!!!r!c|jS)z9The file descriptor associated with the inotify instance.)rNrcs rfdz Inotify.fdrdr!ci|_y)z)Clear cached records of MOVED_FROM eventsN)r\rcs rclear_move_recordszInotify.clear_move_recordss "$r!cz|j|jvr#|j|jjSy)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)rDr\src_path)r]destination_events rsource_for_movezInotify.source_for_moves9  # #t'>'> >**+<+C+CDMM Mr!c6||j|j<y)zf Save this event as the source event for future MOVED_TO events to reference. N)r\rD)r]events rremember_move_from_eventz Inotify.remember_move_from_events 16 -r!c~|j5|j||jdddy#1swYyxYw)zn Adds a watch for the given path. :param path: Path to begin monitoring. N)rQr[rU)r]rXs r add_watchzInotify.add_watchs4ZZ 4 OOD$"2"2 3 4 4 4s3<c|j5|jj|}|j|=t |j |dk(rt jdddy#1swYyxYw)z Removes a watch for the given path. :param path: Path string for which the watch will be removed. rLN)rQrRpoprSr rNrJrM)r]rXrBs r remove_watchzInotify.remove_watchseZZ '""&&t,B!!"% 0 0"5;$$&  ' ' 's AA,,A5c2|j5|j|jvr/|j|j}t|j| t j |jdddy#t$rYwxYw#1swYyxYw)zQ Closes the inotify instance and removes all associated watches. N)rQrTrRr rNrWcloseOSError)r]rBs rryz Inotify.closesZZ zzT...&&tzz2 !1!126 ))*      s*AB A>> B B  B  B  Bc fd}d} tjj|} j5g}tj|D]\}}}} |dk(rj|} | r tjj| | n| } t|||| | } | jrj| nv| j rij#| } | j$vrj$| }j$| =|j$| j&<| j&j|<j(rj$j+j-D]\}}|j/| tjj0j3zsAj$j5|}|j7| | j&}|j$|<|j|<tjj| | } t|||| | } | j8r:jj5|}j$||k(r j$|=|j;| j(sK| j<sY| j>sg jA| jB|jE||  ddd|S#t$rM}|jtj k(rYd}~|jtj k(rgcYd}~Sd}~wwxYw#t$rYwxYw#1swYSxYw)z< Reads events from inotify and yields them. c tg}tj|D] \}}}|D]~} tjj||} j | j }t |tjtjzd||}|j||D]|} tjj|| } jtjj|} t | tjd| |}|j|~|S#t$rYwxYwNr)rWwalkrXjoinr[rU InotifyEventrr-r:appendrzrRdirname) rmeventsrootdirnames filenamesr full_pathwd_direfilename wd_parent_dirr]s r_recursive_simulatez0Inotify.read_events.._recursive_simulates(F-/WWX-> %)h ' G $&GGLLw$? !%D>r!cB|jtjzdkDSr})rrr,rcs rrzInotifyEvent.is_moved_toszz,8881<xx=,,,,r!c4|j|jk7Srrrs r__ne__zInotifyEvent.__ne__Arr!c,t|jSr)hashrrcs r__hash__zInotifyEvent.__hash__DsDHH~r!cg}ttD]@}|jds|dvstt|}||zs0|j |Bdj |S)NIN_)r<r1r2|)dirrrgetattrrr)rCmaskscc_vals r_get_mask_stringzInotifyEvent._get_mask_stringGse%& $A||E"q1(  0!4%<LLO $xxr!cdt|jd|jd|jd|j |j d|j dtj|jd S)N) typer"rmrBrrCrDrWfsdecoderFrcs r__repr__zInotifyEvent.__repr__UssT ##$K /@dggYO**49956i }M[[+.a 1 r!N)!r"r#r$rGrarrmrBrCrDrFrrrrrrrrrrrrrrrrrrrrrrrr!rrrs ";;@@BB99;;;;@@;;??==99>>;;<<  NN--   r!r)+ __future__rr ctypes.utilrrWrrOrrr functoolsrwatchdog.utilsrCDLLlibchasattrr CFUNCTYPEr r r rr&r'r+r,r-r.r/r7r(r*r StructurerAsizeof EVENT_SIZEDEFAULT_NUM_EVENTSrrJrrr!rrs #  ,,*v{{4 n% 4, - 4+ ,