LBRYFoundation/lbry-sdk
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/lbry-sdk.git synced 2025-09-02 18:25:14 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add timing to hash announcements

Browse source 
This could potentially be a performance issue
on reflector or any daemon with a large number of blobs.
This commit is contained in:
Job Evers-Meltzer 2016-12-14 16:52:26 -06:00
parent 3585d861ff
commit 56d394fb5f
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lbrynet/core/server/DHTHashAnnouncer.py
View file

@ -1,6 +1,7 @@
import binascii import binascii
import collections import collections
import logging import logging
import time
from twisted.internet import defer, reactor from twisted.internet import defer, reactor
@ -52,7 +53,11 @@ class DHTHashAnnouncer(object):
return dl return dl
def _announce_hashes(self, hashes): def _announce_hashes(self, hashes):
if not hashes:
return
log.debug('Announcing %s hashes', len(hashes))
# TODO: add a timeit decorator
start = time.time()
ds = [] ds = []
for h in hashes: for h in hashes:
@ -74,7 +79,10 @@ class DHTHashAnnouncer(object):
# TODO: maybe make the 5 configurable # TODO: maybe make the 5 configurable
self._concurrent_announcers += 1 self._concurrent_announcers += 1
announce() announce()
return defer.DeferredList(ds) d = defer.DeferredList(ds)
d.addCallback(lambda _: log.debug('Took %s seconds to announce %s hashes',
time.time() - start, len(hashes)))
return d
class DHTHashSupplier(object): class DHTHashSupplier(object):