summaryrefslogtreecommitdiffstats
path: root/control/zone.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'control/zone.cpp')
-rw-r--r--control/zone.cpp45
1 files changed, 44 insertions, 1 deletions
diff --git a/control/zone.cpp b/control/zone.cpp
index b698c12..018f594 100644
--- a/control/zone.cpp
+++ b/control/zone.cpp
@@ -259,6 +259,17 @@ void Zone::initEvent(const SetSpeedEvent& event)
auto eventTimer = std::get<timerPos>(event);
if (std::get<intervalPos>(eventTimer) != seconds(0))
{
+ // Associate event data with timer
+ std::unique_ptr<EventData> eventData =
+ std::make_unique<EventData>(
+ EventData
+ {
+ std::get<groupPos>(event),
+ "",
+ nullptr,
+ std::get<actionsPos>(event)
+ }
+ );
std::unique_ptr<util::Timer> timer =
std::make_unique<util::Timer>(
_sdEvents,
@@ -273,7 +284,7 @@ void Zone::initEvent(const SetSpeedEvent& event)
timer->start(std::get<intervalPos>(eventTimer),
std::get<typePos>(eventTimer));
}
- _timerEvents.emplace_back(std::move(timer));
+ addTimer(std::move(eventData), std::move(timer));
}
// Run action functions for initial event state
std::for_each(
@@ -332,6 +343,38 @@ void Zone::removeEvent(const SetSpeedEvent& event)
}
}
+std::vector<TimerEvent>::iterator Zone::findTimer(
+ const Group& eventGroup,
+ const std::vector<Action>& eventActions)
+{
+ for (auto it = _timerEvents.begin(); it != _timerEvents.end(); ++it)
+ {
+ auto teEventData = *std::get<timerEventDataPos>(*it);
+ if (std::get<eventActionsPos>(teEventData).size() ==
+ eventActions.size())
+ {
+ // TODO openbmc/openbmc#2328 - Use the action function target
+ // for comparison
+ auto actsEqual = [](auto const& a1,
+ auto const& a2)
+ {
+ return a1.target_type().name() ==
+ a2.target_type().name();
+ };
+ if (std::get<eventGroupPos>(teEventData) == eventGroup &&
+ std::equal(eventActions.begin(),
+ eventActions.end(),
+ std::get<eventActionsPos>(teEventData).begin(),
+ actsEqual))
+ {
+ return it;
+ }
+ }
+ }
+
+ return _timerEvents.end();
+}
+
void Zone::timerExpired(Group eventGroup, std::vector<Action> eventActions)
{
// Perform the actions
OpenPOWER on IntegriCloud