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

diff --git a/p2pool/main.py b/p2pool/main.py
index e01041c..7b3ed2f 100644
--- a/p2pool/main.py
+++ b/p2pool/main.py
@@ -256,6 +256,12 @@ def main(args, net, datadir_path, merged_urls, worker_endpoint):
                 new_known_txs[tx_hash] = tx
             mining_txs_var.set(new_mining_txs)
             known_txs_var.set(new_known_txs)
+        # add p2p transactions from bitcoind to known_txs
+        @factory.new_tx.watch
+        def _(tx):
+            new_known_txs = dict(known_txs_var.value)
+            new_known_txs[bitcoin_data.hash256(bitcoin_data.tx_type.pack(tx))] = tx
+            known_txs_var.set(new_known_txs)
         # forward transactions seen to bitcoind
         @known_txs_var.transitioned.watch
         def _(before, after):