Changeset 7a8d667 for fedd/fedd_create_experiment.py

Timestamp:

Sep 19, 2008 6:25:54 PM (16 years ago)

Author:

Ted Faber <faber@…>

Branches:

axis_example, compt_changes, info-ops, master, version-1.30, version-2.00, version-3.01, version-3.02

Children:

01073f7

Parents:

9d207bd

Message:

reconfigure sshd_config explicitly

File:

• fedd/fedd_create_experiment.py (modified) (3 diffs)

fedd/fedd_create_experiment.py

@@ -32 +32 @@
     scripts = ["fed_bootstrap", "federate.sh", "smbmount.FreeBSD.pl",
         "smbmount.Linux.pl", "make_hosts", "fed-tun.pl", "fed-tun.ucb.pl",
-        "fed_evrepeater", "rc.accounts.patch", "daemon.py",
-        "experiment-setup.py"]
+        "fed_evrepeater", "rc.accounts.patch"]
     
     def __init__(self, 
@@ -693 +692 @@
                 "emulab" : e
                 }
+        # Make the testbed name be the label the user applied
+        p['testbed'] = {'localname': tb }
 
         for u in p['user']:
@@ -1400 +1401 @@
             raise service_error(service_error.req, "No such experiment")
 
+
+
+    def terminate_experiment(self, req, fid):
+        tbparams = { }
+        req = req.get('TerminateRequestBody', None)
+        if not req:
+            raise service_error(service_error.req,
+                    "Bad request format (no TerminateRequestBody)")
+        exp = req.get('experiment', None)
+        if exp:
+            if exp.has_key('fedid'):
+                key = fedid(bits=exp['fedid'])
+                keytype = "fedid"
+            elif exp.has_key('localname'):
+                key = exp['localname']
+                keytype = "localname"
+            else:
+                raise service_error(service_error.req, "Unknown lookup type")
+        else:
+            raise service_error(service_error.req, "No request?")
+
+        fed_exp = self.state.get(key, None)
+
+        if fed_exp:
+            # Construct enough of the tbparams to make the stop_segment calls
+            # work
+            for fed in fed_exp['federant']:
+                try:
+                    for e in fed['name']:
+                        eid = e.get('localname', None)
+                        if eid: break
+                    else:
+                        continue
+
+                    p = fed['emulab']['project']
+
+                    project = p['name']['localname']
+                    tb = p['testbed']['localname']
+                    user = p['user'][0]['userID']['localname']
+
+                    domain = fed['emulab']['domain']
+                    host  = "%s%s" % (fed['emulab']['ops'], domain)
+                except KeyError, e:
+                    continue
+                tbparams[tb] = {\
+                        'user': user,\
+                        'domain': domain,\
+                        'project': project,\
+                        'host': host,\
+                        'eid': eid,\
+                    }
+            # Stop everyone.
+            for tb in tbparams.keys():
+                self.stop_segment(tb, tbparams[tb]['eid'], tbparams)
+            return { 'experiment': exp }
+        else:
+            raise service_error(service_error.req, "No saved state")
+
+
+
+
 if __name__ == '__main__':
     from optparse import OptionParser