Commit c806e8e2 authored by Julian Zobel's avatar Julian Zobel
Browse files

Minitor: Write workload to log when available and finished

parent ffdc6432
......@@ -35,6 +35,7 @@ import org.apache.logging.log4j.Logger;
import de.tud.kom.p2psim.api.simengine.SimulatorObserver;
import de.tud.kom.p2psim.impl.simengine.Simulator;
import de.tud.kom.p2psim.impl.util.db.dao.DAO;
import de.tud.kom.p2psim.impl.util.db.dao.metric.ExperimentDAO;
import de.tudarmstadt.maki.simonstrator.api.Event;
import de.tudarmstadt.maki.simonstrator.api.EventHandler;
import de.tudarmstadt.maki.simonstrator.api.Monitor;
......@@ -214,6 +215,13 @@ public class DefaultMonitor implements MonitorComponent, EventHandler,
analyzer.stop(output);
}
output.write("[DefaultMonitor] Stopped. \n");
String wl = ExperimentDAO.getExperimentWorkload();
if(wl != null) {
output.write("---- \n");
output.write(wl);
}
output.close();
} catch (IOException e) {
throw new AssertionError();
......@@ -229,6 +237,14 @@ public class DefaultMonitor implements MonitorComponent, EventHandler,
for (Analyzer analyzer : analyzers) {
analyzer.start();
}
try {
output.write(Time.getFormattedTime() + ": [DefaultMonitor] started, initialized all analyzers.. \n");
} catch (IOException e) {
throw new AssertionError();
}
} else if (type == MONITOR_TEST) {
//
} else if (type == MONITOR_STOP) {
......
......@@ -88,6 +88,13 @@ public class ExperimentDAO extends DAO {
}
return experiment;
}
public static String getExperimentWorkload() {
if(experiment == null)
return null;
return experiment.getWorkload();
}
public static Experiment retrieveExperiment(long pSeed, Map<String, String> pVariables) {
begin();
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment