alluxio.hub.agent.util.process

Class LinuxProcessTable

java.lang.Object

alluxio.hub.agent.util.process.LinuxProcessTable

All Implemented Interfaces:

ProcessTable

public class LinuxProcessTable
extends Object
implements ProcessTable

A class representing query-able information about the running system's process table.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.hub.agent.util.process.ProcessTable

ProcessTable.Factory

Constructor Summary

Constructors

Constructor and Description
LinuxProcessTable()

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<Integer>	getAllPids() Get all PIDs running on the system.
List<Integer>	getJavaPid(java.util.stream.Stream<Integer> possiblePids, Class<?> clazz) Gets a Java PID running with the given class.
java.util.stream.Stream<Integer>	getJavaPids() Gets all the Java PIDs on the system that are readable by the current process.
boolean	isProcessAlive(int pid)

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.hub.agent.util.process.ProcessTable

isProcessDead, stopProcess

Constructor Detail

LinuxProcessTable

public LinuxProcessTable()

Method Detail

getJavaPids

public java.util.stream.Stream<Integer> getJavaPids()
                                             throws IOException

Description copied from interface: ProcessTable

Gets all the Java PIDs on the system that are readable by the current process. In testing on a half-utilized 32-core system, this method takes ~25ms to execute, so use it sparingly.

Specified by:

getJavaPids in interface ProcessTable

Returns:

a list of PIDs that belong to java processes

Throws:

IOException - if the /proc filesystem is not available

getAllPids

public java.util.stream.Stream<Integer> getAllPids()
                                            throws IOException

Description copied from interface: ProcessTable

Get all PIDs running on the system.

Specified by:

getAllPids in interface ProcessTable

Returns:

a stream of PIDs

Throws:

IOException - if the program cannot read the process table

getJavaPid

public List<Integer> getJavaPid(@Nullable
                                java.util.stream.Stream<Integer> possiblePids,
                                Class<?> clazz)
                         throws IOException

Description copied from interface: ProcessTable

Gets a Java PID running with the given class.

Specified by:

getJavaPid in interface ProcessTable

Parameters:

possiblePids - a list of PIDs to check. If null, it will check all PIDs on the system

clazz - the main class of the process that should be running

Returns:

a list of PIDs running with that main class

Throws:

IOException

isProcessAlive

public boolean isProcessAlive(int pid)

Specified by:

isProcessAlive in interface ProcessTable

Parameters:

pid - pid to test

Returns:

whether the process is alive