관리-도구
편집 파일: adapters.cpython-38.pyc
U *�e�3 � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlZ d dl Z dZ dZ dZ e �e�Ze�dddd d g�Ze�e �Zeeej�d d ���ZG d d� de�ZG dd� de�Z G dd� de �Z G dd� de �Z G dd� de �Z G dd� de �Z!dS )� N)�EINTR� ZiIII)Z IN_Q_OVERFLOWZ IN_UNMOUNT�_INOTIFY_EVENT�wd�mask�cookie�len�DEBUG�0c @ s e Zd ZdS )�EventTimeoutExceptionN)�__name__� __module__� __qualname__� r r �>/opt/hc_python/lib/python3.8/site-packages/inotify/adapters.pyr ( s r c s e Zd Z� fdd�Z� ZS )�TerminalEventExceptionc s t t| ��|� || _d S �N)�superr �__init__�event)�self� type_namer �� __class__r r r - s z TerminalEventException.__init__)r r r r � __classcell__r r r r r , s r c @ s| e Zd Zg efdd�Zdd� Zdd� Zejj fdd�Z dd d �Z dd d �Z dd� Z dd� Zdddefdd�Zedd� �ZdS )�Inotifyc C sl || _ i | _i | _d| _tj�� | _t� d| j� t � � | _ | j � | jt j� d | _|D ]}| �|� qXd S )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�pathr r r r 3 s zInotify.__init__c C s* z | � � W S tk r$ | j Y S X dS )z=Allow the block-duration to be an integer or a function-call.N)r � TypeError�r r r r Z__get_block_durationD s z Inotify.__get_block_durationc C s t �d� t�| j� d S )NzCleaning-up inotify.)r$ r% �os�closer# r1 r r r �__del__M s zInotify.__del__c C sh t �d|� || jkr&t �d|� d S |�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 )r Z path_unicoder Z path_bytesr r r r r, Q s zInotify.add_watchFc C s< | j �|�}|dkrdS t�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)r r/ � superficialr r r r � remove_watchg s �zInotify.remove_watchc C s0 | j |= |dkr,t�d|� tj�| j|� d S )NFz%Removing watch for watch-handle (%d).)r r$ r% r! r" Zinotify_rm_watchr# )r r r: r r r r9 x s z Inotify.remove_watch_with_idc C sZ g }t jj�� D ].\}}||@ r|�|� ||8 }|dkr q@q|dksVtd|f ��|S )Nr z*We could not resolve all event-types: (%d))r! � constantsZ MASK_LOOKUP�items�append�AssertionError)r � event_type�names�bit�namer r r �_get_event_names� s �zInotify._get_event_namesc c s t �|d�}|sdS | j|7 _t| j�}|tk rBt�d� dS | jdt� }t�t |�}t |� }| � |j �}t�d� |�� t|j }||k r�dS | jt|� } | �d�} | j|d� | _| j�|j�} | dk r�| �d�} ||| | fV t| j�} | tk r"�qq"dS )z1Handle a series of events coming-in from inotify.i Nz Not enough bytes for a header.z Events received in stream: {}� r5 )r2 �readr r �_STRUCT_HEADER_LENGTHr$ r% �struct�unpack�_HEADER_STRUCT_FORMATr rD r �format�rstripr r8 r �decode)r r �b�lengthZ peek_sliceZ header_raw�header� type_namesZ event_length�filenameZfilename_bytesr/ Zfilename_unicodeZ buffer_lengthr r r �_handle_inotify_event� s: � z Inotify._handle_inotify_eventNTc c s` d| _ t�� }| �� }z| j�|�}W n\ tk r� } z>|jtkrD� |dk rjt�� | } | |krjW Y ��q\W Y �qW 5 d}~X Y nX |D ]�\} } | �| �} t � d� | �� | � | �D ]p\} }}}t�� }| |||f}|D ]D}|dk �r |||�dk�r ||f| _ dS ||kr�t ||��q�|V q�q�|dk �rLt�� | } | |k�rL�q\|dkrdV qdS )z�Yield one event after another. If `timeout_s` is provided, we'll break when no event is received for that many seconds. Nz Events received from epoll: {}FT)r+ �time� _Inotify__get_block_durationr( �poll�IOError�errnor rD r$ r% rK rS r )r Z timeout_sZ yield_nonesZfilter_predicateZterminal_eventsZ last_hit_sr. �events�eZtime_since_event_s�fdr@ rA rP rQ r/ rR r r r r � event_gen� sF � � zInotify.event_genc C s | j S r )r+ r1 r r r �last_success_return� s zInotify.last_success_return)F)F)r r r � _DEFAULT_EPOLL_BLOCK_DURATION_Sr rU r4 r! r< � IN_ALL_EVENTSr, r; r9 rD rS �_DEFAULT_TERMINAL_EVENTSr\ �propertyr] r r r r r 2 s 1 � >r c @ s4 e Zd Zejjefdd�Zd dd�Ze dd� �ZdS ) � _BaseTreec C s. |t jjB t jjB t jjB | _t|d�| _d S )N)r. )r! r< �IN_ISDIR� IN_CREATEZ IN_DELETE�_maskr �_i)r r r. r r r r s ���z_BaseTree.__init__Fc k s( | j jf |�D �]}|dk �r |\}}}}|jtjj@ �r tj�||�}|jtjj @ sd|jtjj @ r�tj� |�dks||dkr�t � d|� | j �|| j� |jtjj@ r�t � d|� | j j|dd� nX|jtjj@ r�t � d|� | j j|dd� n,|jtjj @ �r t � d|� | j �|| j� |V qdS ) aJ This 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])r: zlA 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])rf r\ r r! r< rc r2 r/ �joinZ IN_MOVED_TOrd �existsr$ r% r, re Z IN_MOVED_FROMr; ) r Zignore_missing_new_folders�kwargsr rP rQ r/ rR � full_pathr r r r\ sB � �������z_BaseTree.event_genc C s | j S r )rf r1 r r r r! F s z_BaseTree.inotifyN)F) r r r r! r< r_ r^ r r\ ra r r r r rb s � 7rb c s2 e Zd ZdZejjef� fdd� Zdd� Z � Z S )� InotifyTreezRecursively watch a path.c s( t t| �j||d� || _| �|� d S �N)r r. )r rk r Z_InotifyTree__root_path�_InotifyTree__load_tree)r r/ r r. r r r r N s zInotifyTree.__init__c C s� t �d|� g }|g}|rn|d }|d= |�|� t�|�D ].}tj�||�}tj�|�dkr`q<|�|� q<q|D ]}| j� || j � qrd S )Nz$Adding initial watches on tree: [%s]r F) r$ r% r> r2 �listdirr/ rg �isdirrf r, re )r r/ r- �q� current_pathrR �entry_filepathr r r Z __load_treeV s zInotifyTree.__load_tree) r r r �__doc__r! r< r_ r^ r rm r r r r r rk K s �rk c s2 e Zd ZdZejjef� fdd� Zdd� Z � Z S )� InotifyTreesz'Recursively watch over a list of trees.c s" t t| �j||d� | �|� d S rl )r rt r �_InotifyTrees__load_trees)r r- r r. r r r r p s zInotifyTrees.__init__c C s� t �dd�tt|��� g }|}|rx|d }|d= |�|� t�|�D ].}tj�||�}tj� |�dkrjqF|�|� qFq |D ]}| j � || j � q|d S )Nz%Adding initial watches on trees: [%s]�,r F) r$ r% rg �map�strr> r2 rn r/ ro rf r, re )r r- �foundrp rq rR rr r/ r r r Z __load_treesv s zInotifyTrees.__load_trees) r r r rs r! r< r_ r^ r ru r r r r r rt m s �rt )"�loggingr& r2 rH � collectionsrT rX r Zinotify.constantsr! Z inotify.callsr^ rJ r` � getLoggerr r$ � namedtupler �calcsizerG �bool�int�environr8 Z _IS_DEBUG� Exceptionr r �objectr rb rk rt r r r r �<module> s: �� QI"