Changeset 4a02274 for fedd/federation/emulab_segment.py

Timestamp:

Mar 10, 2014 11:12:49 AM (10 years ago)

Author:

Ted Faber <faber@…>

Branches:

master

Children:

a2ca699

Parents:

26821ac (diff), dffa585 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Merge branch 'master' into shared_nat

File:

• fedd/federation/emulab_segment.py (modified) (1 diff)

fedd/federation/emulab_segment.py

@@ -181 +181 @@
             self.do_operation(op, l, p, param, top)
         return True
+
+class exports_segment(ssh_emulab_segment, xmlrpc_emulab_segment):
+    '''
+    Class to export parameters from this segment.  For a standard segment these
+    are calculated, so there is no testbed interaction.  For shared-NAT DETER
+    installations, this is more involved.  This class is a hook for that more
+    involved setup.
+    '''
+    def __init__(self, log=None, keyfile=None, debug=False, boss=None,
+            ops=None, cert=None):
+        ssh_emulab_segment.__init__(self, log=log, keyfile=keyfile, debug=debug)
+        xmlrpc_emulab_segment.__init__(self, boss=boss, ops=ops, cert=cert)
+
+    def __call__(self, parent, eid, pid, user, connInfo, tmpdir, timeout=0,
+            gid=None):
+        '''
+        Install the parameter values into each output parameter in each
+        connInfo entry.  This class understands peer and ssh_port output
+        variables.
+        '''
+
+        for c in connInfo:
+            for p in c.get('parameter', []):
+                # Only set output parameters
+                if  p.get('type', '') != 'output':
+                    continue
+                name = p.get('name', '')
+                # Debugging output
+                k = p.get('key', None)
+                if name == 'peer':
+                    if parent.nat_portal:
+                        value = parent.nat_portal
+                    elif k and k.index('/') != -1:
+                        value = "%s.%s.%s%s" % \
+                            (k[k.index('/')+1:], eid, pid, parent.domain)
+                    else:
+                        self.log.error("Bad export request: %s" % p)
+                        continue
+                    p['value'] = value
+                    self.log.debug("Assigning %s to %s" % (k, value))
+                elif name == 'ssh_port':
+                    value = parent.ssh_port
+                    p['value'] = value
+                    self.log.debug("Assigning %s to %s" % (k, value))
+                else:
+                    self.log.error("Unknown export parameter: %s" % \
+                            p.get('name'))
+                    continue
+        return True