christoph/fail
1
Fork 0
Code Actions Packages Releases Activity

experiment.cc (weather-monitor) restored

Browse Source 
The file was accidentally overwritten during last commit... :/

git-svn-id: https://www4.informatik.uni-erlangen.de/i4svn/danceos/trunk/devel/fail@2015 8c4709b5-6ec9-48aa-a5cd-a96041d1645a
This commit is contained in:
hellwig
2013-01-23 14:32:56 +00:00
parent 00f809231f
commit ff7d2ec076
1 changed files with 48 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

99
src/experiments/weather-monitor/experiment.cc
View File

@ -40,7 +40,7 @@ bool WeatherMonitorExperiment::run()
log << "startup" << endl; log << "startup" << endl;
#if 0 #if 1
// STEP 0: record memory map with vptr addresses // STEP 0: record memory map with vptr addresses
GuestListener g; GuestListener g;
while (true) { while (true) {
@ -94,7 +94,7 @@ bool WeatherMonitorExperiment::run()
// -> campaign-ready traces with identical lengths // -> campaign-ready traces with identical lengths
bp.setWatchInstructionPointer(ANY_ADDR); bp.setWatchInstructionPointer(ANY_ADDR);
bp.setCounter(WEATHER_NUMINSTR_TRACING); bp.setCounter(WEATHER_NUMINSTR_TRACING);
#endif #endif
simulator.addListener(&bp); simulator.addListener(&bp);
BPSingleListener ev_count(ANY_ADDR); BPSingleListener ev_count(ANY_ADDR);
simulator.addListener(&ev_count); simulator.addListener(&ev_count);
@ -136,10 +136,10 @@ bool WeatherMonitorExperiment::run()
log << dec << "experiment finished after " << instr_counter log << dec << "experiment finished after " << instr_counter
<< " instructions, seeing wait_end " << WEATHER_NUMITER_AFTER << " times" << endl; << " instructions, seeing wait_end " << WEATHER_NUMITER_AFTER << " times" << endl;
#elif 1 #elif 0
// STEP 3: The actual experiment. // STEP 3: The actual experiment.
#if !LOCAL #if !LOCAL
for (int i = 0; i < 5000; ++i) { // only do 50 sequential experiments, to prevent swapping for (int i = 0; i < 50; ++i) { // only do 50 sequential experiments, to prevent swapping
// 50 exp ~ 0.5GB RAM usage per instance (linearly increasing) // 50 exp ~ 0.5GB RAM usage per instance (linearly increasing)
#endif #endif
@ -159,20 +159,20 @@ bool WeatherMonitorExperiment::run()
param.msg.set_mem_addr(0x00103bdc); param.msg.set_mem_addr(0x00103bdc);
#endif #endif
//int id = param.getWorkloadID(); int id = param.getWorkloadID();
//int instr_offset = param.msg.instr_offset(); int instr_offset = param.msg.instr_offset();
//int mem_addr = param.msg.mem_addr(); int mem_addr = param.msg.mem_addr();
// for each job we're actually doing *8* experiments (one for each bit) // for each job we're actually doing *8* experiments (one for each bit)
for (int bit_offset = 0; bit_offset < 8; ++bit_offset) { for (int bit_offset = 0; bit_offset < 8; ++bit_offset) {
// 8 results in one job // 8 results in one job
WeathermonitorProtoMsg_Result *result = param.msg.add_result(); WeathermonitorProtoMsg_Result *result = param.msg.add_result();
result->set_bit_offset(bit_offset); //!!!!!!!!! result->set_bit_offset(bit_offset);
/*log << dec << "job " << id << " instr " << instr_offset log << dec << "job " << id << " instr " << instr_offset
<< " mem " << mem_addr << "+" << bit_offset << endl; << " mem " << mem_addr << "+" << bit_offset << endl;
log << "restoring state" << endl; log << "restoring state" << endl;
simulator.restore(statename);*/ simulator.restore(statename);
// XXX debug // XXX debug
/* /*
@ -184,21 +184,21 @@ bool WeatherMonitorExperiment::run()
*/ */
// this marks THE END // this marks THE END
/*BPSingleListener ev_end(ANY_ADDR); BPSingleListener ev_end(ANY_ADDR);
ev_end.setCounter(WEATHER_NUMINSTR_TRACING + WEATHER_NUMINSTR_AFTER); ev_end.setCounter(WEATHER_NUMINSTR_TRACING + WEATHER_NUMINSTR_AFTER);
simulator.addListener(&ev_end);*/ simulator.addListener(&ev_end);
// count loop iterations by counting wait_begin() calls // count loop iterations by counting wait_begin() calls
// FIXME would be nice to have a callback API for this as this needs to // FIXME would be nice to have a callback API for this as this needs to
// be done "in parallel" // be done "in parallel"
/*BPSingleListener ev_wait_begin(WEATHER_FUNC_WAIT_BEGIN); BPSingleListener ev_wait_begin(WEATHER_FUNC_WAIT_BEGIN);
simulator.addListener(&ev_wait_begin); simulator.addListener(&ev_wait_begin);
int count_loop_iter_before = 0;*/ int count_loop_iter_before = 0;
// no need to wait if offset is 0 // no need to wait if offset is 0
//if (instr_offset > 0) { if (instr_offset > 0) {
// XXX could be improved with intermediate states (reducing runtime until injection) // XXX could be improved with intermediate states (reducing runtime until injection)
/*bp.setWatchInstructionPointer(ANY_ADDR); bp.setWatchInstructionPointer(ANY_ADDR);
bp.setCounter(instr_offset); bp.setCounter(instr_offset);
simulator.addListener(&bp); simulator.addListener(&bp);
@ -207,18 +207,18 @@ bool WeatherMonitorExperiment::run()
++count_loop_iter_before; ++count_loop_iter_before;
simulator.addListener(&ev_wait_begin); simulator.addListener(&ev_wait_begin);
} }
}*/ }
// --- fault injection --- // --- fault injection ---
/*MemoryManager& mm = simulator.getMemoryManager(); MemoryManager& mm = simulator.getMemoryManager();
byte_t data = mm.getByte(mem_addr); byte_t data = mm.getByte(mem_addr);
byte_t newdata = data ^ (1 << bit_offset); byte_t newdata = data ^ (1 << bit_offset);
mm.setByte(mem_addr, newdata); mm.setByte(mem_addr, newdata);
// note at what IP we did it // note at what IP we did it
int32_t injection_ip = simulator.getRegisterManager().getInstructionPointer(); int32_t injection_ip = simulator.getRegisterManager().getInstructionPointer();
param.msg.set_injection_ip(injection_ip);*/ param.msg.set_injection_ip(injection_ip);
result->set_iter_before_fi(0); //!!!!!!!!!!!!!!!!! result->set_iter_before_fi(count_loop_iter_before);
/*log << "fault injected @ ip " << injection_ip log << "fault injected @ ip " << injection_ip
<< " 0x" << hex << ((int)data) << " -> 0x" << ((int)newdata) << endl; << " 0x" << hex << ((int)data) << " -> 0x" << ((int)newdata) << endl;
// sanity check // sanity check
if (param.msg.has_instr_address() && if (param.msg.has_instr_address() &&
@ -226,13 +226,13 @@ bool WeatherMonitorExperiment::run()
stringstream ss; stringstream ss;
ss << "SANITY CHECK FAILED: " << injection_ip ss << "SANITY CHECK FAILED: " << injection_ip
<< " != " << param.msg.instr_address(); << " != " << param.msg.instr_address();
log << ss.str() << endl;*/ log << ss.str() << endl;
result->set_resulttype(result->UNKNOWN); //!!!!!!!!!!!!!!!! result->set_resulttype(result->UNKNOWN);
result->set_latest_ip(42); //!!!!!!!!!!!!!!!! result->set_latest_ip(injection_ip);
result->set_details("test"); //!!!!!!!!!!!!!!!! result->set_details(ss.str());
result->set_iter_after_fi(0); //!!!!!!!!!!!!!!!! result->set_iter_after_fi(0);
//simulator.clearListeners(); simulator.clearListeners();
continue; continue;
} }
@ -250,7 +250,7 @@ bool WeatherMonitorExperiment::run()
// - (XXX "sane" display?) // - (XXX "sane" display?)
// catch traps as "extraordinary" ending // catch traps as "extraordinary" ending
/*TrapListener ev_trap(ANY_TRAP); TrapListener ev_trap(ANY_TRAP);
simulator.addListener(&ev_trap); simulator.addListener(&ev_trap);
// jump outside text segment // jump outside text segment
BPRangeListener ev_below_text(ANY_ADDR, WEATHER_TEXT_START - 1); BPRangeListener ev_below_text(ANY_ADDR, WEATHER_TEXT_START - 1);
@ -263,7 +263,7 @@ bool WeatherMonitorExperiment::run()
// timeout (e.g., stuck in a HLT instruction) // timeout (e.g., stuck in a HLT instruction)
// 10000us = 500000 instructions // 10000us = 500000 instructions
TimerListener ev_timeout(10000); TimerListener ev_timeout(10000);
simulator.addListener(&ev_timeout); */ simulator.addListener(&ev_timeout);
#if LOCAL && 0 #if LOCAL && 0
// XXX debug // XXX debug
@ -275,60 +275,57 @@ bool WeatherMonitorExperiment::run()
simulator.addFlow(&tp); simulator.addFlow(&tp);
#endif #endif
/*BaseListener* ev; BaseListener* ev;
// count loop iterations // count loop iterations
int count_loop_iter_after = 0; int count_loop_iter_after = 0;
while ((ev = simulator.resume()) == &ev_wait_begin) { while ((ev = simulator.resume()) == &ev_wait_begin) {
++count_loop_iter_after; ++count_loop_iter_after;
simulator.addListener(&ev_wait_begin); simulator.addListener(&ev_wait_begin);
}*/ }
//result->set_iter_after_fi(42); //!!!!!!!!!!!! result->set_iter_after_fi(count_loop_iter_after);
// record latest IP regardless of result // record latest IP regardless of result
//result->set_latest_ip(0x42); //!!!!!!!!!! result->set_latest_ip(simulator.getRegisterManager().getInstructionPointer());
//result->set_resulttype(result->FINISHED); if (ev == &ev_end) {
/*if (ev == &ev_end) {
log << "Result FINISHED (" << dec log << "Result FINISHED (" << dec
<< count_loop_iter_before << "+" << count_loop_iter_after << ")" << endl; << count_loop_iter_before << "+" << count_loop_iter_after << ")" << endl;
result->set_resulttype(result->FINISHED); //!!!!!!!!! result->set_resulttype(result->FINISHED);
} else if (ev == &ev_timeout) { } else if (ev == &ev_timeout) {
log << "Result TIMEOUT (" << dec log << "Result TIMEOUT (" << dec
<< count_loop_iter_before << "+" << count_loop_iter_after << ")" << endl; << count_loop_iter_before << "+" << count_loop_iter_after << ")" << endl;
result->set_resulttype(result->TIMEOUT); //!!!!!!!!! result->set_resulttype(result->TIMEOUT);
} else if (ev == &ev_below_text || ev == &ev_beyond_text) { } else if (ev == &ev_below_text || ev == &ev_beyond_text) {
log << "Result OUTSIDE" << endl; log << "Result OUTSIDE" << endl;
result->set_resulttype(result->OUTSIDE); //!!!!!!!!! result->set_resulttype(result->OUTSIDE);
} else if (ev == &ev_trap) { } else if (ev == &ev_trap) {
log << dec << "Result TRAP #" << ev_trap.getTriggerNumber() << endl; log << dec << "Result TRAP #" << ev_trap.getTriggerNumber() << endl;
result->set_resulttype(result->TRAP); //!!!!!!!!! result->set_resulttype(result->TRAP);
stringstream ss; stringstream ss;
ss << ev_trap.getTriggerNumber(); ss << ev_trap.getTriggerNumber();
result->set_details(ss.str()); //!!!!!!!! result->set_details(ss.str());
} else if (ev == &ev_detected) { } else if (ev == &ev_detected) {
log << dec << "Result DETECTED" << endl; log << dec << "Result DETECTED" << endl;
result->set_resulttype(result->DETECTED); //!!!!!!!! result->set_resulttype(result->DETECTED);
} else { } else {
log << "Result WTF?" << endl; log << "Result WTF?" << endl;
result->set_resulttype(result->UNKNOWN); //!!!!!!!! result->set_resulttype(result->UNKNOWN);
stringstream ss; stringstream ss;
ss << "eventid " << /*ev->getId() << " EIP " << simulator.getRegisterManager().getInstructionPointer();*/ ss << "eventid " << ev->getId() << " EIP " << simulator.getRegisterManager().getInstructionPointer();
//result->set_details(ss.str()); //!!!!!!! result->set_details(ss.str());
}
//result->set_details("test"); }
// sanity check: do we have exactly 8 results? // sanity check: do we have exactly 8 results?
/*if (param.msg.result_size() != 8) { if (param.msg.result_size() != 8) {
log << "WTF? param.msg.result_size() != 8" << endl; log << "WTF? param.msg.result_size() != 8" << endl;
} else {*/ } else {
#if !LOCAL #if !LOCAL
m_jc.sendResult(param); m_jc.sendResult(param);
#endif #endif
//} }
#if !LOCAL #if !LOCAL
} }