| logger = logging.getLogger("io-perf-tool") |
| def discover(cluster_conf): |
| logger.error("No nodes configured") |
| for cluster, cluster_info in cluster_conf.items(): |
| if cluster == "openstack": |
| conn = cluster_info.get('connection') |
| logger.error("No connection provided for %s. Skipping" |
| logger.debug("Discovering openstack nodes " |
| "with connection details: %r" % |
| nodes_to_run.extend(openstack.discover_openstack_nodes( |
| url = cluster_info['connection'].pop('url') |
| creads = cluster_info['connection'] |
| roles = cluster_info['discover'] |
| if isinstance(roles, basestring): |
| nodes_to_run.extend(fuel.discover_fuel_nodes(url, creads, roles)) |
| nodes_to_run.extend(ceph.discover_ceph_node()) |