kademlia now more aggressive

NikolayBlagoev · Mar 6, 2024 · 06f3a96 · 06f3a96
1 parent 997b49b
commit 06f3a96
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/deccom/protocols/peerdiscovery/kademliadiscovery.py b/deccom/protocols/peerdiscovery/kademliadiscovery.py
@@ -35,7 +35,7 @@ async def start(self):
             msg = bytearray([KademliaDiscovery.ASK_FOR_ID])
             await self._lower_sendto(msg,p.addr)
         loop = asyncio.get_event_loop()
-        loop.call_later(self.interval+2, self.refresh_table)
+        loop.call_later(4, self.refresh_table)
 
     def refresh_table(self):
 
@@ -51,7 +51,7 @@ async def _refresh_table(self):
                 await self.introduce_to_peer(p)
                 msg = bytearray([KademliaDiscovery.ASK_FOR_ID])
                 await self._lower_sendto(msg,p.addr)
-                self.refresh_loop = loop.call_later(self.interval+2, self.refresh_table)
+                self.refresh_loop = loop.call_later(4, self.refresh_table)
                 return
         rand_ids = [Peer.me.id_node]
         unique_id = os.urandom(8)

diff --git a/deccom/protocols/streamprotocol.py b/deccom/protocols/streamprotocol.py
@@ -92,7 +92,7 @@ def peer_connected(self,addr,peer: Peer):
             if self.connections.get(peer.id_node) == None:
 
                 asyncio.ensure_future(self.open_connection(peer.addr[0], peer.tcp, peer.id_node))
-        self.connected_callback(peer)
+        self.connected_callback(addr,peer)
         return
 
     async def open_connection(self, remote_ip, remote_port, node_id: bytes, duplicate = False):