Changeset View
Changeset View
Standalone View
Standalone View
test/functional/test_framework/test_framework.py
| Show First 20 Lines • Show All 326 Lines • ▼ Show 20 Lines | def start_nodes(self, extra_args=None, *args, **kwargs): | ||||
| if extra_args is None: | if extra_args is None: | ||||
| extra_args = [None] * self.num_nodes | extra_args = [None] * self.num_nodes | ||||
| assert_equal(len(extra_args), self.num_nodes) | assert_equal(len(extra_args), self.num_nodes) | ||||
| try: | try: | ||||
| for i, node in enumerate(self.nodes): | for i, node in enumerate(self.nodes): | ||||
| node.start(extra_args[i], *args, **kwargs) | node.start(extra_args[i], *args, **kwargs) | ||||
| for node in self.nodes: | for node in self.nodes: | ||||
| node.wait_for_rpc_connection() | node.wait_for_rpc_connection() | ||||
| except: | except BaseException: | ||||
| # If one node failed to start, stop the others | # If one node failed to start, stop the others | ||||
| self.stop_nodes() | self.stop_nodes() | ||||
| raise | raise | ||||
| if self.options.coveragedir is not None: | if self.options.coveragedir is not None: | ||||
| for node in self.nodes: | for node in self.nodes: | ||||
| coverage.write_all_rpc_commands( | coverage.write_all_rpc_commands( | ||||
| self.options.coveragedir, node.rpc) | self.options.coveragedir, node.rpc) | ||||
| ▲ Show 20 Lines • Show All 230 Lines • Show Last 20 Lines | |||||