blob: f7c6fc08dcb0e7adacbe9f2af2b409eed650909f [file] [log] [blame]
/*
// Copyright (c) 2018 Intel 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 <unistd.h>
#include <TachSensor.hpp>
#include <Utils.hpp>
#include <boost/algorithm/string/predicate.hpp>
#include <boost/algorithm/string/replace.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <fstream>
#include <iostream>
#include <limits>
#include <sdbusplus/asio/connection.hpp>
#include <sdbusplus/asio/object_server.hpp>
#include <string>
static constexpr unsigned int pwmPollMs = 500;
static constexpr size_t warnAfterErrorCount = 10;
TachSensor::TachSensor(const std::string &path,
sdbusplus::asio::object_server &objectServer,
std::shared_ptr<sdbusplus::asio::connection> &conn,
std::unique_ptr<PresenceSensor> &&presence,
boost::asio::io_service &io, const std::string &fanName,
std::vector<thresholds::Threshold> &&_thresholds,
const std::string &sensorConfiguration) :
Sensor(),
path(path), objServer(objectServer), dbusConnection(conn),
presence(std::move(presence)),
name(boost::replace_all_copy(fanName, " ", "_")),
configuration(sensorConfiguration),
inputDev(io, open(path.c_str(), O_RDONLY)), waitTimer(io), errCount(0),
// todo, get these from config
maxValue(25000), minValue(0)
{
thresholds = std::move(_thresholds);
sensorInterface = objectServer.add_interface(
"/xyz/openbmc_project/sensors/fan_tach/" + name,
"xyz.openbmc_project.Sensor.Value");
if (thresholds::hasWarningInterface(thresholds))
{
thresholdInterfaceWarning = objectServer.add_interface(
"/xyz/openbmc_project/sensors/fan_tach/" + name,
"xyz.openbmc_project.Sensor.Threshold.Warning");
}
if (thresholds::hasCriticalInterface(thresholds))
{
thresholdInterfaceCritical = objectServer.add_interface(
"/xyz/openbmc_project/sensors/fan_tach/" + name,
"xyz.openbmc_project.Sensor.Threshold.Critical");
}
setInitialProperties(conn);
isPowerOn(dbusConnection); // first call initializes
setupRead();
}
TachSensor::~TachSensor()
{
// close the input dev to cancel async operations
inputDev.close();
waitTimer.cancel();
objServer.remove_interface(thresholdInterfaceWarning);
objServer.remove_interface(thresholdInterfaceCritical);
objServer.remove_interface(sensorInterface);
}
void TachSensor::setupRead(void)
{
boost::asio::async_read_until(
inputDev, readBuf, '\n',
[&](const boost::system::error_code &ec,
std::size_t /*bytes_transfered*/) { handleResponse(ec); });
}
void TachSensor::handleResponse(const boost::system::error_code &err)
{
if (err == boost::system::errc::bad_file_descriptor)
{
return; // we're being destroyed
}
bool missing = false;
if (presence)
{
if (!presence->getValue())
{
sensorInterface->set_property(
"Value", std::numeric_limits<double>::quiet_NaN());
missing = true;
}
}
std::istream responseStream(&readBuf);
if (!missing)
{
if (!err)
{
std::string response;
try
{
std::getline(responseStream, response);
float nvalue = std::stof(response);
responseStream.clear();
if (nvalue != value)
{
updateValue(nvalue);
}
errCount = 0;
}
catch (const std::invalid_argument &)
{
errCount++;
}
}
else
{
errCount++;
}
// only send value update once
if (errCount == warnAfterErrorCount)
{
// only an error if power is on
if (isPowerOn(dbusConnection))
{
std::cerr << "Failure to read sensor " << name << " at " << path
<< "\n";
updateValue(0);
}
else
{
errCount = 0; // check power again in 10 cycles
sensorInterface->set_property(
"Value", std::numeric_limits<double>::quiet_NaN());
}
}
}
responseStream.clear();
inputDev.close();
int fd = open(path.c_str(), O_RDONLY);
if (fd <= 0)
{
return; // we're no longer valid
}
inputDev.assign(fd);
size_t pollTime = pwmPollMs;
if (missing)
{
pollTime *= 10;
}
waitTimer.expires_from_now(boost::posix_time::milliseconds(pollTime));
waitTimer.async_wait([&](const boost::system::error_code &ec) {
if (ec == boost::asio::error::operation_aborted)
{
return; // we're being canceled
}
setupRead();
});
}
void TachSensor::checkThresholds(void)
{
thresholds::checkThresholds(this);
}
void TachSensor::updateValue(const double &newValue)
{
sensorInterface->set_property("Value", newValue);
value = newValue;
checkThresholds();
}
void TachSensor::setInitialProperties(
std::shared_ptr<sdbusplus::asio::connection> &conn)
{
// todo, get max and min from configuration
sensorInterface->register_property("MaxValue", maxValue);
sensorInterface->register_property("MinValue", minValue);
sensorInterface->register_property("Value", value);
for (auto &threshold : thresholds)
{
std::shared_ptr<sdbusplus::asio::dbus_interface> iface;
std::string level;
std::string alarm;
if (threshold.level == thresholds::Level::CRITICAL)
{
iface = thresholdInterfaceCritical;
if (threshold.direction == thresholds::Direction::HIGH)
{
level = "CriticalHigh";
alarm = "CriticalAlarmHigh";
}
else
{
level = "CriticalLow";
alarm = "CriticalAlarmLow";
}
}
else if (threshold.level == thresholds::Level::WARNING)
{
iface = thresholdInterfaceWarning;
if (threshold.direction == thresholds::Direction::HIGH)
{
level = "WarningHigh";
alarm = "WarningAlarmHigh";
}
else
{
level = "WarningLow";
alarm = "WarningAlarmLow";
}
}
else
{
std::cerr << "Unknown threshold level" << threshold.level << "\n";
continue;
}
if (!iface)
{
std::cout << "trying to set uninitialized interface\n";
continue;
}
iface->register_property(
level, threshold.value,
[&](const double &request, double &oldValue) {
oldValue = request; // todo, just let the config do this?
threshold.value = request;
thresholds::persistThreshold(
configuration,
"xyz.openbmc_project.Configuration.AspeedFan", threshold,
conn);
return 1;
});
iface->register_property(alarm, false);
}
if (!sensorInterface->initialize())
{
std::cerr << "error initializing value interface\n";
}
if (thresholdInterfaceWarning && !thresholdInterfaceWarning->initialize())
{
std::cerr << "error initializing warning threshold interface\n";
}
if (thresholdInterfaceCritical && !thresholdInterfaceCritical->initialize())
{
std::cerr << "error initializing critical threshold interface\n";
}
}
PresenceSensor::PresenceSensor(const size_t index, bool inverted,
boost::asio::io_service &io) :
inverted(inverted),
inputDev(io)
{
// todo: use gpiodaemon
std::string device = gpioPath + std::string("gpio") + std::to_string(index);
fd = open((device + "/value").c_str(), O_RDONLY);
if (fd < 0)
{
std::cerr << "Error opening gpio " << index << "\n";
return;
}
std::ofstream deviceFile(device + "/edge");
if (!deviceFile.good())
{
std::cerr << "Error setting edge " << device << "\n";
return;
}
deviceFile << "both";
deviceFile.close();
inputDev.assign(boost::asio::ip::tcp::v4(), fd);
monitorPresence();
read();
}
PresenceSensor::~PresenceSensor()
{
inputDev.close();
close(fd);
}
void PresenceSensor::monitorPresence(void)
{
inputDev.async_wait(boost::asio::ip::tcp::socket::wait_error,
[this](const boost::system::error_code &ec) {
if (ec == boost::system::errc::bad_file_descriptor)
{
return; // we're being destroyed
}
else if (ec)
{
std::cerr
<< "Error on presence sensor socket\n";
}
else
{
read();
}
monitorPresence();
});
}
void PresenceSensor::read(void)
{
constexpr size_t readSize = sizeof("0");
std::string readBuf;
readBuf.resize(readSize);
lseek(fd, 0, SEEK_SET);
size_t r = ::read(fd, readBuf.data(), readSize);
if (r != 1)
{
std::cerr << "Error reading gpio\n";
}
else
{
bool value = std::stoi(readBuf);
if (inverted)
{
value = !value;
}
status = value;
}
}
bool PresenceSensor::getValue(void)
{
return status;
}