o hR @sddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddlm Z m Z m Z ddl mZddlmZddlmZerJddlmZedZeedr^eed r^eed shd ejZeeeje e e e d d d efZeje e e d d d efZeje d d defZGdddZeddejej ej!ej"ej#ej$ej%ej&ej'ej(ej)g Z*Gdddej+Z,e-e,Z.dZ/e/e.dZ0GdddZ1GdddZ2dS)) annotationsN)c_char_pc_intc_uint32)reduce) TYPE_CHECKING)UnsupportedLibcError) Generator inotify_initinotify_add_watchinotify_rm_watchz Unsupported libc version found: T) use_errnoc@seZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Ze e BZd ZdZdZdZdZdZdZdZdZeddeeeeeee e e e e eg ZdZdZdS)InotifyConstants @iii i@iiiii i@lcC||BSNxyrrP/var/www/vscode/kcb/lib/python3.10/site-packages/watchdog/observers/inotify_c.pyBzInotifyConstants.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_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!sRrcCrrrrrrrr Zr!r c@s2eZdZdZdefdefdefdefdeffZdS)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_rrrrr>ks r>rrc@seZdZdZdddd:d dZed;ddZedddZ d?ddZ d@d d!Z dAd"d#Z dAd$d%Zd>d&d'Zed(dBd+d,Zd>d-d.ZdCd0d1ZdDd2d3Zed>d4d5ZedEd8d9ZdS)FInotifyaLinux 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_maskpathbytesrGboolrH int | NonereturnNonecst}|dkr t|_t_d_d_t \_ _ t tdrHt_jjtjjj tjd fdd }|_n d fd d }|_i_i_|_|durat}|_|_t j|rvj|||d n||i_dS) NFTpollrMrKcstfddjDS)Nc3s|] \}}|jkVqdSr _inotify_fd).0fd_selfrr sz4Inotify.__init__..do_poll..)any_pollerrPrrVrrdo_pollsz!Inotify.__init__..do_pollcs$tjjggg}j|dvSNr)selectrR_kill_r)resultrVrr do_selectsz#Inotify.__init__..do_select)rGrMrK)r rF _raise_errorrR threadingLock_lock_closed _is_readingospiper^_kill_whasattrr]rPrZregisterPOLLIN_check_inotify_fd _wd_for_path _path_for_wd_pathWATCHDOG_ALL_EVENTS _event_mask _is_recursiverIisdir_add_dir_watch _add_watch_moved_from_events)rWrIrGrH inotify_fdr[r`rrVr__init__s6      zInotify.__init__intcC|jS)z)The event mask for this inotify instance.)rsrVrrrrHzInotify.event_maskcCr|)z.The path associated with the inotify instance.)rqrVrrrrIr}z Inotify.pathcCr|)z0Whether we are watching directories recursively.)rtrVrrr is_recursiver}zInotify.is_recursivecCr|)z9The file descriptor associated with the inotify instance.rQrVrrrrTr}z Inotify.fdcCs i|_dS)z)Clear cached records of MOVED_FROM eventsN)rxrVrrrclear_move_recordss zInotify.clear_move_recordsdestination_event InotifyEvent bytes | NonecCs|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)rArxsrc_path)rWrrrrsource_for_moves zInotify.source_for_moveeventcCs||j|j<dS)z]Save this event as the source event for future MOVED_TO events to reference. N)rxrA)rWrrrrremember_move_from_eventsz Inotify.remember_move_from_eventcCs:|j|||jWddS1swYdS)zeAdds a watch for the given path. :param path: Path to begin monitoring. N)rerwrs)rWrIrrr add_watchs"zInotify.add_watchcCsh|j'|j|}|j|=t|j|dkr"tWddSWddS1s-wYdS)zRemoves a watch for the given path. :param path: Path string for which the watch will be removed. rON)reropoprpr rRrFrb)rWrIr?rrr remove_watchs  "zInotify.remove_watchcCs|j@|js3d|_|j|jvr|j|j}t|j||jr't|j dn| WddSWddSWddS1sFwYdS)z?Closes the inotify instance and removes all associated watches.T!N) rerfrqror rRrgrhwriterj_close_resources)rWr?rrrcloses     "z Inotify.close)event_buffer_sizerlist[InotifyEvent]c sd fdd }d} zWjjrgWd WSd_Wd n1s)wYr9tj|}jd _jrQgWd WSWd n1s[wYWn'ty}z|j t j kruWYd }~q |j t j krgWYd }~Sd }~ww jg}t |D]\}}}} |d krqj|} | rtj| | n| } t|||| | } | jr| nb| jr#| } | jvrj| }j| =|j| j<| jj|<jrjD]%}|| tjjrj|}|| | j}|j|<|j|<qtj| | } t|||| | } | jr9j|}j||kr9j|=| | jre| j!re| j"rez #| j$Wn ty]Yqw|%|| qWd |S1srwY|S) z*Reads events from inotify and yields them.rrJrMrc sg}t|D]a\}}}|D]6}tt'tj||}|j}t |t j t j Bd||}| |Wdn1s?wYq|D] } tj|| }jtj|} t | t j d| |}| |qGq|Sr\)rhwalk contextlibsuppressOSErrorrIjoinrwrsrrr-r9appendrodirname) reventsrootdirnames filenamesr full_pathwd_direfilename wd_parent_dirrVrr_recursive_simulates:      z0Inotify.read_events.._recursive_simulateTNFrO)rrJrMr)&rerfrgrnrhreadrRrrerrnoEINTREBADFrF_parse_event_bufferrprIrr is_moved_fromr is_moved_torrorr~copy startswithsepencoderreplace is_ignoredr is_directory is_createrwrsextend)rWrr event_bufferr event_listr?r@rArCwd_pathr inotify_event move_src_pathmoved_wdrq _move_to_pathrIrrVr read_events s                33zInotify.read_eventscCs(t|jt|jt|jdSr)rhrrRr^rjrVrrrrs  zInotify._close_resourcesr@c 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) rhrIrurrENOTDIRstrerrorrwrrislink) rWrIr@rGrrrUrrrrrrvs   zInotify._add_dir_watchcCs6t|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. rO)r rRrFrbrorp)rWrIr@r?rrrrws    zInotify._add_watchcCsRt}|tjkrttjd|tjkrttjd|tjkr't|t|dS)z#Raises errors for inotify failures.zinotify watch limit reachedzinotify instance limit reachedN) ctypes get_errnorENOSPCrEMFILEEACCESrhr)errrrrrbs     zInotify._raise_errorr&Generator[tuple[int, int, int, bytes]]ccs|d}|dt|krZdId?d@ZedMdBdCZdNdDdEZ dFS)Ora 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. r?r{r@rArCrJrrMrNcCs"||_||_||_||_||_dSr)_wd_mask_cookie_name _src_path)rWr?r@rArCrrrrrzs  zInotifyEvent.__init__cCr|r)rrVrrrrzInotifyEvent.src_pathcCr|r)rrVrrrr?rzInotifyEvent.wdcCr|r)rrVrrrr@rzInotifyEvent.maskcCr|r)rrVrrrrArzInotifyEvent.cookiecCr|r)rrVrrrrCrzInotifyEvent.namerKcC|jtj@dkSr\)rrr&rVrrr is_modifyzInotifyEvent.is_modifycCrr\)rrr(rVrrris_close_writerzInotifyEvent.is_close_writecCrr\)rrr)rVrrris_close_nowriterzInotifyEvent.is_close_nowritecCrr\)rrr*rVrrris_open rzInotifyEvent.is_opencCrr\)rrr%rVrrr is_accessrzInotifyEvent.is_accesscCrr\)rrr.rVrrr is_deleterzInotifyEvent.is_deletecCrr\)rrr/rVrrris_delete_selfrzInotifyEvent.is_delete_selfcCrr\)rrr-rVrrrrrzInotifyEvent.is_createcCrr\)rrr+rVrrrrrzInotifyEvent.is_moved_fromcCrr\)rrr,rVrrrr"rzInotifyEvent.is_moved_tocCrr\)rrr1rVrrris_move&rzInotifyEvent.is_movecCrr\)rrr0rVrrr is_move_self*rzInotifyEvent.is_move_selfcCrr\)rrr'rVrrr is_attrib.rzInotifyEvent.is_attribcCrr\)rrr4rVrrrr2rzInotifyEvent.is_ignoredcCs|jp |jp |jtj@dkSr\)rrrrr9rVrrrr6szInotifyEvent.is_directory"tuple[bytes, int, int, int, bytes]cCs|j|j|j|j|jfSr)rrrrrrVrrrkey=szInotifyEvent.keyrobjectcCst|tstS|j|jkSr isinstancerNotImplementedrrWrrrr__eq__A  zInotifyEvent.__eq__cCst|tstS|j|jkSrrrrrr__ne__FrzInotifyEvent.__ne__cCs t|jSr)hashrrVrrr__hash__Ks zInotifyEvent.__hash__strcCsJg}ttD]}|dr|dvrtt|}||@r||qd|S)NIN_>r1r;|)dirrrgetattrrr)r@maskscc_valrrr_get_mask_stringNs    zInotifyEvent._get_mask_stringcCsFdt|jd|jd|jd||jd|jdt|j d S)N) typer"rr?rr@rArhfsdecoderCrVrrr__repr__Xs  zInotifyEvent.__repr__N) r?r{r@r{rAr{rCrJrrJrMrNrrra)rMr)rrrMrK)r@r{rMr)rMr)!r"r#r$rDrzrrr?r@rArCrrrrrrrrrrrrrrrrrrrrrrrrrrrsf                           r)3 __future__rrr ctypes.utilrrhr]rrcrrr functoolsrtypingrwatchdog.utilsrcollections.abcr CDLLlibcrkrerror CFUNCTYPEr r r rr&r'r+r,r-r.r/r6r(r)r*rr Structurer>sizeof EVENT_SIZEDEFAULT_NUM_EVENTSrrFrrrrrs\       8  P