/** * Copyright © 2021 IBM Corporation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include "count_state_target.hpp" #include "../manager.hpp" #include "../zone.hpp" #include "action.hpp" #include "group.hpp" #include #include namespace phosphor::fan::control::json { using json = nlohmann::json; // Instance id for setting the unique id of each instance of this action size_t CountStateTarget::instanceId = 0; CountStateTarget::CountStateTarget(const json& jsonObj, const std::vector& groups) : ActionBase(jsonObj, groups) { setCount(jsonObj); setState(jsonObj); setTarget(jsonObj); _id = instanceId++; } void CountStateTarget::run(Zone& zone) { size_t numAtState = 0; for (const auto& group : _groups) { for (const auto& member : group.getMembers()) { try { if (Manager::getObjValueVariant(member, group.getInterface(), group.getProperty()) == _state) { numAtState++; } } catch (const std::out_of_range& oore) { // Default to property not equal when not found } if (numAtState >= _count) { break; } } if (numAtState >= _count) { break; } } // Update zone's target hold based on action results zone.setTargetHold(ActionBase::getName() + std::to_string(_id), _target, (numAtState >= _count)); } void CountStateTarget::setCount(const json& jsonObj) { if (!jsonObj.contains("count")) { throw ActionParseError{ActionBase::getName(), "Missing required count value"}; } _count = jsonObj["count"].get(); } void CountStateTarget::setState(const json& jsonObj) { if (!jsonObj.contains("state")) { throw ActionParseError{ActionBase::getName(), "Missing required state value"}; } _state = getJsonValue(jsonObj["state"]); } void CountStateTarget::setTarget(const json& jsonObj) { if (!jsonObj.contains("target")) { throw ActionParseError{ActionBase::getName(), "Missing required target value"}; } _target = jsonObj["target"].get(); } } // namespace phosphor::fan::control::json