diff options
Diffstat (limited to 'kvmd/inotify.py')
-rw-r--r-- | kvmd/inotify.py | 17 |
1 files changed, 9 insertions, 8 deletions
diff --git a/kvmd/inotify.py b/kvmd/inotify.py index fe9b6391..b66ca443 100644 --- a/kvmd/inotify.py +++ b/kvmd/inotify.py @@ -190,14 +190,15 @@ class Inotify: self.__events_queue: "asyncio.Queue[InotifyEvent]" = asyncio.Queue() - async def watch(self, path: str, mask: int) -> None: - path = os.path.normpath(path) - assert path not in self.__wd_by_path, path - get_logger().info("Watching for %s", path) - # Асинхронно, чтобы не висло на NFS - wd = _inotify_check(await aiotools.run_async(libc.inotify_add_watch, self.__fd, _fs_encode(path), mask)) - self.__wd_by_path[path] = wd - self.__path_by_wd[wd] = path + async def watch(self, mask: int, *paths: str) -> None: + for path in paths: + path = os.path.normpath(path) + assert path not in self.__wd_by_path, path + get_logger().info("Watching for %s", path) + # Асинхронно, чтобы не висло на NFS + wd = _inotify_check(await aiotools.run_async(libc.inotify_add_watch, self.__fd, _fs_encode(path), mask)) + self.__wd_by_path[path] = wd + self.__path_by_wd[wd] = path # def unwatch(self, path: str) -> None: # path = os.path.normpath(path) |