From: Daira Hopwood Date: Tue, 3 Nov 2015 22:23:14 +0000 (+0000) Subject: Detect remote conflict by checking for pending upload. X-Git-Url: https://git.rkrishnan.org/reliability?a=commitdiff_plain;h=13020b99377e622699b659f885fd6db03d0c973b;p=tahoe-lafs%2Ftahoe-lafs.git Detect remote conflict by checking for pending upload. Author: David Stainton Signed-off-by: Daira Hopwood --- diff --git a/src/allmydata/frontends/magic_folder.py b/src/allmydata/frontends/magic_folder.py index ba33c824..df26ebb8 100644 --- a/src/allmydata/frontends/magic_folder.py +++ b/src/allmydata/frontends/magic_folder.py @@ -65,7 +65,8 @@ class MagicFolder(service.MultiService): collective_dirnode = self._client.create_node_from_uri(collective_dircap) self.uploader = Uploader(client, local_path_u, db, upload_dirnode, pending_delay, clock, immediate) - self.downloader = Downloader(client, local_path_u, db, collective_dirnode, upload_dirnode.get_readonly_uri(), clock) + self.downloader = Downloader(client, local_path_u, db, collective_dirnode, + upload_dirnode.get_readonly_uri(), clock, self.uploader.is_pending) def startService(self): # TODO: why is this being called more than once? @@ -265,6 +266,9 @@ class Uploader(QueueMixin): return d + def is_pending(relpath_u): + return relpath_u in self._pending + def _notify(self, opaque, path, events_mask): self._log("inotify event %r, %r, %r\n" % (opaque, path, ', '.join(self._inotify.humanReadableMask(events_mask)))) relpath_u = self._get_relpath(path) @@ -509,7 +513,8 @@ class WriteFileMixin(object): class Downloader(QueueMixin, WriteFileMixin): REMOTE_SCAN_INTERVAL = 3 # facilitates tests - def __init__(self, client, local_path_u, db, collective_dirnode, upload_readonly_dircap, clock): + def __init__(self, client, local_path_u, db, collective_dirnode, + upload_readonly_dircap, clock, is_upload_pending): QueueMixin.__init__(self, client, local_path_u, db, 'downloader', clock) if not IDirectoryNode.providedBy(collective_dirnode): @@ -521,6 +526,7 @@ class Downloader(QueueMixin, WriteFileMixin): self._collective_dirnode = collective_dirnode self._upload_readonly_dircap = upload_readonly_dircap + self._is_upload_pending = is_upload_pending self._turn_delay = self.REMOTE_SCAN_INTERVAL @@ -714,6 +720,12 @@ class Downloader(QueueMixin, WriteFileMixin): if dmd_last_uploaded_uri != local_last_uploaded_uri: is_conflict = True self._count('objects_conflicted') + else: + # XXX todo: mark as conflict if file is in pending upload set + if self._is_upload_pending(relpath_u): + is_conflict = True + self._count('objects_conflicted') + if relpath_u.endswith(u"/"): if metadata.get('deleted', False): self._log("rmdir(%r) ignored" % (abspath_u,))