Initial commit

Author: jlsalmon

.gitattributes

@@ -0,0 +1 @@
+* text=auto

.gitignore

@@ -0,0 +1,21 @@
+# Build files
+*.class
+build/
+target/
+
+# IDE files
+*.iml
+.idea/
+.settings/
+.classpath
+.project
+
+# Package Files
+*.jar
+
+# Virtual machine crash logs
+hs_err_pid*
+
+# MacOSX files
+.DS_Store
+

pom.xml

@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <artifactId>c2mon-daq-parent</artifactId>
+    <groupId>cern.c2mon.daq</groupId>
+    <version>1.8.0-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>c2mon-daq-hostmetrics</artifactId>
+  <version>0.0.1-SNAPSHOT</version>
+
+  <dependencies>
+    <!-- C2MON dependencies -->
+    <dependency>
+      <groupId>cern.c2mon.daq</groupId>
+      <artifactId>c2mon-daq-core</artifactId>
+    </dependency>
+
+    <!-- 3rd party dependencies -->
+    <dependency>
+      <groupId>com.github.dblock</groupId>
+      <artifactId>oshi-core</artifactId>
+      <version>3.2</version>
+    </dependency>
+    <dependency>
+      <groupId>org.projectlombok</groupId>
+      <artifactId>lombok</artifactId>
+    </dependency>
+  </dependencies>
+</project>

src/main/java/cern/c2mon/daq/hostmetrics/HostMetricsMessageHandler.java

@@ -0,0 +1,46 @@
+package cern.c2mon.daq.hostmetrics;
+
+import cern.c2mon.daq.common.EquipmentMessageHandler;
+import cern.c2mon.daq.common.IEquipmentMessageSender;
+import cern.c2mon.daq.tools.equipmentexceptions.EqIOException;
+import cern.c2mon.shared.common.datatag.ValueUpdate;
+import lombok.extern.slf4j.Slf4j;
+import oshi.SystemInfo;
+import oshi.hardware.HardwareAbstractionLayer;
+
+import java.util.concurrent.Executors;
+
+import static java.util.concurrent.TimeUnit.SECONDS;
+
+/**
+ * Simple {@link EquipmentMessageHandler} implementation that uses the OSHI
+ * library to publish metrics about the current host.
+ *
+ * @author Justin Lewis Salmon
+ */
+@Slf4j
+public class HostMetricsMessageHandler extends EquipmentMessageHandler {
+
+  @Override
+  public void connectToDataSource() throws EqIOException {
+    IEquipmentMessageSender sender = getEquipmentMessageSender();
+    sender.confirmEquipmentStateOK();
+
+    HardwareAbstractionLayer hal = new SystemInfo().getHardware();
+
+    Executors.newScheduledThreadPool(1).scheduleAtFixedRate(() -> {
+      sender.update("mem.avail", new ValueUpdate(hal.getMemory().getAvailable()));
+      sender.update("mem.swap.used", new ValueUpdate(hal.getMemory().getSwapUsed()));
+      sender.update("cpu.loadavg", new ValueUpdate(hal.getProcessor().getSystemLoadAverage()));
+    }, 0, 1, SECONDS);
+  }
+
+  @Override
+  public void disconnectFromDataSource() throws EqIOException {}
+
+  @Override
+  public void refreshAllDataTags() {}
+
+  @Override
+  public void refreshDataTag(long dataTagId) {}
+}