From 69934c7eefe375d527ba6d24603a6a7459f8d78a Mon Sep 17 00:00:00 2001
From: hsc <hsc@8c4709b5-6ec9-48aa-a5cd-a96041d1645a>
Date: Thu, 13 Sep 2012 21:27:13 +0000
Subject: [PATCH] RAMpage experiment: output state machine in place

git-svn-id: https://www4.informatik.uni-erlangen.de/i4svn/danceos/trunk/devel/fail@1642 8c4709b5-6ec9-48aa-a5cd-a96041d1645a
---
 src/experiments/rampage/experiment.cc  | 66 ++++++++++++++++++++------
 src/experiments/rampage/experiment.hpp |  9 ++++
 2 files changed, 60 insertions(+), 15 deletions(-)

diff --git a/src/experiments/rampage/experiment.cc b/src/experiments/rampage/experiment.cc
index da211759..14b7da30 100644
--- a/src/experiments/rampage/experiment.cc
+++ b/src/experiments/rampage/experiment.cc
@@ -16,6 +16,11 @@
 
 #define LOCAL 1
 
+#define STR_STATS    "calculating stats"
+#define STR_START    "starting test pass"
+#define STR_TESTED   "tested "
+#define STR_BADFRAME "bad frame at pfn "
+
 using namespace std;
 using namespace fail;
 
@@ -29,8 +34,6 @@ using namespace fail;
 
 bool RAMpageExperiment::run()
 {
-	string output;
-	Logger log("RAMpage", false);
 	address_t addr1 = 1024*1024*62+3;
 	int bit1 = 3;
 	address_t addr2 = 1024*1024*63+8;
@@ -75,28 +78,61 @@ bool RAMpageExperiment::run()
 			data2 |= ((data & (1 << bit1)) == 0) << bit2;
 			mm.setByte(addr2, data2);
 #endif
-			log << "access to addr 0x" << std::hex << addr1 << ", FI!" << endl;
+			m_log << "access to addr 0x" << std::hex << addr1 << ", FI!" << endl;
 		} else if (l == &l_io) {
 			simulator.addListener(&l_io);
-			output += l_io.getData();
-			if (l_io.getData() == '\n') {
-				// calculating stats
-				// starting test pass
-				// tested %08x-%08x %08x-%08x ...
-				// bad frame at pfn %08x
-				// TODO scan + react
-				output.clear();
-
-				// restart local timer
+			if (handleIO(l_io.getData())) {
+				// we saw some progress, restart local timer
 				simulator.removeListener(&l_timeout_local);
 				simulator.addListener(&l_timeout_local);
 			}
 		} else if (l == &l_timeout_local) {
-			log << "local timeout" << std::endl;
+			m_log << "local timeout" << std::endl;
 		} else if (l == &l_timeout_global) {
-			log << "global timeout" << std::endl;
+			m_log << "global timeout" << std::endl;
 		}
 	}
 
 	return true;
 }
+
+bool RAMpageExperiment::handleIO(char c)
+{
+	if (c != '\n') {
+		m_output += c;
+		return false;
+	}
+
+	// calculating stats
+	if (!m_output.compare(0, sizeof(STR_STATS)-1, STR_STATS)) {
+		if (last_line_was_startingtestpass) {
+			// result: NO_PFNS_TESTED
+			m_log << "no PFNs were tested this time" << std::endl;
+			simulator.terminate();
+		}
+		m_log << STR_STATS << std::endl;
+
+	// starting test pass
+	} else if (!m_output.compare(0, sizeof(STR_START)-1, STR_START)) {
+		last_line_was_startingtestpass = true;
+		m_log << STR_START << std::endl;
+
+	// tested %08x-%08x %08x-%08x ...
+	} else if (!m_output.compare(0, sizeof(STR_TESTED)-1, STR_TESTED)) {
+		last_line_was_startingtestpass = false;
+		m_log << STR_TESTED << std::endl;
+
+	// bad frame at pfn %08x
+	} else if (!m_output.compare(0, sizeof(STR_BADFRAME)-1, STR_BADFRAME)) {
+		m_log << STR_BADFRAME << std::endl;
+
+		simulator.terminate();
+	} else {
+		// unknown
+		m_log << "wtf unknown: " << m_output << std::endl;
+		simulator.terminate();
+	}
+
+	m_output.clear();
+	return true;
+}
diff --git a/src/experiments/rampage/experiment.hpp b/src/experiments/rampage/experiment.hpp
index 7522d0cd..e1d503f2 100644
--- a/src/experiments/rampage/experiment.hpp
+++ b/src/experiments/rampage/experiment.hpp
@@ -1,12 +1,21 @@
 #ifndef __RAMPAGE_EXPERIMENT_HPP__
   #define __RAMPAGE_EXPERIMENT_HPP__
   
+#include <string>
+
 #include "efw/ExperimentFlow.hpp"
 #include "efw/JobClient.hpp"
+#include "util/Logger.hpp"
 
 class RAMpageExperiment : public fail::ExperimentFlow {
 	fail::JobClient m_jc;
+	fail::Logger m_log;
+	std::string m_output;
+	bool last_line_was_startingtestpass;
+
+	bool handleIO(char c);
 public:
+	RAMpageExperiment() : m_log("RAMpage"), last_line_was_startingtestpass(false) {}
 	bool run();
 };