self.n = node.Node(factory, bitcoind, [], [], net)
yield self.n.start()
- self.n.p2p_node = node.P2PNode(self.n, 0, 1000000, {}, [('127.0.0.1', peer_port) for peer_port in peer_ports])
+ self.n.p2p_node = node.P2PNode(self.n, port=0, max_incoming_conns=1000000, addr_store={}, connect_addrs=[('127.0.0.1', peer_port) for peer_port in peer_ports])
self.n.p2p_node.start()
wb = work.WorkerBridge(node=self.n, my_pubkey_hash=random.randrange(2**160), donation_percentage=random.uniform(0, 10), merged_urls=merged_urls, worker_fee=3)
@defer.inlineCallbacks
def test_nodes(self):
- try:
- old_successor = data.Share.SUCCESSOR
- data.Share.SUCCESSOR = data.NewShare
-
N = 3
SHARES = 600
for i, n in enumerate(nodes):
assert len(n.n.tracker.items) == SHARES, (i, len(n.n.tracker.items))
assert n.n.tracker.verified.get_height(n.n.best_share_var.value) == SHARES, (i, n.n.tracker.verified.get_height(n.n.best_share_var.value))
- assert type(n.n.tracker.items[nodes[0].n.best_share_var.value]) is data.NewShare
+ assert type(n.n.tracker.items[nodes[0].n.best_share_var.value]) is data.NewNewShare
assert type(n.n.tracker.items[n.n.tracker.get_nth_parent_hash(nodes[0].n.best_share_var.value, SHARES - 5)]) is data.Share
for n in nodes:
gc.collect()
yield deferral.sleep(20) # waiting for work_poller to exit
- finally:
- data.Share.SUCCESSOR = old_successor