From: Daira Hopwood Date: Thu, 15 Oct 2015 22:02:07 +0000 (+0100) Subject: Logging/debugging improvements. X-Git-Url: https://git.rkrishnan.org/components/%3C?a=commitdiff_plain;h=b7f172c04c1abcf1d649a55d4f7b40aa4bf1af08;p=tahoe-lafs%2Ftahoe-lafs.git Logging/debugging improvements. Signed-off-by: Daira Hopwood --- diff --git a/src/allmydata/frontends/magic_folder.py b/src/allmydata/frontends/magic_folder.py index 904fc6fa..91b92f5d 100644 --- a/src/allmydata/frontends/magic_folder.py +++ b/src/allmydata/frontends/magic_folder.py @@ -123,14 +123,14 @@ class QueueMixin(HookMixin): return extend_filepath(self._local_filepath, relpath_u.split(u"/")) def _get_relpath(self, filepath): - print "_get_relpath(%r)" % (filepath,) + self._log("_get_relpath(%r)" % (filepath,)) segments = unicode_segments_from(filepath, self._local_filepath) - print "segments = %r" % (segments,) + self._log("segments = %r" % (segments,)) return u"/".join(segments) def _count(self, counter_name, delta=1): ctr = 'magic_folder.%s.%s' % (self._name, counter_name) - print "%r += %r" % (ctr, delta) + self._log("%s += %r" % (counter_name, delta)) self._client.stats_provider.count(ctr, delta) def _log(self, msg): @@ -140,7 +140,7 @@ class QueueMixin(HookMixin): #open("events", "ab+").write(msg) def _append_to_deque(self, relpath_u): - print "_append_to_deque(%r)" % (relpath_u,) + self._log("_append_to_deque(%r)" % (relpath_u,)) if relpath_u in self._pending or magicpath.should_ignore_file(relpath_u): return self._deque.append(relpath_u) @@ -222,12 +222,12 @@ class Uploader(QueueMixin): self._log("start_scanning") self.is_ready = True self._pending = self._db.get_all_relpaths() - print "all_files %r" % (self._pending) + self._log("all_files %r" % (self._pending)) d = self._scan(u"") def _add_pending(ign): # This adds all of the files that were in the db but not already processed # (normally because they have been deleted on disk). - print "adding %r" % (self._pending) + self._log("adding %r" % (self._pending)) self._deque.extend(self._pending) d.addCallback(_add_pending) d.addCallback(lambda ign: self._turn_deque()) @@ -286,7 +286,7 @@ class Uploader(QueueMixin): fp = self._get_filepath(relpath_u) pathinfo = get_pathinfo(unicode_from_filepath(fp)) - print "pending = %r, about to remove %r" % (self._pending, relpath_u) + self._log("pending = %r, about to remove %r" % (self._pending, relpath_u)) self._pending.remove(relpath_u) encoded_path_u = magicpath.path2magic(relpath_u) @@ -370,7 +370,6 @@ class Uploader(QueueMixin): self._count('objects_succeeded') return res def _failed(f): - print f self._count('objects_failed') self._log("%r while processing %r" % (f, relpath_u)) return f @@ -410,7 +409,7 @@ class Downloader(QueueMixin): self._download_scan_batch = {} # path -> [(filenode, metadata)] def start_scanning(self): - self._log("\nstart_scanning") + self._log("start_scanning") files = self._db.get_all_relpaths() self._log("all files %s" % files) @@ -521,14 +520,14 @@ class Downloader(QueueMixin): return collective_dirmap_d def _add_batch_to_download_queue(self, result): - print "result = %r" % (result,) - print "deque = %r" % (self._deque,) + self._log("result = %r" % (result,)) + self._log("deque = %r" % (self._deque,)) self._deque.extend(result) - print "deque after = %r" % (self._deque,) + self._log("deque after = %r" % (self._deque,)) self._count('objects_queued', len(result)) - print "pending = %r" % (self._pending,) + self._log("pending = %r" % (self._pending,)) self._pending.update(map(lambda x: x[0], result)) - print "pending after = %r" % (self._pending,) + self._log("pending after = %r" % (self._pending,)) def _filter_scan_batch(self, result): extension = [] # consider whether this should be a dict @@ -546,6 +545,7 @@ class Downloader(QueueMixin): return d def _process(self, item, now=None): + self._log("_process(%r)" % (item,)) if now is None: now = time.time() (relpath_u, file_node, metadata) = item diff --git a/src/allmydata/magicfolderdb.py b/src/allmydata/magicfolderdb.py index 5dcea016..ba338138 100644 --- a/src/allmydata/magicfolderdb.py +++ b/src/allmydata/magicfolderdb.py @@ -108,6 +108,7 @@ class MagicFolderDB(object): return row[0] def did_upload_version(self, relpath_u, version, last_uploaded_uri, last_downloaded_uri, last_downloaded_timestamp, pathinfo): + print "%r.did_upload_version(%r, %r, %r, %r, %r, %r)" % (self, relpath_u, version, last_uploaded_uri, last_downloaded_uri, last_downloaded_timestamp, pathinfo) try: print "insert" self.cursor.execute("INSERT INTO local_files VALUES (?,?,?,?,?,?,?,?)", @@ -119,7 +120,7 @@ class MagicFolderDB(object): " WHERE path=?", (pathinfo.size, pathinfo.mtime, pathinfo.ctime, version, last_uploaded_uri, last_downloaded_uri, last_downloaded_timestamp, relpath_u)) self.connection.commit() - print "commited" + print "committed" def is_new_file(self, pathinfo, relpath_u): """