corpusmanager.py 文件源码

def start(self):
        watchPath = self.config["inputs"]
        self.notifier = pyinotify.Notifier(self.wm, self.handler, timeout=10)
        self.wdd = self.wm.add_watch(watchPath, self.mask, rec=False)