Gabe Black has uploaded this change for review. (
https://gem5-review.googlesource.com/c/public/gem5/+/12049
Change subject: systemc: Adjust process status tracking to improve
kill/reset support.
......................................................................
systemc: Adjust process status tracking to improve kill/reset support.
This change rearranges how process status is tracked so that the kill
and reset mechanisms work in more circumstances and more like they're
supposed to according to the spec. This makes another test or two pass.
Change-Id: Ie2a683a796155a82092109d5bb45f07c84e06c76
---
M src/systemc/core/process.cc
M src/systemc/core/process.hh
M src/systemc/core/process_types.hh
3 files changed, 48 insertions(+), 19 deletions(-)
diff --git a/src/systemc/core/process.cc b/src/systemc/core/process.cc
index 6a0e7d5..6b4c427 100644
--- a/src/systemc/core/process.cc
+++ b/src/systemc/core/process.cc
@@ -32,6 +32,8 @@
#include "base/logging.hh"
#include "systemc/core/event.hh"
#include "systemc/core/scheduler.hh"
+#include "systemc/ext/core/sc_process_handle.hh"
+#include "systemc/ext/utils/sc_report_handler.hh"
namespace sc_gem5
{
@@ -201,14 +203,15 @@
return;
// Update our state.
- _terminated = true;
+ terminate();
_isUnwinding = true;
- _suspendedReady = false;
- _suspended = false;
- _syncReset = false;
- // Inject the kill exception into this process.
- injectException(killException);
+ // Make sure this process isn't marked ready
+ popListNode();
+
+ // Inject the kill exception into this process if it's started.
+ if (!_needsStart)
+ injectException(killException);
_terminatedEvent.notify();
}
@@ -224,11 +227,13 @@
if (_isUnwinding)
return;
- // Update our state.
- _isUnwinding = true;
- // Inject the reset exception into this process.
- injectException(resetException);
+ if (_needsStart) {
+ scheduler.runNow(this);
+ } else {
+ _isUnwinding = true;
+ injectException(resetException);
+ }
_resetEvent.notify();
}
@@ -238,6 +243,10 @@
{
if (inc_kids)
forEachKid([&exc](Process *p) { p->throw_it(exc, true); });
+
+ // Only inject an exception into threads that have started.
+ if (!_needsStart)
+ injectException(exc);
}
void
@@ -295,7 +304,6 @@
_isUnwinding = false;
}
} while (reset);
- _terminated = true;
}
void
@@ -346,10 +354,9 @@
::sc_core::sc_report *Process::lastReport() const { return
_lastReport.get(); }
-Process::Process(const char *name, ProcessFuncWrapper *func,
- bool _dynamic, bool needs_start) :
+Process::Process(const char *name, ProcessFuncWrapper *func, bool
_dynamic) :
::sc_core::sc_object(name), excWrapper(nullptr), func(func),
- _needsStart(needs_start), _dynamic(_dynamic), _isUnwinding(false),
+ _needsStart(true), _dynamic(_dynamic), _isUnwinding(false),
_terminated(false), _suspended(false), _disabled(false),
_syncReset(false), refCount(0), stackSize(::Fiber::DefaultStackSize),
dynamicSensitivity(nullptr)
@@ -357,6 +364,20 @@
_newest = this;
}
+void
+Process::terminate()
+{
+ _terminated = true;
+ _suspendedReady = false;
+ _suspended = false;
+ _syncReset = false;
+ delete dynamicSensitivity;
+ dynamicSensitivity = nullptr;
+ for (auto s: staticSensitivities)
+ delete s;
+ staticSensitivities.clear();
+}
+
Process *Process::_newest;
void
diff --git a/src/systemc/core/process.hh b/src/systemc/core/process.hh
index 8abafbd..5f0a72d 100644
--- a/src/systemc/core/process.hh
+++ b/src/systemc/core/process.hh
@@ -325,8 +325,7 @@
::sc_core::sc_report *lastReport() const;
protected:
- Process(const char *name, ProcessFuncWrapper *func, bool _dynamic,
- bool needs_start);
+ Process(const char *name, ProcessFuncWrapper *func, bool _dynamic);
static Process *_newest;
@@ -347,6 +346,8 @@
bool _isUnwinding;
bool _terminated;
+ void terminate();
+
bool _suspended;
bool _suspendedReady;
bool _disabled;
diff --git a/src/systemc/core/process_types.hh
b/src/systemc/core/process_types.hh
index 369fa72..7617d41 100644
--- a/src/systemc/core/process_types.hh
+++ b/src/systemc/core/process_types.hh
@@ -40,7 +40,7 @@
{
public:
Method(const char *name, ProcessFuncWrapper *func, bool
_dynamic=false) :
- Process(name, func, _dynamic, true)
+ Process(name, func, _dynamic)
{}
const char *kind() const override { return "sc_method_process"; }
@@ -56,7 +56,7 @@
{
public:
Thread(const char *name, ProcessFuncWrapper *func, bool
_dynamic=false) :
- Process(name, func, _dynamic, false), ctx(nullptr)
+ Process(name, func, _dynamic), ctx(nullptr)
{}
~Thread() { delete ctx; }
@@ -88,8 +88,15 @@
private:
Thread *thread;
- void main() override { thread->run(); }
+ void
+ main() override
+ {
+ thread->_needsStart = false;
+ thread->run();
+ thread->terminate();
+ }
};
+ friend class Context;
Context *ctx;
};
--
To view, visit https://gem5-review.googlesource.com/c/public/gem5/+/12049
To unsubscribe, or for help writing mail filters, visit
https://gem5-review.googlesource.com/settings
Gerrit-Project: public/gem5
Gerrit-Branch: master
Gerrit-Change-Id: Ie2a683a796155a82092109d5bb45f07c84e06c76
Gerrit-Change-Number: 12049
Gerrit-PatchSet: 1
Gerrit-Owner: Gabe Black <[email protected]>
Gerrit-MessageType: newchange
_______________________________________________
gem5-dev mailing list
[email protected]
http://m5sim.org/mailman/listinfo/gem5-dev
