X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=p2pool%2Fmain.py;h=137071556e78f64e0fc81afb9f6fed663e8b778e;hb=c4bc0e6931608abb5bf718908d58dd83c941efa3;hp=7b3ed2fdddb2adb42801a51c6085d674842df712;hpb=9f3c22e477bec23cf9b1bae83ffec038963647e9;p=p2pool.git

diff --git a/p2pool/main.py b/p2pool/main.py
index 7b3ed2f..1370715 100644
--- a/p2pool/main.py
+++ b/p2pool/main.py
@@ -411,6 +411,18 @@ def main(args, net, datadir_path, merged_urls, worker_endpoint):
         )
         p2p_node.start()
         
+        def forget_old_txs():
+            new_known_txs = {}
+            for peer in p2p_node.peers.itervalues():
+                new_known_txs.update(peer.remembered_txs)
+            new_known_txs.update(mining_txs_var.value)
+            for share in tracker.get_chain(best_share_var.value, min(120, tracker.get_height(best_share_var.value))):
+                for tx_hash in share.share_info['new_transaction_hashes']:
+                    if tx_hash in known_txs_var.value:
+                        new_known_txs[tx_hash] = known_txs_var.value[tx_hash]
+            known_txs_var.set(new_known_txs)
+        task.LoopingCall(forget_old_txs).start(10)
+        
         def save_addrs():
             with open(os.path.join(datadir_path, 'addrs'), 'wb') as f:
                 f.write(json.dumps(p2p_node.addr_store.items()))