self.uploader = Uploader(client, local_path_u, db, upload_dircap, pending_delay, clock)
self.downloader = Downloader(client, local_path_u, db, collective_dircap, clock)
- # FIXME FIXME FIXME horrible, just trying it out
- self.downloader._deleted_files = self.uploader._deleted_files
def startService(self):
# TODO: why is this being called more than once?
self._notifier.watch(self._local_filepath, mask=self.mask, callbacks=[self._notify],
recursive=True)
- # we keep a list of files we've "recently" deleted, as we'll
- # get inotify events for these, but we want to ignore
- # them. (e.g. if we just decided we need to delete a file
- # locally, we don't want to immediately upload a new "deleted"
- # version of it)
- self._deleted_files = []
-
-
def start_monitoring(self):
self._log("start_monitoring")
d = defer.succeed(None)
def _unlink_deleted_file(self, abspath_u, result):
try:
self._log('unlinking: %s' % (abspath_u,))
- self._deleted_files.append(abspath_u)
- shutil.move(abspath_u, abspath_u + '.tmp')
+ shutil.move(abspath_u, abspath_u + '.backup')
except IOError:
self._log("Already gone: '%s'" % (abspath_u,))
return abspath_u