[Globus Packages] / gridway / examples / drmaa / drmaa_java / Howto2.java Repository:
ViewVC logotype

View of /gridway/examples/drmaa/drmaa_java/Howto2.java

Parent Directory Parent Directory | Revision Log Revision Log | View Revision Graph Revision Graph


Revision 1.1 - (download) (as text) (annotate)
Mon Dec 11 12:54:13 2006 UTC (10 years, 9 months ago) by ruben
Branch: MAIN
CVS Tags: MERGE_POINT_TRUNK_210907, merge_gw52_BEINGRID, GW_5_4_0, GW_5_3_0, GW_5_2_0, GW_5_2_1, GW_5_2_2, GW_5_2_BRANCH_MERGE_210907, GW_5_0_2, GW_5_2_BRANCH_MERGE_051007, from_gw52_BEinGRID, gw_5_2_3, GW_5_2_2_MERGE, globus_4_2_1, globus_4_2_0, MERGE_POINT_TRUNK_051007, globus_4_0_7, globus_4_0_6, globus_4_0_5, HEAD
Branch point for: FALCATA, BEinGRID, gw_5_2_branch, globus_4_0_branch, gw_5_4_branch, COLADA
*** empty log message ***
/* -------------------------------------------------------------------------- */
/* Copyright 2002-2006 GridWay Team, Distributed Systems Architecture         */
/* Group, Universidad Complutense de Madrid                                   */
/*                                                                            */
/* Licensed under the Apache License, Version 2.0 (the "License"); you may    */
/* not use this file except in compliance with the License. You may obtain    */
/* a copy of the License at                                                   */
/*                                                                            */
/* http://www.apache.org/licenses/LICENSE-2.0                                 */
/*                                                                            */
/* Unless required by applicable law or agreed to in writing, software        */
/* distributed under the License is distributed on an "AS IS" BASIS,          */
/* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   */
/* See the License for the specific language governing permissions and        */
/* limitations under the License.                                             */
/* -------------------------------------------------------------------------- */

import org.ggf.drmaa.*;
import java.util.*;

public class Howto2
{
	public static void main (String[] args)
	{
		SessionFactory	factory = SessionFactory.getFactory();
		Session		session = factory.getSession();
		
		try
		{
			session.init(null);
			System.out.println("Session Init success");
					
			JobTemplate jt = session.createJobTemplate();
			
			String	    cwd;		
			jt.setWorkingDirectory(java.lang.System.getProperty("user.dir"));
			cwd = jt.getWorkingDirectory();
			System.out.println("The working directory is: " + cwd);
			
			String	    name;		
			jt.setJobName("ht2");
			name = jt.getJobName();
			System.out.println("The jobTemplate name is: " + name);
						
			jt.setRemoteCommand("/bin/ls");
			jt.setArgs(new String[] {"-l","-a"});
			
			jt.setOutputPath("stdout." + SessionImpl.DRMAA_GW_JOB_ID);
			jt.setErrorPath("stderr." + SessionImpl.DRMAA_GW_JOB_ID);
			
			String id = session.runJob(jt);
			
			System.out.println("Job successfully submitted ID: " + id);
			
			try
			{
				Thread.sleep(1000);
			}
			catch (InterruptedException e)
			{
				// Don't care
			}
			
			
			JobInfo info = session.wait(id, Session.DRMAA_TIMEOUT_WAIT_FOREVER);
			
			if (info.ifAborted())
				System.out.println("Job " + info.getJobId() + " never ran");
			else if (info.ifExited())
				System.out.println("Job " + info.getJobId() + " finished regularly with exit status " + info.getExitStatus());
			else if (info.ifSignaled())
				System.out.println("Job " + info.getJobId() + " finished due to signal " + info.getTerminatingSignal());
			else 
				System.out.println("Job " + info.getJobId() + " finished with unclear conditions");

				
			System.out.println("Job usage:");
			Map rmap = info.getResourceUsage();
			Iterator r = rmap.keySet().iterator();
				
			while(r.hasNext())
			{
				String name2 = (String) r.next();
				String value = (String) rmap.get(name2);
				System.out.println(" " + name2 + "=" + value);
			}
						
			session.deleteJobTemplate(jt);
			
			session.exit();
			System.out.println("Session Exit success");
			

		}
		catch (DrmaaException e)
		{
			e.printStackTrace();
		}
	}
}

Webmaster
ViewVC Help
Powered by ViewVC 1.0.1