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

immutable/download: instrument do-you-have-block responses to investigate #732

Browse Source
This commit is contained in:
Brian Warner 2009-06-20 21:12:09 -07:00
parent 2100aef655
commit a6caae9b5d
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/allmydata/immutable/download.py
View File

@ -5,7 +5,7 @@ from twisted.internet.interfaces import IPushProducer, IConsumer
from twisted.application import service from twisted.application import service
from foolscap.api import DeadReferenceError, RemoteException, eventually from foolscap.api import DeadReferenceError, RemoteException, eventually
from allmydata.util import base32, deferredutil, hashutil, log, mathutil from allmydata.util import base32, deferredutil, hashutil, log, mathutil, idlib
from allmydata.util.assertutil import _assert, precondition from allmydata.util.assertutil import _assert, precondition
from allmydata import codec, hashtree, uri from allmydata import codec, hashtree, uri
from allmydata.interfaces import IDownloadTarget, IDownloader, IFileURI, IVerifierURI, \ from allmydata.interfaces import IDownloadTarget, IDownloader, IFileURI, IVerifierURI, \
@ -746,6 +746,9 @@ class CiphertextDownloader(log.PrefixingLogMixin):
dl = [] dl = []
sb = self._storage_broker sb = self._storage_broker
for (peerid,ss) in sb.get_servers(self._storage_index): for (peerid,ss) in sb.get_servers(self._storage_index):
self.log(format="sending DYHB to [%(peerid)s]",
peerid=idlib.shortnodeid_b2a(peerid),
level=log.NOISY, umid="rT03hg")
d = ss.callRemote("get_buckets", self._storage_index) d = ss.callRemote("get_buckets", self._storage_index)
d.addCallbacks(self._got_response, self._got_error, d.addCallbacks(self._got_response, self._got_error,
callbackArgs=(peerid,)) callbackArgs=(peerid,))
@ -759,6 +762,10 @@ class CiphertextDownloader(log.PrefixingLogMixin):
return defer.DeferredList(dl) return defer.DeferredList(dl)
def _got_response(self, buckets, peerid): def _got_response(self, buckets, peerid):
self.log(format="got results from [%(peerid)s]: shnums %(shnums)s",
peerid=idlib.shortnodeid_b2a(peerid),
shnums=sorted(buckets.keys()),
level=log.NOISY, umid="o4uwFg")
self._responses_received += 1 self._responses_received += 1
if self._results: if self._results:
elapsed = time.time() - self._started elapsed = time.time() - self._started