16 Commits

Author SHA1 Message Date
10fbcdb0f6 Add missing classes 2023-03-15 15:20:35 +01:00
f383eb1b79 Add average and max aggregator functions 2023-03-15 15:16:56 +01:00
7b0b419a22 Fix crash on startup 2023-01-19 13:32:56 +01:00
ec480f5a17 Remove leftover include statement 2022-11-05 02:50:18 +01:00
0109f66be3 Remove leftover include statement 2022-11-05 02:47:44 +01:00
75d6af4c8b Remove leftover include statement 2022-11-05 02:47:13 +01:00
815b78aa67 Change required version of boost libs 2022-11-05 02:45:12 +01:00
f718f82ad1 Add option to set frequency in json 2022-10-18 11:05:05 +02:00
596a30b76a Improve logic to handle fans stopping 2022-10-10 00:25:09 +02:00
0f91960ef9 Adapt version 2022-10-06 10:47:55 +02:00
d9192f10be Add SIGTERM handling, adjust limit finding step 2022-10-06 10:39:43 +02:00
f606a1e450 Update version 2022-10-04 09:55:23 +02:00
2d744245fc Fix segmentation fault on shutdown 2022-10-04 09:53:57 +02:00
bd1695b4a7 Update version 2022-10-04 09:42:40 +02:00
987e65fd90 Add stuff to .gitignore 2022-10-04 09:42:14 +02:00
e567ede3ef Add logic to adjust minPWM on fan stop 2022-10-04 09:41:04 +02:00
23 changed files with 332 additions and 104 deletions

5
.gitignore vendored
View File

@@ -1,3 +1,8 @@
oot/ oot/
compile_commands.json compile_commands.json
.cache/ .cache/
pkg/
rel_oot/
./src
*.pkg.tar.zst
*.tar.gz

View File

@@ -1,5 +1,5 @@
pkgname=fantasize pkgname=fantasize
pkgver=0.1.2 pkgver=0.1.9
pkgrel=1 pkgrel=1
pkgdesc='C++ fan control for Linux' pkgdesc='C++ fan control for Linux'
url='https://github.com/Tabascl/fantasize.git' url='https://github.com/Tabascl/fantasize.git'

View File

@@ -1,11 +1,11 @@
cmake_minimum_required(VERSION 3.0) cmake_minimum_required(VERSION 3.0)
project(fantasize VERSION 0.1.2) project(fantasize VERSION 0.1.8)
set(CMAKE_EXPORT_COMPILE_COMMANDS ON) set(CMAKE_EXPORT_COMPILE_COMMANDS ON)
find_package(nlohmann_json 3.11.2 REQUIRED) find_package(nlohmann_json 3.11.2 REQUIRED)
find_package(Boost 1.80 COMPONENTS program_options log log_setup date_time REQUIRED) find_package(Boost 1.74 COMPONENTS program_options log log_setup date_time REQUIRED)
add_executable(${PROJECT_NAME} add_executable(${PROJECT_NAME}
src/main.cxx src/main.cxx
@@ -19,10 +19,12 @@ add_executable(${PROJECT_NAME}
src/fan/HwmonFan.cxx src/fan/HwmonFan.cxx
src/fan/FanCurve.cxx src/fan/FanCurve.cxx
src/fan/FanLabeler.cxx src/fan/FanLabeler.cxx
src/fan/Aggregators.cxx
src/FanGenerator.cxx src/FanGenerator.cxx
src/Serializer.cxx src/Serializer.cxx
src/sensor/SensorManager.cxx src/sensor/SensorManager.cxx
src/Controller.cxx src/Controller.cxx
src/Settings.cxx
src/App.cxx src/App.cxx
) )

View File

@@ -26,7 +26,11 @@ private:
FanLabeler mFanLabeler; FanLabeler mFanLabeler;
FanGenerator mFanGenerator; FanGenerator mFanGenerator;
std::shared_ptr<Settings> mSettings;
std::unique_ptr<Controller> mController; std::unique_ptr<Controller> mController;
std::vector<std::shared_ptr<Fan>> mFans;
}; };
#endif // APP_H_ #endif // APP_H_

View File

@@ -5,11 +5,13 @@
#include <thread> #include <thread>
#include <vector> #include <vector>
#include <Settings.h>
#include <fan/FanCurve.h> #include <fan/FanCurve.h>
class Controller { class Controller {
public: public:
Controller(std::vector<std::shared_ptr<FanCurve>> curves); Controller(std::shared_ptr<Settings> settings,
std::vector<std::shared_ptr<FanCurve>> curves);
~Controller(); ~Controller();
void StartFanControlLoop(); void StartFanControlLoop();
@@ -18,6 +20,8 @@ public:
private: private:
void Loop(); void Loop();
int mTimeout;
std::vector<std::shared_ptr<FanCurve>> mFanCurves; std::vector<std::shared_ptr<FanCurve>> mFanCurves;
std::atomic<bool> mRun; std::atomic<bool> mRun;

View File

@@ -1,12 +1,13 @@
#ifndef SERIALIZER_H_ #ifndef SERIALIZER_H_
#define SERIALIZER_H_ #define SERIALIZER_H_
#include "fan/HwmonFan.h"
#include <memory> #include <memory>
#include <vector> #include <vector>
#include <nlohmann/json.hpp> #include <nlohmann/json.hpp>
#include <Settings.h>
#include <fan/Aggregators.h>
#include <fan/Fan.h> #include <fan/Fan.h>
#include <fan/FanCurve.h> #include <fan/FanCurve.h>
#include <sensor/Sensor.h> #include <sensor/Sensor.h>
@@ -16,19 +17,22 @@
using json = nlohmann::json; using json = nlohmann::json;
class Serializer { class Serializer
{
public: public:
Serializer(); Serializer();
void SerializeFans(std::vector<std::shared_ptr<Fan>> fans); void SerializeFans(std::vector<std::shared_ptr<Fan>> fans);
std::vector<std::shared_ptr<Fan>> std::vector<std::shared_ptr<Fan>> DeserializeFans(
DeserializeFans(std::vector<std::shared_ptr<Sensor>> availableSensors); std::vector<std::shared_ptr<Sensor>> availableSensors);
std::vector<std::shared_ptr<FanCurve>> std::vector<std::shared_ptr<FanCurve>> DeserializeFanCurves(
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);
std::shared_ptr<Settings> DeserializeSettings();
private: private:
void WriteJson(json o); void WriteJson(json o);
json ReadJson(); json ReadJson();
std::unique_ptr<Aggregator> aggregatorFromString(std::string str) const;
}; };
#endif // SERIALIZER_H_ #endif // SERIALIZER_H_

17
app/include/Settings.h Normal file
View File

@@ -0,0 +1,17 @@
#ifndef SETTINGS_H_
#define SETTINGS_H_
#define FREQUENCY_DEFAULT 1
class Settings {
public:
Settings(int frequency);
int Frequency() const;
private:
void LogSettings();
int mFrequency;
};
#endif // SETTINGS_H_

View File

@@ -0,0 +1,27 @@
#ifndef AGGREGATORS_H_
#define AGGREGATORS_H_
#include <sensor/Sensor.h>
class Aggregator
{
public:
virtual int aggregate(std::vector<std::shared_ptr<Sensor>> sensors) const = 0;
virtual const std::string toString() const = 0;
};
class AverageAggregator : public Aggregator
{
public:
int aggregate(std::vector<std::shared_ptr<Sensor>> sensors) const override;
const std::string toString() const override;
};
class MaxAggregator : public Aggregator
{
public:
int aggregate(std::vector<std::shared_ptr<Sensor>> sensors) const override;
const std::string toString() const override;
};
#endif // AGGERGATORS_H_

View File

@@ -18,6 +18,7 @@ public:
virtual int StartPWM() = 0; virtual int StartPWM() = 0;
virtual void FindPWMLimits() = 0; virtual void FindPWMLimits() = 0;
virtual void AdjustPWMLimits() = 0;
}; };
#endif // FAN_H_ #endif // FAN_H_

View File

@@ -4,19 +4,23 @@
#include <memory> #include <memory>
#include <vector> #include <vector>
#include <fan/Aggregators.h>
#include <fan/HwmonFan.h> #include <fan/HwmonFan.h>
#include <sensor/Sensor.h> #include <sensor/Sensor.h>
struct FanStep { struct FanStep
{
int Temp; int Temp;
int Percent; int Percent;
}; };
class FanCurve { class FanCurve
{
public: public:
FanCurve(std::vector<FanStep> steps, 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);
void DoFanControl(); void DoFanControl();
@@ -27,6 +31,7 @@ private:
std::vector<FanStep> mSteps; std::vector<FanStep> mSteps;
std::vector<std::shared_ptr<Sensor>> mTempSensors; std::vector<std::shared_ptr<Sensor>> mTempSensors;
std::vector<std::shared_ptr<Fan>> mFans; std::vector<std::shared_ptr<Fan>> mFans;
std::unique_ptr<Aggregator> mAggregator;
}; };
#endif // FANCURVE_H_ #endif // FANCURVE_H_

View File

@@ -1,7 +1,7 @@
#ifndef HWMONFAN_H_ #ifndef HWMONFAN_H_
#define HWMONFAN_H_ #define HWMONFAN_H_
#include <boost/json/object.hpp> #include <chrono>
#include <memory> #include <memory>
#include <fan/Fan.h> #include <fan/Fan.h>
@@ -25,6 +25,7 @@ public:
int StartPWM() override; int StartPWM() override;
void FindPWMLimits() override; void FindPWMLimits() override;
void AdjustPWMLimits() override;
json toJson() const override; json toJson() const override;
@@ -37,6 +38,7 @@ private:
int mMinPWM; int mMinPWM;
int mStartPWM; int mStartPWM;
std::chrono::time_point<std::chrono::steady_clock> mLastAdjustmentTime;
}; };
#endif // HWMONFAN_H_ #endif // HWMONFAN_H_

View File

@@ -1,7 +1,6 @@
#ifndef PWMCONTROL_H_ #ifndef PWMCONTROL_H_
#define PWMCONTROL_H_ #define PWMCONTROL_H_
#include <boost/json/object.hpp>
#include <string> #include <string>
#include <Printable.h> #include <Printable.h>

View File

@@ -5,12 +5,14 @@
using namespace std; using namespace std;
void App::Init() { void App::Init() {
auto fans = mSerializer.DeserializeFans(mSensorManager.RPMSensors()); mFans = mSerializer.DeserializeFans(mSensorManager.RPMSensors());
auto fanCurves = mSerializer.DeserializeFanCurves( auto fanCurves = mSerializer.DeserializeFanCurves(
mSensorManager.TemperatureSensors(), fans); mSensorManager.TemperatureSensors(), mFans);
mController = make_unique<Controller>(fanCurves); mSettings = mSerializer.DeserializeSettings();
mController = make_unique<Controller>(mSettings, fanCurves);
} }
void App::InitialSetup() { void App::InitialSetup() {
@@ -23,6 +25,8 @@ void App::InitialSetup() {
mFanLabeler.RunFanLabelInteraction(fans); mFanLabeler.RunFanLabelInteraction(fans);
mSerializer.SerializeFans(fans); mSerializer.SerializeFans(fans);
mFans = fans;
} }
void App::NormalOperation() { void App::NormalOperation() {
@@ -30,4 +34,8 @@ void App::NormalOperation() {
mController->StartFanControlLoop(); mController->StartFanControlLoop();
} }
void App::Shutdown() { mController.reset(); } void App::Shutdown() {
mSerializer.SerializeFans(mFans);
mFans.clear();
mController.reset();
}

View File

@@ -6,10 +6,10 @@
using namespace std; using namespace std;
#define TIMEOUT 500 Controller::Controller(shared_ptr<Settings> settings,
vector<shared_ptr<FanCurve>> curves)
Controller::Controller(vector<shared_ptr<FanCurve>> curves) : mTimeout((1 / settings->Frequency()) * 1000), mFanCurves(curves),
: mFanCurves(curves), mRun(false) {} mRun(false) {}
Controller::~Controller() { StopFanControlLoop(); } Controller::~Controller() { StopFanControlLoop(); }
@@ -32,6 +32,6 @@ void Controller::Loop() {
c->DoFanControl(); c->DoFanControl();
} }
this_thread::sleep_for(chrono::milliseconds(TIMEOUT)); this_thread::sleep_for(chrono::milliseconds(mTimeout));
} }
} }

View File

@@ -1,5 +1,3 @@
#include "fan/FanCurve.h"
#include "sensor/Sensor.h"
#include <filesystem> #include <filesystem>
#include <fstream> #include <fstream>
#include <iostream> #include <iostream>
@@ -10,17 +8,21 @@
#include <fan/HwmonFan.h> #include <fan/HwmonFan.h>
#include <pwm/PWMControl.h> #include <pwm/PWMControl.h>
#include <sensor/LMSensor.h> #include <sensor/LMSensor.h>
#include <string>
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 Serializer::SerializeFans(vector<shared_ptr<Fan>> fans) { void
Serializer::SerializeFans(vector<shared_ptr<Fan>> fans)
{
json obj; json obj;
for (auto f : fans) { for (auto f : fans) {
@@ -31,7 +33,8 @@ void 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
@@ -42,7 +45,7 @@ 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"]];
@@ -57,20 +60,22 @@ Serializer::DeserializeFans(vector<shared_ptr<Sensor>> availableSensors) {
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 Serializer::WriteJson(json o) { void
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;
} }
@@ -78,14 +83,18 @@ void Serializer::WriteJson(json o) {
ostrm << obj.dump(2) << "\n"; ostrm << obj.dump(2) << "\n";
} }
json Serializer::ReadJson() { json
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>> Serializer::DeserializeFanCurves( vector<shared_ptr<FanCurve>>
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;
@@ -100,27 +109,57 @@ vector<shared_ptr<FanCurve>> 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()]);
} }
curves.push_back(make_shared<FanCurve>(steps, sensors, fans)); std::unique_ptr<Aggregator> aggregator =
aggregatorFromString(el.value()["AggregateFunction"]);
curves.push_back(
make_shared<FanCurve>(steps, sensors, fans, std::move(aggregator)));
} }
return curves; return curves;
} }
std::unique_ptr<Aggregator>
Serializer::aggregatorFromString(std::string str) const
{
if (str == "max")
return std::make_unique<MaxAggregator>();
else
return std::make_unique<AverageAggregator>();
}
shared_ptr<Settings>
Serializer::DeserializeSettings()
{
int frequency = FREQUENCY_DEFAULT;
auto data = ReadJson();
if (data.contains("settings")) {
auto items = data["settings"];
if (items.contains("frequency"))
frequency = items["frequency"];
}
return make_shared<Settings>(frequency);
}

17
app/src/Settings.cxx Normal file
View File

@@ -0,0 +1,17 @@
#include <iostream>
#include <boost/log/attributes/named_scope.hpp>
#include <boost/log/trivial.hpp>
#include <Settings.h>
Settings::Settings(int frequency) : mFrequency(frequency) { LogSettings(); }
int Settings::Frequency() const { return mFrequency; }
void Settings::LogSettings() {
BOOST_LOG_FUNCTION();
BOOST_LOG_TRIVIAL(info) << "### Settings";
BOOST_LOG_TRIVIAL(info) << "Frequency: " << mFrequency << "Hz";
}

View File

@@ -0,0 +1,39 @@
#include <climits>
#include <fan/Aggregators.h>
int
AverageAggregator::aggregate(std::vector<std::shared_ptr<Sensor>> sensors) const
{
int sum = 0;
for (auto sensor : sensors) {
sum += sensor->value();
}
return sum / sensors.size();
}
const std::string
AverageAggregator::toString() const
{
return "Average";
}
int
MaxAggregator::aggregate(std::vector<std::shared_ptr<Sensor>> sensors) const
{
int max = INT_MIN;
for (auto sensor : sensors) {
if (sensor->value() > max)
max = sensor->value();
}
return max;
}
const std::string
MaxAggregator::toString() const
{
return "Max";
}

View File

@@ -4,18 +4,27 @@
#include <boost/log/trivial.hpp> #include <boost/log/trivial.hpp>
#include <fan/FanCurve.h> #include <fan/FanCurve.h>
#include <memory>
using namespace std; using namespace std;
FanCurve::FanCurve(std::vector<FanStep> steps, 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,
: mSteps(steps), mTempSensors(sensors), mFans(fans) { std::unique_ptr<Aggregator> aggregator)
: mSteps(steps)
, mTempSensors(sensors)
, mFans(fans)
, mAggregator(std::move(aggregator))
{
PrintInfo(); PrintInfo();
} }
void FanCurve::DoFanControl() { void
FanCurve::DoFanControl()
{
BOOST_LOG_FUNCTION(); BOOST_LOG_FUNCTION();
int temp = AggregateTemperature(); int temp = AggregateTemperature();
int t0, t1, p0, p1; int t0, t1, p0, p1;
@@ -43,22 +52,22 @@ void FanCurve::DoFanControl() {
if (f->RPM() <= 0) { if (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();
} else {
f->PWM(targetFanPower); f->PWM(targetFanPower);
} }
}
// Dummy Implementation using AVG
int FanCurve::AggregateTemperature() {
int sum = 0;
for (auto s : mTempSensors) {
sum += s->value();
} }
return sum / mTempSensors.size();
} }
void FanCurve::PrintInfo() { int
FanCurve::AggregateTemperature()
{
return mAggregator->aggregate(mTempSensors);
}
void
FanCurve::PrintInfo()
{
BOOST_LOG_FUNCTION() BOOST_LOG_FUNCTION()
BOOST_LOG_TRIVIAL(info) << "### Fan curve:"; BOOST_LOG_TRIVIAL(info) << "### Fan curve:";
@@ -87,4 +96,10 @@ void FanCurve::PrintInfo() {
} }
BOOST_LOG_TRIVIAL(info) << sStream.str(); BOOST_LOG_TRIVIAL(info) << sStream.str();
sStream.str(string());
sStream << "Aggregate function: " << mAggregator->toString();
BOOST_LOG_TRIVIAL(info) << sStream.str();
} }

View File

@@ -1,13 +1,15 @@
#include <chrono>
#include <iostream> #include <iostream>
#include <ostream> #include <ostream>
#include <thread> #include <thread>
#include "pwm/PWMControl.h" #include <boost/log/attributes/named_scope.hpp>
#include <boost/json/object.hpp> #include <boost/log/trivial.hpp>
#include <fan/HwmonFan.h> #include <fan/HwmonFan.h>
#include <pwm/PWMControl.h>
#define TIMEOUT 10 #define TIMEOUT 10
#define STEP 2
using namespace std; using namespace std;
@@ -33,24 +35,22 @@ void HwmonFan::MinPWM(int value) { mMinPWM = value; }
int HwmonFan::MinPWM() { return mMinPWM; } int HwmonFan::MinPWM() { return mMinPWM; }
int HwmonFan::StartPWM() { return mStartPWM; }
void HwmonFan::StartPWM(int value) { mStartPWM = value; } void HwmonFan::StartPWM(int value) { mStartPWM = value; }
int HwmonFan::StartPWM() { return mStartPWM; }
void HwmonFan::FindPWMLimits() { void HwmonFan::FindPWMLimits() {
cout << "Looking for minimal PWM" << endl; cout << "Looking for minimal PWM" << endl;
int minPWM = 0; int minPWM = 0;
mMinPWM = 0; mMinPWM = 0;
mStartPWM = 0; mStartPWM = 0;
for (int curPWM = 100; curPWM > 0; curPWM -= 5) { for (int curPWM = 100; curPWM > 0; curPWM -= STEP) {
PWM(curPWM); PWM(curPWM);
this_thread::sleep_for(chrono::seconds(TIMEOUT)); this_thread::sleep_for(chrono::seconds(TIMEOUT));
int curRPM = RPM(); if (RPM() <= 0) {
minPWM = curPWM + STEP;
if (curRPM <= 0) {
minPWM = curPWM + 5;
break; break;
} }
} }
@@ -64,13 +64,11 @@ void HwmonFan::FindPWMLimits() {
int startPWM = 0; int startPWM = 0;
cout << "Looking for start PWM!" << endl; cout << "Looking for start PWM!" << endl;
for (int curPWM = minPWM - 5; curPWM < 100; curPWM += 5) { for (int curPWM = minPWM - STEP; curPWM < 100; curPWM += STEP) {
PWM(curPWM); PWM(curPWM);
this_thread::sleep_for(chrono::seconds(TIMEOUT)); this_thread::sleep_for(chrono::seconds(TIMEOUT));
int curRPM = RPM(); if (RPM() > 0) {
if (curRPM > 0) {
cout << "Setting start PWM: " << startPWM << endl; cout << "Setting start PWM: " << startPWM << endl;
startPWM = curPWM; startPWM = curPWM;
break; break;
@@ -81,6 +79,20 @@ void HwmonFan::FindPWMLimits() {
} }
} }
void HwmonFan::AdjustPWMLimits() {
BOOST_LOG_FUNCTION()
chrono::time_point now = chrono::steady_clock::now();
if ((now - mLastAdjustmentTime) >
chrono::duration(chrono::seconds(TIMEOUT))) {
BOOST_LOG_TRIVIAL(info) << "Increasing minimal fan speed";
mLastAdjustmentTime = now;
mMinPWM += 2;
}
}
json HwmonFan::toJson() const { json HwmonFan::toJson() const {
json obj; json obj;
obj = {mPWMControl->toJson(), obj = {mPWMControl->toJson(),

View File

@@ -1,4 +1,3 @@
#include <boost/log/expressions/formatters/named_scope.hpp>
#include <csignal> #include <csignal>
#include <iostream> #include <iostream>
@@ -6,6 +5,7 @@
#include <boost/log/attributes/named_scope.hpp> #include <boost/log/attributes/named_scope.hpp>
#include <boost/log/core.hpp> #include <boost/log/core.hpp>
#include <boost/log/expressions.hpp> #include <boost/log/expressions.hpp>
#include <boost/log/expressions/formatters/named_scope.hpp>
#include <boost/log/expressions/message.hpp> #include <boost/log/expressions/message.hpp>
#include <boost/log/support/date_time.hpp> #include <boost/log/support/date_time.hpp>
#include <boost/log/trivial.hpp> #include <boost/log/trivial.hpp>
@@ -20,6 +20,8 @@
#include <App.h> #include <App.h>
#define PROJECT_VERSION "v0.1.9"
namespace po = boost::program_options; namespace po = boost::program_options;
namespace logging = boost::log; namespace logging = boost::log;
@@ -27,9 +29,15 @@ App app;
static int doInitialSetup = 0; static int doInitialSetup = 0;
void signal_handler(int s) { app.Shutdown(); } void
signal_handler(int s)
{
app.Shutdown();
}
void InitLogging(bool verbose) { void
InitLogging(bool verbose)
{
logging::add_console_log( logging::add_console_log(
std::clog, std::clog,
logging::keywords::format = logging::keywords::format =
@@ -58,13 +66,19 @@ void InitLogging(bool verbose) {
} }
} }
int main(int argc, char **argv) { int
main(int argc, char** argv)
{
BOOST_LOG_FUNCTION()
BOOST_LOG_TRIVIAL(info) << "Version: " << PROJECT_VERSION;
signal(SIGINT, signal_handler); signal(SIGINT, signal_handler);
signal(SIGTERM, signal_handler);
po::options_description desc("Allowed options"); po::options_description desc("Allowed options");
desc.add_options()("help,h", "produce help message")( desc.add_options()("help,h", "produce help message")(
"setup,s", po::bool_switch(), "setup,s", po::bool_switch(), "run initial setup")(
"run initial setup")("verbose,v", po::bool_switch(), "print debug info"); "verbose,v", po::bool_switch(), "print debug info");
po::variables_map vm; po::variables_map vm;
po::store(po::parse_command_line(argc, argv, desc), vm); po::store(po::parse_command_line(argc, argv, desc), vm);
@@ -84,7 +98,7 @@ int main(int argc, char **argv) {
app.Init(); app.Init();
app.NormalOperation(); app.NormalOperation();
} }
} catch (const std::exception &e) { } catch (const std::exception& e) {
std::cout << "An exception was caught: " << e.what() << std::endl; std::cout << "An exception was caught: " << e.what() << std::endl;
} }

View File

@@ -15,7 +15,9 @@
using namespace std; using namespace std;
namespace fs = filesystem; namespace fs = filesystem;
PWMControl::PWMControl(string controlPath) : mControlPath(controlPath) { PWMControl::PWMControl(string controlPath)
: mControlPath(controlPath)
{
fs::path pathEnable(mControlPath + PWM_POSTFIX_ENABLE); fs::path pathEnable(mControlPath + PWM_POSTFIX_ENABLE);
fs::path pathMode(mControlPath + PWM_POSTFIX_MODE); fs::path pathMode(mControlPath + PWM_POSTFIX_MODE);
@@ -35,21 +37,24 @@ PWMControl::PWMControl(string controlPath) : mControlPath(controlPath) {
istrm.close(); istrm.close();
} }
PWMControl::~PWMControl() { PWMControl::~PWMControl()
{
BOOST_LOG_FUNCTION(); BOOST_LOG_FUNCTION();
BOOST_LOG_TRIVIAL(trace) << "Cleanup"; BOOST_LOG_TRIVIAL(trace) << "Cleanup";
Reset(); Reset();
} }
void PWMControl::Power(int percent) { void
PWMControl::Power(int percent)
{
BOOST_LOG_FUNCTION(); BOOST_LOG_FUNCTION();
int pwmValue = (PWM_MAX_VALUE * percent) / 100; int pwmValue = (PWM_MAX_VALUE * percent) / 100;
if (percent != mCurrentValue) { if (percent != mCurrentValue) {
BOOST_LOG_TRIVIAL(trace) BOOST_LOG_TRIVIAL(trace) << "Updating control value of " << toString()
<< "Updating control value to " << percent << "% (" << pwmValue << ")"; << " to " << percent << "% (" << pwmValue << ")";
ofstream ostrm(mControlPath, ios::trunc); ofstream ostrm(mControlPath, ios::trunc);
ostrm << pwmValue; ostrm << pwmValue;
ostrm.close(); ostrm.close();
@@ -58,7 +63,9 @@ void PWMControl::Power(int percent) {
} }
} }
int PWMControl::Power() { int
PWMControl::Power()
{
int value; int value;
ifstream istrm; ifstream istrm;
@@ -68,13 +75,17 @@ int PWMControl::Power() {
return (value * 100) / PWM_MAX_VALUE; return (value * 100) / PWM_MAX_VALUE;
} }
void PWMControl::EnableManualControl() { void
PWMControl::EnableManualControl()
{
ofstream ostrm(mEnablePath, ios::trunc); ofstream ostrm(mEnablePath, ios::trunc);
ostrm << static_cast<int>(PWM_ENABLE::MANUAL_CONTROL); ostrm << static_cast<int>(PWM_ENABLE::MANUAL_CONTROL);
ostrm.close(); ostrm.close();
} }
void PWMControl::Reset() { void
PWMControl::Reset()
{
ofstream ostrm(mEnablePath, ios::trunc); ofstream ostrm(mEnablePath, ios::trunc);
ostrm << mInitialEnable; ostrm << mInitialEnable;
@@ -86,11 +97,15 @@ void PWMControl::Reset() {
ostrm.close(); ostrm.close();
} }
const string PWMControl::toString() const { const string
PWMControl::toString() const
{
return fs::path(mControlPath).filename(); return fs::path(mControlPath).filename();
} }
json PWMControl::toJson() const { json
json obj = {"PWMControl", mControlPath}; PWMControl::toJson() const
{
json obj = { "PWMControl", mControlPath };
return obj; return obj;
} }

View File

@@ -1,4 +1,3 @@
#include <boost/json/object.hpp>
#include <include/nvml.h> #include <include/nvml.h>
#include <sensor/NvidiaSensor.h> #include <sensor/NvidiaSensor.h>

View File

@@ -7,4 +7,4 @@ ExecStart=/usr/local/bin/fantasize
Restart=always Restart=always
[Install] [Install]
WantedBy=multi-user.target WantedBy=graphical.target