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

mutable-retrieve: only record server response times for queries that we don't ignore

Browse Source
This commit is contained in:
Brian Warner 2008-03-04 21:10:52 -07:00
parent 8160a4f2f2
commit f46cb5cd6d
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/allmydata/mutable.py
View File

@ -471,15 +471,16 @@ class Retrieve:
return verifier return verifier
def _got_results(self, datavs, peerid, readsize, stuff, started): def _got_results(self, datavs, peerid, readsize, stuff, started):
elapsed = time.time() - started
if peerid not in self._status.timings["fetch_per_server"]:
self._status.timings["fetch_per_server"][peerid] = []
self._status.timings["fetch_per_server"][peerid].append(elapsed)
self._queries_outstanding.discard(peerid) self._queries_outstanding.discard(peerid)
self._used_peers.add(peerid) self._used_peers.add(peerid)
if not self._running: if not self._running:
return return
elapsed = time.time() - started
if peerid not in self._status.timings["fetch_per_server"]:
self._status.timings["fetch_per_server"][peerid] = []
self._status.timings["fetch_per_server"][peerid].append(elapsed)
if peerid not in self._status.sharemap: if peerid not in self._status.sharemap:
self._status.sharemap[peerid] = set() self._status.sharemap[peerid] = set()