Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/util.py
| Show First 20 Lines • Show All 420 Lines • ▼ Show 20 Lines | def connect_nodes(from_node, to_node): | ||||
| ip_port = host + ':' + str(to_node.p2p_port) | ip_port = host + ':' + str(to_node.p2p_port) | ||||
| from_node.addnode(ip_port, "onetry") | from_node.addnode(ip_port, "onetry") | ||||
| # poll until version handshake complete to avoid race conditions | # poll until version handshake complete to avoid race conditions | ||||
| # with transaction relaying | # with transaction relaying | ||||
| wait_until(lambda: all(peer['version'] | wait_until(lambda: all(peer['version'] | ||||
| != 0 for peer in from_node.getpeerinfo())) | != 0 for peer in from_node.getpeerinfo())) | ||||
| def connect_nodes_bi(a, b): | |||||
| connect_nodes(a, b) | |||||
| connect_nodes(b, a) | |||||
| def sync_blocks(rpc_connections, *, wait=1, timeout=60): | def sync_blocks(rpc_connections, *, wait=1, timeout=60): | ||||
| """ | """ | ||||
| Wait until everybody has the same tip. | Wait until everybody has the same tip. | ||||
| sync_blocks needs to be called with an rpc_connections set that has least | sync_blocks needs to be called with an rpc_connections set that has least | ||||
| one node already synced to the latest, stable tip, otherwise there's a | one node already synced to the latest, stable tip, otherwise there's a | ||||
| chance it might return before all nodes are stably synced. | chance it might return before all nodes are stably synced. | ||||
| """ | """ | ||||
| ▲ Show 20 Lines • Show All 161 Lines • Show Last 20 Lines | |||||