Forgot to attach my Exec.java. Sorry! ----- Original Message ----- From: External Lists <[EMAIL PROTECTED]> To: <[EMAIL PROTECTED]> Sent: Saturday, May 06, 2000 3:03 PM Subject: Suggestion for exec task
> We have a need to exec tasks during our build asynchronously, because they > interact with subsequent tasks to automate them. For example: > > <exec command="poke_input" /> > <exec command="thing_to_poke" /> > > Using "start poke_input" doesn't appear to work without it, but perhaps > "poke_input &" would work in Unix. > > So I've implemented a modification to Exec.java (attached) that takes an > optional async="yes|on|true" attribute. The proc.waitFor() and thread joins > will happen asynchronously if async="yes" is set. Otherwise, the behavior > is synchronous as before. > > <exec command="poke_input" async="yes" /> > <exec command="thing_to_poke" /> > > For your evaluation. > > Thanks, > > John > >
/* * The Apache Software License, Version 1.1 * * Copyright (c) 1999 The Apache Software Foundation. All rights * reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in * the documentation and/or other materials provided with the * distribution. * * 3. The end-user documentation included with the redistribution, if * any, must include the following acknowlegement: * "This product includes software developed by the * Apache Software Foundation (http://www.apache.org/)." * Alternately, this acknowlegement may appear in the software itself, * if and wherever such third-party acknowlegements normally appear. * * 4. The names "The Jakarta Project", "Tomcat", and "Apache Software * Foundation" must not be used to endorse or promote products derived * from this software without prior written permission. For written * permission, please contact [EMAIL PROTECTED] * * 5. Products derived from this software may not be called "Apache" * nor may "Apache" appear in their names without prior written * permission of the Apache Group. * * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE * DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. * ==================================================================== * * This software consists of voluntary contributions made by many * individuals on behalf of the Apache Software Foundation. For more * information on the Apache Software Foundation, please see * <http://www.apache.org/>. */ package org.apache.tools.ant.taskdefs; import org.apache.tools.ant.*; import java.io.*; /** * Executes a given command if the os platform is appropriate. * * @author [EMAIL PROTECTED] * @author [EMAIL PROTECTED] */ public class Exec extends Task implements Runnable { private String os; private String out; private File dir; private String command; private String osCommand; private boolean async; private static final int BUFFER_SIZE = 512; public void execute() throws BuildException { run(command); } int err = -1; // assume the worst protected int run(String command) throws BuildException { // test if os match String myos = System.getProperty("os.name"); project.log("Myos = " + myos, Project.MSG_VERBOSE); if ((os != null) && (os.indexOf(myos) < 0)){ // this command will be executed only on the specified OS project.log("Not found in " + os, Project.MSG_VERBOSE); return 0; } // default directory to the project's base directory if (dir == null) dir = project.getBaseDir(); if (myos.toLowerCase().indexOf("windows") >= 0) { osCommand = "cmd /c cd " + dir + " && " + command; } else { String ant = project.getProperty("ant.home"); if (ant == null) throw new BuildException("Property 'ant.home' not found"); String antRun = project.resolveFile(ant + "/bin/antRun").toString(); osCommand = antRun + " " + dir + " " + command; } if (async) { new Thread( this ).start(); return 0; } else { run(); return err; } } public void setDir(String d) { this.dir = project.resolveFile(d); } public void setOs(String os) { this.os = os; } public void setCommand(String command) { this.command = command; } public void setOutput(String out) { this.out = out; } public void setAsync(String async) { this.async = project.toBoolean( async ); } public void run() { try { // show the command project.log(osCommand, "exec", Project.MSG_VERBOSE); // exec command on system runtime Process proc = Runtime.getRuntime().exec(osCommand); PrintWriter fos=null; if( out!=null ) { fos=new PrintWriter( new FileWriter( out ) ); project.log("Output redirected to " + out, Project.MSG_VERBOSE); } // copy input and error to the output stream StreamPumper inputPumper = new StreamPumper(proc.getInputStream(), "exec", project, fos); StreamPumper errorPumper = new StreamPumper(proc.getErrorStream(), "error", project, fos); // starts pumping away the generated output/error inputPumper.start(); errorPumper.start(); // Wait for everything to finish proc.waitFor(); inputPumper.join(); errorPumper.join(); proc.destroy(); // close the output file if required if (fos != null) fos.close(); // check its exit value err = proc.exitValue(); if (err != 0) { project.log("Result: " + err, "exec", Project.MSG_ERR); } } catch (IOException ioe) { throw new BuildException("Error exec: " + osCommand ); } catch (InterruptedException ex) {} } // Inner class for continually pumping the input stream during // Process's runtime. class StreamPumper extends Thread { private BufferedReader din; private String name; private boolean endOfStream = false; private int SLEEP_TIME = 5; private Project project; private PrintWriter fos; public StreamPumper(InputStream is, String name, Project project, PrintWriter fos) { this.din = new BufferedReader(new InputStreamReader(is)); this.name = name; this.project = project; this.fos = fos; } public void pumpStream() throws IOException { byte[] buf = new byte[BUFFER_SIZE]; if (!endOfStream) { String line = din.readLine(); if (line != null) { if (fos == null) project.log(line, name, Project.MSG_INFO); else fos.println(line); } else { endOfStream = true; } } } public void run() { try { try { while (!endOfStream) { pumpStream(); sleep(SLEEP_TIME); } } catch (InterruptedException ie) {} din.close(); } catch (IOException ioe) {} } } }
