Changeset 5b19c3a for fedd/federation/protogeni_access.py

Timestamp:

Nov 11, 2010 8:59:19 AM (13 years ago)

Author:

Ted Faber <faber@…>

Branches:

version-3.01

Parents:

807b5ca

Message:

This rolls back the 3.01 branch to the original 3.01 state. I erroneously kept the changes between 3.01 and 3.02 in this branch. With the new branch created, this restores the 3.01 tag's correctness.

File:

• fedd/federation/protogeni_access.py (modified) (11 diffs)

fedd/federation/protogeni_access.py

@@ -344 +344 @@
                         self.d[self.current_key] = {
                                 'hostname': attrs.get('hostname', None),
-                                'interfaces': { },
-                                'mac': { }
+                                'interfaces': { }
                                 }
                 elif name == 'interface' and self.current_key:
@@ -351 +350 @@
                             [attrs.get('virtual_id','')] = \
                             attrs.get('component_id', None)
-                elif name == 'interface_ref':
-                    # Collect mac address information from an interface_ref.
-                    # These appear after the node info has been parsed.
-                    nid = attrs.get('virtual_node_id', None)
-                    ifid = attrs.get('virtual_interface_id', None)
-                    mac = attrs.get('MAC', None)
-                    self.d[nid]['mac'][ifid] = mac
             #  When a node is finished, clear current_key
             def end_element(self, name):
@@ -660 +652 @@
 
         ifconfig = "/sbin/ifconfig"
-        findif = '/usr/local/etc/emulab/findif'
         stage_file = stage_file_type(user, self.staging_host, stagingdir)
         pname = node.get('hostname', None)
@@ -675 +666 @@
                     if not i.get_attribute('portal')]:
                 pinf = node['interfaces'].get(i.name, None)
-                pmac = node['mac'].get(i.name, None)
                 addr = i.get_attribute('ip4_address') 
                 netmask = i.get_attribute('ip4_netmask') or '255.255.255.0'
-                # The interface names in manifests are not to be trusted, so we
-                # find the interface to configure using the local node's script
-                # to match mac address to interface name.
-                if pinf and addr and pmac:
-                    print >>script, '# %s' % pinf
+                if pinf and addr:
                     print >>script, \
-                            "%s `%s %s` %s netmask %s"  % \
-                            (ifconfig, findif, pmac, addr, netmask)
+                            "%s %s %s netmask %s"  % \
+                            (ifconfig, pinf, addr, netmask)
                 else:
                     self.log.error("Missing interface or address for %s" \
@@ -944 +930 @@
                     "ProtoGENI: %s %s" % (e.code, e))
 
-        return (slice_urn, slice_cred, manifest, rspec)
+        return (slice_urn, slice_cred, manifest)
 
     def wait_for_slice(self, segment_commands, slice_cred, slice_urn, ctxt, 
@@ -1011 +997 @@
                 certfile, certpw)
 
-        if not ctxt: return False, {}
+        if not ctxt: return False
 
         self.set_up_staging_filespace(segment_commands, user, host, stagingdir)
         slicename = self.get_free_slicename(segment_commands, user, gcred, ctxt)
         self.log.info("Creating %s" % slicename)
-        slice_urn, slice_cred, manifest, rpsec = self.allocate_slice(
+        slice_urn, slice_cred, manifest = self.allocate_slice(
                 segment_commands, slicename, rspec, gcred, ctxt)
 
@@ -1037 +1023 @@
                                 user, host, "%s/%s" % (stagingdir, f)):
                             self.log.error("Scp failed")
-                            return False, {}
+                            return False
 
 
@@ -1046 +1032 @@
             self.log.error('Sliver failed to start on ProtoGENI')
             self.delete_slice(segment_commands, slice_cred, slice_urn, ctxt)
-            return False, {}
+            return False
         elif status == 'timeout':
             self.log.error('Sliver failed to start on ProtoGENI (timeout)')
             self.delete_slice(segment_commands, slice_cred, slice_urn, ctxt)
-            return False, {}
+            return False
         else:
             # All good: save ProtoGENI info in shared state
@@ -1058 +1044 @@
             self.allocation[aid]['slice_credential'] = slice_cred
             self.allocation[aid]['manifest'] = manifest
-            self.allocation[aid]['rspec'] = rspec
             self.allocation[aid]['certfile'] = certfile
             self.allocation[aid]['certpw'] = certpw
@@ -1411 +1396 @@
             param = {
                     'credential': cred,
-                    'urn': slice_urn,
+                    'hrn': name,
+                    'type': 'Slice',
+                    }
+            slice = segment_commands.slice_authority_call('Resolve', 
+                    param, ctxt)
+            uuid = slice.get('uuid', None)
+            if uuid == None:
+                sys.exit('No uuid for %s' % slicename)
+
+            print 'Calling GetCredential (uuid)'
+            param = {
+                    'credential': cred,
+                    'uuid': uuid,
                     'type': 'Slice',
                     }
@@ -1421 +1418 @@
             return None
         try:
+            print 'Calling RenewSlice (CM)'
             param = {
                     'credentials': [new_scred,],