Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

whoops

Browse source
This commit is contained in:
Jack 2016-08-26 20:13:10 -04:00
parent 31655a641c
commit be3633622c
3 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbrynet/lbrynet_daemon/LBRYDaemon.py
View file

@ -1378,7 +1378,7 @@ class LBRYDaemon(jsonrpc.JSONRPC):
reflector_server = random.choice(REFLECTOR_SERVERS) reflector_server = random.choice(REFLECTOR_SERVERS)
reflector_address, reflector_port = reflector_server[0], reflector_server[1] reflector_address, reflector_port = reflector_server[0], reflector_server[1]
log.info("Start reflector client") log.info("Start reflector client")
factory = reflector.LBRYBlobReflectorClient( factory = reflector.LBRYBlobReflectorClientFactory(
self.session.blob_manager, self.session.blob_manager,
blob_hashes blob_hashes
) )

2
lbrynet/reflector/__init__.py
View file

@ -1,2 +1,2 @@
from lbrynet.reflector.server.server import ReflectorServerFactory as ServerFactory from lbrynet.reflector.server.server import ReflectorServerFactory as ServerFactory
from lbrynet.reflector.client.client import LBRYFileReflectorClientFactory, LBRYBlobReflectorClient from lbrynet.reflector.client.client import LBRYFileReflectorClientFactory, LBRYBlobReflectorClientFactory

1
lbrynet/reflector/client/client.py
View file

@ -329,6 +329,7 @@ class LBRYBlobReflectorClient(Protocol):
def send_handshake(self): def send_handshake(self):
log.debug('Sending handshake') log.debug('Sending handshake')
self.write(json.dumps({'version': 0})) self.write(json.dumps({'version': 0}))
return defer.succeed(None)
def parse_response(self, buff): def parse_response(self, buff):
try: try: