From: Daira Hopwood Date: Tue, 22 Sep 2015 15:15:14 +0000 (+0100) Subject: Debug prints. X-Git-Url: https://git.rkrishnan.org/reliability?a=commitdiff_plain;h=4e0ecc0881d242e9d514bb09efb7762110a58f99;p=tahoe-lafs%2Ftahoe-lafs.git Debug prints. Signed-off-by: Daira Hopwood --- diff --git a/src/allmydata/frontends/magic_folder.py b/src/allmydata/frontends/magic_folder.py index 5ea68bd8..7f7b719d 100644 --- a/src/allmydata/frontends/magic_folder.py +++ b/src/allmydata/frontends/magic_folder.py @@ -128,7 +128,9 @@ class QueueMixin(HookMixin): return u"/".join(segments) def _count(self, counter_name, delta=1): - self._client.stats_provider.count('magic_folder.%s.%s' % (self._name, counter_name), delta) + ctr = 'magic_folder.%s.%s' % (self._name, counter_name) + print "%r += %r" % (ctr, delta) + self._client.stats_provider.count(ctr, delta) def _log(self, msg): s = "Magic Folder %s %s: %s" % (quote_output(self._client.nickname), self._name, msg) @@ -267,6 +269,7 @@ class Uploader(QueueMixin): abspath_u = self._get_abspath(relpath_u) pathinfo = get_pathinfo(abspath_u) + print "pending = %r, about to remove %r" % (self._pending, relpath_u) self._pending.remove(relpath_u) encoded_name_u = magicpath.path2magic(relpath_u) @@ -341,6 +344,7 @@ class Uploader(QueueMixin): self._count('objects_succeeded') return res def _failed(f): + print f self._count('objects_queued', -1) self._count('objects_failed') self._log("%r while processing %r" % (f, relpath_u)) @@ -489,8 +493,13 @@ 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._deque.extend(result) + print "deque after = %r" % (self._deque,) + print "pending = %r" % (self._pending,) self._pending.update(map(lambda x: x[0], result)) + print "pending after = %r" % (self._pending,) def _filter_scan_batch(self, result): extension = [] # consider whether this should be a dict