o Pa@[…3ã@söddlZddlZddlZddlZddlZddlZddlmZddlZ ddl Z dZ dZ dZ e e¡Ze dgd¢¡Ze e ¡Zeeej dd ¡ƒƒZGd d „d eƒZGd d „d eƒZGdd„deƒZGdd„deƒZGdd„deƒZ Gdd„deƒZ!dS)éN)ÚEINTRéZiIII)Z IN_Q_OVERFLOWZ IN_UNMOUNTÚ_INOTIFY_EVENT)ÚwdÚmaskZcookieÚlenÚDEBUGÚ0c@s eZdZdS)ÚEventTimeoutExceptionN)Ú__name__Ú __module__Ú __qualname__©rrú4usr/lib/python3.10/site-packages/inotify/adapters.pyr (sr cseZdZ‡fdd„Z‡ZS)ÚTerminalEventExceptioncstt|ƒ |¡||_dS©N)ÚsuperrÚ__init__Úevent)ÚselfÚ type_namer©Ú __class__rrr-s zTerminalEventException.__init__)r r r rÚ __classcell__rrrrr,src@s|eZdZgefdd„Zdd„Zdd„Zejj fdd„Z dd d „Z dd d „Z dd„Z dd„Zdddefdd„Zedd„ƒZdS)ÚInotifycCsl||_i|_i|_d|_tj ¡|_t  d|j¡t   ¡|_ |j   |jt j¡d|_|D]}| |¡q,dS)NózInotify handle is (%d).)Ú_Inotify__block_durationÚ_Inotify__watchesÚ_Inotify__watches_rÚ_Inotify__bufferÚinotifyÚcallsZ inotify_initÚ_Inotify__inotify_fdÚ_LOGGERÚdebugÚselectÚepollÚ_Inotify__epollÚregisterÚPOLLINÚ_Inotify__last_success_returnÚ add_watch)rÚpathsÚblock_duration_sÚpathrrrr3s   ÿzInotify.__init__cCs$z| ¡WSty|jYSw)z=Allow the block-duration to be an integer or a function-call.)rÚ TypeError©rrrrZ__get_block_durationDs    þzInotify.__get_block_durationcCst d¡t |j¡dS)NzCleaning-up inotify.)r#r$ÚosÚcloser"r0rrrÚ__del__Ms zInotify.__del__cCsht d|¡||jvrt d|¡dS| d¡}tj |j||¡}t d||¡||j|<||j |<|S)NzAdding watch: [%s]z Path already being watched: [%s]Úutf8zAdded watch (%d): [%s]) r#r$rÚwarningÚencoder r!Zinotify_add_watchr"r)rZ path_unicoderZ path_bytesrrrrr+Qs      zInotify.add_watchFcCs<|j |¡}|dur dSt d||¡|j|=| |¡dS)zÙRemove our tracking information and call inotify to stop watching the given path. When a directory is removed, we'll just have to remove our tracking since inotify already cleans-up the watch. Nz*Removing watch for watch-handle (%d): [%s])rÚgetr#r$Úremove_watch_with_id)rr.Ú superficialrrrrÚ remove_watchgs ÿzInotify.remove_watchcCs4|j|=|durt d|¡tj |j|¡dSdS)NFz%Removing watch for watch-handle (%d).)rr#r$r r!Zinotify_rm_watchr")rrr9rrrr8xs  ýzInotify.remove_watch_with_idcCsZg}tjj ¡D]\}}||@r| |¡||8}|dkrnq|dks+Jd|fƒ‚|S)Nrz*We could not resolve all event-types: (%d))r Ú constantsZ MASK_LOOKUPÚitemsÚappend)rÚ event_typeÚnamesÚbitÚnamerrrÚ_get_event_names€s € ÿzInotify._get_event_namesccst |d¡}|s dS|j|7_ t|jƒ}|tkr#t d¡dS|jdt…}t t |¡}t |Ž}|  |j ¡}t d  |¡¡t|j}||krMdS|jt|…} |  d¡} |j|d…|_|j |j¡} | durx|  d¡} ||| | fVt|jƒ} | tkrƒdSq)z1Handle a series of events coming-in from inotify.iNrzNot enough bytes for a header.zEvents received in stream: {}ór4)r1ÚreadrrÚ_STRUCT_HEADER_LENGTHr#r$ÚstructÚunpackÚ_HEADER_STRUCT_FORMATrrBrÚformatÚrstriprr7rÚdecode)rrÚbÚlengthZ peek_sliceZ header_rawÚheaderÚ type_namesZ event_lengthÚfilenameZfilename_bytesr.Zfilename_unicodeZ buffer_lengthrrrÚ_handle_inotify_events@€   þ     ÛzInotify._handle_inotify_eventNTc csVd|_t ¡} | ¡}z|j |¡}Wn-tyB}z!|jtkr#‚|dur8t ¡|} | |kr8WYd}~dSWYd}~qd}~ww|D]M\} } | | ¡} t   d  | ¡¡|  | ¡D]6\} }}}t ¡}| |||f}|D] }|dur„|||ƒdur„||f|_dS||vrt ||ƒ‚qm|Vq[qE|dur£t ¡|} | |kr£dS|durªdVq )zˆYield one event after another. If `timeout_s` is provided, we'll break when no event is received for that many seconds. NTzEvents received from epoll: {}F)r*ÚtimeÚ_Inotify__get_block_durationr'ÚpollÚIOErrorÚerrnorrBr#r$rIrQr)rZ timeout_sZ yield_nonesZfilter_predicateZterminal_eventsZ last_hit_sr-ÚeventsÚeZtime_since_event_sÚfdr>r?rNrOr.rPrrrrÚ event_gen¿sR€    €÷ ÿ    ÿó ÑzInotify.event_gencCó|jSr)r*r0rrrÚlast_success_returnýózInotify.last_success_return©F)r r r Ú_DEFAULT_EPOLL_BLOCK_DURATION_SrrSr3r r;Ú IN_ALL_EVENTSr+r:r8rBrQÚ_DEFAULT_TERMINAL_EVENTSrZÚpropertyr\rrrrr2s   1 þ>rc@s4eZdZejjefdd„Zd dd„Ze dd„ƒZdS) Ú _BaseTreecCs.|tjjBtjjBtjjB|_t|d|_dS)N)r-)r r;ÚIN_ISDIRÚ IN_CREATEZ IN_DELETEÚ_maskrÚ_i)rrr-rrrrsÿþýz_BaseTree.__init__Fc ks&|jjd i|¤ŽD]†}|dur|\}}}}|jtjj@rtj ||¡}|jtjj @s2|jtjj @rLtj  |¡dus>|durLt   d|¡|j ||j¡|jtjj@rbt   d|¡|jj|ddn+|jtjj@rxt   d|¡|jj|ddn|jtjj @rt   d|¡|j ||j¡|Vq dS) aJThis is a secondary generator that wraps the principal one, and adds/removes watches as directories are added/removed. If we're doing anything funky and allowing the events to queue while a rename occurs then the folder may no longer exist. In this case, set `ignore_missing_new_folders`. NTFz^A directory has been created. We're adding a watch on it (because we're being recursive): [%s]zlA directory has been removed. We're being recursive, but it would have automatically been deregistered: [%s])r9zlA directory has been renamed. We're being recursive, but it would have automatically been deregistered: [%s]z^A directory has been renamed. We're adding a watch on it (because we're being recursive): [%s]r)rgrZrr r;rdr1r.ÚjoinZ IN_MOVED_TOreÚexistsr#r$r+rfZ IN_MOVED_FROMr:) rZignore_missing_new_foldersÚkwargsrrNrOr.rPÚ full_pathrrrrZsB€   ÿ þþýýþÔz_BaseTree.event_gencCr[r)rgr0rrrr Fr]z_BaseTree.inotifyNr^) r r r r r;r`r_rrZrbrrrrrcs ÿ 7rccó2eZdZdZejjef‡fdd„ Zdd„Z ‡Z S)Ú InotifyTreezRecursively watch a path.cs(tt|ƒj||d||_| |¡dS©N)rr-)rrmrZ_InotifyTree__root_pathÚ_InotifyTree__load_tree)rr.rr-rrrrNszInotifyTree.__init__cCsŽt d|¡g}|g}|r8|d}|d=| |¡t |¡D]}tj ||¡}tj |¡dur0q| |¡q|s |D] }|j  ||j ¡q:dS)Nz$Adding initial watches on tree: [%s]rF) r#r$r=r1Úlistdirr.rhÚisdirrgr+rf)rr.r,ÚqÚ current_pathrPÚentry_filepathrrrZ __load_treeVs   õ ÿzInotifyTree.__load_tree) r r r Ú__doc__r r;r`r_rrorrrrrrmKs ÿrmcrl)Ú InotifyTreesz'Recursively watch over a list of trees.cs"tt|ƒj||d| |¡dSrn)rrvrÚ_InotifyTrees__load_trees)rr,rr-rrrrpszInotifyTrees.__init__cCs˜t dd tt|ƒ¡¡g}|}|r=|d}|d=| |¡t |¡D]}tj ||¡}tj  |¡dur5q#| |¡q#|s|D] }|j   ||j ¡q?dS)Nz%Adding initial watches on trees: [%s]ú,rF) r#r$rhÚmapÚstrr=r1rpr.rqrgr+rf)rr,ÚfoundrrrsrPrtr.rrrZ __load_treesvs   õÿzInotifyTrees.__load_trees) r r r rur r;r`r_rrwrrrrrrvms ÿrv)"Úloggingr%r1rFÚ collectionsrRrVrZinotify.constantsr Z inotify.callsr_rHraÚ getLoggerr r#Ú namedtuplerÚcalcsizerEÚboolÚintÚenvironr7Z _IS_DEBUGÚ Exceptionr rÚobjectrrcrmrvrrrrÚs4  þ QI"