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

encode/upload: add more logging, to understand the test failure on a slow buildslave

Browse Source
This commit is contained in:
Brian Warner 2007-04-06 15:45:45 -07:00
parent 654854635a
commit 97a40bf20f
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/allmydata/encode.py
View File

@ -233,6 +233,7 @@ class Encoder(object):
return sh.callRemote("put_block", segment_num, subshare)
def send_all_subshare_hash_trees(self):
log.msg("%s sending hash trees" % self)
dl = []
for shareid,hashes in enumerate(self.subshare_hashes):
# hashes is a list of the hashes of all subshares that were sent
@ -280,4 +281,5 @@ class Encoder(object):
return defer.DeferredList(dl)
def done(self):
log.msg("%s: upload done" % self)
return self.root_hash

4
src/allmydata/upload.py
View File

@ -129,12 +129,12 @@ class FileUploader:
log.msg(" still need homes for %d shares, still have %d usable peers" % (len(self.unallocated_sharenums), len(self.usable_peers)))
if not self.unallocated_sharenums:
# Finished allocating places for all shares.
log.msg("%s._locate_all_shareholders() Finished allocating places for all shares.")
log.msg("%s._locate_all_shareholders() Finished allocating places for all shares." % self)
log.msg("used_peers is %s" % (self.used_peers,))
return self.used_peers
if not self.usable_peers:
# Ran out of peers who have space.
log.msg("%s._locate_all_shareholders() Ran out of peers who have space.")
log.msg("%s._locate_all_shareholders() Ran out of peers who have space." % self)
if len(self.unallocated_sharenums) < (self.total_shares - self.shares_of_happiness):
# But we allocated places for enough shares.
log.msg("%s._locate_all_shareholders() But we allocated places for enough shares.")