| Modifier and Type | Class and Description |
|---|---|
private static class |
MonitorThread.Report
|
Thread.State, Thread.UncaughtExceptionHandler
| Modifier and Type | Field and Description |
|---|---|
private int |
deviceCount
|
private Logger |
logger
|
private String |
nodeName
|
private com.sun.management.OperatingSystemMXBean |
osBean
|
static String |
REPORT_TOPIC
|
private org.apache.kafka.clients.producer.KafkaProducer<String,String> |
reportProducer
|
private Runtime |
runtime
|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY| Constructor and Description |
|---|
MonitorThread(Logger logger,
SystemPropertyCenter propCenter)
|
| Modifier and Type | Method and Description |
|---|---|
private int |
getDeviceCount()
|
private int |
getFanSpeed(int index)
|
private long |
getFreeMemory(int index)
|
private int |
getPowerLimit(int index)
|
private int |
getPowerUsage(int index)
|
private int |
getShutdownTemperatureThreshold(int index)
|
private int |
getSlowDownTemperatureThreshold(int index)
|
private int |
getTemperature(int index)
|
private long |
getTotalMemory(int index)
|
private long |
getUsedMemory(int index)
|
private int |
getUtilizationRate(int index)
|
private int |
initNVML()
|
void |
run()
|
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler,
getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler,
setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yieldpublic static final String REPORT_TOPIC
private final Logger logger
private final org.apache.kafka.clients.producer.KafkaProducer<String,String> reportProducer
private final Runtime runtime
private final com.sun.management.OperatingSystemMXBean osBean
private final int deviceCount
private final String nodeName
public MonitorThread(Logger logger, SystemPropertyCenter propCenter) throws MalformedObjectNameException, ReflectionException, InstanceNotFoundException
private int initNVML()
private int getDeviceCount()
private int getFanSpeed(int index)
private int getUtilizationRate(int index)
private long getFreeMemory(int index)
private long getTotalMemory(int index)
private long getUsedMemory(int index)
private int getTemperature(int index)
private int getSlowDownTemperatureThreshold(int index)
private int getShutdownTemperatureThreshold(int index)
private int getPowerLimit(int index)
private int getPowerUsage(int index)