block session startup on joinNetwork
This commit is contained in:
parent
1bcf7bd2f7
commit
93b91f8602
1 changed files with 2 additions and 2 deletions
|
@ -260,8 +260,7 @@ class Session(object):
|
||||||
addresses.append(value)
|
addresses.append(value)
|
||||||
return addresses
|
return addresses
|
||||||
|
|
||||||
def start_dht(addresses):
|
def start_dht(join_network_result):
|
||||||
self.dht_node.joinNetwork(addresses)
|
|
||||||
self.peer_finder.run_manage_loop()
|
self.peer_finder.run_manage_loop()
|
||||||
self.hash_announcer.run_manage_loop()
|
self.hash_announcer.run_manage_loop()
|
||||||
return True
|
return True
|
||||||
|
@ -283,6 +282,7 @@ class Session(object):
|
||||||
|
|
||||||
dl = defer.DeferredList(ds)
|
dl = defer.DeferredList(ds)
|
||||||
dl.addCallback(join_resolved_addresses)
|
dl.addCallback(join_resolved_addresses)
|
||||||
|
dl.addCallback(self.dht_node.joinNetwork)
|
||||||
dl.addCallback(start_dht)
|
dl.addCallback(start_dht)
|
||||||
return dl
|
return dl
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue