fix routing_table_get
This commit is contained in:
parent
4fbaaac3f3
commit
adca5f5993
1 changed files with 2 additions and 7 deletions
|
@ -3150,18 +3150,13 @@ class Daemon(AuthJSONRPCServer):
|
||||||
"""
|
"""
|
||||||
|
|
||||||
result = {}
|
result = {}
|
||||||
data_store = deepcopy(self.session.dht_node._dataStore._dict)
|
data_store = self.session.dht_node._dataStore._dict
|
||||||
datastore_len = len(data_store)
|
datastore_len = len(data_store)
|
||||||
hosts = {}
|
hosts = {}
|
||||||
|
|
||||||
if datastore_len:
|
if datastore_len:
|
||||||
for k, v in data_store.iteritems():
|
for k, v in data_store.iteritems():
|
||||||
for value, lastPublished, originallyPublished, originalPublisherID in v:
|
for contact, value, lastPublished, originallyPublished, originalPublisherID in v:
|
||||||
try:
|
|
||||||
contact = self.session.dht_node._routingTable.getContact(
|
|
||||||
originalPublisherID)
|
|
||||||
except (ValueError, IndexError):
|
|
||||||
continue
|
|
||||||
if contact in hosts:
|
if contact in hosts:
|
||||||
blobs = hosts[contact]
|
blobs = hosts[contact]
|
||||||
else:
|
else:
|
||||||
|
|
Loading…
Add table
Reference in a new issue