Don't transfer key values to node if we have recently

Author: cpacia

dht/protocol.py

@@ -31,6 +31,7 @@ def __init__(self, sourceNode, storage, ksize, database, signing_key):
         self.signing_key = signing_key
         self.log = Logger(system=self)
         self.handled_commands = [PING, STUN, STORE, DELETE, FIND_NODE, FIND_VALUE, HOLE_PUNCH, INV, VALUES]
+        self.recent_transfers = set()
         RPCProtocol.__init__(self, sourceNode, self.router)
 
     def connect_multiplexer(self, multiplexer):
@@ -225,7 +226,10 @@ def handleCallResponse(self, result, node):
         we get no response, make sure it's removed from the routing table.
         """
         if result[0]:
-            if self.isNewConnection(node):
+            if self.isNewConnection(node) and node.id not in self.recent_transfers:
+                if len(self.recent_transfers) == 10:
+                    self.recent_transfers.pop()
+                self.recent_transfers.add(node.id)
                 self.log.debug("call response from new node, transferring key/values")
                 reactor.callLater(1, self.transferKeyValues, node)
             self.router.addContact(node)
@@ -240,7 +244,10 @@ def addToRouter(self, node):
         We add the node to our router and transfer our stored values
         if they are new and within our neighborhood.
         """
-        if self.isNewConnection(node):
+        if self.isNewConnection(node) and node.id not in self.recent_transfers:
+            if len(self.recent_transfers) == 10:
+                self.recent_transfers.pop()
+            self.recent_transfers.add(node.id)
             self.log.debug("found a new node, transferring key/values")
             reactor.callLater(1, self.transferKeyValues, node)
         self.router.addContact(node)

seed/httpseed.py

@@ -89,7 +89,7 @@ def __init__(self, kserver_r):
                         self.nodes[(node.ip, node.port)] = node
                 self.nodes[(this_node.ip, this_node.port)] = this_node
                 loopingCall = task.LoopingCall(self.crawl)
-                loopingCall.start(180, True)
+                loopingCall.start(900, True)
 
             def crawl(self):
                 def gather_results(result):