X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=p2pool%2Fnode.py;h=a3914d5b4be8e046ca175b5d38109cc2761f3481;hb=2ae8b4e27a9e593e3ab9af8e743119d5d8e7c995;hp=1c988667fcbe770ac75ad6c2d6bb4169a086d0d1;hpb=19bf4eac02eb3e12ca168ebc87f61f561e848d90;p=p2pool.git diff --git a/p2pool/node.py b/p2pool/node.py index 1c98866..a3914d5 100644 --- a/p2pool/node.py +++ b/p2pool/node.py @@ -2,7 +2,7 @@ import random import sys import time -from twisted.internet import defer, reactor, task +from twisted.internet import defer, reactor from twisted.python import log from p2pool import data as p2pool_data, p2p @@ -25,7 +25,11 @@ class P2PNode(p2p.Node): print 'Processing %i shares from %s...' % (len(shares), '%s:%i' % peer.addr if peer is not None else None) new_count = 0 - for share in shares: + all_new_txs = {} + for share, new_txs in shares: + if new_txs is not None: + all_new_txs.update((bitcoin_data.hash256(bitcoin_data.tx_type.pack(new_tx)), new_tx) for new_tx in new_txs) + if share.hash in self.node.tracker.items: #print 'Got duplicate share, ignoring. Hash: %s' % (p2pool_data.format_hash(share.hash),) continue @@ -36,6 +40,10 @@ class P2PNode(p2p.Node): self.node.tracker.add(share) + new_known_txs = dict(self.node.known_txs_var.value) + new_known_txs.update(all_new_txs) + self.node.known_txs_var.set(new_known_txs) + if new_count: self.node.set_best_share() @@ -56,7 +64,7 @@ class P2PNode(p2p.Node): except: log.err(None, 'in handle_share_hashes:') else: - self.handle_shares(shares, peer) + self.handle_shares([(share, []) for share in shares], peer) def handle_get_shares(self, hashes, parents, stops, peer): parents = min(parents, 1000//len(hashes)) @@ -72,7 +80,7 @@ class P2PNode(p2p.Node): return shares def handle_bestblock(self, header, peer): - if self.node.net.PARENT.POW_FUNC(bitcoin_data.block_header_type.pack(header)) > header['bits'].target: + if bitcoin_data.scrypt(bitcoin_data.block_header_type.pack(header)) > header['bits'].target: raise p2p.PeerMisbehavingError('received block header fails PoW test') self.node.handle_header(header) @@ -124,7 +132,7 @@ class P2PNode(p2p.Node): if not shares: yield deferral.sleep(1) # sleep so we don't keep rerequesting the same share nobody has continue - self.handle_shares(shares, peer) + self.handle_shares([(share, []) for share in shares], peer) @self.node.best_block_header.changed.watch @@ -137,6 +145,9 @@ class P2PNode(p2p.Node): @self.node.tracker.verified.added.watch def _(share): + if share.timestamp < share.min_header['timestamp']: + return + if not (share.pow_hash <= share.header['bits'].target): return @@ -181,24 +192,28 @@ class Node(object): self.bitcoind_work.set((yield helper.getwork(self.bitcoind, self.bitcoind_work.value['use_getblocktemplate']))) except: log.err() - yield defer.DeferredList([flag, deferral.sleep(15)], fireOnOneCallback=True) + yield defer.DeferredList([flag, deferral.sleep(5)], fireOnOneCallback=True) work_poller() # PEER WORK self.best_block_header = variable.Variable(None) + self.pow_subsidy = 0 def handle_header(new_header): + self.pow_bits = self.bitcoind_work.value['bits'] + self.pow_subsidy = self.bitcoind_work.value['subsidy'] + # check that header matches current target - if not (self.net.PARENT.POW_FUNC(bitcoin_data.block_header_type.pack(new_header)) <= self.bitcoind_work.value['bits'].target): + if not (bitcoin_data.scrypt(bitcoin_data.block_header_type.pack(new_header)) <= self.bitcoind_work.value['bits'].target): return bitcoind_best_block = self.bitcoind_work.value['previous_block'] if (self.best_block_header.value is None or ( new_header['previous_block'] == bitcoind_best_block and - bitcoin_data.hash256(bitcoin_data.block_header_type.pack(self.best_block_header.value)) == bitcoind_best_block + bitcoin_data.scrypt(bitcoin_data.block_header_type.pack(self.best_block_header.value)) == bitcoind_best_block ) # new is child of current and previous is current or ( - bitcoin_data.hash256(bitcoin_data.block_header_type.pack(new_header)) == bitcoind_best_block and + bitcoin_data.scrypt(bitcoin_data.block_header_type.pack(new_header)) == bitcoind_best_block and self.best_block_header.value['previous_block'] != bitcoind_best_block )): # new is current and previous is not a child of current self.best_block_header.set(new_header) @@ -237,6 +252,10 @@ 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) @@ -275,25 +294,32 @@ class Node(object): if tx_hash in self.known_txs_var.value: new_known_txs[tx_hash] = self.known_txs_var.value[tx_hash] self.known_txs_var.set(new_known_txs) - t = task.LoopingCall(forget_old_txs) + t = deferral.RobustLoopingCall(forget_old_txs) t.start(10) stop_signal.watch(t.stop) - t = task.LoopingCall(self.clean_tracker) + t = deferral.RobustLoopingCall(self.clean_tracker) t.start(5) stop_signal.watch(t.stop) def set_best_share(self): - best, desired, decorated_heads = self.tracker.think(self.get_height_rel_highest, self.bitcoind_work.value['previous_block'], self.bitcoind_work.value['bits'], self.known_txs_var.value) + best, desired, decorated_heads, bad_peer_addresses = self.tracker.think(self.get_height_rel_highest, self.bitcoind_work.value['previous_block'], self.bitcoind_work.value['bits'], self.known_txs_var.value) self.best_share_var.set(best) self.desired_var.set(desired) + if self.p2p_node is not None: + for bad_peer_address in bad_peer_addresses: + # XXX O(n) + for peer in self.p2p_node.peers.itervalues(): + if peer.addr == bad_peer_address: + peer.badPeerHappened() + break def get_current_txouts(self): return p2pool_data.get_expected_payouts(self.tracker, self.best_share_var.value, self.bitcoind_work.value['bits'].target, self.bitcoind_work.value['subsidy'], self.net) def clean_tracker(self): - best, desired, decorated_heads = self.tracker.think(self.get_height_rel_highest, self.bitcoind_work.value['previous_block'], self.bitcoind_work.value['bits'], self.known_txs_var.value) + best, desired, decorated_heads, bad_peer_addresses = self.tracker.think(self.get_height_rel_highest, self.bitcoind_work.value['previous_block'], self.bitcoind_work.value['bits'], self.known_txs_var.value) # eat away at heads if decorated_heads: