X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Frspecs%2Fpg_rspec.py;h=a9cf102a8e7b6a7327e53a608c60d3a37900fe08;hb=13c091992eb9ca4da8369385eaaf454772f31db1;hp=a151b0a68a68360ac700ef430052dc4232033675;hpb=a267816cecd4a5dce57ad57769509269079e0fec;p=sfa.git diff --git a/sfa/rspecs/pg_rspec.py b/sfa/rspecs/pg_rspec.py index a151b0a6..a9cf102a 100755 --- a/sfa/rspecs/pg_rspec.py +++ b/sfa/rspecs/pg_rspec.py @@ -34,13 +34,13 @@ class PGRSpec(RSpec): return nodes def get_nodes(self, network=None): - return self.xml.xpath('//rspecv2:node[@component_uuid]/@component_uuid', namespaces=self.namespaces) + return self.xml.xpath('//rspecv2:node[@component_name]/@component_name', namespaces=self.namespaces) def get_nodes_with_slivers(self, network=None): if network: - return self.xml.xpath('//node[@component_manager_uuid="%s"][sliver_type]/@component_uuid' % network, namespaces=self.namespaces) + return self.xml.xpath('//node[@component_manager_uuid="%s"][sliver_type]/@component_name' % network, namespaces=self.namespaces) else: - return self.xml.xpath('//node[sliver_type]/@component_uuid' % network, namespaces=self.namespaces) + return self.xml.xpath('//node[sliver_type]/@component_name', namespaces=self.namespaces) def get_nodes_without_slivers(self, network=None): pass @@ -56,12 +56,12 @@ class PGRSpec(RSpec): continue node_tag = etree.SubElement(self.xml, 'node') - if 'network' in node: - node_tag.set('component_manager_id', node['network']) + if 'network_urn' in node: + node_tag.set('component_manager_id', node['network_urn']) if 'urn' in node: node_tag.set('component_id', node['urn']) if 'hostname' in node: - node_tag.set('name', node['hostname']) + node_tag.set('component_name', node['hostname']) node_type_tag = etree.SubElement(node_tag, 'node_type', type_name='pcvm', type_slots='100') available_tag = etree.SubElement(node_tag, 'available').text = 'true' exclusive_tag = etree.SubElement(node_tag, 'exclusive').text = 'false' @@ -74,8 +74,19 @@ class PGRSpec(RSpec): #if 'interfaces' in node: - def add_slivers(self, slivers, check_for_dupes=False): - pass + def add_slivers(self, hostnames, check_for_dupes=False): + if not isinstance(hostnames, list): + hostnames = [hostnames] + + nodes_with_slivers = self.get_nodes_with_slivers() + for hostname in hostnames: + if hostname in nodes_with_slivers: + continue + nodes = self.xml.xpath('//node[@component_name="%s"]' % hostname, namespaces=self.namespaces) + if nodes: + node = nodes[0] + node.set('client_id', hostname) + etree.SubElement(node, 'sliver_type', name='planetlab-vnode') def add_interfaces(self, interfaces, check_for_dupes=False): pass