Файловый менеджер - Редактировать - /home/digitalm/venv/lib/python3.7/site-packages/watchdog/observers/__pycache__/kqueue.cpython-37.pyc
Назад
B �P�g�] � @ st d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl m Z m Z m Z m Z mZmZmZmZmZmZmZmZ d dlmZmZmZmZ d dlm Z d dl m Z dZ d Z e �!� r�e Z"n ej#ej$B Z"ej%Z&ej'ej(B ej)B Z*ej+ej,B ej-B ej.B ej/B ej0B ej1B Z2d d � Z3d d � Z4dd� Z5dd� Z6dd� Z7G dd� d�Z8G dd� d�Z9G dd� de�Z:G dd� de�Z;dS ) � )� annotationsN)�S_ISDIR) �EVENT_TYPE_CREATED�EVENT_TYPE_DELETED�EVENT_TYPE_MOVED�DirCreatedEvent�DirDeletedEvent�DirModifiedEvent� DirMovedEvent�FileCreatedEvent�FileDeletedEvent�FileModifiedEvent�FileMovedEvent�generate_sub_moved_events)�DEFAULT_EMITTER_TIMEOUT�DEFAULT_OBSERVER_TIMEOUT� BaseObserver� EventEmitter)�platform)�DirectorySnapshoti i � c C s t j�t j�| ��S )N)�os�path�abspath�normpath)r � r �O/home/digitalm-up/venv/lib/python3.7/site-packages/watchdog/observers/kqueue.py� absolute_path~ s r c C s | j tj@ S )z8Determines whether the given kevent represents deletion.)�fflags�select�KQ_NOTE_DELETE)�kevr r r � is_deleted� s r! c C s | j }|tj@ p|tj@ S )z<Determines whether the given kevent represents modification.)r r �KQ_NOTE_EXTEND� KQ_NOTE_WRITE)r r r r r � is_modified� s r$ c C s | j tj@ S )zFDetermines whether the given kevent represents attribute modification.)r r �KQ_NOTE_ATTRIB)r r r r �is_attrib_modified� s r& c C s | j tj@ S )z8Determines whether the given kevent represents movement.)r r �KQ_NOTE_RENAME)r r r r � is_renamed� s r( c @ s� e Zd ZdZdd� Zedd� �Zedd� �Zdd � Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd S ) �KeventDescriptorSetz3 Thread-safe kevent descriptor collection. c C s. t � | _t� | _t� | _t� | _t�� | _ d S )N) �set� _descriptors�dict�_descriptor_for_path�_descriptor_for_fd�list�_kevents� threading�Lock�_lock)�selfr r r �__init__� s z KeventDescriptorSet.__init__c C s | j � | jS Q R X dS )z, List of kevents monitored. N)r3 r0 )r4 r r r �kevents� s zKeventDescriptorSet.keventsc C s | j � t| j�� �S Q R X dS )zD List of paths for which kevents have been created. N)r3 r/ r- �keys)r4 r r r �paths� s zKeventDescriptorSet.pathsc C s | j � | j| S Q R X dS )z� Given a file descriptor, returns the kevent descriptor object for it. :param fd: OS file descriptor. :type fd: ``int`` :returns: A :class:`KeventDescriptor` object. N)r3 r. )r4 �fdr r r � get_for_fd� s z KeventDescriptorSet.get_for_fdc C s$ | j � t|�}| �|�S Q R X dS )z� Obtains a :class:`KeventDescriptor` object for the specified path. :param path: Path for which the descriptor will be obtained. N)r3 r �_get)r4 r r r r �get� s zKeventDescriptorSet.getc C s$ | j � t|�}| �|�S Q R X dS )z� Determines whether a :class:`KeventDescriptor has been registered for the specified path. :param path: Path for which the descriptor will be obtained. N)r3 r � _has_path)r4 r r r r � __contains__� s z KeventDescriptorSet.__contains__c C s8 | j �( t|�}| �|�s*| �t||�� W dQ R X dS )an Adds a :class:`KeventDescriptor` to the collection for the given path. :param path: The path for which a :class:`KeventDescriptor` object will be added. :param is_directory: ``True`` if the path refers to a directory; ``False`` otherwise. :type is_directory: ``bool`` N)r3 r r= �_add_descriptor�KeventDescriptor)r4 r � is_directoryr r r �add� s zKeventDescriptorSet.addc C s8 | j �( t|�}| �|�r*| �| �|�� W dQ R X dS )z� Removes the :class:`KeventDescriptor` object for the given path if it already exists. :param path: Path for which the :class:`KeventDescriptor` object will be removed. N)r3 r r= �_remove_descriptorr; )r4 r r r r �remove� s zKeventDescriptorSet.removec C sR | j �B x| jD ] }|�� qW | j�� | j�� | j�� g | _W dQ R X dS )zH Clears the collection and closes all open descriptors. N)r3 r+ �close�clearr. r- r0 )r4 � descriptorr r r rF s zKeventDescriptorSet.clearc C s | j | S )z-Returns a kevent descriptor for a given path.)r- )r4 r r r r r; s zKeventDescriptorSet._getc C s || j kS )zoDetermines whether a :class:`KeventDescriptor` for the specified path exists already in the collection.)r- )r4 r r r r r= s z KeventDescriptorSet._has_pathc C s6 | j �|� | j�|j� || j|j< || j|j< dS )z� Adds a descriptor to the collection. :param descriptor: An instance of :class:`KeventDescriptor` to be added. N) r+ rB r0 �append�keventr- r r. r9 )r4 rG r r r r? s z#KeventDescriptorSet._add_descriptorc C s: | j �|� | j|j= | j|j= | j�|j� |�� dS )z� Removes a descriptor from the collection. :param descriptor: An instance of :class:`KeventDescriptor` to be removed. N) r+ rD r. r9 r- r r0 rI rE )r4 rG r r r rC ' s z&KeventDescriptorSet._remove_descriptorN)�__name__� __module__� __qualname__�__doc__r5 �propertyr6 r8 r: r< r> rB rD rF r; r= r? rC r r r r r) � s r) c @ s| e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zed d � �Z d d � Z edd� �Z dd� Z dd� Z dd� Zdd� ZdS )r@ a� A kevent descriptor convenience data structure to keep together: * kevent * directory status * path * file descriptor :param path: Path string for which a kevent descriptor will be created. :param is_directory: ``True`` if the path refers to a directory; ``False`` otherwise. :type is_directory: ``bool`` c C s8 t |�| _|| _t�|t�| _tj| jt t t d�| _ d S )N)�filter�flagsr ) r �_path� _is_directoryr �open�WATCHDOG_OS_OPEN_FLAGS�_fdr rI �WATCHDOG_KQ_FILTER�WATCHDOG_KQ_EV_FLAGS�WATCHDOG_KQ_FFLAGS�_kev)r4 r rA r r r r5 G s zKeventDescriptor.__init__c C s | j S )z-OS file descriptor for the kevent descriptor.)rU )r4 r r r r9 R s zKeventDescriptor.fdc C s | j S )z/The path associated with the kevent descriptor.)rQ )r4 r r r r W s zKeventDescriptor.pathc C s | j S )z8The kevent object associated with the kevent descriptor.)rY )r4 r r r rI \ s zKeventDescriptor.keventc C s | j S )z}Determines whether the kevent descriptor refers to a directory. :returns: ``True`` or ``False`` )rR )r4 r r r rA a s z KeventDescriptor.is_directoryc C s* yt �| j� W n tk r$ Y nX dS )zQ Closes the file descriptor associated with a kevent descriptor. N)r rE r9 �OSError)r4 r r r rE j s zKeventDescriptor.closec C s | j | jfS )N)r rA )r4 r r r �keys s zKeventDescriptor.keyc C s | j |j kS )N)r[ )r4 rG r r r �__eq__w s zKeventDescriptor.__eq__c C s | j |j kS )N)r[ )r4 rG r r r �__ne__z s zKeventDescriptor.__ne__c C s t | j�S )N)�hashr[ )r4 r r r �__hash__} s zKeventDescriptor.__hash__c C s" dt | �j� d| j�d| j� d�S )N�<z: path=z, is_directory=�>)�typerJ r rA )r4 r r r �__repr__� s zKeventDescriptor.__repr__N)rJ rK rL rM r5 rN r9 r rI rA rE r[ r\ r] r_ rc r r r r r@ 5 s r@ c sr e Zd ZdZeejf� fdd� Zdd� Zdd� Z dd � Z d d � Z d d � Z dd� Z ddd�Zdd� Zdd� Z� ZS )� KqueueEmittera� kqueue(2)-based event emitter. .. ADMONITION:: About ``kqueue(2)`` behavior and this implementation ``kqueue(2)`` monitors file system events only for open descriptors, which means, this emitter does a lot of book-keeping behind the scenes to keep track of open descriptors for every entry in the monitored directory tree. This also means the number of maximum open file descriptors on your system must be increased **manually**. Usually, issuing a call to ``ulimit`` should suffice:: ulimit -n 1024 Ensure that you pick a number that is larger than the number of files you expect to be monitored. ``kqueue(2)`` does not provide enough information about the following things: * The destination path of a file or directory that is renamed. * Creation of a file or directory within a directory; in this case, ``kqueue(2)`` only indicates a modified event on the parent directory. Therefore, this emitter takes a snapshot of the directory tree when ``kqueue(2)`` detects a change on the file system to be able to determine the above information. :param event_queue: The event queue to fill with events. :param watch: A watch object representing the directory to monitor. :type watch: :class:`watchdog.observers.api.ObservedWatch` :param timeout: Read events blocking timeout (in seconds). :type timeout: ``float`` :param stat: stat function. See ``os.stat`` for details. c sT t � �|||� t�� | _t�� | _t� | _ | f� fdd� }t |j |j |d�| _ d S )Nc s � | �}|� | t|j�� |S )N)�_register_keventr �st_mode)r r4 � stat_info)�statr r � custom_stat� s z+KqueueEmitter.__init__.<locals>.custom_stat)� recursiverh )�superr5 r Zkqueue�_kqr1 �RLockr3 r) r+ r r � is_recursive� _snapshot)r4 Z event_queue�watch�timeoutrh ri )� __class__)rh r r5 � s zKqueueEmitter.__init__c C sX y| j �||� W n@ tk rR } z"|jtjkr2n|jtjkr@n� W dd}~X Y nX dS )a4 Registers a kevent descriptor for the given path. :param path: Path for which a kevent descriptor will be created. :param is_directory: ``True`` if the path refers to a directory; ``False`` otherwise. :type is_directory: ``bool`` N)r+ rB rZ �errno�ENOENT� EOPNOTSUPP)r4 r rA �er r r re � s z KqueueEmitter._register_keventc C s | j �|� dS )z� Convenience function to close the kevent descriptor for a specified kqueue-monitored path. :param path: Path for which the kevent descriptor will be closed. N)r+ rD )r4 r r r r �_unregister_kevent� s z KqueueEmitter._unregister_keventc C sj t �| |� |jtkr(| �|j|j� n>|jtkrP| �|j� | �|j |j� n|jt krf| �|j� dS )z� Handles queueing a single event object. :param event: An instance of :class:`watchdog.events.FileSystemEvent` or a subclass. N) r � queue_eventZ event_typer re �src_pathrA r rw � dest_pathr )r4 �eventr r r rx � s zKqueueEmitter.queue_eventc c s� | j �|j�}|j}t|�r@x�| �||j||�D ] }|V q0W n�t|�rf|jrZt|�V q�t |�V n^t |�r�|jr�| j j s�| j j|kr�t|�V q�t |�V n$t |�r�|jr�t|�V n t|�V dS )a� Generate events from the kevent list returned from the call to :meth:`select.kqueue.control`. .. NOTE:: kqueue only tells us about deletions, file modifications, attribute modifications. The other events, namely, file creation, directory modification, file rename, directory rename, directory creation, etc. are determined by comparing directory snapshots. N)r+ r: �identr r( �_gen_renamed_eventsrA r& r r r$ rp rn r! r r )r4 r � ref_snapshot� new_snapshotrG ry r{ r r r �_gen_kqueue_events s& z KqueueEmitter._gen_kqueue_eventsc C s t tj�|��S )zR Helper to generate a DirModifiedEvent on the parent of src_path. )r r r �dirname)r4 ry r r r �_parent_dir_modified; s z"KqueueEmitter._parent_dir_modifiedc c s� y|� |�}W nB tk rP |r8t|�V t|�V nt|�V t|�V dS X |�|�}|dk r�t|�}|r�t||�}|V n t ||�V | � |�V | � |�V |r�| j j r�x@t ||�D ] }|V q�W n&|r�t|�V n t|�V | � |�V dS )a Compares information from two directory snapshots (one taken before the rename operation and another taken right after) to determine the destination path of the file system object renamed, and yields the appropriate events to be queued. N)�inode�KeyErrorr r r r r r r r r� rp rn r ) r4 ry rA r~ r Zf_inoderz r{ Z sub_eventr r r r} A s4 z!KqueueEmitter._gen_renamed_eventsNc C s | j �| jjt|�S )z� Reads events from a call to the blocking :meth:`select.kqueue.control()` method. :param timeout: Blocking timeout for reading events. :type timeout: ``float`` (seconds) )rl �controlr+ r6 � MAX_EVENTS)r4 rq r r r � _read_eventsu s zKqueueEmitter._read_eventsc C s | j �� y�| �|�}|�� t| jj| jj�}| j}|| _|| }x |jD ]}| � t |�� qJW x |j D ]}| � t |�� qhW x |j D ]}| � t|�� q�W x.|D ]&} x | �| ||�D ]} | � | � q�W q�W W n0 tk r� } z| jtjkr� W dd} ~ X Y nX W dQ R X dS )z� Queues events by reading them from a call to the blocking :meth:`select.kqueue.control()` method. :param timeout: Blocking timeout for reading events. :type timeout: ``float`` (seconds) N)r3 r� �reverser rp r rn ro � dirs_createdrx r Z files_createdr Zfiles_modifiedr r� rZ rs �EBADF) r4 rq � event_listr r~ Z diff_eventsZdirectory_createdZ file_createdZ file_modifiedr r{ rv r r r � queue_events� s, zKqueueEmitter.queue_eventsc C s* | j � | j�� | j�� W d Q R X d S )N)r3 r+ rF rl rE )r4 r r r �on_thread_stop� s z KqueueEmitter.on_thread_stop)N)rJ rK rL rM r r rh r5 re rw rx r� r� r} r� r� r� � __classcell__r r )rr r rd � s ,+ +4 +rd c s$ e Zd ZdZef� fdd� Z� ZS )�KqueueObserverzi Observer thread that schedules watching directories and dispatches calls to event handlers. c s t � jt|d� d S )N)Z emitter_classrq )rk r5 rd )r4 rq )rr r r r5 � s zKqueueObserver.__init__)rJ rK rL rM r r5 r� r r )rr r r� � s r� )<� __future__r rs r �os.pathr r1 rh r Zwatchdog.eventsr r r r r r r r r r r r Zwatchdog.observers.apir r r r Zwatchdog.utilsr Zwatchdog.utils.dirsnapshotr r� Z O_EVTONLYZ is_darwinrT �O_RDONLY� O_NONBLOCKZKQ_FILTER_VNODErV Z KQ_EV_ADDZ KQ_EV_ENABLEZ KQ_EV_CLEARrW r r# r" r% Z KQ_NOTE_LINKr' ZKQ_NOTE_REVOKErX r r! r$ r& r( r) r@ rd r� r r r r �<module> s< = 8 * O 1
| ver. 1.4 |
Github
|
.
| PHP 8.3.23 | Генерация страницы: 0.03 |
proxy
|
phpinfo
|
Настройка