First test case for MemSwapUtilizationDisplayFilter

src/test/java/kieker/analysis/plugin/filter/sink/MemSwapUtilizationDisplayFilterTest.java

+package kieker.analysis.plugin.filter.sink;
+
+import static org.hamcrest.core.Is.is;
+import static org.junit.Assert.assertThat;
+import static teetime.framework.test.StageTester.test;
+
+import java.util.Date;
+import java.util.concurrent.TimeUnit;
+
+import org.junit.Before;
+import org.junit.Test;
+
+import kieker.common.record.system.MemSwapUsageRecord;
+
+/**
+ * Test cases for MemSwapUtilizationDisplayFilterTest
+ *
+ * @author Lars Erik Bluemke
+ */
+public class MemSwapUtilizationDisplayFilterTest {
+
+	private MemSwapUsageRecord record;
+	private MemSwapUtilizationDisplayFilter memSwapUtilFilter;
+
+	private final int numberOfEntries = 3;
+	private final TimeUnit recordsTimeUnit = TimeUnit.MILLISECONDS;
+
+	private final long timestamp = 1L;
+	private final String hostname = "test_host";
+	private final long memTotal = 2097152000L;
+	private final long memUsed = 1572864000L;
+	private final long memFree = 524288000L;
+	private final long swapTotal = 20971520L;
+	private final long swapUsed = 15728640L;
+	private final long swapFree = 5242880L;
+
+	@Before
+	public void initializeMemSwapUtilizationDisplayFilter() {
+		record = new MemSwapUsageRecord(timestamp, hostname, memTotal, memUsed, memFree, swapTotal, swapUsed, swapFree);
+		memSwapUtilFilter = new MemSwapUtilizationDisplayFilter(numberOfEntries, recordsTimeUnit);
+	}
+
+	@Test
+	public void xyPlotEntriesShouldBeCorrect() {
+		test(memSwapUtilFilter).and().send(record).to(memSwapUtilFilter.getInputPort()).start();
+
+		final Date date = new Date(TimeUnit.MILLISECONDS.convert(record.getLoggingTimestamp(), recordsTimeUnit));
+		final String minutesAndSeconds = date.toString().substring(14, 19);
+
+		final String id = record.getHostname();
+
+		long actualMemTotal = (long) memSwapUtilFilter.getXYPlot().getEntries(id + " - " + MemSwapUtilizationDisplayFilter.MEM_TOTAL).get(minutesAndSeconds);
+		long actualMemUsed = (long) memSwapUtilFilter.getXYPlot().getEntries(id + " - " + MemSwapUtilizationDisplayFilter.MEM_USED).get(minutesAndSeconds);
+		long actualMemFree = (long) memSwapUtilFilter.getXYPlot().getEntries(id + " - " + MemSwapUtilizationDisplayFilter.MEM_FREE).get(minutesAndSeconds);
+		long actualSwapTotal = (long) memSwapUtilFilter.getXYPlot().getEntries(id + " - " + MemSwapUtilizationDisplayFilter.SWAP_TOTAL).get(minutesAndSeconds);
+		long actualSwapUsed = (long) memSwapUtilFilter.getXYPlot().getEntries(id + " - " + MemSwapUtilizationDisplayFilter.SWAP_USED).get(minutesAndSeconds);
+		long actualSwapFree = (long) memSwapUtilFilter.getXYPlot().getEntries(id + " - " + MemSwapUtilizationDisplayFilter.SWAP_FREE).get(minutesAndSeconds);
+
+		// Converting back form MB to Byte
+		assertThat(actualMemTotal * 1048576, is(memTotal));
+		assertThat(actualMemUsed * 1048576, is(memUsed));
+		assertThat(actualMemFree * 1048576, is(memFree));
+		assertThat(actualSwapTotal * 1048576, is(swapTotal));
+		assertThat(actualSwapUsed * 1048576, is(swapUsed));
+		assertThat(actualSwapFree * 1048576, is(swapFree));
+
+	}
+
+}