Thread: [Cogkit-svn] SF.net SVN: cogkit: [662] trunk/current/src/cog/modules

SourceForge Headquarters 1320 Columbia Street Suite 310 San Diego, CA 92101 +1 (858) 422-6466

Revision: 662
Author:   hategan
Date:     2006-08-29 18:33:14 -0700 (Tue, 29 Aug 2006)
ViewCVS:  http://svn.sourceforge.net/cogkit/?rev=662&view=rev

Log Message:
-----------
moved examples

Added Paths:
-----------
    trunk/current/src/cog/modules/examples/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/RemoteCompileExecute.java

Removed Paths:
-------------
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/etc/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/execution/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/file/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/invocation/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/queue/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/set/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/RemoteCompileExecute.java
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/transfer/
    trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/xml/
Copied: trunk/current/src/cog/modules/examples (from rev 656, trunk/current/src/cog/modules/abstraction-examples)

Deleted: trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java
===================================================================

--- trunk/current/src/cog/modules/abstraction-examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java	2006-08-28 22:19:16 UTC (rev 656)
+++ trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java	2006-08-30 01:33:14 UTC (rev 662)
@@ -1,182 +0,0 @@
-// ----------------------------------------------------------------------
-// This code is developed as part of the Java CoG Kit project
-// The terms of the license can be found at http://www.cogkit.org/license
-// This message may not be removed or altered.
-// ----------------------------------------------------------------------
-
-package org.globus.cog.abstraction.examples.taskgraph;
-
-import org.apache.log4j.Logger;
-import org.globus.cog.abstraction.examples.transfer.FileTransfer;
-import org.globus.cog.abstraction.impl.common.StatusEvent;
-import org.globus.cog.abstraction.impl.common.task.IllegalSpecException;
-import org.globus.cog.abstraction.impl.common.task.InvalidSecurityContextException;
-import org.globus.cog.abstraction.impl.common.task.InvalidServiceContactException;
-import org.globus.cog.abstraction.impl.common.task.TaskSubmissionException;
-import org.globus.cog.abstraction.impl.common.taskgraph.TaskGraphHandlerImpl;
-import org.globus.cog.abstraction.impl.common.taskgraph.TaskGraphImpl;
-import org.globus.cog.abstraction.interfaces.ExecutableObject;
-import org.globus.cog.abstraction.interfaces.Status;
-import org.globus.cog.abstraction.interfaces.StatusListener;
-import org.globus.cog.abstraction.interfaces.Task;
-import org.globus.cog.abstraction.interfaces.TaskGraph;
-import org.globus.cog.abstraction.interfaces.TaskGraphHandler;
-
-/*
- * This class serves as an example to demonstrate the execution of hierarchical
- * taskgraphs (DAGs). It simply shows the semantics of how a user can create a
- * hierarchy of task graph and submit additional tasks to an already executing
- * task graph (a.k.a adding tasks to a "live taskgraph"). The parameters to the
- * task specification MUST be changed to suite your requirements and
- * environment.
- */
-public class HierarchicalDAG implements StatusListener {
-    static Logger logger = Logger.getLogger(HierarchicalDAG.class.getName());
-    protected org.globus.cog.abstraction.interfaces.TaskGraph taskGraph;
-    protected boolean active = false;
-    private boolean submitted = false;
-    private Task task6 = null;
-    private Task task9 = null;
-    private TaskGraph tg5 = null;
-
-    public void createDAG() throws Exception {
-        TaskGraph tg1 = new TaskGraphImpl();
-        try {
-            tg1.setName("TG1");
-            Task task1 = prepareTask("Task1",
-                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile1",
-                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile1");
-            Task task2 = prepareTask("Task2",
-                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile2",
-                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile2");
-            tg1.add(task1);
-            tg1.add(task2);
-            tg1.addDependency(task1, task2);
-
-            TaskGraph tg2 = new TaskGraphImpl();
-            tg2.setName("TG2");
-            Task task3 = prepareTask("Task3",
-                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile3",
-                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile3");
-            Task task4 = prepareTask("Task4",
-                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile4",
-                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile4");
-            tg2.add(task3);
-            tg2.add(task4);
-            tg2.addDependency(task3, task4);
-
-            TaskGraph tg3 = new TaskGraphImpl();
-            tg3.setName("TG3");
-            tg3.add(tg1);
-            tg3.add(tg2);
-            tg3.addDependency(tg1, tg2);
-
-            TaskGraph tg4 = new TaskGraphImpl();
-            tg4.setName("TG4");
-            Task task5 = prepareTask("Task5",
-                    "gridftp://new.mcs.anl.gov:2811//home/cog/gridfile6",
-                    "gridftp://old.mcs.anl.gov:2811//home/cog/gridfile7");
-            tg4.add(tg3);
-            tg4.add(task5);
-            tg4.addDependency(tg3, task5);
-
-            tg5 = new TaskGraphImpl();
-
-            Task task7 = prepareTask("Task7",
-                    "gridftp://old.mcs.anl.gov:2811//home/cog/gridfile8",
-                    "gridftp://new.mcs.anl.gov:2811//home/cog/gridfile9");
-            Task task8 = prepareTask("Task8",
-                    "gridftp://here.mcs.anl.gov:2811//home/cog/gridfile10",
-                    "gridftp://there.mcs.anl.gov:2811//home/cog/gridfile10");
-            task9 = prepareTask("Task9",
-                    "gridftp://here.mcs.anl.gov:2811//home/cog/gridfile11",
-                    "gridftp://there.mcs.anl.gov:2811//home/cog/gridfile11");
-
-            tg5.add(task7);
-            tg5.add(task8);
-            tg5.add(task9);
-            tg5.add(tg4);
-
-            tg5.addDependency(task7, task8);
-            tg5.addDependency(task8, task9);
-            tg5.addDependency(task8, tg4);
-            tg5.addDependency(task9, tg4);
-
-            this.taskGraph = tg5;
-            this.taskGraph.setName("Main Graph");
-            this.taskGraph.addStatusListener(this);
-        } catch (Exception e) {
-            logger.error("Unable to create DAG", e);
-        }
-    }
-
-    public void submitDAG() {
-        TaskGraphHandler handler = new TaskGraphHandlerImpl();
-        try {
-            handler.submit(this.taskGraph);
-            logger.debug("TaskGraph submitted");
-        } catch (InvalidSecurityContextException ise) {
-            logger.error("Security Exception");
-            ise.printStackTrace();
-            System.exit(1);
-        } catch (TaskSubmissionException tse) {
-            logger.error("TaskSubmission Exception");
-            tse.printStackTrace();
-            System.exit(1);
-        } catch (IllegalSpecException ispe) {
-            logger.error("Specification Exception");
-            ispe.printStackTrace();
-            System.exit(1);
-        } catch (InvalidServiceContactException isce) {
-            logger.error("Service Contact Exception");
-            isce.printStackTrace();
-            System.exit(1);
-        }
-    }
-
-    private Task prepareTask(String name, String source, String destination)
-            throws Exception {
-        FileTransfer fileTransfer = new FileTransfer(name, source, destination);
-        fileTransfer.prepareTask();
-        Task task = fileTransfer.getFileTransferTask();
-        task.removeStatusListener(fileTransfer);
-        return task;
-    }
-
-    public void statusChanged(StatusEvent event) {
-        ExecutableObject eo = event.getSource();
-        logger.debug(eo.getName());
-        Status status = event.getStatus();
-        logger.debug("Status changed to: " + status.getStatusString());
-
-        // demonstrating "live" task graphs
-        if (status.getStatusCode() == Status.SUBMITTED && !submitted) {
-            submitted = true;
-            try {
-                task6 = prepareTask("Task6",
-                        "gridftp://this.mcs.anl.gov:2811//home/cog/gridfile12",
-                        "gridftp://that.mcs.anl.gov:2811//home/cog/gridfile12");
-                tg5.addDependency(task6, task9);
-                tg5.add(task6);
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-        }
-
-        if (status.getStatusCode() == Status.COMPLETED
-                || status.getStatusCode() == Status.FAILED) {
-            logger.info("Task Graph Done");
-            // System.exit(1);
-        }
-    }
-
-    public static void main(String arg[]) {
-        try {
-            HierarchicalDAG dag = new HierarchicalDAG();
-            dag.createDAG();
-            dag.submitDAG();
-        } catch (Exception e) {
-            logger.error("Exception caught: ", e);
-        }
-    }
-}
\ No newline at end of file

Copied: trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java (from rev 658, trunk/current/src/cog/modules/abstraction-examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java)
===================================================================
--- trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java	                        (rev 0)
+++ trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/HierarchicalDAG.java	2006-08-30 01:33:14 UTC (rev 662)
@@ -0,0 +1,182 @@
+// ----------------------------------------------------------------------
+// This code is developed as part of the Java CoG Kit project
+// The terms of the license can be found at http://www.cogkit.org/license
+// This message may not be removed or altered.
+// ----------------------------------------------------------------------
+
+package org.globus.cog.abstraction.examples.taskgraph;
+
+import org.apache.log4j.Logger;
+import org.globus.cog.abstraction.impl.common.StatusEvent;
+import org.globus.cog.abstraction.impl.common.task.IllegalSpecException;
+import org.globus.cog.abstraction.impl.common.task.InvalidSecurityContextException;
+import org.globus.cog.abstraction.impl.common.task.InvalidServiceContactException;
+import org.globus.cog.abstraction.impl.common.task.TaskSubmissionException;
+import org.globus.cog.abstraction.impl.common.taskgraph.TaskGraphHandlerImpl;
+import org.globus.cog.abstraction.impl.common.taskgraph.TaskGraphImpl;
+import org.globus.cog.abstraction.interfaces.ExecutableObject;
+import org.globus.cog.abstraction.interfaces.Status;
+import org.globus.cog.abstraction.interfaces.StatusListener;
+import org.globus.cog.abstraction.interfaces.Task;
+import org.globus.cog.abstraction.interfaces.TaskGraph;
+import org.globus.cog.abstraction.interfaces.TaskGraphHandler;
+import org.globus.cog.abstraction.tools.transfer.FileTransfer;
+
+/*
+ * This class serves as an example to demonstrate the execution of hierarchical
+ * taskgraphs (DAGs). It simply shows the semantics of how a user can create a
+ * hierarchy of task graph and submit additional tasks to an already executing
+ * task graph (a.k.a adding tasks to a "live taskgraph"). The parameters to the
+ * task specification MUST be changed to suite your requirements and
+ * environment.
+ */
+public class HierarchicalDAG implements StatusListener {
+    static Logger logger = Logger.getLogger(HierarchicalDAG.class.getName());
+    protected org.globus.cog.abstraction.interfaces.TaskGraph taskGraph;
+    protected boolean active = false;
+    private boolean submitted = false;
+    private Task task6 = null;
+    private Task task9 = null;
+    private TaskGraph tg5 = null;
+
+    public void createDAG() throws Exception {
+        TaskGraph tg1 = new TaskGraphImpl();
+        try {
+            tg1.setName("TG1");
+            Task task1 = prepareTask("Task1",
+                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile1",
+                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile1");
+            Task task2 = prepareTask("Task2",
+                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile2",
+                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile2");
+            tg1.add(task1);
+            tg1.add(task2);
+            tg1.addDependency(task1, task2);
+
+            TaskGraph tg2 = new TaskGraphImpl();
+            tg2.setName("TG2");
+            Task task3 = prepareTask("Task3",
+                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile3",
+                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile3");
+            Task task4 = prepareTask("Task4",
+                    "gridftp://cold.mcs.anl.gov:2811//home/cog/gridfile4",
+                    "gridftp://hot.mcs.anl.gov:2811//home/cog/gridfile4");
+            tg2.add(task3);
+            tg2.add(task4);
+            tg2.addDependency(task3, task4);
+
+            TaskGraph tg3 = new TaskGraphImpl();
+            tg3.setName("TG3");
+            tg3.add(tg1);
+            tg3.add(tg2);
+            tg3.addDependency(tg1, tg2);
+
+            TaskGraph tg4 = new TaskGraphImpl();
+            tg4.setName("TG4");
+            Task task5 = prepareTask("Task5",
+                    "gridftp://new.mcs.anl.gov:2811//home/cog/gridfile6",
+                    "gridftp://old.mcs.anl.gov:2811//home/cog/gridfile7");
+            tg4.add(tg3);
+            tg4.add(task5);
+            tg4.addDependency(tg3, task5);
+
+            tg5 = new TaskGraphImpl();
+
+            Task task7 = prepareTask("Task7",
+                    "gridftp://old.mcs.anl.gov:2811//home/cog/gridfile8",
+                    "gridftp://new.mcs.anl.gov:2811//home/cog/gridfile9");
+            Task task8 = prepareTask("Task8",
+                    "gridftp://here.mcs.anl.gov:2811//home/cog/gridfile10",
+                    "gridftp://there.mcs.anl.gov:2811//home/cog/gridfile10");
+            task9 = prepareTask("Task9",
+                    "gridftp://here.mcs.anl.gov:2811//home/cog/gridfile11",
+                    "gridftp://there.mcs.anl.gov:2811//home/cog/gridfile11");
+
+            tg5.add(task7);
+            tg5.add(task8);
+            tg5.add(task9);
+            tg5.add(tg4);
+
+            tg5.addDependency(task7, task8);
+            tg5.addDependency(task8, task9);
+            tg5.addDependency(task8, tg4);
+            tg5.addDependency(task9, tg4);
+
+            this.taskGraph = tg5;
+            this.taskGraph.setName("Main Graph");
+            this.taskGraph.addStatusListener(this);
+        } catch (Exception e) {
+            logger.error("Unable to create DAG", e);
+        }
+    }
+
+    public void submitDAG() {
+        TaskGraphHandler handler = new TaskGraphHandlerImpl();
+        try {
+            handler.submit(this.taskGraph);
+            logger.debug("TaskGraph submitted");
+        } catch (InvalidSecurityContextException ise) {
+            logger.error("Security Exception");
+            ise.printStackTrace();
+            System.exit(1);
+        } catch (TaskSubmissionException tse) {
+            logger.error("TaskSubmission Exception");
+            tse.printStackTrace();
+            System.exit(1);
+        } catch (IllegalSpecException ispe) {
+            logger.error("Specification Exception");
+            ispe.printStackTrace();
+            System.exit(1);
+        } catch (InvalidServiceContactException isce) {
+            logger.error("Service Contact Exception");
+            isce.printStackTrace();
+            System.exit(1);
+        }
+    }
+
+    private Task prepareTask(String name, String source, String destination)
+            throws Exception {
+        FileTransfer fileTransfer = new FileTransfer(name, source, destination);
+        fileTransfer.prepareTask();
+        Task task = fileTransfer.getFileTransferTask();
+        task.removeStatusListener(fileTransfer);
+        return task;
+    }
+
+    public void statusChanged(StatusEvent event) {
+        ExecutableObject eo = event.getSource();
+        logger.debug(eo.getName());
+        Status status = event.getStatus();
+        logger.debug("Status changed to: " + status.getStatusString());
+
+        // demonstrating "live" task graphs
+        if (status.getStatusCode() == Status.SUBMITTED && !submitted) {
+            submitted = true;
+            try {
+                task6 = prepareTask("Task6",
+                        "gridftp://this.mcs.anl.gov:2811//home/cog/gridfile12",
+                        "gridftp://that.mcs.anl.gov:2811//home/cog/gridfile12");
+                tg5.addDependency(task6, task9);
+                tg5.add(task6);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+
+        if (status.getStatusCode() == Status.COMPLETED
+                || status.getStatusCode() == Status.FAILED) {
+            logger.info("Task Graph Done");
+            // System.exit(1);
+        }
+    }
+
+    public static void main(String arg[]) {
+        try {
+            HierarchicalDAG dag = new HierarchicalDAG();
+            dag.createDAG();
+            dag.submitDAG();
+        } catch (Exception e) {
+            logger.error("Exception caught: ", e);
+        }
+    }
+}
\ No newline at end of file

Deleted: trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/RemoteCompileExecute.java
===================================================================
--- trunk/current/src/cog/modules/abstraction-examples/src/org/globus/cog/abstraction/examples/taskgraph/RemoteCompileExecute.java	2006-08-28 22:19:16 UTC (rev 656)
+++ trunk/current/src/cog/modules/examples/src/org/globus/cog/abstraction/examples/taskgraph/RemoteCompileExecute.java	2006-08-30 01:33:14 UTC (rev 662)
@@ -1,303 +0,0 @@
-// ----------------------------------------------------------------------
-//This code is developed as part of the Java CoG Kit project
-//The terms of the license can be found at http://www.cogkit.org/license
-//This message may not be removed or altered.
-//----------------------------------------------------------------------
-
-package org.globus.cog.abstraction.examples.taskgraph;
-
-import java.io.File;
-
-import org.apache.log4j.Logger;
-import org.globus.cog.abstraction.examples.transfer.FileTransfer;
-import org.globus.cog.abstraction.impl.common.AbstractionFactory;
-import org.globus.cog.abstraction.impl.common.AbstractionProperties;
-import org.globus.cog.abstraction.impl.common.ProviderMethodException;
-import org.globus.cog.abstraction.impl.common.StatusEvent;
-import org.globus.cog.abstraction.impl.common.task.ExecutionServiceImpl;
-import org.globus.cog.abstraction.impl.common.task.IllegalSpecException;
-import org.globus.cog.abstraction.impl.common.task.InvalidProviderException;
-import org.globus.cog.abstraction.impl.common.task.InvalidSecurityContextException;
-import org.globus.cog.abstraction.impl.common.task.InvalidServiceContactException;
-import org.globus.cog.abstraction.impl.common.task.JobSpecificationImpl;
-import org.globus.cog.abstraction.impl.common.task.ServiceContactImpl;
-import org.globus.cog.abstraction.impl.common.task.TaskImpl;
-import org.globus.cog.abstraction.impl.common.task.TaskSubmissionException;
-import org.globus.cog.abstraction.impl.common.taskgraph.TaskGraphHandlerImpl;
-import org.globus.cog.abstraction.impl.common.taskgraph.TaskGraphImpl;
-import org.globus.cog.abstraction.interfaces.ExecutableObject;
-import org.globus.cog.abstraction.interfaces.ExecutionService;
-import org.globus.cog.abstraction.interfaces.JobSpecification;
-import org.globus.cog.abstraction.interfaces.SecurityContext;
-import org.globus.cog.abstraction.interfaces.ServiceContact;
-import org.globus.cog.abstraction.interfaces.Status;
-import org.globus.cog.abstraction.interfaces.StatusListener;
-import org.globus.cog.abstraction.interfaces.Task;
-import org.globus.cog.abstraction.interfaces.TaskGraph;
-import org.globus.cog.abstraction.interfaces.TaskGraphHandler;
-import org.globus.cog.util.ArgumentParser;
-import org.globus.cog.util.ArgumentParserException;
-
-/*
- * This example demonstrates an execution flow where a local java file needs to
- * be compiled and executed remotely. Then it transfers the stdout of the remote
- * execution back to the local machine.
- */
-public class RemoteCompileExecute implements StatusListener {
-    static Logger logger = Logger.getLogger(RemoteCompileExecute.class
-            .getName());
-    private String serviceContact = null;
-    private String executionProvider = null;
-    private String transferProvider = null;
-    private String sourceFile = null;
-    private String normalizedFileName = null;
-    private String javaHome = null;
-    private String classpath = null;
-    private TaskGraph tg = null;
-
-    public static void main(String args[]) {
-        ArgumentParser ap = new ArgumentParser();
-        ap.setExecutableName("cog-compile-execute");
-        ap.addOption("src", "Name of the Java source file", "filename",
-                ArgumentParser.NORMAL);
-        ap.addAlias("src", "s");
-        ap.addOption("javaHome",
-                "Path of the Java environment on the remote machine", "path",
-                ArgumentParser.NORMAL);
-        ap.addAlias("javaHome", "j");
-        ap.addOption("classpath",
-                "Path of the Java classpath on the remote machine", "path",
-                ArgumentParser.OPTIONAL);
-        ap.addAlias("classpath", "cp");
-        ap.addOption("execution-provider",
-                "Execution provider; available providers: "
-                        + AbstractionProperties.getProviders().toString(),
-                "provider", ArgumentParser.NORMAL);
-        ap.addAlias("execution-provider", "ep");
-        ap.addOption("transfer-provider",
-                "Transfer provider; available providers: "
-                        + AbstractionProperties.getProviders().toString(),
-                "provider", ArgumentParser.NORMAL);
-        ap.addAlias("transfer-provider", "tp");
-        ap.addOption("service-contact", "Service contact for the remote host",
-                "host", ArgumentParser.NORMAL);
-        ap.addAlias("service-contact", "sc");
-        ap.addFlag("verbose",
-                "If enabled, display information about what is being done");
-        ap.addAlias("verbose", "v");
-        ap.addFlag("help", "Display usage");
-        ap.addAlias("help", "h");
-        try {
-            ap.parse(args);
-            if (ap.isPresent("help")) {
-                ap.usage();
-            } else {
-                ap.checkMandatory();
-                try {
-                    RemoteCompileExecute rce = new RemoteCompileExecute();
-                    rce.setServiceContact(ap.getStringValue("service-contact"));
-                    rce.setExecutionProvider(ap
-                            .getStringValue("execution-provider"));
-                    rce.setTransferProvider(ap
-                            .getStringValue("transfer-provider"));
-                    rce.setSourceFile(ap.getStringValue("src"));
-                    rce.setJavaHome(ap.getStringValue("javaHome"));
-                    rce.setClasspath(ap.getStringValue("classpath", null));
-                    rce.prepareTaskGraph();
-                    rce.submit();
-                } catch (Exception e) {
-                    logger.error("Exception in main", e);
-                }
-            }
-        } catch (ArgumentParserException e) {
-            System.err.println("Error parsing arguments: " + e.getMessage());
-            ap.usage();
-        }
-    }
-
-    private void prepareTaskGraph() throws Exception {
-        this.tg = new TaskGraphImpl();
-        tg.setName("Workflow");
-        Task transferTask = prepareFileTransferTask();
-        Task compileTask = prepareCompileTask();
-        Task executeTask = prepareExecutionTask();
-        tg.add(transferTask);
-        tg.add(compileTask);
-        tg.add(executeTask);
-
-        tg.addDependency(transferTask, compileTask);
-        tg.addDependency(compileTask, executeTask);
-        tg.addStatusListener(this);
-    }
-
-    private void submit() {
-        TaskGraphHandler handler = new TaskGraphHandlerImpl();
-        try {
-            handler.submit(this.tg);
-            logger.debug("TaskGraph submitted");
-        } catch (InvalidSecurityContextException ise) {
-            logger.error("Security Exception");
-            ise.printStackTrace();
-            System.exit(1);
-        } catch (TaskSubmissionException tse) {
-            logger.error("TaskSubmission Exception");
-            tse.printStackTrace();
-            System.exit(1);
-        } catch (IllegalSpecException ispe) {
-            logger.error("Specification Exception");
-            ispe.printStackTrace();
-            System.exit(1);
-        } catch (InvalidServiceContactException isce) {
-            logger.error("Service Contact Exception");
-            isce.printStackTrace();
-            System.exit(1);
-        }
-    }
-
-    private Task prepareFileTransferTask() throws Exception {
-        FileTransfer fileTransfer = new FileTransfer("Transfer_Task", "file://"
-                + this.sourceFile, this.transferProvider + "://"
-                + this.serviceContact + "///tmp/" + normalizedFileName
-                + ".java");
-        fileTransfer.prepareTask();
-        Task task = fileTransfer.getFileTransferTask();
-        task.removeStatusListener(fileTransfer);
-        task.addStatusListener(this);
-        return task;
-    }
-
-    private Task prepareCompileTask() throws InvalidProviderException,
-            ProviderMethodException {
-        Task task = new TaskImpl("Compile_Task", Task.JOB_SUBMISSION);
-        JobSpecification spec = new JobSpecificationImpl();
-
-        spec.setExecutable(this.javaHome + "/bin/javac");
-        if (this.classpath != null) {
-            spec.addArgument(" -classpath");
-            spec.addArgument(this.classpath);
-        }
-        spec.addArgument("/tmp/" + this.normalizedFileName + ".java");
-        spec.setRedirected(true);
-        task.setSpecification(spec);
-
-        ExecutionService service = new ExecutionServiceImpl();
-        service.setProvider(this.executionProvider.toLowerCase());
-
-        SecurityContext securityContext = AbstractionFactory
-                .newSecurityContext(this.executionProvider.toLowerCase());
-        securityContext.setCredentials(null);
-        service.setSecurityContext(securityContext);
-
-        ServiceContact sc = new ServiceContactImpl(this.serviceContact);
-        service.setServiceContact(sc);
-        task.addService(service);
-
-        task.addStatusListener(this);
-        return task;
-    }
-
-    private Task prepareExecutionTask() throws InvalidProviderException,
-            ProviderMethodException {
-        Task task = new TaskImpl("Execution_Task", Task.JOB_SUBMISSION);
-
-        JobSpecification spec = new JobSpecificationImpl();
-
-        spec.setExecutable(this.javaHome + "/bin/java");
-        if (this.classpath == null) {
-            spec.addArgument(" -classpath");
-            spec.addArgument("/tmp");
-        } else {
-            spec.addArgument(" -classpath");
-            spec.addArgument("/tmp" + File.pathSeparator + this.classpath);
-        }
-        spec.addArgument(normalizedFileName);
-        spec.setRedirected(true);
-        task.setSpecification(spec);
-
-        ExecutionService service = new ExecutionServiceImpl();
-        service.setProvider(this.executionProvider.toLowerCase());
-
-        SecurityContext securityContext = AbstractionFactory
-                .newSecurityContext(this.executionProvider.toLowerCase());
-        securityContext.setCredentials(null);
-        service.setSecurityContext(securityContext);
-
-        ServiceContact sc = new ServiceContactImpl(this.serviceContact);
-        service.setServiceContact(sc);
-        task.addService(service);
-
-        task.addStatusListener(this);
-        return task;
-    }
-
-    public String getExecutionProvider() {
-        return executionProvider;
-    }
-
-    public void setExecutionProvider(String provider) {
-        this.executionProvider = provider;
-    }
-
-    public String getSourceFile() {
-        return sourceFile;
-    }
-
-    public void setSourceFile(String sourceFile) {
-        this.sourceFile = sourceFile;
-        String filename = this.sourceFile.substring(this.sourceFile
-                .lastIndexOf("/"));
-        filename = filename.substring(1, filename.lastIndexOf(".java"));
-        this.normalizedFileName = filename;
-        logger.debug("Normalized file " + this.normalizedFileName);
-    }
-
-    public String getServiceContact() {
-        return serviceContact;
-    }
-
-    public void setServiceContact(String serviceContact) {
-        this.serviceContact = serviceContact;
-    }
-
-    public String getJavaHome() {
-        return javaHome;
-    }
-
-    public void setJavaHome(String javaHome) {
-        this.javaHome = javaHome;
-    }
-
-    public void statusChanged(StatusEvent event) {
-        ExecutableObject eo = event.getSource();
-        Status status = event.g...
 
[truncated message content]

Thread: [Cogkit-svn] SF.net SVN: cogkit: [662] trunk/current/src/cog/modules

cogkit-svn