ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2024-12-20 05:28:04 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

log a running total of how much of your file has been uploaded

Browse Source
This commit is contained in:
Zooko O'Whielacronx 2007-03-30 18:01:37 -07:00
parent 077eb7507c
commit 82f7303179
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/allmydata/encode_new.py
View File

@ -2,6 +2,7 @@
from zope.interface import implements from zope.interface import implements
from twisted.internet import defer from twisted.internet import defer
from twisted.python import log
from allmydata.chunk import HashTree, roundup_pow2 from allmydata.chunk import HashTree, roundup_pow2
from allmydata.Crypto.Cipher import AES from allmydata.Crypto.Cipher import AES
from allmydata.util import mathutil, hashutil from allmydata.util import mathutil, hashutil
@ -220,7 +221,9 @@ class Encoder(object):
dl.append(d) dl.append(d)
subshare_hash = hashutil.tagged_hash("encoded subshare", subshare) subshare_hash = hashutil.tagged_hash("encoded subshare", subshare)
self.subshare_hashes[shareid].append(subshare_hash) self.subshare_hashes[shareid].append(subshare_hash)
return defer.DeferredList(dl) dl = defer.DeferredList(dl)
dl.addCallback(lambda res: log.msg("%s uploaded %s / %s bytes of your file." % (self, self.segment_size*(segnum+1), self.segment_size*self.num_segments)))
return dl
def send_subshare(self, shareid, segment_num, subshare): def send_subshare(self, shareid, segment_num, subshare):
return self.send(shareid, "put_block", segment_num, subshare) return self.send(shareid, "put_block", segment_num, subshare)