zcnddlZddlmZddlmZddlmZejeZ GddeZ dS)N) BaseThread) DelayedQueue)Inotifyc<eZdZdZdZd dZdZdZdZdZ d Z d S) InotifyBufferzA wrapper for `Inotify` that holds events for `delay` seconds. During this time, IN_MOVED_FROM and IN_MOVED_TO events are paired. g?Fctj|t|j|_t |||_|dSN)r__init__rdelay_queuer_inotifystart)selfpath recursives Alib/python3.11/site-packages/watchdog/observers/inotify_buffer.pyr zInotifyBuffer.__init__ sFD!!!"4:.. i00  c4|jS)zReturns a single event or a tuple of from/to events in case of a paired move event. If this buffer has been closed, immediately return None. )r getrs r read_eventzInotifyBuffer.read_event&s {   rcj|j|jdSr )r closer rs ron_thread_stopzInotifyBuffer.on_thread_stop-s0  rcV||dSr )stopjoinrs rrzInotifyBuffer.close1s   rcg}|D]ˊtdfd}jrt|D]\}}||r |f||<nd|j|}|||ftd|||S)zGroup any matching move eventsz in-event %sc^t|t o|jo|jjkSr ) isinstancetuple is_moved_fromcookie)event inotify_events rmatching_from_eventz8InotifyBuffer._group_events..matching_from_event;s7&ue444A9LA!LM,@@BrNz'could not find matching move_from event)loggerdebug is_moved_to enumerater removeappend)r event_listgroupedr&indexr$ from_eventr%s @r _group_eventszInotifyBuffer._group_events5s' . .M LL 6 6 6 B B B B B( .$-g$6$6 6 6LE5**511*/)? "&!3!34G!H!HJ!6 M'BCCCC %NOOO}555}----rcd}|r|s|j}||}|D]m}t |t  o|j}|j||t |t s|j r|j |jj krd}n|r|dSdSdSdS)zRead event from `inotify` and add them to `queue`. When reading a IN_MOVE_TO event, remove the previous added matching IN_MOVE_FROM event and add them back to the queue as a tuple. FTN) should_keep_runningr read_eventsr1r r!r"r putis_delete_selfsrc_pathr)r deleted_selfinotify_eventsgrouped_eventsr%r s rrunzInotifyBuffer.runQs  &&(( ( (!]6688N!//??N!/ ( ( &}e<<<\A\  u555!-77(MrFs"%%%%%%555555000000  8 $ $I(I(I(I(I(JI(I(I(I(I(r