Package com.linkedin.venice.utils

Class ForkedJavaProcess

java.lang.Object

java.lang.Process

com.linkedin.venice.utils.ForkedJavaProcess

public final class ForkedJavaProcess
extends Process

Adapted from https://stackoverflow.com/a/723914/791758

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ForkedJavaProcess.LogInfo

Method Summary

Modifier and Type	Method	Description
void	destroy()
static ForkedJavaProcess	exec(Class appClass, String... args)
static ForkedJavaProcess	exec(Class appClass, List<String> args, List<String> jvmArgs)
static ForkedJavaProcess	exec(Class appClass, List<String> args, List<String> jvmArgs, boolean killOnExit)
static ForkedJavaProcess	exec(Class appClass, List<String> args, List<String> jvmArgs, boolean killOnExit, Optional<LogContext> loggerPrefix)
static ForkedJavaProcess	exec(Class appClass, List<String> args, List<String> jvmArgs, String classPath, boolean killOnExit, Optional<LogContext> logContext)
int	exitValue()
static String	getClasspath()
InputStream	getErrorStream()
InputStream	getInputStream()
OutputStream	getOutputStream()
long	pid()
static void	processAndExtractLevelFromForkedProcessLog(ForkedJavaProcess.LogInfo logInfo, String log)
int	waitFor()

Methods inherited from class java.lang.Process

children, descendants, destroyForcibly, errorReader, errorReader, info, inputReader, inputReader, isAlive, onExit, outputWriter, outputWriter, supportsNormalTermination, toHandle, waitFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

exec

public static ForkedJavaProcess exec(Class appClass,
 List<String> args,
 List<String> jvmArgs,
 String classPath,
 boolean killOnExit,
 Optional<LogContext> logContext)
                              throws IOException

Throws:

IOException

exec

public static ForkedJavaProcess exec(Class appClass,
 List<String> args,
 List<String> jvmArgs,
 boolean killOnExit,
 Optional<LogContext> loggerPrefix)
                              throws IOException

Throws:

IOException

exec

public static ForkedJavaProcess exec(Class appClass,
 List<String> args,
 List<String> jvmArgs,
 boolean killOnExit)
                              throws IOException

Throws:

IOException

exec

public static ForkedJavaProcess exec(Class appClass,
 List<String> args,
 List<String> jvmArgs)
                              throws IOException

Throws:

IOException

exec

public static ForkedJavaProcess exec(Class appClass,
 String... args)
                              throws IOException

Throws:

IOException

getClasspath

public static String getClasspath()

destroy

public void destroy()

Specified by:

destroy in class Process

processAndExtractLevelFromForkedProcessLog

public static void processAndExtractLevelFromForkedProcessLog(ForkedJavaProcess.LogInfo logInfo,
 String log)

pid

public long pid()

Overrides:

pid in class Process

getOutputStream

public OutputStream getOutputStream()

Specified by:

getOutputStream in class Process

getInputStream

public InputStream getInputStream()

Specified by:

getInputStream in class Process

getErrorStream

public InputStream getErrorStream()

Specified by:

getErrorStream in class Process

waitFor

public int waitFor()
            throws InterruptedException

Specified by:

waitFor in class Process

Throws:

InterruptedException

exitValue

public int exitValue()

Specified by:

exitValue in class Process