Changeset c167378 for fedd/federation/proxy_emulab_segment.py

Timestamp:

Oct 11, 2011 10:38:17 AM (13 years ago)

Author:

Ted Faber <faber@…>

Branches:

compt_changes, info-ops, master

Children:

8cb269a

Parents:

451fb96

Message:

Restore mnemonic names and allow seer_master experiments in groups. NB:
all existing experiments that are reused on DETER get deleted now.
Don't save anything in there.

File:

• fedd/federation/proxy_emulab_segment.py (modified) (3 diffs)

fedd/federation/proxy_emulab_segment.py

@@ -285 +285 @@
         Start a sub-experiment on a federant.
 
-        Get the current state, modify or create as appropriate, ship data
+        Get the current state, and terminate the experiment if it exists. The
+        group membership of the experiment is difficult to determine or change,
+        so start with a clean slate.  Create a new one and ship data
         and configs and start the experiment.  There are small ordering
-        differences based on the initial state of the sub-experiment.
         """
         # ops node in the federant
@@ -296 +297 @@
             return False
         
-        if state == 'none':
-            # Put a dummy in place to capture logs, and establish an experiment
-            # directory.
-            if not self.make_null_experiment(user, host, pid, eid, tmpdir, gid):
-                return False
+        if state != 'none':
+            self.ssh_cmd(user, host, 
+                    "/usr/testbed/bin/endexp -w %s %s" % (pid, eid))
+
+        # Put a dummy in place to capture logs, and establish an experiment
+        # directory.
+        if not self.make_null_experiment(user, host, pid, eid, tmpdir, gid):
+            return False
 
         if not self.set_up_experiment_filespace(user, host, pid, eid, tmpdir):
@@ -318 +322 @@
             # if it hangs, assume the worst.
             return False
-        # Active experiments are still swapped, this swaps the others in.
-        if state != 'active':
-            if not self.swap_in(user, host, pid, eid):
-                return False
+
+        if not self.swap_in(user, host, pid, eid):
+            self.log.error("swap in failed")
+            return False
         # Everything has gone OK.
         self.get_mapping(user, host, pid,eid)