a
«°i” ã @ s* d gZ ddlmZmZ G dd „ d eƒZdS )ÚWatcheré )ÚGioÚGLibc @ sd e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dS )r c C s" || _ || _i | _i | _g | _d S ©N)Ú _callbackÚ_timeoutÚ _monitorsÚ _timeoutsÚ_blocked)ÚselfÚcallbackÚtimeout© r ú9/usr/lib/python3.9/site-packages/firewall/core/watcher.pyÚ__init__ s
zWatcher.__init__c C s: t j |¡}| t jjd ¡| j|< | j| d| j¡ d S ©NZchanged) r ÚFileÚ new_for_pathZmonitor_directoryÚFileMonitorFlagsÚNONEr ÚconnectÚ_file_changed_cb)r Z directoryÚgfiler r r Ú
add_watch_dir" s
ÿ
zWatcher.add_watch_dirc C s: t j |¡}| t jjd ¡| j|< | j| d| j¡ d S r ) r r r Z monitor_filer r r r r )r Úfilenamer r r r Úadd_watch_file( s
ÿ
zWatcher.add_watch_filec C s
| j ¡ S r )r Úkeys)r r r r Ú get_watches. s zWatcher.get_watchesc C s
|| j v S r ©r ©r r r r r Ú has_watch1 s zWatcher.has_watchc C s | j |= d S r r r r r r Ú remove_watch4 s zWatcher.remove_watchc C s || j vr| j |¡ d S r )r
Úappendr r r r Ú block_source7 s
zWatcher.block_sourcec C s || j v r| j |¡ d S r )r
Úremover r r r Úunblock_source; s
zWatcher.unblock_sourcec C s0 t | j ¡ ƒD ] }t | j| ¡ | j|= qd S r )Úlistr r r Ú
source_remover r r r Úclear_timeouts? s zWatcher.clear_timeoutsc C s || j vr| |¡ | j|= d S r )r
r r r r r r Ú_call_callbackD s
zWatcher._call_callbackc C s¦ | ¡ }|| jv r8|| jv r4t | j| ¡ | j|= d S |tjjksh|tjjksh|tjj ksh|tjj
kr¢|| jv rŠt | j| ¡ | j|= t | j | j
|¡| j|< d S r )Zget_parse_namer
r r r' r ZFileMonitorEventZCHANGEDZCREATEDZDELETEDZATTRIBUTE_CHANGEDZtimeout_add_secondsr r) )r ZmonitorZgio_fileZgio_other_fileZeventr r r r r I s&
ÿ
þ
ý
ÿzWatcher._file_changed_cbN)Ú__name__Ú
__module__Ú __qualname__r r r r r r! r# r% r( r) r r r r r r s N)Ú__all__Z
gi.repositoryr r Úobjectr r r r r Ú s