Lines Matching refs:raw_event
670 def process_IN_CREATE(self, raw_event): argument
677 if raw_event.mask & IN_ISDIR:
678 watch_ = self._watch_manager.get_watch(raw_event.wd)
679 created_dir = os.path.join(watch_.path, raw_event.name)
716 return self.process_default(raw_event)
718 def process_IN_MOVED_FROM(self, raw_event): argument
722 watch_ = self._watch_manager.get_watch(raw_event.wd)
724 src_path = os.path.normpath(os.path.join(path_, raw_event.name))
725 self._mv_cookie[raw_event.cookie] = (src_path, datetime.now())
726 return self.process_default(raw_event, {'cookie': raw_event.cookie})
728 def process_IN_MOVED_TO(self, raw_event): argument
733 watch_ = self._watch_manager.get_watch(raw_event.wd)
735 dst_path = os.path.normpath(os.path.join(path_, raw_event.name))
736 mv_ = self._mv_cookie.get(raw_event.cookie)
737 to_append = {'cookie': raw_event.cookie}
746 elif (raw_event.mask & IN_ISDIR and watch_.auto_add and
756 return self.process_default(raw_event, to_append)
758 def process_IN_MOVE_SELF(self, raw_event): argument
770 watch_ = self._watch_manager.get_watch(raw_event.wd)
798 return self.process_default(raw_event)
800 def process_IN_Q_OVERFLOW(self, raw_event): argument
805 return Event({'mask': raw_event.mask})
807 def process_IN_IGNORED(self, raw_event): argument
814 event_ = self.process_default(raw_event)
815 self._watch_manager.del_watch(raw_event.wd)
818 def process_default(self, raw_event, to_append=None): argument
825 watch_ = self._watch_manager.get_watch(raw_event.wd)
826 if raw_event.mask & (IN_DELETE_SELF | IN_MOVE_SELF):
830 dir_ = bool(raw_event.mask & IN_ISDIR)
831 dict_ = {'wd': raw_event.wd,
832 'mask': raw_event.mask,
834 'name': raw_event.name,
1251 raw_event = self._eventq.popleft() # pop next event
1253 log.debug("Event ignored: %s" % repr(raw_event))
1255 watch_ = self._watch_manager.get_watch(raw_event.wd)
1256 if (watch_ is None) and not (raw_event.mask & IN_Q_OVERFLOW):
1257 if not (raw_event.mask & IN_IGNORED):
1262 repr(raw_event))
1264 revent = self._sys_proc_fun(raw_event) # system processings