HEX

File: //lib/python3/dist-packages/twisted/internet/__pycache__/inotify.cpython-38.pyc
U


W[c9�@s�dZddlmZddlZddlZddlmZddlmZddl	m
Z
mZdZdZ
d	Zd
ZdZdZd
ZdZdZdZdZdZdZdZdZdZdZdZdZdZeeBZ eeBZ!e
eBZ"e
eBeBeBeBeBeBeBeBZ#edfe
dfedfedfedfed fed!fed"fed#fed$fed%fed&fed'fed(fed)fed*fed+fed,fed-fed.fgZ$d/d0�Z%Gd1d2�d2e&�Z'Gd3d4�d4ee&�Z(ej)Z)d4d0d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKdLgZ*dS)Ma
This module provides support for Twisted to linux inotify API.

In order to use this support, simply do the following (and start a reactor
at some point)::

    from twisted.internet import inotify
    from twisted.python import filepath

    def notify(ignored, filepath, mask):
        """
        For historical reasons, an opaque handle is passed as first
        parameter. This object should never be used.

        @param filepath: FilePath on which the event happened.
        @param mask: inotify event as hexadecimal masks
        """
        print("event %s on %s" % (
            ', '.join(inotify.humanReadableMask(mask)), filepath))

    notifier = inotify.INotify()
    notifier.startReading()
    notifier.watch(filepath.FilePath("/some/directory"), callbacks=[notify])
    notifier.watch(filepath.FilePath(b"/some/directory2"), callbacks=[notify])

Note that in the above example, a L{FilePath} which is a L{bytes} path name
or L{str} path name may be used.  However, no matter what type of
L{FilePath} is passed to this module, internally the L{FilePath} is
converted to L{bytes} according to L{sys.getfilesystemencoding}.
For any L{FilePath} returned by this module, the caller is responsible for
converting from a L{bytes} path name to a L{str} path name.

@since: 10.1
�)�print_functionN)�fdesc)�FileDescriptor)�log�_inotify������ �@��iiii i@i�iii i@l�accessZmodifyZattribZclose_writeZ
close_nowrite�openZ
moved_fromZmoved_toZcreate�deleteZdelete_selfZ	move_selfZunmountZqueue_overflowZignoredZonly_dirZdont_followZmask_add�is_dirZone_shotcCs(g}tD]\}}||@r|�|�q|S)zh
    Auxiliary function that converts a hexadecimal mask into a series
    of human readable flags.
    )�_FLAG_TO_HUMAN�append)�mask�s�k�v�r�:/usr/lib/python3/dist-packages/twisted/internet/inotify.py�humanReadableMaskms
rc@s(eZdZdZeddfdd�Zdd�ZdS)�_Watcha�
    Watch object that represents a Watch point in the filesystem. The
    user should let INotify to create these objects

    @ivar path: The path over which this watch point is monitoring
    @ivar mask: The events monitored by this watchpoint
    @ivar autoAdd: Flag that determines whether this watch point
        should automatically add created subdirectories
    @ivar callbacks: L{list} of callback functions that will be called
        when an event occurs on this watch.
    FNcCs,|��|_||_||_|dkr"g}||_dS)N)�asBytesMode�pathr�autoAdd�	callbacks)�selfrrr r!rrr�__init__�s
z_Watch.__init__cCs$|��}|jD]}||||�qdS)zL
        Callback function used by L{INotify} to dispatch an event.
        N)rr!)r"�filepathZevents�callbackrrr�_notify�s
z_Watch._notify)�__name__�
__module__�__qualname__�__doc__�
IN_WATCH_MASKr#r&rrrrrzs
�

rc@sxeZdZdZeZddd�Zdd�Zdd�Zd	d
�Zdd�Z	d
d�Z
dd�Zdd�Ze
dddfdd�Zdd�Zdd�ZdS)�INotifya�
    The INotify file descriptor, it basically does everything related
    to INotify, from reading to notifying watch points.

    @ivar _buffer: a L{bytes} containing the data read from the inotify fd.

    @ivar _watchpoints: a L{dict} that maps from inotify watch ids to
        watchpoints objects

    @ivar _watchpaths: a L{dict} that maps from watched paths to the
        inotify watch ids
    NcCsTtj||d�|j��|_t�|j�t�|j�d|_d|_	d|_
i|_i|_dS)N)�reactorrT�)
rr#rZinit�_fdrZsetNonBlockingZ_setCloseOnExecZ	connectedZ_writeDisconnected�_buffer�_watchpoints�_watchpaths)r"r-rrrr#�szINotify.__init__cCs@|��}|j�|j||�}t||||�}||j|<||j|<|S)a~
        Private helper that abstracts the use of ctypes.

        Calls the internal inotify API and checks for any errors after the
        call. If there's an error L{INotify._addWatch} can raise an
        INotifyError. If there's no error it proceeds creating a watchpoint and
        adding a watchpath for inverse lookup of the file descriptor from the
        path.
        )rr�addr/rr1r2)r"rrr r!�wd�iwprrr�	_addWatch�s


zINotify._addWatchcCs.|j�|j|�|j�|�}|j�|j�dS)a
        Private helper that abstracts the use of ctypes.

        Calls the internal inotify API to remove an fd from inotify then
        removes the corresponding watchpoint from the internal mapping together
        with the file descriptor from the watchpath.
        N)r�remover/r1�popr2r)r"r4r5rrr�_rmWatch�szINotify._rmWatchc
CsZt�||�|jdkrVzt�|j�Wn.tk
rT}zt�|d�W5d}~XYnXdS)zR
        Release the inotify file descriptor and do the necessary cleanup
        rz'Couldn't close INotify file descriptor.N)r�connectionLostr/�os�close�OSErrorr�err)r"�reason�errrr:�s
zINotify.connectionLostcCs|jS)z�
        Get the underlying file descriptor from this inotify observer.
        Required by L{abstract.FileDescriptor} subclasses.
        )r/�r"rrr�fileno�szINotify.filenocCst�|j|j�dS)zC
        Read some data from the observed file descriptors
        N)rZ
readFromFDr/�_doReadrArrr�doRead�szINotify.doReadc
Cs |j|7_t|j�dk�rt�d|jdd��\}}}}|rZ|jdd|��d�}nd}|jd|d�|_z|j|}Wntk
r�YqYnX|j��}|r�|�	|�}|�
||�|j�r|t@�r|t
@�r|j||jd|jd�}	|j�d|j|j|	�|t@r|�|�qdS)zF
        Work on the data just read from the file descriptor.
        rz=LLLLr�NT�rr r!)r0�len�structZunpack�rstripr1�KeyErrorrr�childr&r �IN_ISDIR�	IN_CREATE�watchrr!r-�	callLater�_addChildren�IN_DELETE_SELFr9)
r"Zin_r4rZcookie�size�namer5rZnew_wdrrrrC�s8


�
�zINotify._doReadcCs�z|j��}Wntk
r$YdSX|D]b}|��rt|j||jd|jd�}|�|tt	B�|j
�d|j|j
|�|��r*|�|t	tB�q*dS)a�
        This is a very private method, please don't even think about using it.

        Note that this is a fricking hack... it's because we cannot be fast
        enough in adding a watch to a directory and so we basically end up
        getting here too late if some operations have already been going on in
        the subdir, we basically need to catchup.  This eventually ends up
        meaning that we generate double events, your app must be resistant.
        NTrFr)rZchildrenr=�isdirrNrr!r&rLrMr-rOrPr1�isfile�IN_CLOSE_WRITE)r"r5�listdir�fr4rrrrP*s&
��zINotify._addChildrenFcCs^|r0|��D] }|��r|j||||dd�qn*|�|�}|rB|S|tB}|�||||�SdS)aL
        Watch the 'mask' events in given path. Can raise C{INotifyError} when
        there's a problem while adding a directory.

        @param path: The path needing monitoring
        @type path: L{FilePath}

        @param mask: The events that should be watched
        @type mask: L{int}

        @param autoAdd: if True automatically add newly created
                        subdirectories
        @type autoAdd: L{bool}

        @param callbacks: A list of callbacks that should be called
                          when an event happens in the given path.
                          The callback should accept 3 arguments:
                          (ignored, filepath, mask)
        @type callbacks: L{list} of callables

        @param recursive: Also add all the subdirectories in this path
        @type recursive: L{bool}
        F)�	recursiveN)�walkrTrN�
_isWatchedrQr6)r"rrr r!rYrKr4rrrrNQs�

z
INotify.watchcCs8|��}|�|�}|dkr*td|f��n
|�|�dS)z�
        Remove the watch point monitoring the given path

        @param path: The path that should be ignored
        @type path: L{FilePath}
        Nz%r is not watched)rr[rJr9)r"rr4rrr�ignores

zINotify.ignorecCs|��}|j�|d�S)z�
        Helper function that checks if the path is already monitored
        and returns its watchdescriptor if so or None otherwise.

        @param path: The path that should be checked
        @type path: L{FilePath}
        N)rr2�get)r"rrrrr[�szINotify._isWatched)N)r'r(r)r*rr#r6r9r:rBrDrCrPr+rNr\r[rrrrr,�s 

.'�
.r,r+�	IN_ACCESS�	IN_MODIFY�	IN_ATTRIB�IN_CLOSE_NOWRITErV�IN_OPEN�
IN_MOVED_FROM�IN_MOVED_TOrM�	IN_DELETErQ�IN_MOVE_SELF�
IN_UNMOUNT�
IN_Q_OVERFLOW�
IN_IGNORED�
IN_ONLYDIR�IN_DONT_FOLLOW�IN_MASK_ADDrL�
IN_ONESHOT�IN_CLOSE�IN_MOVED�
IN_CHANGED)+r*Z
__future__rr;rHZtwisted.internetrZtwisted.internet.abstractrZtwisted.pythonrrr^r_r`rVrarbrcrdrMrerQrfrgrhrirjrkrlrLrmrnrorpr+rr�objectrr,ZINotifyError�__all__rrrr�<module>s�#��������
 �