Add support for zero-fan mode, fix sensor identifiers

This commit is contained in:
2023-07-24 13:55:53 +02:00
parent ad12f7a981
commit ff72f8d2ea
6 changed files with 53 additions and 58 deletions

View File

@@ -17,6 +17,9 @@ public:
virtual void StartPWM(int value) = 0; virtual void StartPWM(int value) = 0;
virtual int StartPWM() = 0; virtual int StartPWM() = 0;
virtual void ZeroFanModeSupported(bool value) = 0;
virtual bool ZeroFanModeSupported() = 0;
virtual void FindPWMLimits() = 0; virtual void FindPWMLimits() = 0;
virtual void AdjustPWMLimits() = 0; virtual void AdjustPWMLimits() = 0;
}; };

View File

@@ -24,6 +24,9 @@ public:
void StartPWM(int value) override; void StartPWM(int value) override;
int StartPWM() override; int StartPWM() override;
void ZeroFanModeSupported(bool value) override;
bool ZeroFanModeSupported() override;
void FindPWMLimits() override; void FindPWMLimits() override;
void AdjustPWMLimits() override; void AdjustPWMLimits() override;
@@ -36,8 +39,9 @@ private:
std::shared_ptr<Sensor> mRpmSensor; std::shared_ptr<Sensor> mRpmSensor;
std::string mLabel; std::string mLabel;
int mMinPWM; int mMinPWM = 0;
int mStartPWM; int mStartPWM = 0;
bool mZeroFanModeSupported = false;
std::chrono::time_point<std::chrono::steady_clock> mLastAdjustmentTime; std::chrono::time_point<std::chrono::steady_clock> mLastAdjustmentTime;
}; };

View File

@@ -13,16 +13,13 @@
using namespace std; using namespace std;
namespace fs = filesystem; namespace fs = filesystem;
Serializer::Serializer() Serializer::Serializer() {
{
if (!fs::exists(SERIALIZATION_DIR)) { if (!fs::exists(SERIALIZATION_DIR)) {
fs::create_directory(SERIALIZATION_DIR); fs::create_directory(SERIALIZATION_DIR);
} }
} }
void void Serializer::SerializeFans(vector<shared_ptr<Fan>> fans) {
Serializer::SerializeFans(vector<shared_ptr<Fan>> fans)
{
json obj; json obj;
for (auto f : fans) { for (auto f : fans) {
@@ -33,8 +30,7 @@ Serializer::SerializeFans(vector<shared_ptr<Fan>> fans)
} }
vector<shared_ptr<Fan>> vector<shared_ptr<Fan>>
Serializer::DeserializeFans(vector<shared_ptr<Sensor>> availableSensors) Serializer::DeserializeFans(vector<shared_ptr<Sensor>> availableSensors) {
{
vector<shared_ptr<Fan>> fans; vector<shared_ptr<Fan>> fans;
// Create a for the sensors first, then searching becomes cheaper // Create a for the sensors first, then searching becomes cheaper
@@ -45,37 +41,37 @@ Serializer::DeserializeFans(vector<shared_ptr<Sensor>> availableSensors)
auto data = ReadJson(); auto data = ReadJson();
try { try {
for (auto& el : data["fans"].items()) { for (auto &el : data["fans"].items()) {
auto pwmControl = make_shared<PWMControl>(el.value()["PWMControl"]); auto pwmControl = make_shared<PWMControl>(el.value()["PWMControl"]);
auto rpmSensor = sensorMap[el.value()["LMSensor"]]; auto rpmSensor = sensorMap[el.value()["LMSensor"]];
int minPWM = el.value()["MinPWM"]; int minPWM = el.value()["MinPWM"];
int startPWM = el.value()["StartPWM"]; int startPWM = el.value()["StartPWM"];
string label = el.value()["Label"]; string label = el.value()["Label"];
bool zeroFan = el.value()["ZeroFan"];
auto fan = make_shared<HwmonFan>(pwmControl, rpmSensor); auto fan = make_shared<HwmonFan>(pwmControl, rpmSensor);
fan->MinPWM(minPWM); fan->MinPWM(minPWM);
fan->StartPWM(startPWM); fan->StartPWM(startPWM);
fan->Label(label); fan->Label(label);
fan->ZeroFanModeSupported(zeroFan);
fans.push_back(fan); fans.push_back(fan);
} }
} catch (const std::exception& e) { } catch (const std::exception &e) {
std::cout << "Deserialization error! Message: " << e.what() << std::endl; std::cout << "Deserialization error! Message: " << e.what() << std::endl;
} }
return fans; return fans;
} }
void void Serializer::WriteJson(json o) {
Serializer::WriteJson(json o)
{
json obj; json obj;
if (fs::exists(fs::path(SERIALIZATION_DIR) / FANS_JSON_FILENAME)) { if (fs::exists(fs::path(SERIALIZATION_DIR) / FANS_JSON_FILENAME)) {
obj = ReadJson(); obj = ReadJson();
} }
for (auto& [key, value] : o.items()) { for (auto &[key, value] : o.items()) {
obj[key] = value; obj[key] = value;
} }
@@ -83,18 +79,14 @@ Serializer::WriteJson(json o)
ostrm << obj.dump(2) << "\n"; ostrm << obj.dump(2) << "\n";
} }
json json Serializer::ReadJson() {
Serializer::ReadJson()
{
ifstream istrm(fs::path(SERIALIZATION_DIR) / FANS_JSON_FILENAME); ifstream istrm(fs::path(SERIALIZATION_DIR) / FANS_JSON_FILENAME);
return json::parse(istrm); return json::parse(istrm);
} }
vector<shared_ptr<FanCurve>> vector<shared_ptr<FanCurve>> Serializer::DeserializeFanCurves(
Serializer::DeserializeFanCurves( std::vector<std::shared_ptr<Sensor>> availableSensors,
std::vector<std::shared_ptr<Sensor>> availableSensors, std::vector<std::shared_ptr<Fan>> availableFans) {
std::vector<std::shared_ptr<Fan>> availableFans)
{
auto data = ReadJson(); auto data = ReadJson();
map<string, shared_ptr<Sensor>> sensorMap; map<string, shared_ptr<Sensor>> sensorMap;
@@ -109,47 +101,44 @@ Serializer::DeserializeFanCurves(
vector<shared_ptr<FanCurve>> curves; vector<shared_ptr<FanCurve>> curves;
for (auto& el : data["fancurves"].items()) { for (auto &el : data["fancurves"].items()) {
vector<FanStep> steps; vector<FanStep> steps;
vector<shared_ptr<Sensor>> sensors; vector<shared_ptr<Sensor>> sensors;
vector<shared_ptr<Fan>> fans; vector<shared_ptr<Fan>> fans;
for (auto& step : el.value()["FanSteps"].items()) { for (auto &step : el.value()["FanSteps"].items()) {
steps.push_back(FanStep{ step.value()[0], step.value()[1] }); steps.push_back(FanStep{step.value()[0], step.value()[1]});
} }
for (auto& sensor : el.value()["Sensors"].items()) { for (auto &sensor : el.value()["Sensors"].items()) {
if (sensorMap.contains(sensor.value())) if (sensorMap.contains(sensor.value()))
sensors.push_back(sensorMap[sensor.value()]); sensors.push_back(sensorMap[sensor.value()]);
} }
for (auto& fan : el.value()["Fans"].items()) { for (auto &fan : el.value()["Fans"].items()) {
if (fanMap.contains(fan.value())) if (fanMap.contains(fan.value()))
fans.push_back(fanMap[fan.value()]); fans.push_back(fanMap[fan.value()]);
} }
std::unique_ptr<Aggregator> aggregator = std::unique_ptr<Aggregator> aggregator =
aggregatorFromString(el.value()["AggregateFunction"]); aggregatorFromString(el.value()["AggregateFunction"]);
curves.push_back( curves.push_back(
make_shared<FanCurve>(steps, sensors, fans, std::move(aggregator))); make_shared<FanCurve>(steps, sensors, fans, std::move(aggregator)));
} }
return curves; return curves;
} }
std::unique_ptr<Aggregator> std::unique_ptr<Aggregator>
Serializer::aggregatorFromString(std::string str) const Serializer::aggregatorFromString(std::string str) const {
{
if (str == "max") if (str == "max")
return std::make_unique<MaxAggregator>(); return std::make_unique<MaxAggregator>();
else else
return std::make_unique<AverageAggregator>(); return std::make_unique<AverageAggregator>();
} }
shared_ptr<Settings> shared_ptr<Settings> Serializer::DeserializeSettings() {
Serializer::DeserializeSettings()
{
int frequency = FREQUENCY_DEFAULT; int frequency = FREQUENCY_DEFAULT;
auto data = ReadJson(); auto data = ReadJson();

View File

@@ -12,22 +12,17 @@ FanCurve::FanCurve(std::vector<FanStep> steps,
std::vector<std::shared_ptr<Sensor>> sensors, std::vector<std::shared_ptr<Sensor>> sensors,
std::vector<std::shared_ptr<Fan>> fans, std::vector<std::shared_ptr<Fan>> fans,
std::unique_ptr<Aggregator> aggregator) std::unique_ptr<Aggregator> aggregator)
: mSteps(steps) : mSteps(steps), mTempSensors(sensors), mFans(fans),
, mTempSensors(sensors) mAggregator(std::move(aggregator)) {
, mFans(fans)
, mAggregator(std::move(aggregator))
{
PrintInfo(); PrintInfo();
} }
void void FanCurve::DoFanControl() {
FanCurve::DoFanControl()
{
BOOST_LOG_FUNCTION(); BOOST_LOG_FUNCTION();
int temp = AggregateTemperature(); int temp = AggregateTemperature();
int t0, t1, p0, p1; int t0 = 0, t1 = 0, p0 = 0, p1 = 0;
int targetFanPower; int targetFanPower;
if (temp <= mSteps[0].Temp) { if (temp <= mSteps[0].Temp) {
@@ -35,7 +30,7 @@ FanCurve::DoFanControl()
} else if (temp > mSteps[mSteps.size() - 1].Temp) { } else if (temp > mSteps[mSteps.size() - 1].Temp) {
targetFanPower = mSteps[mSteps.size() - 1].Percent; targetFanPower = mSteps[mSteps.size() - 1].Percent;
} else { } else {
for (int i = 0; i < mSteps.size(); i++) { for (int i = 0; i < (int)mSteps.size(); i++) {
if (temp > mSteps[i].Temp) { if (temp > mSteps[i].Temp) {
t0 = mSteps[i].Temp; t0 = mSteps[i].Temp;
p0 = mSteps[i].Percent; p0 = mSteps[i].Percent;
@@ -49,7 +44,7 @@ FanCurve::DoFanControl()
} }
for (auto f : mFans) { for (auto f : mFans) {
if (f->RPM() <= 0) { if (!f->ZeroFanModeSupported() && f->RPM() <= 0) {
BOOST_LOG_TRIVIAL(warning) << "Fan stopped completely!"; BOOST_LOG_TRIVIAL(warning) << "Fan stopped completely!";
f->PWM(f->StartPWM()); f->PWM(f->StartPWM());
f->AdjustPWMLimits(); f->AdjustPWMLimits();
@@ -59,15 +54,11 @@ FanCurve::DoFanControl()
} }
} }
int int FanCurve::AggregateTemperature() {
FanCurve::AggregateTemperature()
{
return mAggregator->aggregate(mTempSensors); return mAggregator->aggregate(mTempSensors);
} }
void void FanCurve::PrintInfo() {
FanCurve::PrintInfo()
{
BOOST_LOG_FUNCTION() BOOST_LOG_FUNCTION()
BOOST_LOG_TRIVIAL(info) << "### Fan curve:"; BOOST_LOG_TRIVIAL(info) << "### Fan curve:";

View File

@@ -39,6 +39,12 @@ void HwmonFan::StartPWM(int value) { mStartPWM = value; }
int HwmonFan::StartPWM() { return mStartPWM; } int HwmonFan::StartPWM() { return mStartPWM; }
void HwmonFan::ZeroFanModeSupported(bool value) {
mZeroFanModeSupported = value;
}
bool HwmonFan::ZeroFanModeSupported() { return mZeroFanModeSupported; }
void HwmonFan::FindPWMLimits() { void HwmonFan::FindPWMLimits() {
cout << "Looking for minimal PWM" << endl; cout << "Looking for minimal PWM" << endl;
int minPWM = 0; int minPWM = 0;
@@ -95,11 +101,9 @@ void HwmonFan::AdjustPWMLimits() {
json HwmonFan::toJson() const { json HwmonFan::toJson() const {
json obj; json obj;
obj = {mPWMControl->toJson(), obj = {mPWMControl->toJson(), mRpmSensor->toJson(),
mRpmSensor->toJson(), {"Label", mLabel}, {"MinPWM", mMinPWM},
{"Label", mLabel}, {"StartPWM", mStartPWM}, {"ZeroFan", mZeroFanModeSupported}};
{"MinPWM", mMinPWM},
{"StartPWM", mStartPWM}};
return obj; return obj;
} }

View File

@@ -1,3 +1,5 @@
#include <iostream>
#include <boost/json/kind.hpp> #include <boost/json/kind.hpp>
#include <sensor/LMSensor.h> #include <sensor/LMSensor.h>
#include <sensors/sensors.h> #include <sensors/sensors.h>
@@ -17,7 +19,9 @@ int LMSensor::value() {
} }
const string LMSensor::toString() const { const string LMSensor::toString() const {
return sensors_get_label(mChipName, mFeature); ostringstream os;
os << mChipName->prefix << "." << sensors_get_label(mChipName, mFeature);
return os.str();
} }
json LMSensor::toJson() const { json LMSensor::toJson() const {