spacefreak/pyinotifyd
1
0
Fork 0
Code Issues Pull Requests Releases Activity

reformat source

Browse Source
This commit is contained in:
Thomas Oettli
2020-11-04 15:24:08 +01:00
parent b6839808dc
commit 6feaf9d2b2
1 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
pyinotifyd.py
View File

@@ -128,9 +128,9 @@ class TaskScheduler:
if path in self._tasks: if path in self._tasks:
task = self._tasks[path] task = self._tasks[path]
self._log.info(f"received event {maskname} on '{path}', " self._log.info(
f"re-schedule task {task.task_id} " f"received event {maskname} on '{path}', "
f"(delay={self._delay}s)") f"re-schedule task {task.task_id} (delay={self._delay}s)")
task.restart() task.restart()
else: else:
task_id = str(uuid4()) task_id = str(uuid4())
@@ -150,8 +150,9 @@ class TaskScheduler:
maskname = event.maskname.split("|", 1)[0] maskname = event.maskname.split("|", 1)[0]
if path in self._tasks: if path in self._tasks:
task = self._tasks[path] task = self._tasks[path]
self._log.info(f"received event {maskname} on '{path}', " self._log.info(
f"cancel scheduled task {task.task_id}") f"received event {maskname} on '{path}', "
f"cancel scheduled task {task.task_id}")
task.cancel() task.cancel()
del self._tasks[path] del self._tasks[path]
@@ -183,8 +184,9 @@ class ShellScheduler(TaskScheduler):
class EventMap: class EventMap:
flags = {**pyinotify.EventsCodes.OP_FLAGS, flags = {
**pyinotify.EventsCodes.EVENT_FLAGS} **pyinotify.EventsCodes.OP_FLAGS,
**pyinotify.EventsCodes.EVENT_FLAGS}
def __init__(self, event_map=None, default_task=None): def __init__(self, event_map=None, default_task=None):
self._map = {} self._map = {}
@@ -253,8 +255,9 @@ class Watch:
else: else:
mask = EventMap.flags[flag] mask = EventMap.flags[flag]
wm.add_watch(self.path, mask, rec=self.rec, auto_add=self.auto_add, wm.add_watch(
do_glob=True) self.path, mask, rec=self.rec, auto_add=self.auto_add,
do_glob=True)
return pyinotify.AsyncioNotifier(wm, loop, default_proc_fun=handler) return pyinotify.AsyncioNotifier(wm, loop, default_proc_fun=handler)
@@ -558,8 +561,10 @@ def main():
for signame in ["SIGINT", "SIGTERM"]: for signame in ["SIGINT", "SIGTERM"]:
loop.add_signal_handler( loop.add_signal_handler(
getattr(signal, signame), lambda: asyncio.ensure_future(shutdown( getattr(signal, signame),
signame, notifiers, myname, timeout=cfg.shutdown_timeout))) lambda: asyncio.ensure_future(
shutdown(
signame, notifiers, myname, timeout=cfg.shutdown_timeout)))
loop.run_forever() loop.run_forever()
loop.close() loop.close()