Changeset c167378 for fedd/federation/local_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/local_emulab_segment.py (modified) (3 diffs)

fedd/federation/local_emulab_segment.py

@@ -63 +63 @@
         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.
@@ -70 +72 @@
         state = self.get_state(pid, eid)
 
-        if state == 'none':
-            if not self.make_null_experiment(pid, eid, tmpdir, gid):
-                return False
+        if state != 'none':
+            self.terminate_exp(pid, eid)
+
+        if not self.make_null_experiment(pid, eid, tmpdir, gid):
+            return False
 
         if not self.set_up_experiment_filespace(pid, eid, tmpdir):
@@ -84 +88 @@
             return False
         
-        # Stage the new configuration (active experiments will stay swapped
-        # in now)
+        # Stage the new configuration
         if not self.modify_exp(pid, eid, tcl):
             self.log.error("modify failed")
             return False
-        # Active experiments are still swapped, this swaps the others in.
-        if state != 'active':
-            if not self.swap_exp(pid, eid, 'in'):
-                return False
+
+        if not self.swap_exp(pid, eid, 'in'):
+            self.log.error("swap in failed")
+            return False
         # Everything has gone OK.
         self.get_mapping(pid,eid)