Differential D2247 Diff 6483 test/functional/test_framework/util.py

Changeset View

Standalone View

	Show First 20 Lines • Show All 375 Lines • ▼ Show 20 Lines


	def set_node_times(nodes, t):			def set_node_times(nodes, t):
	for node in nodes:			for node in nodes:
	node.setmocktime(t)			node.setmocktime(t)


	def disconnect_nodes(from_node, to_node):			def disconnect_nodes(from_node, to_node):
	node_num = to_node.index			for peer_id in [peer['id'] for peer in from_node.getpeerinfo() if to_node.name in peer['subver']]:
	for peer_id in [peer['id'] for peer in from_node.getpeerinfo() if "testnode%d" % node_num in peer['subver']]:
	from_node.disconnectnode(nodeid=peer_id)			from_node.disconnectnode(nodeid=peer_id)

	for _ in range(50):			for _ in range(50):
	if [peer['id'] for peer in from_node.getpeerinfo() if "testnode%d" % node_num 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(p2p_port(to_node.index))
	▲ Show 20 Lines • Show All 240 Lines • Show Last 20 Lines