Examples of ProcessExecutor

ProcessExecuting.ProcessExecutor
@author partizanka
com.sun.enterprise.util.ProcessExecutor
@author Kedar @version 1.0
org.epic.core.util.ProcessExecutor
Responsible for execution of external, non-interactive processes which expect input in form of command-line parameters and stdin and provide output through stdout and/or stderr.
The Perl interpreter is one such process (when run non-interactively). A specialized client class is available for this case and should be used instead of the generic ProcessExecutor.
@see org.epic.core.util.PerlExecutor2 @author jploski
org.geotools.process.ProcessExecutor
An {@link Executor} that provides methods to manage termination andmethods that can produce a {@link Progress} for tracking one or moreasynchronous tasks.
Method submit extends base method {@link ExecutorService#submit} by creating and returning a{@link Progress} that can be used to track how a processis doing in addition to cancelling execution and/or waiting for completion. @author Jody @source $URL$
org.rhq.core.util.exec.ProcessExecutor
Executes processes using the Java API. This instance is thread safe and can be reused.
Warning: caution should be exercised when using this class - it allows any process to be started with no security restrictions.
@author John Mazzitelli
org.zeroturnaround.exec.ProcessExecutor
Helper for executing sub processes.
It's implemented as a wrapper of {@link ProcessBuilder} complementing it with additional features such as:
- Handling process streams (copied from Commons Exec library).
- Destroying process on VM exit (copied from Commons Exec library).
- Checking process exit code.
- Setting a timeout for running the process and automatically stopping it in case of timeout.
- Either waiting for the process to finish ( {@link #execute()}) or returning a {@link Future} ({@link #start()}.
- Reading the process output stream into a buffer ( {@link #readOutput(boolean)}, {@link ProcessResult}).
The default configuration for executing a process is following:
- Process is not automatically destroyed on VM exit.
- Error stream is redirected to its output stream. Use {@link #redirectErrorStream(boolean)} to override it.
- Output stream is pumped to a {@link NullOutputStream}, Use {@link #streams(ExecuteStreamHandler)}, {@link #redirectOutput(OutputStream)}, or any of the redirectOutputAs* methods.to override it.
- Any exit code is allowed. Use {@link #exitValues(Integer)} to override it.
- In case of timeout or cancellation {@link Process#destroy()} is invoked.

Examples of com.sun.enterprise.util.ProcessExecutor

            path2Auths = System.getProperty("PATH_2_AUTHS");
        if (System.getProperty("AUTH_TOKEN") != null)
            at = System.getProperty("AUTH_TOKEN");
        try {
            final String[] cmd = new String[]{path2Auths, user};
            ProcessExecutor pe = new ProcessExecutor(cmd);
            pe.setExecutionRetentionFlag(true);
            pe.execute();
            auths.append(pe.getLastExecutionOutput());
            final StringTokenizer st = new StringTokenizer(pe.getLastExecutionOutput(), at);
            while (st.hasMoreTokens()) {
                String t = st.nextToken();
                if (t != null)
                    t = t.trim();
                if (AUTH1.equals(t) || AUTH2.equals(t) || AUTH3.equals(t)) {

View Full Code Here

Examples of com.sun.enterprise.util.ProcessExecutor


    private boolean serviceNameExists(final String sn) {
        boolean exists = false;
        try {
            final String[] cmd = new String[]{"/usr/bin/svcs", sn};
            ProcessExecutor pe = new ProcessExecutor(cmd);
            pe.setExecutionRetentionFlag(true);
            pe.execute();
            exists = true;
        }
        catch (final Exception e) {
            //returns a non-zero status -- the service does not exist, status is already set
        }

View Full Code Here

Examples of com.sun.enterprise.util.ProcessExecutor

            printOut("Manifest validated: " + manifestPath);
    }


    private void validateService() throws Exception {
        final String[] cmda = new String[]{SMFService.SVCCFG, "validate", getManifestFilePath()};
        final ProcessExecutor pe = new ProcessExecutor(cmda);
        pe.execute();
        if (info.trace)
            printOut("Validated the SMF Service: " + info.fqsn + " using: " + SMFService.SVCCFG);
    }

View Full Code Here

Examples of com.sun.enterprise.util.ProcessExecutor

            printOut("Validated the SMF Service: " + info.fqsn + " using: " + SMFService.SVCCFG);
    }


    private boolean importService() throws Exception {
        final String[] cmda = new String[]{SMFService.SVCCFG, "import", getManifestFilePath()};
        final ProcessExecutor pe = new ProcessExecutor(cmda);


        if (info.dryRun)
            cleanupManifest();
        else
            pe.execute(); //throws ExecException in case of an error


        if (info.trace)
            printOut("Imported the SMF Service: " + info.fqsn);
        return (true);
    }

View Full Code Here

Examples of com.sun.enterprise.util.ProcessExecutor

            path2Auths = System.getProperty("PATH_2_AUTHS");
        if (System.getProperty("AUTH_TOKEN") != null)
            at = System.getProperty("AUTH_TOKEN");
        try {
            final String[] cmd = new String[]{path2Auths, user};
            ProcessExecutor pe = new ProcessExecutor(cmd);
            pe.setExecutionRetentionFlag(true);
            pe.execute();
            auths.append(pe.getLastExecutionOutput());
            final StringTokenizer st = new StringTokenizer(pe.getLastExecutionOutput(), at);
            while (st.hasMoreTokens()) {
                String t = st.nextToken();
                if (t != null)
                    t = t.trim();
                if (AUTH1.equals(t) || AUTH2.equals(t) || AUTH3.equals(t)) {

View Full Code Here

Examples of com.sun.enterprise.util.ProcessExecutor


    private boolean serviceNameExists(final String sn) {
        boolean exists = false;
        try {
            final String[] cmd = new String[]{"/usr/bin/svcs", sn};
            ProcessExecutor pe = new ProcessExecutor(cmd);
            pe.setExecutionRetentionFlag(true);
            pe.execute();
            exists = true;
        }
        catch (final Exception e) {
            //returns a non-zero status -- the service does not exist, status is already set
        }

View Full Code Here

Examples of com.sun.enterprise.util.ProcessExecutor

            printOut("Manifest validated: " + manifestPath);
    }


    private void validateService() throws Exception {
        final String[] cmda = new String[]{SMFService.SVCCFG, "validate", getManifestFilePath()};
        final ProcessExecutor pe = new ProcessExecutor(cmda);
        pe.execute();
        if (info.trace)
            printOut("Validated the SMF Service: " + info.fqsn + " using: " + SMFService.SVCCFG);
    }

View Full Code Here

Examples of com.sun.enterprise.util.ProcessExecutor

            printOut("Validated the SMF Service: " + info.fqsn + " using: " + SMFService.SVCCFG);
    }


    private boolean importService() throws Exception {
        final String[] cmda = new String[]{SMFService.SVCCFG, "import", getManifestFilePath()};
        final ProcessExecutor pe = new ProcessExecutor(cmda);


        if (info.dryRun)
            cleanupManifest();
        else
            pe.execute(); //throws ExecException in case of an error


        if (info.trace)
            printOut("Imported the SMF Service: " + info.fqsn);
        return (true);
    }

View Full Code Here

Examples of org.epic.core.util.ProcessExecutor

{
    public CygwinPathMapper() throws CoreException
    {
        try
        {        
            ProcessExecutor executor = new ProcessExecutor();
            ProcessOutput output = 
                executor.execute(new String[] { "mount" }, "", new File("."), null);
            
            initMappings(output.stdout.replaceAll("\n", "\r\n"));
        }
        catch (InterruptedException e) { /* can't occur */ }
        catch (IOException e)

View Full Code Here

Examples of org.geotools.process.ProcessExecutor

        Geometry geom = wktReader.read("MULTIPOINT (1 1, 5 4, 7 9, 5 5, 2 2)");
        
        Name name = new NameImpl("tutorial","octagonalEnvelope");
        Process process = Processors.createProcess( name );
        
        ProcessExecutor engine = Processors.newProcessExecutor(2);
        
        // quick map of inputs
        Map<String,Object> input = new KVP("geom", geom);
        Progress working = engine.submit(process, input );
        
        // you could do other stuff whle working is doing its thing
        if( working.isCancelled() ){
            return;
        }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.