X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=p2pool%2Fnode.py;fp=p2pool%2Fnode.py;h=c3d09aa22d978ae7ab8cf1bb9e26a4bfe4483e1e;hb=454013d9d67629e444944c6bed91abfb1c61c6c3;hp=85b501b187d1a826ded737a7a1681ca8f32e1078;hpb=d66ad5d6f8c934b8c9d3f1d31e7452c0916446ef;p=p2pool.git

diff --git a/p2pool/node.py b/p2pool/node.py
index 85b501b..c3d09aa 100644
--- a/p2pool/node.py
+++ b/p2pool/node.py
@@ -190,12 +190,10 @@ class Node(object):
 
         self.pow_bits = variable.Variable(None)
         self.pow_subsidy = 0
-        self.last_block_time = 0
 
         def handle_header(new_header):
             self.pow_bits = self.bitcoind_work.value['bits']
             self.pow_subsidy = self.bitcoind_work.value['subsidy']
-            self.last_block_time = self.bitcoind_work.value['time']
 
             # check that header matches current target
             #
@@ -251,6 +249,12 @@ class Node(object):
         # add p2p transactions from bitcoind to known_txs
         @self.factory.new_tx.watch
         def _(tx):
+            if tx.timestamp > time.time() + 3600:
+                return
+            
+            if tx.timestamp > self.bitcoind_work.value['txn_timestamp']:
+                self.bitcoind_work.value['txn_timestamp'] = tx.timestamp
+            
             new_known_txs = dict(self.known_txs_var.value)
             new_known_txs[bitcoin_data.hash256(bitcoin_data.tx_type.pack(tx))] = tx
             self.known_txs_var.set(new_known_txs)