Файловый менеджер - Редактировать - /home/digitalm/venv/lib/python3.7/site-packages/watchdog/observers/__pycache__/inotify_c.cpython-37.pyc
Назад
B �P�gM � @ s| d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m Z d dl m Z d dl mZ e�d�Zeed�r�eed�r�eed�s�ed ej� ���eje e ee d d �def�Zeje e e d d �def�Zeje d d �def�ZG d d � d �Ze dd� ejejejejej ej ej ej ej ej!g �Z"G dd� dej#�Z$e�%e$�Z&dZ'e'e&d Z(G dd� d�Z)G dd� d�Z*dS )� )� annotationsN)�c_char_p�c_int�c_uint32)�reduce)�UnsupportedLibc� inotify_init�inotify_add_watch�inotify_rm_watchz Unsupported libc version found: T)Z use_errnoc @ s� e Zd ZdZdZdZdZdZdZdZ dZ d Z d Z d Z d ZeeB Ze e B Zd ZdZdZdZdZdZdZdZdZedd� eeeeeee e e e e eg �ZdZ dZ dS )�InotifyConstants� � � � � � �@ � � i i i i i @ i � i i i i i @l c C s | |B S )N� )�x�yr r �R/home/digitalm-up/venv/lib/python3.7/site-packages/watchdog/observers/inotify_c.py�<lambda>S � zInotifyConstants.<lambda>N) �__name__� __module__� __qualname__� IN_ACCESS� IN_MODIFY� IN_ATTRIB�IN_CLOSE_WRITE�IN_CLOSE_NOWRITE�IN_OPEN� IN_MOVED_FROM� IN_MOVED_TO� IN_CREATE� IN_DELETE�IN_DELETE_SELF� IN_MOVE_SELF�IN_CLOSE�IN_MOVEZ IN_UNMOUNTZ IN_Q_OVERFLOW� IN_IGNOREDZ IN_ONLYDIR�IN_DONT_FOLLOWZIN_EXCL_UNLINKZ IN_MASK_ADD�IN_ISDIRZ IN_ONESHOTr � IN_ALL_EVENTSZ IN_CLOEXECZ IN_NONBLOCKr r r r r 1 sN r c C s | |B S )Nr )r r r r r r k r r c @ s2 e Zd ZdZdefdefdefdefdefgZdS )�inotify_event_structa� Structure representation of the inotify_event structure (used in buffer size calculations):: struct inotify_event { __s32 wd; /* watch descriptor */ __u32 mask; /* watch mask */ __u32 cookie; /* cookie to synchronize two events */ __u32 len; /* length (including nulls) of name */ char name[0]; /* stub for possible name */ }; �wd�mask�cookie�len�nameN)r r r �__doc__r r r Z_fields_r r r r r0 { s r0 i r c @ s� e Zd ZdZdefdd�Zedd� �Zedd� �Zed d � �Z ed d � �Z d d� Z dd� Z dd� Z dd� Zdd� Zdd� Zefdd�Zdd � Zd d � Zed d � �Zed!d"� �Zd#S )$�Inotifya Linux inotify(7) API wrapper class. :param path: The directory path for which we want an inotify object. :type path: :class:`bytes` :param recursive: ``True`` if subdirectories should be monitored; ``False`` otherwise. Fc C sv t � }|dkrt�� || _t�� | _i | _i | _|| _ || _ || _ t j �|�r`| �|||� n | �||� i | _d S )N���)r r7 � _raise_error� _inotify_fd� threading�Lock�_lock� _wd_for_path� _path_for_wd�_path� _event_mask� _is_recursive�os�path�isdir�_add_dir_watch� _add_watch�_moved_from_events)�selfrD � recursive� event_maskZ inotify_fdr r r �__init__� s zInotify.__init__c C s | j S )z)The event mask for this inotify instance.)rA )rI r r r rK � s zInotify.event_maskc C s | j S )z.The path associated with the inotify instance.)r@ )rI r r r rD � s z Inotify.pathc C s | j S )z0Whether we are watching directories recursively.)rB )rI r r r � is_recursive� s zInotify.is_recursivec C s | j S )z9The file descriptor associated with the inotify instance.)r: )rI r r r �fd� s z Inotify.fdc C s i | _ dS )z)Clear cached records of MOVED_FROM eventsN)rH )rI r r r �clear_move_records� s zInotify.clear_move_recordsc C s" |j | jkr| j|j jS dS dS )z� The source path corresponding to the given MOVED_TO event. If the source path is outside the monitored directories, None is returned instead. N)r3 rH �src_path)rI Zdestination_eventr r r �source_for_move� s zInotify.source_for_movec C s || j |j< dS )zf Save this event as the source event for future MOVED_TO events to reference. N)rH r3 )rI �eventr r r �remember_move_from_event� s z Inotify.remember_move_from_eventc C s$ | j � | �|| j� W dQ R X dS )zn Adds a watch for the given path. :param path: Path to begin monitoring. N)r= rG rA )rI rD r r r � add_watch� s zInotify.add_watchc C sB | j �2 | j�|�}| j|= t| j|�dkr4t�� W dQ R X dS )z� Removes a watch for the given path. :param path: Path string for which the watch will be removed. r8 N)r= r> �popr? r r: r7 r9 )rI rD r1 r r r � remove_watch� s zInotify.remove_watchc C s` | j �P | j| jkr,| j| j }t| j|� yt�| j� W n tk rP Y nX W dQ R X dS )zQ Closes the inotify instance and removes all associated watches. N)r= r@ r> r r: rC �close�OSError)rI r1 r r r rW � s z Inotify.closec sL � fdd�}d}x^yt �� j|�}W nD tk rh } z&|jtjkrFwn|jtjkrVg S � W dd}~X Y nX P qW � j��� g }�x�t� |�D �]�\}}}} |dkr�q�� j | } | r�t j � | | �n| } t |||| | �} | jr� �| � n�| j�r�� �| �} | � jk�r�� j| }� j| = |� j| j< | j� j |< � j�r�xb� j�� �� D ]P\}}|�| t j j�� ��rF� j�|�}|�| | j�}|� j|< |� j |< �qFW t j � | | �} t |||| | �} | j �r� j �|�}� j| |k�r� j|= |� | � � jr�| j r�| j r�y� � | � j!� W n tk �r* w�Y nX |�"|| �� q�W W dQ R X |S )z< Reads events from inotify and yields them. c s� g }x�t �| �D ]�\}}}xd|D ]\}yBt j�||�}� �|� j�}t|tjtj B d||�}|� |� W q t k rz Y q X q W xH|D ]@} t j�|| �}� j t j� |� } t| tjd| |�}|� |� q�W qW |S )Nr )rC �walkrD �joinrG rA � InotifyEventr r& r. �appendrX r> �dirname) rP �events�root�dirnames� filenamesr] � full_pathZwd_dir�e�filenameZ wd_parent_dir)rI r r �_recursive_simulate s4 z0Inotify.read_events.<locals>._recursive_simulateNr8 )#rC �readr: rX �errnoZEINTR�EBADFr= r7 �_parse_event_bufferr? rD rZ r[ � is_moved_fromrS � is_moved_torQ r> rP rM �copy�items� startswith�sep�encoderU �replace� is_ignoredr\ � is_directory� is_createrG rA �extend)rI Zevent_buffer_sizere � event_bufferrc � event_listr1 r2 r3 r5 Zwd_pathrP � inotify_eventZ move_src_pathZmoved_wdr@ �_wdZ _move_to_pathrD r )rI r � read_events sl zInotify.read_eventsc C s� t j�|�s"ttjt �tj�|��| �||� |r�xNt �|�D ]@\}}}x4|D ],}t j� ||�}t j� |�rnqN| �||� qNW q>W dS )a/ Adds a watch (optionally recursively) for the given directory path to monitor events specified by the mask. :param path: Path to monitor :param recursive: ``True`` to monitor recursively. :param mask: Event bit mask. N) rC rD rE rX rg �ENOTDIR�strerrorrG rY rZ �islink) rI rD rJ r2 r_ r` �_r] rb r r r rF } s zInotify._add_dir_watchc C s6 t | j||�}|dkr t�� || j|< || j|< |S )z� Adds a watch for the given path to monitor events specified by the mask. :param path: Path to monitor :param mask: Event bit mask. r8 )r r: r7 r9 r> r? )rI rD r2 r1 r r r rG � s zInotify._add_watchc C sV t �� } | tjkr ttjd��n2| tjkr8ttjd��n| tjkrRt| t�| ���dS )z5 Raises errors for inotify failures. zinotify watch limit reachedz inotify instance limit reachedN) �ctypesZ get_errnorg ZENOSPCrX �EMFILE�EACCESrC r| )�errr r r r9 � s zInotify._raise_errorc c sl d}xb|d t | �krft�d| |�\}}}}| |d |d | � �d�}|d| 7 }||||fV qW dS )a� Parses an event buffer of ``inotify_event`` structs returned by inotify:: struct inotify_event { __s32 wd; /* watch descriptor */ __u32 mask; /* watch mask */ __u32 cookie; /* cookie to synchronize two events */ __u32 len; /* length (including nulls) of name */ char name[0]; /* stub for possible name */ }; The ``cookie`` member of this struct is used to pair two related events, for example, it pairs an IN_MOVED_FROM event with an IN_MOVED_TO event. r r ZiIII� N)r4 �struct� unpack_from�rstrip)rv �ir1 r2 r3 �lengthr5 r r r ri � s zInotify._parse_event_bufferN)r r r r6 �WATCHDOG_ALL_EVENTSrL �propertyrK rD rM rN rO rQ rS rT rV rW �DEFAULT_EVENT_BUFFER_SIZErz rF rG � staticmethodr9 ri r r r r r7 � s" t r7 c @ s@ e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zed d � �Z ed d � �Z edd� �Z edd� �Z edd� �Z edd� �Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �Zed*d+� �Zed,d-� �Zd.d/� Zd0d1� Z d2d3� Z e d4d5� �Z d6d7� Z d8S )9r[ a Inotify event struct wrapper. :param wd: Watch descriptor :param mask: Event mask :param cookie: Event cookie :param name: Base name of the event source path. :param src_path: Full event source path. c C s" || _ || _|| _|| _|| _d S )N)ry �_mask�_cookie�_name� _src_path)rI r1 r2 r3 r5 rP r r r rL � s zInotifyEvent.__init__c C s | j S )N)r� )rI r r r rP � s zInotifyEvent.src_pathc C s | j S )N)ry )rI r r r r1 � s zInotifyEvent.wdc C s | j S )N)r� )rI r r r r2 � s zInotifyEvent.maskc C s | j S )N)r� )rI r r r r3 � s zInotifyEvent.cookiec C s | j S )N)r� )rI r r r r5 � s zInotifyEvent.namec C s | j tj@ dkS )Nr )r� r r )rI r r r � is_modify� s zInotifyEvent.is_modifyc C s | j tj@ dkS )Nr )r� r r! )rI r r r �is_close_write� s zInotifyEvent.is_close_writec C s | j tj@ dkS )Nr )r� r r" )rI r r r �is_close_nowrite� s z InotifyEvent.is_close_nowritec C s | j tj@ dkS )Nr )r� r r# )rI r r r �is_open s zInotifyEvent.is_openc C s | j tj@ dkS )Nr )r� r r )rI r r r � is_access s zInotifyEvent.is_accessc C s | j tj@ dkS )Nr )r� r r' )rI r r r � is_delete s zInotifyEvent.is_deletec C s | j tj@ dkS )Nr )r� r r( )rI r r r �is_delete_self s zInotifyEvent.is_delete_selfc C s | j tj@ dkS )Nr )r� r r& )rI r r r rt s zInotifyEvent.is_createc C s | j tj@ dkS )Nr )r� r r$ )rI r r r rj s zInotifyEvent.is_moved_fromc C s | j tj@ dkS )Nr )r� r r% )rI r r r rk s zInotifyEvent.is_moved_toc C s | j tj@ dkS )Nr )r� r r+ )rI r r r �is_move s zInotifyEvent.is_movec C s | j tj@ dkS )Nr )r� r r) )rI r r r � is_move_self# s zInotifyEvent.is_move_selfc C s | j tj@ dkS )Nr )r� r r )rI r r r � is_attrib' s zInotifyEvent.is_attribc C s | j tj@ dkS )Nr )r� r r, )rI r r r rr + s zInotifyEvent.is_ignoredc C s | j p| jp| jtj@ dkS )Nr )r� r� r� r r. )rI r r r rs / s zInotifyEvent.is_directoryc C s | j | j| j| j| jfS )N)r� ry r� r� r� )rI r r r �key: s zInotifyEvent.keyc C s | j |j kS )N)r� )rI rx r r r �__eq__> s zInotifyEvent.__eq__c C s | j |j kS )N)r� )rI rx r r r �__ne__A s zInotifyEvent.__ne__c C s t | j�S )N)�hashr� )rI r r r �__hash__D s zInotifyEvent.__hash__c C sN g }x>t t�D ]2}|�d�r|dkrtt|�}| |@ r|�|� qW d�|�S )NZIN_)r/ r* r+ �|)�dirr rn �getattrr\ rZ )r2 �masks�cZc_valr r r �_get_mask_stringG s z InotifyEvent._get_mask_stringc C sF dt | �j� d| j�d| j� d| �| j�� d| j� dt�| j ��d� S )N�<z : src_path=z, wd=z, mask=z , cookie=z, name=�>) �typer rP r1 r� r2 r3 rC �fsdecoder5 )rI r r r �__repr__U s zInotifyEvent.__repr__N)!r r r r6 rL r� rP r1 r2 r3 r5 r� r� r� r� r� r� r� rt rj rk r� r� r� rr rs r� r� r� r� r� r� r� r r r r r[ � s8 r[ )+� __future__r r � ctypes.utilrg rC r� r; r r r � functoolsr Zwatchdog.utilsr �CDLL�libc�hasattrr� Z CFUNCTYPEr r r r r r r$ r% r& r' r( r- r! r# r� Z Structurer0 ZsizeofZ EVENT_SIZEZDEFAULT_NUM_EVENTSr� r7 r[ r r r r �<module> sP 9 7
| ver. 1.4 |
Github
|
.
| PHP 8.3.23 | Генерация страницы: 0.03 |
proxy
|
phpinfo
|
Настройка