Changeset c2dbca8 for fedd/federation

Timestamp:

Jul 22, 2009 9:55:54 AM (15 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:

4b362df

Parents:

79b6596

Message:

Now all the filesystem tree stuff is done in a script.

File:

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

fedd/federation/experiment_control.py

@@ -532 +532 @@
             return True
 
+
+    def create_config_tree(self, src_dir, dest_dir, script):
+        """
+        Append commands to script that will create the directory hierarchy on
+        the remote federant.
+        """
+
+        if os.path.isdir(src_dir):
+            print >>script, "mkdir -p %s" % dest_dir
+            print >>script, "chmod 770 %s" % dest_dir
+
+            for f in os.listdir(src_dir):
+                if os.path.isdir(f):
+                    self.create_config_tree("%s/%s" % (src_dir, f), 
+                            "%s/%s" % (dest_dir, f), script)
+        else:
+            self.log.debug("[create_config_tree]: Not a directory: %s" \
+                    % src_dir)
+
     def ship_configs(self, host, user, src_dir, dest_dir):
         """
         Copy federant-specific configuration files to the federant.
         """
-        if not self.ssh_cmd(user, host, "mkdir -p %s" % dest_dir):
-            return False
-        if not self.ssh_cmd(user, host, "chmod 770 %s" % dest_dir):
-            return False
-
         for f in os.listdir(src_dir):
             if os.path.isdir(f):
@@ -571 +585 @@
             dev_null = open("/dev/null", "a")
         except IOError, e:
-            self.log.error("[start_segment]: can't open /dev/null: %s" %e)
+            self.log.error("[get_state]: can't open /dev/null: %s" %e)
 
         if self.debug:
@@ -670 +684 @@
             print >>scriptfile, "mkdir -p %s" % d
         print >>scriptfile, 'mkdir -p %s' % proj_dir
+        self.create_config_tree("%s/%s" % (tmpdir, tb), proj_dir, scriptfile)
+        if os.path.isdir("%s/tarfiles" % tmpdir):
+            self.create_config_tree("%s/tarfiles" % tmpdir, tarfiles_dir,
+                    scriptfile)
+        if os.path.isdir("%s/rpms" % tmpdir):
+            self.create_config_tree("%s/rpms" % tmpdir, rpms_dir, 
+                    scriptfile)
         print >>scriptfile, "rm -f %s" % scriptbase
         scriptfile.close()