diff options
author | Matthew Barth <msbarth@us.ibm.com> | 2017-08-15 10:51:37 -0500 |
---|---|---|
committer | Matthew Barth <msbarth@us.ibm.com> | 2017-08-16 09:47:08 -0500 |
commit | 9014980aa76692cd7f08b5e69565133122c758cd (patch) | |
tree | 92caf9df963449625d513e8c1cc5c704681eb7f9 | |
parent | 172f393696b967f23e1d166fc7eb952a11994c5d (diff) | |
download | phosphor-fan-presence-9014980aa76692cd7f08b5e69565133122c758cd.tar.gz phosphor-fan-presence-9014980aa76692cd7f08b5e69565133122c758cd.zip |
Add timer option to run set speed event actions
For groups within set speed events where the property values of the
group may not signal its action to occur, an optional timer may be added
to the event. This timer is configured as a repeating timer on the
interval provided where upon timer expiration, the event's action is
run.
Change-Id: I4cbe8a0ab1b734bfc7828706a6515af7f6d78b52
Signed-off-by: Matthew Barth <msbarth@us.ibm.com>
-rwxr-xr-x | control/gen-fan-zone-defs.py | 32 | ||||
-rw-r--r-- | control/types.hpp | 11 | ||||
-rw-r--r-- | control/zone.cpp | 30 | ||||
-rw-r--r-- | control/zone.hpp | 19 |
4 files changed, 90 insertions, 2 deletions
diff --git a/control/gen-fan-zone-defs.py b/control/gen-fan-zone-defs.py index 45ca774..a2a49a8 100755 --- a/control/gen-fan-zone-defs.py +++ b/control/gen-fan-zone-defs.py @@ -112,6 +112,9 @@ const std::vector<ZoneGroup> Manager::_zoneLayouts %endif %endfor )), + Timer{ + ${event['timer']['interval']} + }, std::vector<PropertyChange>{ %for s in event['signal']: PropertyChange{ @@ -146,6 +149,9 @@ const std::vector<ZoneGroup> Manager::_zoneLayouts %if ('pc' in event) and (event['pc'] is not None): } )), + Timer{ + ${event['pc']['pctime']['interval']} + }, std::vector<PropertyChange>{ %for s in event['pc']['pcsig']: PropertyChange{ @@ -264,6 +270,20 @@ def addPrecondition(event, events_data): signal.append(signals) precond['pcsig'] = signal + # Add optional action call timer + timer = {} + interval = "static_cast<std::chrono::seconds>" + if ('timer' in event['precondition']) and \ + (event['precondition']['timer'] is not None): + timer['interval'] = (interval + + "(" + + str(event['precondition']['timer']['interval']) + + ")") + else: + timer['interval'] = (interval + + "(" + str(0) + ")") + precond['pctime'] = timer + return precond @@ -350,6 +370,18 @@ def getEventsInZone(zone_num, zone_conditions, events_data): signal.append(signals) event['signal'] = signal + # Add optional action call timer + timer = {} + interval = "static_cast<std::chrono::seconds>" + if ('timer' in e) and \ + (e['timer'] is not None): + timer['interval'] = (interval + + "(" + str(e['timer']['interval']) + ")") + else: + timer['interval'] = (interval + + "(" + str(0) + ")") + event['timer'] = timer + events.append(event) return events diff --git a/control/types.hpp b/control/types.hpp index bac5402..b788ac5 100644 --- a/control/types.hpp +++ b/control/types.hpp @@ -3,6 +3,7 @@ #include <tuple> #include <vector> #include <sdbusplus/server.hpp> +#include "timer.hpp" namespace phosphor { @@ -52,15 +53,20 @@ using PrecondGroup = std::tuple<std::string, std::string, PropertyVariantType>; +constexpr auto intervalPos = 0; +using Timer = std::tuple<std::chrono::seconds>; + constexpr auto signaturePos = 0; constexpr auto handlerObjPos = 1; using PropertyChange = std::tuple<std::string, Handler>; constexpr auto groupPos = 0; constexpr auto actionPos = 1; -constexpr auto propChangeListPos = 2; +constexpr auto timerPos = 2; +constexpr auto propChangeListPos = 3; using SetSpeedEvent = std::tuple<Group, Action, + Timer, std::vector<PropertyChange>>; constexpr auto eventGroupPos = 0; @@ -68,6 +74,9 @@ constexpr auto eventHandlerPos = 1; constexpr auto eventActionPos = 2; using EventData = std::tuple<Group, Handler, Action>; +constexpr auto timerTimerPos = 0; +using TimerEvent = std::tuple<phosphor::fan::util::Timer>; + constexpr auto signalEventDataPos = 0; constexpr auto signalMatchPos = 1; using SignalEvent = diff --git a/control/zone.cpp b/control/zone.cpp index cef375c..9670127 100644 --- a/control/zone.cpp +++ b/control/zone.cpp @@ -29,6 +29,7 @@ namespace control { using namespace std::chrono; +using namespace phosphor::fan; using namespace phosphor::logging; using InternalFailure = sdbusplus::xyz::openbmc_project::Common:: Error::InternalFailure; @@ -45,7 +46,8 @@ Zone::Zone(Mode mode, _incDelay(std::get<incDelayPos>(def)), _decInterval(std::get<decIntervalPos>(def)), _incTimer(events, [this](){ this->incTimerExpired(); }), - _decTimer(events, [this](){ this->decTimerExpired(); }) + _decTimer(events, [this](){ this->decTimerExpired(); }), + _sdEvents(events) { auto& fanDefs = std::get<fanListPos>(def); @@ -216,6 +218,26 @@ void Zone::initEvent(const SetSpeedEvent& event) ); _signalEvents.emplace_back(std::move(eventData), std::move(match)); } + // Attach a timer to run the action of an event + auto eventTimer = std::get<timerPos>(event); + if (std::get<intervalPos>(eventTimer) != seconds(0)) + { + std::unique_ptr<util::Timer> timer = + std::make_unique<util::Timer>( + _sdEvents, + [this, + action = &(std::get<actionPos>(event)), + group = &(std::get<groupPos>(event))]() + { + this->timerExpired(*group, *action); + }); + if (!timer->running()) + { + timer->start(std::get<intervalPos>(eventTimer), + util::Timer::TimerType::repeating); + } + _timerEvents.emplace_back(std::move(timer)); + } // Run action function for initial event state std::get<actionPos>(event)(*this, std::get<groupPos>(event)); @@ -279,6 +301,12 @@ void Zone::getProperty(sdbusplus::bus::bus& bus, hostResponseMsg.read(value); } +void Zone::timerExpired(Group eventGroup, Action eventAction) +{ + // Perform the action + eventAction(*this, eventGroup); +} + void Zone::handleEvent(sdbusplus::message::message& msg, const EventData* eventData) { diff --git a/control/zone.hpp b/control/zone.hpp index a56b1c7..6e81bd1 100644 --- a/control/zone.hpp +++ b/control/zone.hpp @@ -247,6 +247,15 @@ class Zone */ void decTimerExpired(); + /** + * @brief Callback function for event timers that processes the given + * action for a group + * + * @param[in] eventGroup - Group to process action on + * @param[in] eventAction - Event action to run + */ + void timerExpired(Group eventGroup, Action eventAction); + private: /** @@ -330,6 +339,11 @@ class Zone phosphor::fan::util::Timer _decTimer; /** + * Dbus event used on set speed event timers + */ + phosphor::fan::event::EventPtr& _sdEvents; + + /** * The vector of fans in this zone */ std::vector<std::unique_ptr<Fan>> _fans; @@ -353,6 +367,11 @@ class Zone std::vector<SignalEvent> _signalEvents; /** + * @brief List of timers for events + */ + std::vector<std::unique_ptr<phosphor::fan::util::Timer>> _timerEvents; + + /** * @brief Refresh the given property's cached value * * @param[in] bus - the bus to use |