Changeset View
Changeset View
Standalone View
Standalone View
test/functional/abc_p2p_avalanche_quorum.py
| Show First 20 Lines • Show All 105 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
| services=NODE_NETWORK | NODE_AVALANCHE, | services=NODE_NETWORK | NODE_AVALANCHE, | ||||
| ) | ) | ||||
| p2p_idx += 1 | p2p_idx += 1 | ||||
| avapeer.nodeid = node.getpeerinfo()[-1]['id'] | avapeer.nodeid = node.getpeerinfo()[-1]['id'] | ||||
| peer['node'] = avapeer | peer['node'] = avapeer | ||||
| addavalanchenode(node, peer) | addavalanchenode(node, peer) | ||||
| # There is no compact proof request if the node is in IBD state | |||||
| if not node.getblockchaininfo()['initialblockdownload']: | |||||
| avapeer.wait_until( | avapeer.wait_until( | ||||
| lambda: avapeer.last_message.get("getavaproofs")) | lambda: avapeer.last_message.get("getavaproofs")) | ||||
| avapeer.send_and_ping(msg_avaproofs()) | avapeer.send_and_ping(msg_avaproofs()) | ||||
| avapeer.wait_until( | avapeer.wait_until( | ||||
| lambda: avapeer.last_message.get("avaproofsreq")) | lambda: avapeer.last_message.get("avaproofsreq")) | ||||
| return avapeer | return avapeer | ||||
| def add_avapeer_and_check_status(peer, expected_status): | def add_avapeer_and_check_status(peer, expected_status): | ||||
| for i, node in enumerate(self.nodes): | for i, node in enumerate(self.nodes): | ||||
| get_ava_outbound(node, peer) | get_ava_outbound(node, peer) | ||||
| poll_and_assert_response(node, expected_status[i]) | poll_and_assert_response(node, expected_status[i]) | ||||
| ▲ Show 20 Lines • Show All 65 Lines • Show Last 20 Lines | |||||