Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/util.py
| Show First 20 Lines • Show All 387 Lines • ▼ Show 20 Lines | for _ in range(50): | ||||
| if [peer['id'] for peer in from_node.getpeerinfo() if to_node.name in peer['subver']] == []: | if [peer['id'] for peer in from_node.getpeerinfo() if to_node.name in peer['subver']] == []: | ||||
| break | break | ||||
| time.sleep(0.1) | time.sleep(0.1) | ||||
| else: | else: | ||||
| raise AssertionError("timed out waiting for disconnect") | raise AssertionError("timed out waiting for disconnect") | ||||
| def connect_nodes(from_node, to_node): | def connect_nodes(from_node, to_node): | ||||
| ip_port = "127.0.0.1:" + str(p2p_port(to_node.index)) | ip_port = "127.0.0.1:" + 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 | ||||
| while any(peer['version'] == 0 for peer in from_node.getpeerinfo()): | while any(peer['version'] == 0 for peer in from_node.getpeerinfo()): | ||||
| time.sleep(0.1) | time.sleep(0.1) | ||||
| def connect_nodes_bi(a, b): | def connect_nodes_bi(a, b): | ||||
| ▲ Show 20 Lines • Show All 232 Lines • Show Last 20 Lines | |||||