utility.py 文件源码

def __init__(self, **kwargs):
        super(Utility, self).__init__(**kwargs)
        self.rsync = Rsync(**kwargs)
        self.syncevt = SyncEvent(sync_method = self.rsync.sync)
        self.watchman = None #pyinotify.WatchManager()
        self.watch_delay = kwargs.get("delay", 30)
        self.notifier = None
        self.statusq = list()
        default_events = [
            "IN_CLOSE_WRITE",
            "IN_CREATE",
            "IN_DELETE",
            "IN_MOVED_FROM",
            "IN_MOVED_TO"
        ]
        self.events = kwargs.get("watch_events", default_events)