From 416701e404c74a3e0dcac0b5d36289844667ad47 Mon Sep 17 00:00:00 2001 From: Zooko O'Whielacronx Date: Fri, 30 Sep 2011 05:46:28 +0000 Subject: [PATCH] debugprint the values of blocks and hashes thereof; make the test data and the seg size small in order to make the debugprints easy to look at --- src/allmydata/mutable/publish.py | 3 ++- src/allmydata/mutable/retrieve.py | 3 +++ src/allmydata/test/test_mutable.py | 4 ++-- 3 files changed, 7 insertions(+), 3 deletions(-) diff --git a/src/allmydata/mutable/publish.py b/src/allmydata/mutable/publish.py index 87854cba..5eb4206d 100644 --- a/src/allmydata/mutable/publish.py +++ b/src/allmydata/mutable/publish.py @@ -25,7 +25,7 @@ from allmydata.mutable.layout import get_version_from_checkstring,\ SDMFSlotWriteProxy KiB = 1024 -DEFAULT_MAX_SEGMENT_SIZE = 128 * KiB +DEFAULT_MAX_SEGMENT_SIZE = 64 PUSHING_BLOCKS_STATE = 0 PUSHING_EVERYTHING_ELSE_STATE = 1 DONE_STATE = 2 @@ -763,6 +763,7 @@ class Publish: hashed = sharedata block_hash = hashutil.block_hash(hashed) self.blockhashes[shareid][segnum] = block_hash + log.msg("yyy 0 shareid: %s, segnum: %s, blockhash: %s, sharedata: %s, salt: %s" % (shareid, segnum, base32.b2a(block_hash), base32.b2a(sharedata), base32.b2a(salt),)) # find the writer for this share writer = self.writers[shareid] writer.put_block(sharedata, segnum, salt) diff --git a/src/allmydata/mutable/retrieve.py b/src/allmydata/mutable/retrieve.py index 0e507704..9419ede6 100644 --- a/src/allmydata/mutable/retrieve.py +++ b/src/allmydata/mutable/retrieve.py @@ -772,6 +772,9 @@ class Retrieve: sharehashes[1].keys()) bht = self._block_hash_trees[reader.shnum] + for bhk, bhv in blockhashes.iteritems(): + log.msg("xxx 0 blockhash: %s %s" % (bhk, base32.b2a(bhv),)) + if bht.needed_hashes(segnum, include_leaf=True): try: bht.set_hashes(blockhashes) diff --git a/src/allmydata/test/test_mutable.py b/src/allmydata/test/test_mutable.py index 980e8451..0facb7d8 100644 --- a/src/allmydata/test/test_mutable.py +++ b/src/allmydata/test/test_mutable.py @@ -2872,7 +2872,7 @@ class Version(GridTestMixin, unittest.TestCase, testutil.ShouldFailMixin, \ self.set_up_grid() self.c = self.g.clients[0] self.nm = self.c.nodemaker - self.data = "test data" * 100000 # about 900 KiB; MDMF + self.data = "test data" * 32 # about 900 KiB; MDMF self.small_data = "test data" * 10 # about 90 B; SDMF @@ -3245,7 +3245,7 @@ class Update(GridTestMixin, unittest.TestCase, testutil.ShouldFailMixin): self.set_up_grid() self.c = self.g.clients[0] self.nm = self.c.nodemaker - self.data = "testdata " * 100000 # about 900 KiB; MDMF + self.data = "testdata " * 30 # about 900 KiB; MDMF self.small_data = "test data" * 10 # about 90 B; SDMF -- 2.37.2