diff options
| author | Tomás Touceda <chiiph@leap.se> | 2013-08-30 12:29:33 -0300 |
|---|---|---|
| committer | Micah Anderson <micah@riseup.net> | 2013-08-30 12:40:08 -0400 |
| commit | c494895d435da359961248c9d18763f33c5628ec (patch) | |
| tree | ba22dfdbbab57da09b0890ccfacf8f4c4ec71589 | |
| parent | 60f1a9227f1e22a33480c54db28db5816b6e6428 (diff) | |
Keep file watcher in memory to prevent losing file events
| -rw-r--r-- | changes/bug_keep_watcher_in_memory | 1 | ||||
| -rw-r--r-- | src/leap/mx/mail_receiver.py | 10 |
2 files changed, 6 insertions, 5 deletions
diff --git a/changes/bug_keep_watcher_in_memory b/changes/bug_keep_watcher_in_memory new file mode 100644 index 0000000..4ac9541 --- /dev/null +++ b/changes/bug_keep_watcher_in_memory @@ -0,0 +1 @@ + o Keep file watcher in memory to prevent losing file events.
\ No newline at end of file diff --git a/src/leap/mx/mail_receiver.py b/src/leap/mx/mail_receiver.py index cabb5cb..24ba2fe 100644 --- a/src/leap/mx/mail_receiver.py +++ b/src/leap/mx/mail_receiver.py @@ -72,16 +72,16 @@ class MailReceiver(Service): Starts the MailReceiver service """ Service.startService(self) - wm = inotify.INotify() - wm.startReading() + self.wm = inotify.INotify() + self.wm.startReading() mask = inotify.IN_CREATE for directory, recursive in self._directories: log.msg("Watching %s --- Recursive: %s" % (directory, recursive)) - wm.watch(filepath.FilePath(directory), mask, - callbacks=[self._process_incoming_email], - recursive=recursive) + self.wm.watch(filepath.FilePath(directory), mask, + callbacks=[self._process_incoming_email], + recursive=recursive) def _gather_uuid_pubkey(self, results): if len(results) < 2: |