From c4bc0e6931608abb5bf718908d58dd83c941efa3 Mon Sep 17 00:00:00 2001 From: Forrest Voight Date: Sat, 13 Oct 2012 13:45:09 -0400 Subject: [PATCH] forget about unnecessary transactions --- p2pool/main.py | 12 ++++++++++++ 1 files changed, 12 insertions(+), 0 deletions(-) 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())) -- 1.7.1