rnhmjoj/magnetico
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

Do explicit look-up of bootstrap nodes, and query all responses.

Browse Source
This commit is contained in:
Richard Kiss 2017-05-15 15:58:13 -07:00
parent e6098ffb4a
commit 3e4eba740c
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
magneticod/magneticod/dht.py
View File

@ -89,7 +89,7 @@ class SybilNode:
while True: while True:
await asyncio.sleep(1) await asyncio.sleep(1)
if len(self._routing_table) == 0: if len(self._routing_table) == 0:
self.__bootstrap() await self.__bootstrap()
self.__make_neighbours() self.__make_neighbours()
self._routing_table.clear() self._routing_table.clear()
if not self._is_paused: if not self._is_paused:
@ -217,10 +217,16 @@ class SybilNode:
except asyncio.TimeoutError: except asyncio.TimeoutError:
pass pass
def __bootstrap(self) -> None: async def __bootstrap(self) -> None:
for addr in BOOTSTRAPPING_NODES: for node in BOOTSTRAPPING_NODES:
data = self.__build_FIND_NODE_query(self.__true_id) try:
self.sendto(data, addr) # AF_INET means ip4 only
responses = await self._loop.getaddrinfo(*node, family=socket.AF_INET)
for (family, type, proto, canonname, sockaddr) in responses:
data = self.__build_FIND_NODE_query(self.__true_id)
self.sendto(data, sockaddr)
except Exception:
logging.exception("bootstrap problem")
def __make_neighbours(self) -> None: def __make_neighbours(self) -> None:
for node_id, addr in self._routing_table.items(): for node_id, addr in self._routing_table.items():