limit remote_tx_hashes set to 10000 items
authorForrest Voight <forrest@forre.st>
Sun, 4 Nov 2012 22:34:11 +0000 (17:34 -0500)
committerForrest Voight <forrest@forre.st>
Mon, 5 Nov 2012 21:45:10 +0000 (16:45 -0500)
p2pool/p2p.py

index 697fd06..102990e 100644 (file)
@@ -325,13 +325,15 @@ class Protocol(p2protocol.Protocol):
         ('tx_hashes', pack.ListType(pack.IntType(256))),
     ])
     def handle_have_tx(self, tx_hashes):
-        assert self.remote_tx_hashes.isdisjoint(tx_hashes)
+        #assert self.remote_tx_hashes.isdisjoint(tx_hashes)
         self.remote_tx_hashes.update(tx_hashes)
+        while len(self.remote_tx_hashes) > 10000:
+            self.remote_tx_hashes.pop()
     message_losing_tx = pack.ComposedType([
         ('tx_hashes', pack.ListType(pack.IntType(256))),
     ])
     def handle_losing_tx(self, tx_hashes):
-        assert self.remote_tx_hashes.issuperset(tx_hashes)
+        #assert self.remote_tx_hashes.issuperset(tx_hashes)
         self.remote_tx_hashes.difference_update(tx_hashes)