diff --git a/python2/pyinotify.py b/python2/pyinotify.py index d2f0816..47e2038 100755 --- a/python2/pyinotify.py +++ b/python2/pyinotify.py @@ -1244,6 +1244,7 @@ class Notifier: raise NotifierError(msg) log.debug('Event queue size: %d', queue_size) rsum = 0 # counter + events = 0 # counter while rsum < queue_size: s_size = 16 # Retrieve wd, mask, cookie and fname_len @@ -1262,6 +1263,8 @@ class Notifier: else: self._eventq.append(rawevent) rsum += s_size + fname_len + events += 1 + return [events, rsum, queue_size] def process_events(self): """ diff --git a/python3/pyinotify.py b/python3/pyinotify.py index bc24313..fd5ea82 100755 --- a/python3/pyinotify.py +++ b/python3/pyinotify.py @@ -1227,6 +1227,7 @@ class Notifier: raise NotifierError(msg) log.debug('Event queue size: %d', queue_size) rsum = 0 # counter + events = 0 # counter while rsum < queue_size: s_size = 16 # Retrieve wd, mask, cookie and fname_len @@ -1247,6 +1248,8 @@ class Notifier: else: self._eventq.append(rawevent) rsum += s_size + fname_len + events += 1 + return [events, rsum, queue_size] def process_events(self): """