def is_triggering(self):
self._lock.acquire()
try:
+ now = time.time()
return ( self._got_event and
- (time.time() - self._last_event_time > self._cool_time) ) or \
- time.time() - self._last_reset_time > self._max_time
+ (now - self._last_event_time > self._cool_time) ) or \
+ now - self._last_reset_time > self._max_time
finally:
self._lock.release()
def reset(self):
- self._got_event = False
- self._last_reset_time = time.time()
+ self._lock.acquire()
+ try:
+ self._got_event = False
+ self._last_reset_time = time.time()
+ finally:
+ self._lock.release()
def on_any_event(self, event):
if event.event_type == FileDeletedEvent or event.event_type == DirDeletedEvent: