3 Y�j��@s*dgZddlmZmZGdd�de�ZdS)�Watcher�)�Gio�GLibc@sdeZdZdd�Zdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z dd�Z dd�Zdd�Zdd�Z dS)rcCs"||_||_i|_i|_g|_dS)N)� _callback�_timeout� _monitors� _timeouts�_blocked)�self�callbackZtimeout�r�/usr/lib/python3.6/watcher.py�__init__s zWatcher.__init__cCs:tjj|�}|jtjjd�|j|<|j|jd|j�dS)N�changed) r�File�new_for_pathZmonitor_directory�FileMonitorFlags�NONEr�connect�_file_changed_cb)r Z directory�gfilerrr � add_watch_dir"szWatcher.add_watch_dircCs:tjj|�}|jtjjd�|j|<|j|jd|j�dS)Nr) rrrZmonitor_filerrrrr)r �filenamerrrr �add_watch_file(szWatcher.add_watch_filecCs |jj�S)N)r�keys)r rrr �get_watches.szWatcher.get_watchescCs ||jkS)N)r)r rrrr � has_watch1szWatcher.has_watchcCs|j|=dS)N)r)r rrrr �remove_watch4szWatcher.remove_watchcCs||jkr|jj|�dS)N)r �append)r rrrr �block_source7s zWatcher.block_sourcecCs||jkr|jj|�dS)N)r �remove)r rrrr �unblock_source;s zWatcher.unblock_sourcecCs4x.t|jj��D]}tj|j|�|j|=qWdS)N)�listrrr� source_remove)r rrrr �clear_timeouts?szWatcher.clear_timeoutscCs ||jkr|j|�|j|=dS)N)r rr)r rrrr �_call_callbackDs zWatcher._call_callbackcCs�|j�}||jkr8||jkr4tj|j|�|j|=dS|tjjksh|tjjksh|tjj ksh|tjj kr�||jkr�tj|j|�|j|=tj|j|j |�|j|<dS)N)Zget_parse_namer rrr#rZFileMonitorEventZCHANGEDZCREATEDZDELETEDZATTRIBUTE_CHANGEDZtimeout_add_secondsrr%)r ZmonitorZgio_fileZgio_other_fileZeventrrrr rIs zWatcher._file_changed_cbN)�__name__� __module__�__qualname__rrrrrrrr!r$r%rrrrr rsN)�__all__Z gi.repositoryrr�objectrrrrr �s