org.spf4j.os

Class OperatingSystem

java.lang.Object

org.spf4j.os.OperatingSystem

public final class OperatingSystem
extends Object

Utility to wrap access to JDK specific Operating system Mbean attributes.

Author:

Zoltan Farkas

Field Summary

Fields

Modifier and Type	Field and Description
static long	MAX_NR_OPENFILES

Method Summary

Modifier and Type	Method and Description
static String	forkExec(String[] command, long timeoutMillis)
static <T,E> ProcessResponse<T,E>	forkExec(String[] command, ProcessHandler<T,E> handler, long timeoutMillis, long terminationTimeoutMillis) Process execution utility.
static void	forkExecLog(String[] command, long timeoutMillis)
static long	getMaxFileDescriptorCount()
static long	getOpenFileDescriptorCount()
static OperatingSystemMXBean	getOSMbean()
static com.sun.management.OperatingSystemMXBean	getSunJdkOSMBean()
static com.sun.management.UnixOperatingSystemMXBean	getUnixOsMBean()
static int	killProcess(Process proc, long terminateTimeoutMillis, long forceTerminateTimeoutMillis)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_NR_OPENFILES

public static final long MAX_NR_OPENFILES

Method Detail

getOSMbean

public static OperatingSystemMXBean getOSMbean()

getSunJdkOSMBean

@Nullable
public static com.sun.management.OperatingSystemMXBean getSunJdkOSMBean()

getUnixOsMBean

@Nullable
public static com.sun.management.UnixOperatingSystemMXBean getUnixOsMBean()

getOpenFileDescriptorCount

public static long getOpenFileDescriptorCount()

getMaxFileDescriptorCount

public static long getMaxFileDescriptorCount()

killProcess

public static int killProcess(Process proc,
                              long terminateTimeoutMillis,
                              long forceTerminateTimeoutMillis)
                       throws InterruptedException,
                              TimeoutException

Throws:

InterruptedException

TimeoutException

forkExec

public static <T,E> ProcessResponse<T,E> forkExec(String[] command,
                                                  ProcessHandler<T,E> handler,
                                                  long timeoutMillis,
                                                  long terminationTimeoutMillis)
                                           throws IOException,
                                                  InterruptedException,
                                                  ExecutionException,
                                                  TimeoutException

Process execution utility.

Type Parameters:

T - type the stdout is reduced to.

E - type stderr is reduced to.

Parameters:

command - the command to execute.

handler - handler for child stdin, stdout and stderr. stdout and stderr handling will be done in 2 threads from the DefaultExecutor thread pool. while stdin handling will execute in the current thread.

timeoutMillis - time to wait for the process to execute.

terminationTimeoutMillis - this is the timeout used when trying to terminate the process gracefully.

Returns:

the response (respCode, stdout reduction, stderr reduction)

Throws:

IOException

InterruptedException

ExecutionException

TimeoutException - when timeout happens.

forkExec

@CheckReturnValue
public static String forkExec(String[] command,
                                                long timeoutMillis)
                                         throws IOException,
                                                InterruptedException,
                                                ExecutionException,
                                                TimeoutException

Throws:

IOException

InterruptedException

ExecutionException

TimeoutException

forkExecLog

public static void forkExecLog(String[] command,
                               long timeoutMillis)
                        throws IOException,
                               InterruptedException,
                               ExecutionException,
                               TimeoutException

Throws:

IOException

InterruptedException

ExecutionException

TimeoutException