Gecko [ aodai.devttt.com ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
_pydoctortemplates	[ DIR ]	drwxr-xr-x
test	[ DIR ]	drwxr-xr-x
__init__.py	598 B	-rw-r--r--
_appdirs.py	820 B	-rw-r--r--
_inotify.py	3.41 KB	-rw-r--r--
_pydoctor.py	6.58 KB	-rw-r--r--
_release.py	18.44 KB	-rw-r--r--
_shellcomp.py	24.69 KB	-rw-r--r--
_textattributes.py	8.88 KB	-rw-r--r--
_tzhelper.py	3.05 KB	-rw-r--r--
_url.py	228 B	-rw-r--r--
compat.py	16.53 KB	-rw-r--r--
components.py	13.87 KB	-rw-r--r--
constants.py	513 B	-rw-r--r--
context.py	3.96 KB	-rw-r--r--
deprecate.py	27.02 KB	-rw-r--r--
failure.py	26.37 KB	-rw-r--r--
fakepwd.py	6.57 KB	-rw-r--r--
filepath.py	52.76 KB	-rw-r--r--
formmethod.py	11.82 KB	-rw-r--r--
htmlizer.py	3.54 KB	-rw-r--r--
lockfile.py	7.84 KB	-rw-r--r--
log.py	21.78 KB	-rw-r--r--
logfile.py	9.88 KB	-rw-r--r--
modules.py	26.09 KB	-rw-r--r--
monkey.py	2.11 KB	-rw-r--r--
procutils.py	1.34 KB	-rw-r--r--
randbytes.py	3.38 KB	-rw-r--r--
rebuild.py	6.96 KB	-rw-r--r--
reflect.py	20 KB	-rw-r--r--
release.py	1.08 KB	-rw-r--r--
roots.py	7.01 KB	-rw-r--r--
runtime.py	5.79 KB	-rw-r--r--
sendmsg.py	2.62 KB	-rw-r--r--
shortcut.py	2.25 KB	-rw-r--r--
syslog.py	3.57 KB	-rw-r--r--
systemd.py	2.92 KB	-rw-r--r--
text.py	5.29 KB	-rw-r--r--
threadable.py	3.25 KB	-rw-r--r--
threadpool.py	9.96 KB	-rw-r--r--
twisted-completion.zsh	1.34 KB	-rw-r--r--
url.py	244 B	-rw-r--r--
urlpath.py	8.25 KB	-rw-r--r--
usage.py	33.77 KB	-rw-r--r--
util.py	26.79 KB	-rw-r--r--
versions.py	273 B	-rw-r--r--
win32.py	4.68 KB	-rw-r--r--
zippath.py	8.82 KB	-rw-r--r--
zipstream.py	9.45 KB	-rw-r--r--

Code Editor : _inotify.py

# -*- test-case-name: twisted.internet.test.test_inotify -*-
# Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.

"""
Very low-level ctypes-based interface to Linux inotify(7).

ctypes and a version of libc which supports inotify system calls are
required.
"""

import ctypes
import ctypes.util
from typing import cast

from twisted.python.filepath import FilePath

class INotifyError(Exception):
    """
    Unify all the possible exceptions that can be raised by the INotify API.
    """

def init() -> int:
    """
    Create an inotify instance and return the associated file descriptor.
    """
    fd = cast(int, libc.inotify_init())
    if fd < 0:
        raise INotifyError("INotify initialization error.")
    return fd

def add(fd: int, path: FilePath, mask: int) -> int:
    """
    Add a watch for the given path to the inotify file descriptor, and return
    the watch descriptor.

@param fd: The file descriptor returned by C{libc.inotify_init}.
    @param path: The path to watch via inotify.
    @param mask: Bitmask specifying the events that inotify should monitor.
    """
    wd = cast(int, libc.inotify_add_watch(fd, path.asBytesMode().path, mask))
    if wd < 0:
        raise INotifyError(f"Failed to add watch on '{path!r}' - ({wd!r})")
    return wd

def remove(fd: int, wd: int) -> None:
    """
    Remove the given watch descriptor from the inotify file descriptor.
    """
    # When inotify_rm_watch returns -1 there's an error:
    # The errno for this call can be either one of the following:
    #  EBADF: fd is not a valid file descriptor.
    #  EINVAL: The watch descriptor wd is not valid; or fd is
    #          not an inotify file descriptor.
    #
    # if we can't access the errno here we cannot even raise
    # an exception and we need to ignore the problem, one of
    # the most common cases is when you remove a directory from
    # the filesystem and that directory is observed. When inotify
    # tries to call inotify_rm_watch with a non existing directory
    # either of the 2 errors might come up because the files inside
    # it might have events generated way before they were handled.
    # Unfortunately only ctypes in Python 2.6 supports accessing errno:
    #  http://bugs.python.org/issue1798 and in order to solve
    # the problem for previous versions we need to introduce
    # code that is quite complex:
    #  http://stackoverflow.com/questions/661017/access-to-errno-from-python
    #
    # See #4310 for future resolution of this issue.
    libc.inotify_rm_watch(fd, wd)

def initializeModule(libc: ctypes.CDLL) -> None:
    """
    Initialize the module, checking if the expected APIs exist and setting the
    argtypes and restype for C{inotify_init}, C{inotify_add_watch}, and
    C{inotify_rm_watch}.
    """
    for function in ("inotify_add_watch", "inotify_init", "inotify_rm_watch"):
        if getattr(libc, function, None) is None:
            raise ImportError("libc6 2.4 or higher needed")
    libc.inotify_init.argtypes = []
    libc.inotify_init.restype = ctypes.c_int

libc.inotify_rm_watch.argtypes = [ctypes.c_int, ctypes.c_int]
    libc.inotify_rm_watch.restype = ctypes.c_int

libc.inotify_add_watch.argtypes = [ctypes.c_int, ctypes.c_char_p, ctypes.c_uint32]
    libc.inotify_add_watch.restype = ctypes.c_int

name = ctypes.util.find_library("c")
if not name:
    raise ImportError("Can't find C library.")
libc = ctypes.cdll.LoadLibrary(name)
initializeModule(libc)

${this.title}

Code Editor : _inotify.py