ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-04-25 13:29:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

encode: add more logging to investigate occasional test failures

Browse Source
This commit is contained in:
Brian Warner 2007-04-06 18:04:38 -07:00
parent dd673370ec
commit 5168c7c8d6
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/allmydata/encode.py
View File

@ -151,7 +151,7 @@ class Encoder(object):
d.addCallback(lambda res: self.send_all_subshare_hash_trees()) d.addCallback(lambda res: self.send_all_subshare_hash_trees())
d.addCallback(lambda res: self.send_all_share_hash_trees()) d.addCallback(lambda res: self.send_all_share_hash_trees())
d.addCallback(lambda res: self.close_all_shareholders()) d.addCallback(lambda res: self.close_all_shareholders())
d.addCallback(lambda res: self.done()) d.addCallbacks(lambda res: self.done(), self.err)
return d return d
def setup_encryption(self): def setup_encryption(self):
@ -233,7 +233,7 @@ class Encoder(object):
return sh.callRemote("put_block", segment_num, subshare) return sh.callRemote("put_block", segment_num, subshare)
def send_all_subshare_hash_trees(self): def send_all_subshare_hash_trees(self):
log.msg("%s sending hash trees" % self) log.msg("%s sending subshare hash trees" % self)
dl = [] dl = []
for shareid,hashes in enumerate(self.subshare_hashes): for shareid,hashes in enumerate(self.subshare_hashes):
# hashes is a list of the hashes of all subshares that were sent # hashes is a list of the hashes of all subshares that were sent
@ -252,6 +252,7 @@ class Encoder(object):
return sh.callRemote("put_block_hashes", all_hashes) return sh.callRemote("put_block_hashes", all_hashes)
def send_all_share_hash_trees(self): def send_all_share_hash_trees(self):
log.msg("%s sending all share hash trees" % self)
dl = [] dl = []
for h in self.share_root_hashes: for h in self.share_root_hashes:
assert h assert h
@ -275,6 +276,7 @@ class Encoder(object):
return sh.callRemote("put_share_hashes", needed_hashes) return sh.callRemote("put_share_hashes", needed_hashes)
def close_all_shareholders(self): def close_all_shareholders(self):
log.msg("%s: closing shareholders" % self)
dl = [] dl = []
for shareid in range(self.num_shares): for shareid in range(self.num_shares):
dl.append(self.landlords[shareid].callRemote("close")) dl.append(self.landlords[shareid].callRemote("close"))
@ -283,3 +285,7 @@ class Encoder(object):
def done(self): def done(self):
log.msg("%s: upload done" % self) log.msg("%s: upload done" % self)
return self.root_hash return self.root_hash
def err(self, f):
log.msg("%s: upload failed: %s" % (self, f))
return f