LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

job's comments

Browse source
This commit is contained in:
Jack 2016-09-30 14:26:13 -04:00
parent 640e000b9f
commit d83abd81f8
1 changed files with 2 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lbrynet/core/BlobAvailability.py
View file

@ -36,10 +36,7 @@ class BlobAvailabilityTracker(object):
def get_blob_availability(self, blob):
def _get_peer_count(peers):
have_blob = 0
for peer in peers:
if peer.is_available():
have_blob += 1
have_blob = sum(1 for peer in peers if peer.is_available())
return {blob: have_blob}
d = self._peer_finder.find_peers_for_blob(blob)
@ -47,10 +44,7 @@ class BlobAvailabilityTracker(object):
return d
def get_availability_for_blobs(self, blobs):
dl = []
for blob in blobs:
if blob:
dl.append(self.get_blob_availability(blob))
dl = [self.get_blob_availability(blob) for blob in blobs if blob]
d = defer.DeferredList(dl)
d.addCallback(lambda results: [r[1] for r in results])
return d