Файловый менеджер - Редактировать - /home/digitalm/venv/lib/python3.7/site-packages/watchdog/observers/__pycache__/fsevents2.cpython-37.pyc
Назад
B �P�gz% � @ sr d Z ddlmZ ddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z ddlZddlmZmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z' ddl(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1 ddl2m3Z3m4Z4m5Z5m6Z6 e�7e8�Z9d Z:e�;e:e<� e9�=e:� G d d � d e �Z>G d d � d �Z?G dd� de6�Z@G dd� de5�ZAdS )zk :module: watchdog.observers.fsevents2 :synopsis: FSEvents based emitter implementation. :platforms: macOS � )� annotationsN)�Thread)�List�Optional�Type)�CFRunLoopGetCurrent� CFRunLoopRun� CFRunLoopStop�FSEventStreamCreate�FSEventStreamInvalidate�FSEventStreamRelease� FSEventStreamScheduleWithRunLoop�FSEventStreamStart�FSEventStreamStop�kCFAllocatorDefault�kCFRunLoopDefaultMode�"kFSEventStreamCreateFlagFileEvents� kFSEventStreamCreateFlagNoDefer�&kFSEventStreamEventFlagItemChangeOwner�"kFSEventStreamEventFlagItemCreated�(kFSEventStreamEventFlagItemFinderInfoMod�'kFSEventStreamEventFlagItemInodeMetaMod� kFSEventStreamEventFlagItemIsDir�$kFSEventStreamEventFlagItemIsSymlink�#kFSEventStreamEventFlagItemModified�"kFSEventStreamEventFlagItemRemoved�"kFSEventStreamEventFlagItemRenamed�#kFSEventStreamEventFlagItemXattrMod� kFSEventStreamEventIdSinceNow) �DirCreatedEvent�DirDeletedEvent�DirModifiedEvent� DirMovedEvent�FileCreatedEvent�FileDeletedEvent�FileModifiedEvent�FileMovedEvent�FileSystemEvent)�DEFAULT_EMITTER_TIMEOUT�DEFAULT_OBSERVER_TIMEOUT� BaseObserver� EventEmitterzSwatchdog.observers.fsevents2 is deprecated and will be removed in a future release.c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � FSEventsQueuezLow level FSEvents client.c C sz t �| � t�� | _d | _t|t�r.t� |�}t � d|�| _ d }d}t t| j|| j gt|ttB �| _| jd krvtd��d S )N�NFCg �?z"FSEvents. Could not create stream.)r �__init__�queue�Queue�_queue� _run_loop� isinstance�bytes�os�fsdecode� unicodedata� normalize�_pathr r � _callbackr r r � _stream_ref�OSError)�self�path�contextZlatency� r@ �R/home/digitalm-up/venv/lib/python3.7/site-packages/watchdog/observers/fsevents2.pyr. S s$ zFSEventsQueue.__init__c C s� t j�� �� }t� | _t| j| jt� t | j�sLt | j� t | j� t d��t � t| j� t | j� t | j� ~| j�d � d S )Nz!FSEvents. Could not start stream.)�AppKitZNSAutoreleasePoolZalloc�initr r2 r r; r r r r r< r r r1 �put)r= �poolr@ r@ rA �runj s zFSEventsQueue.runc C s | j d k rt| j � d S )N)r2 r )r= r@ r@ rA �stop} s zFSEventsQueue.stopc C sP dd� t |||�D �}t�d|� d�� x|D ]}t�|� q.W | j�|� d S )Nc S s g | ]\}}}t |||��qS r@ )� NativeEvent)�.0r> �flags�_idr@ r@ rA � <listcomp>� s z+FSEventsQueue._callback.<locals>.<listcomp>zFSEvents callback. Got z events:)�zip�logger�debugr1 rD ) r= Z streamRefZclientCallBackInfoZ numEventsZ eventPathsZ eventFlagsZeventIDs�events�er@ r@ rA r: � s zFSEventsQueue._callbackc C s | � � s dS | j�� S )zo Returns a list or one or more events, or None if there are no more events to be read. N)�is_aliver1 �get)r= r@ r@ rA � read_events� s zFSEventsQueue.read_eventsN) �__name__� __module__� __qualname__�__doc__r. rF rG r: rT r@ r@ r@ rA r, P s r, c @ s( e Zd Zdd� Zedd� �Zdd� ZdS )rH c C s� || _ || _|| _t|t@ �| _t|t@ �| _t|t@ �| _ t|t @ �| _ t|t @ �| _ t|t@ �| _t|t@ �| _t|t@ �| _t|t@ �| _t|t@ �| _d S )N)r> rJ �event_id�boolr � is_createdr � is_removedr � is_renamedr � is_modifiedr Zis_change_ownerr �is_inode_meta_modr Zis_finder_info_modr � is_xattr_modr � is_symlinkr � is_directory)r= r> rJ rY r@ r@ rA r. � s zNativeEvent.__init__c C s@ | j r dS | jrdS | jr dS | jr(dS | jr2dS | jr<dS dS )N�CreatedZRemovedZRenamedZModifiedZ InodeMetaModZXattrMod�Unknown)r[ r\ r] r^ r_ r` )r= r@ r@ rA � _event_type� s zNativeEvent._event_typec C s> dt | �j� d| j�d| j� d| j� dt| j�� d| j� d� S )N�<z: path=z, type=z , is_dir=z, flags=z, id=�>)�typerU r> re rb �hexrJ rY )r= r@ r@ rA �__repr__� s zNativeEvent.__repr__N)rU rV rW r. �propertyre rj r@ r@ r@ rA rH � s rH c s4 e Zd ZdZef� fdd� Zdd� Zdd� Z� ZS )�FSEventsEmitterzL FSEvents based event emitter. Handles conversion of native events. c s* t � �|||� t|j�| _| j�� d S )N)�superr. r, r> � _fsevents�start)r= Z event_queue�watch�timeout)� __class__r@ rA r. � s zFSEventsEmitter.__init__c C s | j �� d S )N)rn rG )r= r@ r@ rA �on_thread_stop� s z FSEventsEmitter.on_thread_stopc C s, | j �� }|d krd S d}�x |t|�k �r&|| }|j�r`|d t|�k r�||d jr�||d j|jd kr�|jr|tnt}| �||j ||d j �� | �t t j � |j ��� | �t t j � ||d j ��� |d7 }n�t j � |j ��r&|jr�tnt}| �||j �� | �t t j � |j ��� n8|j�r2tnt}| �||j �� | �t t j � |j ��� n�|j�sx|j�sx|j�r�|j�r�t nt}| �||j �� n�|j�r�|j�r�tnt}| �||j �� | �t t j � |j ��� n@|j�r |j�r�tnt}| �||j �� | �t t j � |j ��� |d7 }q W d S )Nr � )rn rT �lenr] rY rb r" r& Z queue_eventr> r! r5 �dirname�existsr r# r r$ r^ r_ r` r% r[ r\ )r= rq rP �i�event�clsr@ r@ rA � queue_events� sF z FSEventsEmitter.queue_events) rU rV rW rX r( r. rs r{ � __classcell__r@ r@ )rr rA rl � s rl c s e Zd Zef� fdd� Z� ZS )�FSEventsObserver2c s t � jt|d� d S )N)Z emitter_classrq )rm r. rl )r= rq )rr r@ rA r. s zFSEventsObserver2.__init__)rU rV rW r) r. r| r@ r@ )rr rA r} s r} )BrX � __future__r �loggingr5 r/ r7 �warnings� threadingr �typingr r r rB ZFSEventsr r r r r r r r r r r r r r r r r r r r r r r r Zwatchdog.eventsr r r! r" r# r$ r% r& r' Zwatchdog.observers.apir( r) r* r+ � getLoggerrU rN �message�warn�DeprecationWarning�warningr, rH rl r} r@ r@ r@ rA �<module> s( h, G'F
| ver. 1.4 |
Github
|
.
| PHP 8.3.23 | Генерация страницы: 0.03 |
proxy
|
phpinfo
|
Настройка